public class ProfileManagerImpl extends Object implements ProfileManager
Constructor and Description |
---|
ProfileManagerImpl(RouterContext context) |
Modifier and Type | Method and Description |
---|---|
void |
commErrorOccurred(Hash peer)
Note that there was some sort of communication error talking with the peer
|
void |
dbLookupFailed(Hash peer)
Note that the peer was unable to reply to a db lookup - either with data or with
a lookupReply redirecting the user elsewhere
This will force creation of DB stats
|
void |
dbLookupReceived(Hash peer)
Note that the local router received a db lookup from the given peer
|
void |
dbLookupReply(Hash peer,
int newPeers,
int oldPeers,
int invalid,
int duplicate,
long responseTimeMs)
Note that the peer replied to a db lookup with a redirect to other routers, where
the list of redirected users included newPeers routers that the local router didn't
know about, oldPeers routers that the local router already knew about, the given invalid
routers that were invalid in some way, and the duplicate number of routers that we explicitly
asked them not to send us, but they did anyway
|
void |
dbLookupSuccessful(Hash peer,
long responseTimeMs)
Note that the peer was able to return the valid data for a db lookup
This will force creation of DB stats
|
void |
dbStoreFailed(Hash peer)
Note that we were unable to confirm a successful send of db data to
the peer, at least not within our timeout period
This will force creation of DB stats
|
void |
dbStoreReceived(Hash peer,
boolean wasNewKey)
Note that the local router received an unprompted db store from the given peer
|
void |
dbStoreSent(Hash peer,
long responseTimeMs)
Note that we've confirmed a successful send of db data to the peer (though we haven't
necessarily requested it again from them, so they /might/ be lying)
This is not really interesting, since they could be lying, so we do not
increment any DB stats at all.
|
void |
dbStoreSuccessful(Hash peer)
Note that we've verified a successful send of db data to the floodfill peer
by querying another floodfill.
|
void |
heardAbout(Hash peer)
Note that the local router received a reference to the given peer, either
through an explicit dbStore or in a dbLookupReply
|
void |
heardAbout(Hash peer,
long when)
Note that the local router received a reference to the given peer
at a certain time.
|
void |
messageFailed(Hash peer)
Note that the router failed to send a message to the peer over any transport.
|
void |
messageFailed(Hash peer,
String transport)
Note that the router failed to send a message to the peer over the transport specified.
|
void |
messageReceived(Hash peer,
String style,
long msToReceive,
int bytesRead)
Note that the router received a message from the given peer on the specified
transport.
|
void |
messageSent(Hash peer,
String transport,
long msToSend,
long bytesSent)
Note that it took msToSend to send a message of size bytesSent to the peer over the transport.
|
Properties |
summarizePeers(int numPeers)
Deprecated.
unused
|
void |
tunnelDataPushed(Hash peer,
long rtt,
int size)
Note that we were able to push some data through a tunnel that the peer
is participating in (detected after rtt).
|
void |
tunnelDataPushed1m(Hash peer,
int size)
Note that the peer is participating in a tunnel that pushed the given amount of data
over the last minute.
|
void |
tunnelFailed(Hash peer,
int pct)
Note that the peer participated in a tunnel that failed.
|
void |
tunnelJoined(Hash peer,
long responseTimeMs)
Note that the router agreed to participate in a tunnel
|
void |
tunnelLifetimePushed(Hash peer,
long lifetime,
long size)
Note that we were able to push the given amount of data through a tunnel
that the peer is participating in
|
void |
tunnelRejected(Hash peer,
long responseTimeMs,
int severity)
Note that a router explicitly rejected joining a tunnel.
|
void |
tunnelTestSucceeded(Hash peer,
long responseTimeMs)
Note that a tunnel that the router is participating in
was successfully tested with the given round trip latency
|
void |
tunnelTimedOut(Hash peer)
Note that a router did not respond to a tunnel join.
|
public ProfileManagerImpl(RouterContext context)
public void messageSent(Hash peer, String transport, long msToSend, long bytesSent)
messageSent
in interface ProfileManager
public void messageFailed(Hash peer, String transport)
messageFailed
in interface ProfileManager
public void messageFailed(Hash peer)
messageFailed
in interface ProfileManager
public void commErrorOccurred(Hash peer)
commErrorOccurred
in interface ProfileManager
public void tunnelJoined(Hash peer, long responseTimeMs)
tunnelJoined
in interface ProfileManager
public void tunnelRejected(Hash peer, long responseTimeMs, int severity)
tunnelRejected
in interface ProfileManager
responseTimeMs
- ignoredseverity
- how much the peer doesnt want to participate in the
tunnel (large == more severe)peer
- who rejected uspublic void tunnelTimedOut(Hash peer)
tunnelTimedOut
in interface ProfileManager
peer
- who rejected uspublic void tunnelTestSucceeded(Hash peer, long responseTimeMs)
tunnelTestSucceeded
in interface ProfileManager
public void tunnelDataPushed(Hash peer, long rtt, int size)
ProfileManager
tunnelDataPushed
in interface ProfileManager
public void tunnelDataPushed1m(Hash peer, int size)
ProfileManager
tunnelDataPushed1m
in interface ProfileManager
public void tunnelLifetimePushed(Hash peer, long lifetime, long size)
ProfileManager
tunnelLifetimePushed
in interface ProfileManager
public void tunnelFailed(Hash peer, int pct)
tunnelFailed
in interface ProfileManager
public void dbLookupSuccessful(Hash peer, long responseTimeMs)
dbLookupSuccessful
in interface ProfileManager
public void dbLookupFailed(Hash peer)
dbLookupFailed
in interface ProfileManager
public void dbLookupReply(Hash peer, int newPeers, int oldPeers, int invalid, int duplicate, long responseTimeMs)
dbLookupReply
in interface ProfileManager
public void dbLookupReceived(Hash peer)
dbLookupReceived
in interface ProfileManager
public void dbStoreReceived(Hash peer, boolean wasNewKey)
dbStoreReceived
in interface ProfileManager
public void dbStoreSent(Hash peer, long responseTimeMs)
dbStoreSent
in interface ProfileManager
responseTimeMs
- ignoredpublic void dbStoreSuccessful(Hash peer)
dbStoreSuccessful
in interface ProfileManager
public void dbStoreFailed(Hash peer)
dbStoreFailed
in interface ProfileManager
public void heardAbout(Hash peer)
heardAbout
in interface ProfileManager
public void heardAbout(Hash peer, long when)
heardAbout
in interface ProfileManager
public void messageReceived(Hash peer, String style, long msToReceive, int bytesRead)
messageReceived
in interface ProfileManager
@Deprecated public Properties summarizePeers(int numPeers)
summarizePeers
in interface ProfileManager