[freenet-cvs] r11977 - trunk/freenet/src/freenet/client/async

[t...@freenetproject.org]

Author: toad
Date: 2007-03-05 20:49:25 +0000 (Mon, 05 Mar 2007)
New Revision: 11977

Modified:
   trunk/freenet/src/freenet/client/async/SplitFileFetcherSegment.java
Log:
Indent

Modified: trunk/freenet/src/freenet/client/async/SplitFileFetcherSegment.java
===================================================================
--- trunk/freenet/src/freenet/client/async/SplitFileFetcherSegment.java 
2007-03-05 20:48:42 UTC (rev 11976)
+++ trunk/freenet/src/freenet/client/async/SplitFileFetcherSegment.java 
2007-03-05 20:49:25 UTC (rev 11977)
@@ -141,34 +141,34 @@
                boolean decodeNow = false;
                logMINOR = Logger.shouldLog(Logger.MINOR, this);
                synchronized(this) {
-               if(isFinished()) return;
-               if(blockNo < dataKeys.length) {
-                       if(dataKeys[blockNo] == null) {
-                               Logger.error(this, "Block already finished: 
"+blockNo);
+                       if(isFinished()) return;
+                       if(blockNo < dataKeys.length) {
+                               if(dataKeys[blockNo] == null) {
+                                       Logger.error(this, "Block already 
finished: "+blockNo);
+                                       return;
+                               }
+                               dataKeys[blockNo] = null;
+                               dataBuckets[blockNo].setData(result.asBucket());
+                       } else if(blockNo < checkKeys.length + dataKeys.length) 
{
+                               blockNo -= dataKeys.length;
+                               if(checkKeys[blockNo] == null) {
+                                       Logger.error(this, "Check block already 
finished: "+blockNo);
+                                       return;
+                               }
+                               checkKeys[blockNo] = null;
+                               
checkBuckets[blockNo].setData(result.asBucket());
+                       } else
+                               Logger.error(this, "Unrecognized block number: 
"+blockNo, new Exception("error"));
+                       fetchedBlocks++;
+                       if(logMINOR) Logger.minor(this, "Fetched 
"+fetchedBlocks+" blocks in onSuccess("+blockNo+")");
+                       if(startedDecode) {
                                return;
+                       } else {
+                               decodeNow = (fetchedBlocks >= minFetched);
+                               startedDecode = true;
+                               finishing = true;
                        }
-                       dataKeys[blockNo] = null;
-                       dataBuckets[blockNo].setData(result.asBucket());
-               } else if(blockNo < checkKeys.length + dataKeys.length) {
-                       blockNo -= dataKeys.length;
-                       if(checkKeys[blockNo] == null) {
-                               Logger.error(this, "Check block already 
finished: "+blockNo);
-                               return;
-                       }
-                       checkKeys[blockNo] = null;
-                       checkBuckets[blockNo].setData(result.asBucket());
-               } else
-                       Logger.error(this, "Unrecognized block number: 
"+blockNo, new Exception("error"));
-               fetchedBlocks++;
-               if(logMINOR) Logger.minor(this, "Fetched "+fetchedBlocks+" 
blocks in onSuccess("+blockNo+")");
-               if(startedDecode) {
-                       return;
-               } else {
-                       decodeNow = (fetchedBlocks >= minFetched);
-                       startedDecode = true;
-                       finishing = true;
                }
-               }
                parentFetcher.parent.completedBlock(dontNotify);
                Runnable r = new Decoder();
                Thread t = new Thread(r, "Decoder for "+this);