Author: j16sdiz Date: 2008-05-05 12:11:25 +0000 (Mon, 05 May 2008) New Revision: 19755
Modified:
trunk/freenet/src/freenet/client/FECCodec.java
Log:
indent
Modified: trunk/freenet/src/freenet/client/FECCodec.java
===================================================================
--- trunk/freenet/src/freenet/client/FECCodec.java 2008-05-05 12:11:06 UTC
(rev 19754)
+++ trunk/freenet/src/freenet/client/FECCodec.java 2008-05-05 12:11:25 UTC
(rev 19755)
@@ -397,41 +397,41 @@
try {
while(true) {
FECJob job = null;
- // Get a job
- synchronized(_awaitingJobs) {
- while
(_awaitingJobs.isEmpty())
-
_awaitingJobs.wait(Integer.MAX_VALUE);
- job = (FECJob)
_awaitingJobs.removeLast();
- }
+ // Get a job
+ synchronized (_awaitingJobs) {
+ while (_awaitingJobs.isEmpty())
+
_awaitingJobs.wait(Integer.MAX_VALUE);
+ job = (FECJob)
_awaitingJobs.removeLast();
+ }
- // Encode it
- try {
- if(job.isADecodingJob)
-
job.codec.realDecode(job.dataBlockStatus, job.checkBlockStatus,
job.blockLength, job.bucketFactory);
- else {
-
job.codec.realEncode(job.dataBlocks, job.checkBlocks, job.blockLength,
job.bucketFactory);
- // Update
SplitFileBlocks from buckets if necessary
-
if((job.dataBlockStatus != null) || (job.checkBlockStatus != null)) {
- for(int
i = 0; i < job.dataBlocks.length; i++)
-
job.dataBlockStatus[i].setData(job.dataBlocks[i]);
- for(int
i = 0; i < job.checkBlocks.length; i++)
-
job.checkBlockStatus[i].setData(job.checkBlocks[i]);
- }
+ // Encode it
+ try {
+ if (job.isADecodingJob)
+
job.codec.realDecode(job.dataBlockStatus, job.checkBlockStatus, job.blockLength,
+
job.bucketFactory);
+ else {
+
job.codec.realEncode(job.dataBlocks, job.checkBlocks, job.blockLength,
job.bucketFactory);
+ // Update
SplitFileBlocks from buckets if necessary
+ if
((job.dataBlockStatus != null) || (job.checkBlockStatus != null)) {
+ for (int i = 0;
i < job.dataBlocks.length; i++)
+
job.dataBlockStatus[i].setData(job.dataBlocks[i]);
+ for (int i = 0;
i < job.checkBlocks.length; i++)
+
job.checkBlockStatus[i].setData(job.checkBlocks[i]);
}
- } catch(IOException e) {
- Logger.error(this,
"BOH! ioe:" + e.getMessage());
}
+ } catch (IOException e) {
+ Logger.error(this, "BOH! ioe:"
+ e.getMessage());
+ }
- // Call the callback
- try {
- if(job.isADecodingJob)
-
job.callback.onDecodedSegment();
- else
-
job.callback.onEncodedSegment();
-
- } catch(Throwable e) {
- Logger.error(this, "The
callback failed!" + e.getMessage(), e);
- }
+ // Call the callback
+ try {
+ if (job.isADecodingJob)
+
job.callback.onDecodedSegment();
+ else
+
job.callback.onEncodedSegment();
+ } catch (Throwable e) {
+ Logger.error(this, "The
callback failed!" + e.getMessage(), e);
+ }
}
} catch (Throwable t) {
Logger.error(this, "Caught "+t+" in "+this, t);
