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

added the following to prevent writting to a socket that is not bound - if (!clientChannel.finishConnect() || !clientChannel.socket().isBound())

Browse Source
This commit is contained in:
Rob Austin
2014-12-03 15:19:58 +00:00
parent 40c791671e
commit ca98f659fd
1 changed files with 9 additions and 6 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/main/java/net/openhft/chronicle/map/StatelessChronicleMap.java
+9 -6
View File
@@ -287,9 +287,12 @@ class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, Closeable, Clon
this.connectionOutBuffer.clear();
// read a single byte back
if (!clientChannel.finishConnect() || !clientChannel.socket().isBound())
return;
// read a single byte back
while (this.connectionOutBuffer.position() <= 0) {
clientChannel.read(this.connectionOutBuffer);
clientChannel.read(this.connectionOutBuffer); // the remote identifier
checkTimeout(timeoutTime);
}
@@ -983,13 +986,13 @@ class StatelessChronicleMap<K, V> implements ChronicleMap<K, V>, Closeable, Clon
final long inTransactionId = bytes.readLong();
if (inTransactionId != transactionId) {
LOG.error("", new IllegalStateException("Skipped Message with transaction-id=" +
LOG.error("", new IllegalStateException("Skipped Message with transaction-id=" +
inTransactionId +
", this can occur when you have another thread which has called the " +
"stateless client and terminated abruptly before the message has been " +
"returned from the server"));
"stateless client and terminated abruptly before the message has been " +
"returned from the server"));
blockingFetch(timeoutTime,transactionId);
blockingFetch(timeoutTime, transactionId);
}
if (isException) {