Commit e0d6542c authored by Emma Li's avatar Emma Li
Browse files

Merge pull request #34 from Kinetic/asyncQueuePutFix 

Fix for issue #32 - asyncQueuedSize is not always respected.
parents 72321bd8 fb26b191

kinetic-client/src/main/java/com/seagate/kinetic/client/io/MessageHandler.java

+3 −6
Original line number Diff line number Diff line
@@ -321,15 +321,12 @@ public class MessageHandler implements ClientMessageService, Runnable { 
		Long seq = Long.valueOf(message.getCommand().getHeader()

				.getSequence());



        // synchronized (this) {

			while (this.ackmap.size() >= this.asyncQueuedSize && this.isRunning) {

		while (ackmap.size() >= asyncQueuedSize && (isClosed == false)) {

			this.wait();

            // }

		}



		this.ackmap.put(seq, context);

		

		// this.iohandler.write(message);

		this.doWrite(message);

	}