Author: nextgens
Date: 2008-01-29 21:54:00 +0000 (Tue, 29 Jan 2008)
New Revision: 17402
Modified:
trunk/freenet/src/freenet/node/fcp/FCPConnectionOutputHandler.java
Log:
revert r17325
Modified: trunk/freenet/src/freenet/node/fcp/FCPConnectionOutputHandler.java
===================================================================
--- trunk/freenet/src/freenet/node/fcp/FCPConnectionOutputHandler.java
2008-01-29 20:10:56 UTC (rev 17401)
+++ trunk/freenet/src/freenet/node/fcp/FCPConnectionOutputHandler.java
2008-01-29 21:54:00 UTC (rev 17402)
@@ -44,13 +44,12 @@
private void realRun() throws IOException {
OutputStream os = new
BufferedOutputStream(handler.sock.getOutputStream(), 4096);
while(true) {
- boolean closed, empty = false;
+ boolean closed;
FCPMessage msg = null;
while(true) {
closed = handler.isClosed();
synchronized(outQueue) {
- empty = outQueue.isEmpty();
- if(empty) {
+ if(outQueue.isEmpty()) {
if(closed) break;
os.flush();
try {
@@ -65,7 +64,7 @@
}
}
if(msg == null) {
- if(closed && empty) {
+ if(closed) {
os.flush();
os.close();
return;