Class DHTTransportStatsImpl
- java.lang.Object
-
- com.biglybt.core.dht.transport.util.DHTTransportStatsImpl
-
- All Implemented Interfaces:
DHTTransportStats
- Direct Known Subclasses:
DHTTransportLoopbackStatsImpl
,DHTTransportUDPStatsImpl
public abstract class DHTTransportStatsImpl extends java.lang.Object implements DHTTransportStats
-
-
Field Summary
Fields Modifier and Type Field Description private long[]
aliens
private long[]
data
private long[]
find_nodes
private long[]
find_values
private long[]
incoming_request_versions
private long
incoming_requests
private long
incoming_version_requests
private long[]
key_blocks
private long
last_skew_average
private long
last_skew_average_time
private long[]
outgoing_request_versions
private long
outgoing_requests
private long
outgoing_version_requests
private long[]
pings
private byte
protocol_version
private int[]
rtt_history
private static int
RTT_HISTORY
private int
rtt_history_pos
private BloomFilter
skew_originator_bloom
private int
skew_pos
private static int
SKEW_VALUE_MAX
private int[]
skew_values
private long[]
stats
private long[]
store_queries
private long[]
stores
-
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 Modifier Constructor Description protected
DHTTransportStatsImpl(byte _protocol_version)
-
Method Summary
-
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 Detail
-
RTT_HISTORY
private static final int RTT_HISTORY
- See Also:
- Constant Field Values
-
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:
- Constant Field Values
-
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
private final BloomFilter skew_originator_bloom
-
rtt_history
private final int[] rtt_history
-
rtt_history_pos
private int rtt_history_pos
-
-
Method Detail
-
getProtocolVersion
protected byte getProtocolVersion()
-
receivedRTT
public void receivedRTT(int rtt)
-
getRTTHistory
public int[] getRTTHistory()
- Specified by:
getRTTHistory
in interfaceDHTTransportStats
-
add
public void add(DHTTransportStatsImpl other)
-
add
private void add(long[] a, long[] b)
-
snapshotSupport
protected void snapshotSupport(DHTTransportStatsImpl clone)
-
pingSent
public void pingSent(DHTUDPPacketRequest request)
-
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
public void keyBlockSent(DHTUDPPacketRequest request)
-
keyBlockOK
public void keyBlockOK()
-
keyBlockFailed
public void keyBlockFailed()
-
keyBlockReceived
public void keyBlockReceived()
-
getKeyBlocks
public long[] getKeyBlocks()
- Specified by:
getKeyBlocks
in interfaceDHTTransportStats
-
queryStoreSent
public void queryStoreSent(DHTUDPPacketRequest request)
-
queryStoreOK
public void queryStoreOK()
-
queryStoreFailed
public void queryStoreFailed()
-
queryStoreReceived
public void queryStoreReceived()
-
getQueryStores
public long[] getQueryStores()
- Specified by:
getQueryStores
in interfaceDHTTransportStats
-
findNodeSent
public void findNodeSent(DHTUDPPacketRequest request)
-
findNodeOK
public void findNodeOK()
-
findNodeFailed
public void findNodeFailed()
-
findNodeReceived
public void findNodeReceived()
-
getFindNodes
public long[] getFindNodes()
- Specified by:
getFindNodes
in interfaceDHTTransportStats
-
findValueSent
public void findValueSent(DHTUDPPacketRequest request)
-
findValueOK
public void findValueOK()
-
findValueFailed
public void findValueFailed()
-
findValueReceived
public void findValueReceived()
-
getFindValues
public long[] getFindValues()
- Specified by:
getFindValues
in interfaceDHTTransportStats
-
storeSent
public void storeSent(DHTUDPPacketRequest request)
-
storeOK
public void storeOK()
-
storeFailed
public void storeFailed()
-
storeReceived
public void storeReceived()
-
getStores
public long[] getStores()
- Specified by:
getStores
in interfaceDHTTransportStats
-
statsSent
public void statsSent(DHTUDPPacketRequest request)
-
statsOK
public void statsOK()
-
statsFailed
public void statsFailed()
-
statsReceived
public void statsReceived()
-
dataSent
public void dataSent(DHTUDPPacketRequest request)
-
dataOK
public void dataOK()
-
dataFailed
public void dataFailed()
-
dataReceived
public void dataReceived()
-
getData
public long[] getData()
- Specified by:
getData
in interfaceDHTTransportStats
-
outgoingRequestSent
protected void outgoingRequestSent(DHTUDPPacketRequest request)
-
incomingRequestReceived
public void incomingRequestReceived(DHTUDPPacketRequest request, boolean alien)
-
getAliens
public long[] getAliens()
- Specified by:
getAliens
in interfaceDHTTransportStats
-
getIncomingRequests
public long getIncomingRequests()
- Specified by:
getIncomingRequests
in interfaceDHTTransportStats
-
recordSkew
public void recordSkew(java.net.InetSocketAddress originator_address, long skew)
-
getSkewAverage
public long getSkewAverage()
- Specified by:
getSkewAverage
in interfaceDHTTransportStats
-
getString
public java.lang.String getString()
- Specified by:
getString
in interfaceDHTTransportStats
-
getString
protected java.lang.String getString(long[] x)
-
-