Class DHTTransportStatsImpl
java.lang.Object
com.biglybt.core.dht.transport.util.DHTTransportStatsImpl
- All Implemented Interfaces:
DHTTransportStats
- Direct Known Subclasses:
DHTTransportLoopbackStatsImpl
,DHTTransportUDPStatsImpl
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate long[]
private long[]
private long[]
private long[]
private final long[]
private long
private long
private long[]
private long
private long
private final long[]
private long
private long
private long[]
private final byte
private final int[]
private static final int
private int
private final BloomFilter
private int
private static final int
private final int[]
private final long[]
private long[]
private long[]
Fields inherited from interface com.biglybt.core.dht.transport.DHTTransportStats
AT_FIND_NODE, AT_FIND_VALUE, AT_KEY_BLOCK, AT_PING, AT_QUERY_STORE, AT_STATS, AT_STORE, STAT_FAILED, STAT_OK, STAT_RECEIVED, STAT_SENT
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionprivate void
add
(long[] a, long[] b) void
add
(DHTTransportStatsImpl other) void
void
dataOK()
void
void
dataSent
(DHTUDPPacketRequest request) void
void
void
void
findNodeSent
(DHTUDPPacketRequest request) void
void
void
void
findValueSent
(DHTUDPPacketRequest request) long[]
long[]
getData()
long[]
long[]
long
long[]
long[]
getPings()
returns pings sent, pings succeeded, pings failed, pings receivedprotected byte
long[]
int[]
long
long[]
protected String
getString
(long[] x) void
incomingRequestReceived
(DHTUDPPacketRequest request, boolean alien) void
void
void
void
keyBlockSent
(DHTUDPPacketRequest request) protected void
outgoingRequestSent
(DHTUDPPacketRequest request) void
void
pingOK()
void
void
pingSent
(DHTUDPPacketRequest request) void
void
void
void
queryStoreSent
(DHTUDPPacketRequest request) void
receivedRTT
(int rtt) void
recordSkew
(InetSocketAddress originator_address, long skew) protected void
void
void
statsOK()
void
void
statsSent
(DHTUDPPacketRequest request) void
void
storeOK()
void
void
storeSent
(DHTUDPPacketRequest request) Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface com.biglybt.core.dht.transport.DHTTransportStats
getBytesReceived, getBytesSent, getPacketsReceived, getPacketsSent, getRequestsTimedOut, getRouteablePercentage, snapshot
-
Field Details
-
RTT_HISTORY
private static final int RTT_HISTORY- See Also:
-
protocol_version
private final byte protocol_version -
pings
private long[] pings -
find_nodes
private long[] find_nodes -
find_values
private long[] find_values -
stores
private long[] stores -
stats
private final long[] stats -
data
private long[] data -
key_blocks
private long[] key_blocks -
store_queries
private long[] store_queries -
aliens
private long[] aliens -
incoming_requests
private long incoming_requests -
outgoing_requests
private long outgoing_requests -
incoming_version_requests
private long incoming_version_requests -
incoming_request_versions
private final long[] incoming_request_versions -
outgoing_version_requests
private long outgoing_version_requests -
outgoing_request_versions
private final long[] outgoing_request_versions -
SKEW_VALUE_MAX
private static final int SKEW_VALUE_MAX- See Also:
-
skew_values
private final int[] skew_values -
skew_pos
private int skew_pos -
last_skew_average
private long last_skew_average -
last_skew_average_time
private long last_skew_average_time -
skew_originator_bloom
-
rtt_history
private final int[] rtt_history -
rtt_history_pos
private int rtt_history_pos
-
-
Constructor Details
-
DHTTransportStatsImpl
protected DHTTransportStatsImpl(byte _protocol_version)
-
-
Method Details
-
getProtocolVersion
protected byte getProtocolVersion() -
receivedRTT
public void receivedRTT(int rtt) -
getRTTHistory
public int[] getRTTHistory()- Specified by:
getRTTHistory
in interfaceDHTTransportStats
-
add
-
add
private void add(long[] a, long[] b) -
snapshotSupport
-
pingSent
-
pingOK
public void pingOK() -
pingFailed
public void pingFailed() -
pingReceived
public void pingReceived() -
getPings
public long[] getPings()Description copied from interface:DHTTransportStats
returns pings sent, pings succeeded, pings failed, pings received- Specified by:
getPings
in interfaceDHTTransportStats
- Returns:
-
keyBlockSent
-
keyBlockOK
public void keyBlockOK() -
keyBlockFailed
public void keyBlockFailed() -
keyBlockReceived
public void keyBlockReceived() -
getKeyBlocks
public long[] getKeyBlocks()- Specified by:
getKeyBlocks
in interfaceDHTTransportStats
-
queryStoreSent
-
queryStoreOK
public void queryStoreOK() -
queryStoreFailed
public void queryStoreFailed() -
queryStoreReceived
public void queryStoreReceived() -
getQueryStores
public long[] getQueryStores()- Specified by:
getQueryStores
in interfaceDHTTransportStats
-
findNodeSent
-
findNodeOK
public void findNodeOK() -
findNodeFailed
public void findNodeFailed() -
findNodeReceived
public void findNodeReceived() -
getFindNodes
public long[] getFindNodes()- Specified by:
getFindNodes
in interfaceDHTTransportStats
-
findValueSent
-
findValueOK
public void findValueOK() -
findValueFailed
public void findValueFailed() -
findValueReceived
public void findValueReceived() -
getFindValues
public long[] getFindValues()- Specified by:
getFindValues
in interfaceDHTTransportStats
-
storeSent
-
storeOK
public void storeOK() -
storeFailed
public void storeFailed() -
storeReceived
public void storeReceived() -
getStores
public long[] getStores()- Specified by:
getStores
in interfaceDHTTransportStats
-
statsSent
-
statsOK
public void statsOK() -
statsFailed
public void statsFailed() -
statsReceived
public void statsReceived() -
dataSent
-
dataOK
public void dataOK() -
dataFailed
public void dataFailed() -
dataReceived
public void dataReceived() -
getData
public long[] getData()- Specified by:
getData
in interfaceDHTTransportStats
-
outgoingRequestSent
-
incomingRequestReceived
-
getAliens
public long[] getAliens()- Specified by:
getAliens
in interfaceDHTTransportStats
-
getIncomingRequests
public long getIncomingRequests()- Specified by:
getIncomingRequests
in interfaceDHTTransportStats
-
recordSkew
-
getSkewAverage
public long getSkewAverage()- Specified by:
getSkewAverage
in interfaceDHTTransportStats
-
getString
- Specified by:
getString
in interfaceDHTTransportStats
-
getString
-