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

include the (redundant) rtt in the output file to let tools that dont know how to combine columns do so

Browse Source 
*cough*
This commit is contained in:
jrandom
2004-04-30 06:56:25 +00:00
committed by zzz
parent 4b0d1aac15
commit 86d55b32a6
1 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
apps/heartbeat/java/src/net/i2p/heartbeat/PeerDataWriter.java
View File

@ -59,7 +59,7 @@ public class PeerDataWriter {
String header = getHeader(data); String header = getHeader(data);
out.write(header.getBytes()); out.write(header.getBytes());
out.write("#action\tstatus\tdate and time sent \tsendMs\treplyMs\n".getBytes()); out.write("#action\tstatus\tdate and time sent \tsendMs\treplyMs\troundTrip\n".getBytes());
for (Iterator iter = data.getDataPoints().iterator(); iter.hasNext();) { for (Iterator iter = data.getDataPoints().iterator(); iter.hasNext();) {
PeerData.EventDataPoint point = (PeerData.EventDataPoint) iter.next(); PeerData.EventDataPoint point = (PeerData.EventDataPoint) iter.next();
String line = getEvent(point); String line = getEvent(point);
@ -84,12 +84,15 @@ public class PeerDataWriter {
buf.append("lifetimeSent \t").append(data.getLifetimeSent()).append('\n'); buf.append("lifetimeSent \t").append(data.getLifetimeSent()).append('\n');
buf.append("lifetimeRecv \t").append(data.getLifetimeReceived()).append('\n'); buf.append("lifetimeRecv \t").append(data.getLifetimeReceived()).append('\n');
int periods[] = data.getAveragePeriods(); int periods[] = data.getAveragePeriods();
buf.append("#averages\tminutes\tsendMs\trecvMs\tnumLost\n"); buf.append("#averages\tminutes\tsendMs\trecvMs\tnumLost\troundTrip\n");
for (int i = 0; i < periods.length; i++) { for (int i = 0; i < periods.length; i++) {
buf.append("periodAverage\t").append(periods[i]).append('\t'); buf.append("periodAverage\t").append(periods[i]).append('\t');
buf.append(getNum(data.getAverageSendTime(periods[i]))).append('\t'); buf.append(getNum(data.getAverageSendTime(periods[i]))).append('\t');
buf.append(getNum(data.getAverageReceiveTime(periods[i]))).append('\t'); buf.append(getNum(data.getAverageReceiveTime(periods[i]))).append('\t');
buf.append(getNum(data.getLostMessages(periods[i]))).append('\n'); buf.append(getNum(data.getLostMessages(periods[i]))).append('\t');
double rtt = data.getAverageSendTime(periods[i])
+ data.getAverageReceiveTime(periods[i]);
buf.append(getNum(rtt)).append('\n');
} }
return buf.toString(); return buf.toString();
} }
@ -105,6 +108,7 @@ public class PeerDataWriter {
if (point.getWasPonged()) { if (point.getWasPonged()) {
buf.append(point.getPongSent() - point.getPingSent()).append('\t'); buf.append(point.getPongSent() - point.getPingSent()).append('\t');
buf.append(point.getPongReceived() - point.getPongSent()).append('\t'); buf.append(point.getPongReceived() - point.getPongSent()).append('\t');
buf.append(point.getPongReceived() - point.getPingSent()).append('\t');
} }
buf.append('\n'); buf.append('\n');
return buf.toString(); return buf.toString();