Alawn/Chronicle-Map
1
0
Fork 0
mirror of https://github.com/OpenHFT/Chronicle-Map.git synced 2021-09-13 01:26:12 +00:00
Code Releases Activity

Fixed some bugs in StatelessClientConnector

Browse Source
This commit is contained in:
leventov
2015-01-19 07:11:12 +07:00
parent ffb239fc94
commit 55763cdb4b
1 changed files with 3 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+3 -3
View File
@@ -1687,7 +1687,7 @@ class StatelessServerConnector<K, V> {
final long sizeLocation, long timestamp, byte id) {
try {
writer.ensureBufferSize(1L);
bytesMap.replace(reader, reader, reader);
writer.in().writeBoolean(bytesMap.replace(reader, reader, reader));
} catch (Throwable e) {
return sendException(writer, sizeLocation, e);
}
@@ -1813,7 +1813,7 @@ class StatelessServerConnector<K, V> {
@NotNull TcpReplicator.TcpSocketChannelEntryWriter writer,
final long sizeLocation) {
try {
writer.in().writeBoolean(map.containsKey(reader));
writer.in().writeBoolean(bytesMap.containsKey(reader));
} catch (Throwable e) {
return sendException(writer, sizeLocation, e);
}
@@ -1843,7 +1843,7 @@ class StatelessServerConnector<K, V> {
final long sizeLocation, long transactionId) {
bytesMap.output = writer;
try {
map.get(reader);
bytesMap.get(reader);
} catch (Throwable e) {
return sendException(writer, sizeLocation, e);
} finally {