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;


Reply via email to