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

new stat monitoring the netDb search reply message sizes

Browse Source
This commit is contained in:
jrandom
2004-07-25 23:35:50 +00:00
committed by zzz
parent abaa5d87f6
commit 476e23db5b
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
router/java/src/net/i2p/data/i2np/DatabaseSearchReplyMessage.java
View File

@ -39,6 +39,8 @@ public class DatabaseSearchReplyMessage extends I2NPMessageImpl {
public DatabaseSearchReplyMessage(I2PAppContext context) {
super(context);
_context.statManager().createRateStat("netDb.searchReplyMessageSend", "How many search reply messages we send", "Network Database", new long[] { 60*1000, 5*60*1000, 10*60*1000, 60*60*1000 });
_context.statManager().createRateStat("netDb.searchReplyMessageReceive", "How many search reply messages we receive", "Network Database", new long[] { 60*1000, 5*60*1000, 10*60*1000, 60*60*1000 });
setSearchKey(null);
_routerInfoStructures = new ArrayList();
setFromHash(null);
@ -83,6 +85,8 @@ public class DatabaseSearchReplyMessage extends I2NPMessageImpl {
_from = new Hash();
_from.readBytes(in);
_context.statManager().addRateData("netDb.searchReplyMessageReceive", compressedLength + 64, 1);
} catch (DataFormatException dfe) {
throw new I2NPMessageException("Unable to load the message data", dfe);
}
@ -98,6 +102,7 @@ public class DatabaseSearchReplyMessage extends I2NPMessageImpl {
if (_from == null)
throw new I2NPMessageException("No 'from' address specified!");
byte rv[] = null;
ByteArrayOutputStream os = new ByteArrayOutputStream(32);
try {
_key.writeBytes(os);
@ -113,10 +118,13 @@ public class DatabaseSearchReplyMessage extends I2NPMessageImpl {
DataHelper.writeLong(os, 2, compressed.length);
os.write(compressed);
_from.writeBytes(os);
rv = os.toByteArray();
_context.statManager().addRateData("netDb.searchReplyMessageSendSize", rv.length, 1);
} catch (DataFormatException dfe) {
throw new I2NPMessageException("Error writing out the message data", dfe);
}
return os.toByteArray();
return rv;
}
public int getType() { return MESSAGE_TYPE; }