|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectnet.i2p.router.peermanager.PeerProfile
public class PeerProfile
Constructor Summary | |
---|---|
PeerProfile(RouterContext context,
Hash peer)
|
|
PeerProfile(RouterContext context,
Hash peer,
boolean expand)
|
Method Summary | |
---|---|
void |
coalesceStats()
update the stats and rates (this should be called once a minute) |
(package private) void |
dataPushed(int size)
|
(package private) void |
dataPushed1m(int size)
the tunnel pushed that much data in a 1 minute period |
boolean |
equals(java.lang.Object obj)
|
void |
expandProfile()
When the given peer is performing well enough that we want to keep detailed stats on them again, call this to set up the info we dropped during shrinkProfile. |
double |
getCapacityBonus()
extra factor added to the capacity ranking - this can be updated in the profile written to disk to affect how the algorithm ranks capacity. |
double |
getCapacityValue()
How many tunnels do we think this peer can handle over the next hour? |
RateStat |
getCommError()
how long between communication errors with the peer (disconnection, etc), calculated over a 1 minute, 1 hour, and 1 day period |
DBHistory |
getDBHistory()
history of db activity with the peer |
RateStat |
getDbIntroduction()
how many new peers we get from dbSearchReplyMessages or dbStore messages, calculated over a 1 hour, 1 day, and 1 week period |
RateStat |
getDbResponseTime()
how long it takes to get a db response from the peer (in milliseconds), calculated over a 1 minute, 1 hour, and 1 day period |
long |
getFirstHeardAbout()
when did we first hear about this peer? |
long |
getIntegrationBonus()
extra factor added to the integration ranking - this can be updated in the profile written to disk to affect how the algorithm ranks integration. |
double |
getIntegrationValue()
How well integrated into the network is this peer (as measured by how much they've told us that we didn't already know). |
boolean |
getIsActive()
Is this peer active at the moment (sending/receiving messages within the last 5 minutes) |
boolean |
getIsActive(long period)
Is this peer active at the moment (sending/receiving messages within the given period?) |
boolean |
getIsExpanded()
are we keeping an expanded profile on the peer, or just the bare minimum. |
boolean |
getIsFailing()
is this peer actively failing (aka not worth touching)? |
long |
getLastHeardAbout()
when did we last hear about this peer? |
long |
getLastHeardFrom()
when did we last hear from the peer? |
long |
getLastSendFailed()
when did we last have a problem sending to this peer? |
long |
getLastSendSuccessful()
when did we last send to this peer successfully? |
double |
getOldSpeedValue()
|
double |
getPeakThroughputKBps()
|
double |
getPeakTunnel1mThroughputKBps()
|
double |
getPeakTunnelThroughputKBps()
|
Hash |
getPeer()
what peer is being profiled |
RateStat |
getReceiveSize()
how large received messages are, calculated over a 1 minute, 1 hour, and 1 day period |
long |
getReliabilityBonus()
extra factor added to the reliability ranking - this can be updated in the profile written to disk to affect how the algorithm ranks reliability. |
double |
getReliabilityValue()
How likely are they to stay up and pass on messages over the next few minutes. |
RateStat |
getSendFailureSize()
how large messages that could not be sent were, calculated over a 1 minute, 1 hour, and 1 day period |
RateStat |
getSendSuccessSize()
how large successfully sent messages are, calculated over a 1 minute, 1 hour, and 1 day period |
long |
getSpeedBonus()
extra factor added to the speed ranking - this can be updated in the profile written to disk to affect how the algorithm ranks speed. |
double |
getSpeedValue()
How fast is the peer, taking into consideration both throughput and latency. |
RateStat |
getTunnelCreateResponseTime()
how long it takes to get a tunnel create response from the peer (in milliseconds), calculated over a 1 minute, 1 hour, and 1 day period |
TunnelHistory |
getTunnelHistory()
history of tunnel activity with the peer |
RateStat |
getTunnelTestResponseTime()
how long it takes to successfully test a tunnel this peer participates in (in milliseconds), calculated over a 10 minute, 1 hour, and 1 day period |
RateStat |
getTunnelTestResponseTimeSlow()
how long it takes to successfully test the peer (in milliseconds) when the time exceeds 5s |
double |
getTunnelTestTimeAverage()
|
int |
hashCode()
|
int |
incrementShitlists()
|
static void |
main(java.lang.String[] args)
Read in all of the profiles specified and print out their calculated values. |
static void |
main2(java.lang.String[] args)
Calculate the memory consumption of profiles. |
void |
setCapacityBonus(long bonus)
|
void |
setDBHistory(DBHistory hist)
|
void |
setFirstHeardAbout(long when)
|
void |
setIntegrationBonus(long bonus)
|
(package private) void |
setIsFailing(boolean val)
|
void |
setLastHeardAbout(long when)
|
void |
setLastHeardFrom(long when)
|
void |
setLastSendFailed(long when)
|
void |
setLastSendSuccessful(long when)
|
void |
setPeakThroughputKBps(double kBps)
|
void |
setPeakTunnel1mThroughputKBps(double kBps)
|
void |
setPeakTunnelThroughputKBps(double kBps)
|
void |
setPeer(Hash peer)
|
void |
setReliabilityBonus(long bonus)
|
void |
setSpeedBonus(long bonus)
|
void |
setTunnelHistory(TunnelHistory history)
|
(package private) void |
setTunnelTestTimeAverage(double avg)
|
void |
shrinkProfile()
when the given peer is performing so poorly that we don't want to bother keeping extensive stats on them, call this to discard excess data points. |
java.lang.String |
toString()
|
(package private) void |
tunnelDataTransferred(long tunnelByteLifetime)
the tunnel pushed that much data in its lifetime |
void |
unshitlist()
|
(package private) void |
updateTunnelTestTimeAverage(long ms)
|
Methods inherited from class java.lang.Object |
---|
clone, finalize, getClass, notify, notifyAll, wait, wait, wait |
Constructor Detail |
---|
public PeerProfile(RouterContext context, Hash peer)
public PeerProfile(RouterContext context, Hash peer, boolean expand)
Method Detail |
---|
public Hash getPeer()
public void setPeer(Hash peer)
public boolean getIsExpanded()
public int incrementShitlists()
public void unshitlist()
public boolean getIsActive()
public boolean getIsActive(long period)
public long getFirstHeardAbout()
public void setFirstHeardAbout(long when)
public long getLastHeardAbout()
public void setLastHeardAbout(long when)
public long getLastSendSuccessful()
public void setLastSendSuccessful(long when)
public long getLastSendFailed()
public void setLastSendFailed(long when)
public long getLastHeardFrom()
public void setLastHeardFrom(long when)
public TunnelHistory getTunnelHistory()
public void setTunnelHistory(TunnelHistory history)
public DBHistory getDBHistory()
public void setDBHistory(DBHistory hist)
public RateStat getSendSuccessSize()
public RateStat getSendFailureSize()
public RateStat getReceiveSize()
public RateStat getDbResponseTime()
public RateStat getTunnelCreateResponseTime()
public RateStat getTunnelTestResponseTime()
public RateStat getTunnelTestResponseTimeSlow()
public RateStat getCommError()
public RateStat getDbIntroduction()
public long getSpeedBonus()
public void setSpeedBonus(long bonus)
public long getReliabilityBonus()
public void setReliabilityBonus(long bonus)
public double getCapacityBonus()
public void setCapacityBonus(long bonus)
public long getIntegrationBonus()
public void setIntegrationBonus(long bonus)
public double getSpeedValue()
public double getOldSpeedValue()
public double getReliabilityValue()
public double getCapacityValue()
public double getIntegrationValue()
public boolean getIsFailing()
public double getTunnelTestTimeAverage()
void setTunnelTestTimeAverage(double avg)
void updateTunnelTestTimeAverage(long ms)
public double getPeakThroughputKBps()
public void setPeakThroughputKBps(double kBps)
void dataPushed(int size)
void tunnelDataTransferred(long tunnelByteLifetime)
public double getPeakTunnelThroughputKBps()
public void setPeakTunnelThroughputKBps(double kBps)
void dataPushed1m(int size)
public double getPeakTunnel1mThroughputKBps()
public void setPeakTunnel1mThroughputKBps(double kBps)
public void shrinkProfile()
public void expandProfile()
public void coalesceStats()
void setIsFailing(boolean val)
public int hashCode()
hashCode
in class java.lang.Object
public boolean equals(java.lang.Object obj)
equals
in class java.lang.Object
public java.lang.String toString()
toString
in class java.lang.Object
public static void main2(java.lang.String[] args)
public static void main(java.lang.String[] args)
PeerProfile [filename]*
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |