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: [email protected]
For additional commands, e-mail: [email protected]
