cache: set handshake future prior to writing handshake

This commit is contained in:
Adam
2017-04-30 10:41:28 -04:00
parent 9615083da9
commit 31a781e5f2

View File

@@ -118,13 +118,14 @@ public class CacheClient implements AutoCloseable
message.writeInt(msg.getRevision()); // client revision
state = ClientState.HANDSHAKING;
channel.writeAndFlush(message);
logger.info("Sent handshake with revision {}", msg.getRevision());
assert handshakeFuture == null;
handshakeFuture = new CompletableFuture<>();
channel.writeAndFlush(message);
logger.info("Sent handshake with revision {}", msg.getRevision());
return handshakeFuture;
}