[freenet-cvs] r13455 - trunk/freenet/src/freenet/io/xfer

[t...@freenetproject.org]

Author: toad
Date: 2007-06-01 19:52:49 +0000 (Fri, 01 Jun 2007)
New Revision: 13455

Modified:
   trunk/freenet/src/freenet/io/xfer/BulkReceiver.java
Log:
And other fixes

Modified: trunk/freenet/src/freenet/io/xfer/BulkReceiver.java
===================================================================
--- trunk/freenet/src/freenet/io/xfer/BulkReceiver.java 2007-06-01 19:52:31 UTC 
(rev 13454)
+++ trunk/freenet/src/freenet/io/xfer/BulkReceiver.java 2007-06-01 19:52:49 UTC 
(rev 13455)
@@ -54,9 +54,9 @@
         * @return True if the whole file was received, false otherwise.
         */
        public boolean receive() {
-               MessageFilter mfSendKilled = 
MessageFilter.create().setSource(peer).setType(DMT.FNPBulkSendAborted) 
.setField(DMT.UID, uid).setTimeout(TIMEOUT);
-               MessageFilter mfPacket = 
MessageFilter.create().setSource(peer).setType(DMT.FNPBulkPacketSend) 
.setField(DMT.UID, uid).setTimeout(TIMEOUT);
                while(true) {
+                       MessageFilter mfSendKilled = 
MessageFilter.create().setSource(peer).setType(DMT.FNPBulkSendAborted) 
.setField(DMT.UID, uid).setTimeout(TIMEOUT);
+                       MessageFilter mfPacket = 
MessageFilter.create().setSource(peer).setType(DMT.FNPBulkPacketSend) 
.setField(DMT.UID, uid).setTimeout(TIMEOUT);
                        if(prb.hasWholeFile()) {
                                try {
                                        
peer.sendAsync(DMT.createFNPBulkReceivedAll(uid), null, 0, null);