[freenet-cvs] r11200 - trunk/freenet/src/freenet/node

[nextg...@freenetproject.org]

Author: nextgens
Date: 2006-12-02 19:49:31 +0000 (Sat, 02 Dec 2006)
New Revision: 11200

Modified:
   trunk/freenet/src/freenet/node/KeyTracker.java
Log:

Indent


Modified: trunk/freenet/src/freenet/node/KeyTracker.java
===================================================================
--- trunk/freenet/src/freenet/node/KeyTracker.java      2006-12-02 19:43:37 UTC 
(rev 11199)
+++ trunk/freenet/src/freenet/node/KeyTracker.java      2006-12-02 19:49:31 UTC 
(rev 11200)
@@ -485,26 +485,26 @@
      */
     public synchronized void acknowledgedPackets(int[] seqNos) {
        AsyncMessageCallback[][] callbacks = new 
AsyncMessageCallback[seqNos.length][];
-               for(int i=0;i<seqNos.length;i++) {
-                       int realSeqNo = seqNos[i];
-                       if(logMINOR) Logger.minor(this, "Acknowledged packet: 
"+realSeqNo);
-            try {
-                               removeAckRequest(realSeqNo);
-                       } catch (UpdatableSortedLinkedListKilledException e) {
-                               // Ignore, we are processing an incoming packet
+       for(int i=0;i<seqNos.length;i++) {
+               int realSeqNo = seqNos[i];
+               if(logMINOR) Logger.minor(this, "Acknowledged packet: 
"+realSeqNo);
+               try {
+                       removeAckRequest(realSeqNo);
+               } catch (UpdatableSortedLinkedListKilledException e) {
+                       // Ignore, we are processing an incoming packet
+               }
+               if(logMINOR) Logger.minor(this, "Removed ack request");
+               callbacks[i] = sentPacketsContents.getCallbacks(realSeqNo);
+               byte[] buf = sentPacketsContents.get(realSeqNo);
+               long timeAdded = sentPacketsContents.getTime(realSeqNo);
+               if(sentPacketsContents.remove(realSeqNo)) {
+                       if(buf.length > Node.PACKET_SIZE) {
+                               PacketThrottle throttle = getThrottle();
+                               throttle.notifyOfPacketAcknowledged();
+                               
throttle.setRoundTripTime(System.currentTimeMillis() - timeAdded);
                        }
-                       if(logMINOR) Logger.minor(this, "Removed ack request");
-            callbacks[i] = sentPacketsContents.getCallbacks(realSeqNo);
-            byte[] buf = sentPacketsContents.get(realSeqNo);
-            long timeAdded = sentPacketsContents.getTime(realSeqNo);
-            if(sentPacketsContents.remove(realSeqNo)) {
-               if(buf.length > Node.PACKET_SIZE) {
-                       PacketThrottle throttle = getThrottle();
-                       throttle.notifyOfPacketAcknowledged();
-                       throttle.setRoundTripTime(System.currentTimeMillis() - 
timeAdded);
-               }
-            }
-               }
+               }
+       }
        int cbCount = 0;
        for(int i=0;i<callbacks.length;i++) {
                AsyncMessageCallback[] cbs = callbacks[i];
@@ -532,12 +532,12 @@
        logMINOR = Logger.shouldLog(Logger.MINOR, this);
         AsyncMessageCallback[] callbacks;
         if(logMINOR) Logger.minor(this, "Acknowledged packet: "+realSeqNo);
-        try {
-                       removeAckRequest(realSeqNo);
-               } catch (UpdatableSortedLinkedListKilledException e) {
-                       // Ignore, we are processing an incoming packet
-               }
-               if(logMINOR) Logger.minor(this, "Removed ack request");
+       try {
+               removeAckRequest(realSeqNo);
+       } catch (UpdatableSortedLinkedListKilledException e) {
+               // Ignore, we are processing an incoming packet
+       }
+       if(logMINOR) Logger.minor(this, "Removed ack request");
         callbacks = sentPacketsContents.getCallbacks(realSeqNo);
         byte[] buf = sentPacketsContents.get(realSeqNo);
         long timeAdded = sentPacketsContents.getTime(realSeqNo);