I2P_Developers/i2p.itoopie
3
0
Fork 0
Code Issues Pull Requests Actions 1 Packages Projects Releases Wiki Activity

keep track of how many messages are processed in the tunnel

Browse Source
This commit is contained in:
jrandom
2004-06-20 01:09:04 +00:00
committed by zzz
parent 6a02c8383c
commit 9957e6ef17
1 changed files with 16 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

16
router/java/src/net/i2p/router/TunnelInfo.java
View File

@ -31,11 +31,14 @@ import net.i2p.data.i2np.TunnelSessionKey;
import net.i2p.data.i2np.TunnelSigningPrivateKey; import net.i2p.data.i2np.TunnelSigningPrivateKey;
import net.i2p.data.i2np.TunnelSigningPublicKey; import net.i2p.data.i2np.TunnelSigningPublicKey;
import net.i2p.util.Log;
/** /**
* Defines the information associated with a tunnel * Defines the information associated with a tunnel
*/ */
public class TunnelInfo extends DataStructureImpl { public class TunnelInfo extends DataStructureImpl {
private I2PAppContext _context; private I2PAppContext _context;
private static Log _log;
private TunnelId _id; private TunnelId _id;
private Hash _nextHop; private Hash _nextHop;
private Hash _thisHop; private Hash _thisHop;
@ -51,9 +54,12 @@ public class TunnelInfo extends DataStructureImpl {
private long _lastTested; private long _lastTested;
private boolean _ready; private boolean _ready;
private boolean _wasEverReady; private boolean _wasEverReady;
private int _messagesProcessed;
public TunnelInfo(I2PAppContext context) { public TunnelInfo(I2PAppContext context) {
_context = context; _context = context;
if (_log == null)
_log = context.logManager().getLog(TunnelInfo.class);
setTunnelId(null); setTunnelId(null);
setThisHop(null); setThisHop(null);
setNextHop(null); setNextHop(null);
@ -69,6 +75,7 @@ public class TunnelInfo extends DataStructureImpl {
_wasEverReady = false; _wasEverReady = false;
_created = _context.clock().now(); _created = _context.clock().now();
_lastTested = -1; _lastTested = -1;
_messagesProcessed = 0;
} }
public TunnelId getTunnelId() { return _id; } public TunnelId getTunnelId() { return _id; }
@ -162,6 +169,15 @@ public class TunnelInfo extends DataStructureImpl {
return len; return len;
} }
/** how many messages have passed through this tunnel in its lifetime? */
public int getMessagesProcessed() {
if (_log.shouldLog(Log.DEBUG))
_log.debug("Tunnel " + _id.getTunnelId() + " processed " + _messagesProcessed + " messages");
return _messagesProcessed;
}
/** we have just processed a message for this tunnel */
public void messageProcessed() { _messagesProcessed++; }
public void readBytes(InputStream in) throws DataFormatException, IOException { public void readBytes(InputStream in) throws DataFormatException, IOException {
_options = DataHelper.readProperties(in); _options = DataHelper.readProperties(in);
Boolean includeDest = DataHelper.readBoolean(in); Boolean includeDest = DataHelper.readBoolean(in);