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

nextgens at freenetproject.org nextgens at freenetproject.org
Sat Dec 2 19:49:32 UTC 2006


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);




More information about the cvs mailing list