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

[toad at 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);