PeerSocketHandler: bugfix for incomplete message headers at the end of

the buffer
This commit is contained in:
Oscar Guindzberg 2015-03-27 15:42:10 -03:00
parent e5b52fb73b
commit 64e09452f4

View file

@ -140,6 +140,7 @@ public abstract class PeerSocketHandler extends AbstractTimeoutHandler implement
processMessage(serializer.deserializePayload(header, ByteBuffer.wrap(largeReadBuffer))); processMessage(serializer.deserializePayload(header, ByteBuffer.wrap(largeReadBuffer)));
largeReadBuffer = null; largeReadBuffer = null;
header = null; header = null;
firstMessage = false;
} else // ...or just returning if we don't have enough bytes yet } else // ...or just returning if we don't have enough bytes yet
return buff.position(); return buff.position();
} }