zzz/i2p.i2p
1
0
Fork 0
forked from I2P_Developers/i2p.i2p
Code Issues Pull Requests Packages Projects Releases Wiki Activity

2004-12-31 jrandom

Browse Source 
* Speling fxi (thanks digum!)
    * Bugfix for the I2PTunnel web interface so that it now properly launches
      newly added tunnels that are defined to be run on startup (thanks ugha!)
This commit is contained in:
jrandom
2004-12-31 17:18:05 +00:00
committed by zzz
parent aec0b0c86a
commit 70d6332bad
6 changed files with 31 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
router/java/src/net/i2p/router/RouterVersion.java
View File

@@ -15,9 +15,9 @@ import net.i2p.CoreVersion;
*
*/
public class RouterVersion {
public final static String ID = "$Revision: 1.126 $ $Date: 2004/12/29 17:16:42 $";
public final static String ID = "$Revision: 1.127 $ $Date: 2004/12/30 17:51:16 $";
public final static String VERSION = "0.4.2.5";
public final static long BUILD = 4;
public final static long BUILD = 5;
public static void main(String args[]) {
System.out.println("I2P Router version: " + VERSION);
System.out.println("Router ID: " + RouterVersion.ID);

24
router/java/src/net/i2p/router/transport/tcp/ConnectionRunner.java
View File

@@ -27,7 +27,8 @@ class ConnectionRunner implements Runnable {
private boolean _keepRunning;
private byte _writeBuffer[];
private long _lastTimeSend;
private long _lastWrite;
private long _lastWriteEnd;
private long _lastWriteBegin;
private static final long TIME_SEND_FREQUENCY = 60*1000;
@@ -36,7 +37,8 @@ class ConnectionRunner implements Runnable {
_log = ctx.logManager().getLog(ConnectionRunner.class);
_con = con;
_keepRunning = false;
_lastWrite = ctx.clock().now();
_lastWriteBegin = ctx.clock().now();
_lastWriteEnd = _lastWriteBegin;
}
public void startRunning() {
@@ -106,23 +108,21 @@ class ConnectionRunner implements Runnable {
OutputStream out = _con.getOutputStream();
boolean ok = false;
long before = -1;
long after = -1;
try {
synchronized (out) {
before = _context.clock().now();
_lastWriteBegin = _context.clock().now();
out.write(buf, 0, written);
if (sendTime) {
out.write(buildTimeMessage().toByteArray());
_lastTimeSend = _context.clock().now();
}
out.flush();
after = _context.clock().now();
_lastWriteEnd = _context.clock().now();
}
if (_log.shouldLog(Log.DEBUG))
_log.debug("Just sent message " + msg.getMessageId() + " to "
+ msg.getTarget().getIdentity().getHash().toBase64().substring(0,6)
+ " writeTime = " + (after-before) +"ms"
+ " writeTime = " + (_lastWriteEnd - _lastWriteBegin) +"ms"
+ " lifetime = " + msg.getLifetime() + "ms");
ok = true;
@@ -131,8 +131,7 @@ class ConnectionRunner implements Runnable {
_log.warn("Error writing out the message", ioe);
_con.closeConnection();
}
_con.sent(msg, ok, after - before);
_lastWrite = after;
_con.sent(msg, ok, _lastWriteEnd - _lastWriteBegin);
}
/**
@@ -160,7 +159,9 @@ class ConnectionRunner implements Runnable {
public void timeReached() {
if (!_keepRunning) return;
if (_con.getIsClosed()) return;
long timeSinceWrite = _context.clock().now() - _lastWrite;
long now = _context.clock().now();
long timeSinceWrite = now - _lastWriteEnd;
long timeSinceWriteBegin = now - _lastWriteBegin;
if (timeSinceWrite > 5*TIME_SEND_FREQUENCY) {
TCPTransport t = _con.getTransport();
String msg = "Connection closed with "
@@ -168,6 +169,9 @@ class ConnectionRunner implements Runnable {
+ " due to " + DataHelper.formatDuration(timeSinceWrite)
+ " of inactivity after "
+ DataHelper.formatDuration(_con.getLifetime());
if (_lastWriteBegin > _lastWriteEnd)
msg = msg + " with a message being written for " +
DataHelper.formatDuration(timeSinceWriteBegin);
t.addConnectionErrorMessage(msg);
if (_log.shouldLog(Log.INFO))
_log.info(msg);