Update of /cvsroot/freenet/freenet/src/freenet/node/states/request
In directory sc8-pr-cvs1:/tmp/cvs-serv4463/src/freenet/node/states/request
Modified Files:
InsertPending.java
Log Message:
Indenting
Index: InsertPending.java
===================================================================
RCS file: /cvsroot/freenet/freenet/src/freenet/node/states/request/InsertPending.java,v
retrieving revision 1.30
retrieving revision 1.31
diff -u -w -r1.30 -r1.31
--- InsertPending.java 22 Nov 2003 20:48:47 -0000 1.30
+++ InsertPending.java 3 Dec 2003 11:15:26 -0000 1.31
@@ -47,8 +47,7 @@
public String toString() {
String s = super.toString();
- return s + ", "+(approved ? "approved" : "not-approved")+
- ", insertReplyTime="+insertReplyTime;
+ return s + ", " + (approved ? "approved" : "not-approved") + ",
insertReplyTime=" + insertReplyTime;
}
/**
@@ -154,8 +153,7 @@
public State receivedMessage(Node n, QueryAborted qf) throws StateException {
if (!fromOrigPeer(qf)) {
- throw new BadStateException("QueryAborted from the wrong peer! for "+
- this);
+ throw new BadStateException("QueryAborted from the wrong peer!
for " + this);
}
cancelNoInsert();
queryAborted(n, qf);
@@ -263,9 +261,7 @@
insertReplyTime = System.currentTimeMillis();
if (!approved) {
if (routedTime > 0)
- Core.diagnostics.occurrenceContinuous("hopTime",
- (System.currentTimeMillis() -
- routedTime) / hopsToLive);
+ Core.diagnostics.occurrenceContinuous("hopTime",
(System.currentTimeMillis() - routedTime) / hopsToLive);
checkTime = System.currentTimeMillis();
cancelRestart();
@@ -334,9 +330,7 @@
try {
n.sendMessage(qf, lastPeer, Core.hopTime(origHopsToLive));
} catch (CommunicationException e) {
- Core.logger.log(this,
- "Failed to send QueryAborted upstream for "+
- this, e, Logger.MINOR);
+ Core.logger.log(this, "Failed to send QueryAborted
upstream for " + this, e, Logger.MINOR);
}
}
}
@@ -401,15 +395,11 @@
throw new RequestAbortException(this);
}
if(logDEBUG)
- Core.logger.log(this, "Relaying insert pending "+searchKey+
- " without RAE for "+this, new Exception("debug"),
- Logger.DEBUG);
- sendingData = new SendData(Core.getRandSource().nextLong(), this.id, out, doc,
- doc.length(),
- doc.getStorables().getPartSize(), n);
+ Core.logger.log(this, "Relaying insert pending " + searchKey +
" without RAE for " + this, new Exception("debug"), Logger.DEBUG);
+ sendingData = new SendData(Core.getRandSource().nextLong(), this.id,
out, doc, doc.length(), doc.getStorables().getPartSize(), n);
sendingData.schedule(n);
- if(logDEBUG) Core.logger.log(this, "Scheduled "+sendingData+" for "+this,
- Logger.DEBUG);
+ if (logDEBUG)
+ Core.logger.log(this, "Scheduled " + sendingData + " for " +
this, Logger.DEBUG);
}
protected boolean isInsert() {
_______________________________________________
cvs mailing list
[EMAIL PROTECTED]
http://dodo.freenetproject.org/cgi-bin/mailman/listinfo/cvs
