You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@qpid.apache.org by rg...@apache.org on 2015/11/16 12:51:59 UTC
svn commit: r1714563 -
/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
Author: rgodfrey
Date: Mon Nov 16 11:51:59 2015
New Revision: 1714563
URL: http://svn.apache.org/viewvc?rev=1714563&view=rev
Log:
QPID-6840 : Address review comments from [~lorenz.quack]
Modified:
qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
Modified: qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java
URL: http://svn.apache.org/viewvc/qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java?rev=1714563&r1=1714562&r2=1714563&view=diff
==============================================================================
--- qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java (original)
+++ qpid/java/trunk/broker-core/src/main/java/org/apache/qpid/server/transport/NonBlockingConnection.java Mon Nov 16 11:51:59 2015
@@ -319,7 +319,7 @@ public class NonBlockingConnection imple
{
doWrite();
long bytesWritten = size - getBufferedSize();
- if(bytesWritten < (networkBufferSize /2))
+ if(bytesWritten < (networkBufferSize / 2))
{
break;
}
@@ -331,13 +331,13 @@ public class NonBlockingConnection imple
}
}
- boolean processPendingAndReads = !_pendingIterator.hasNext();
+ boolean complete = !_pendingIterator.hasNext();
if (getBufferedSize() >= networkBufferSize)
{
doWrite();
- processPendingAndReads &= getBufferedSize() < networkBufferSize /2;
+ complete &= getBufferedSize() < networkBufferSize /2;
}
- return processPendingAndReads;
+ return complete;
}
private long getBufferedSize()
---------------------------------------------------------------------
To unsubscribe, e-mail: commits-unsubscribe@qpid.apache.org
For additional commands, e-mail: commits-help@qpid.apache.org