com.aelitis.azureus.core.dht.transport.util
Class DHTTransportStatsImpl

java.lang.Object
  extended by com.aelitis.azureus.core.dht.transport.util.DHTTransportStatsImpl
All Implemented Interfaces:
DHTTransportStats
Direct Known Subclasses:
DHTTransportLoopbackStatsImpl, DHTTransportUDPStatsImpl

public abstract class DHTTransportStatsImpl
extends Object
implements DHTTransportStats

Author:
parg

Field Summary
 
Fields inherited from interface com.aelitis.azureus.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
protected DHTTransportStatsImpl(byte _protocol_version)
           
 
Method Summary
 void add(DHTTransportStatsImpl other)
           
 void dataFailed()
           
 void dataOK()
           
 void dataReceived()
           
 void dataSent(DHTUDPPacketRequest request)
           
 void findNodeFailed()
           
 void findNodeOK()
           
 void findNodeReceived()
           
 void findNodeSent(DHTUDPPacketRequest request)
           
 void findValueFailed()
           
 void findValueOK()
           
 void findValueReceived()
           
 void findValueSent(DHTUDPPacketRequest request)
           
 long[] getAliens()
           
 long[] getData()
           
 long[] getFindNodes()
           
 long[] getFindValues()
           
 long getIncomingRequests()
           
 long[] getKeyBlocks()
           
 long[] getPings()
          returns pings sent, pings succeeded, pings failed, pings received
protected  byte getProtocolVersion()
           
 long[] getQueryStores()
           
 int[] getRTTHistory()
           
 long getSkewAverage()
           
 long[] getStores()
           
 String getString()
           
protected  String getString(long[] x)
           
 void incomingRequestReceived(DHTUDPPacketRequest request, boolean alien)
           
 void keyBlockFailed()
           
 void keyBlockOK()
           
 void keyBlockReceived()
           
 void keyBlockSent(DHTUDPPacketRequest request)
           
protected  void outgoingRequestSent(DHTUDPPacketRequest request)
           
 void pingFailed()
           
 void pingOK()
           
 void pingReceived()
           
 void pingSent(DHTUDPPacketRequest request)
           
 void queryStoreFailed()
           
 void queryStoreOK()
           
 void queryStoreReceived()
           
 void queryStoreSent(DHTUDPPacketRequest request)
           
 void receivedRTT(int rtt)
           
 void recordSkew(InetSocketAddress originator_address, long skew)
           
protected  void snapshotSupport(DHTTransportStatsImpl clone)
           
 void statsFailed()
           
 void statsOK()
           
 void statsReceived()
           
 void statsSent(DHTUDPPacketRequest request)
           
 void storeFailed()
           
 void storeOK()
           
 void storeReceived()
           
 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.aelitis.azureus.core.dht.transport.DHTTransportStats
getBytesReceived, getBytesSent, getPacketsReceived, getPacketsSent, getRequestsTimedOut, getRouteablePercentage, snapshot
 

Constructor Detail

DHTTransportStatsImpl

protected DHTTransportStatsImpl(byte _protocol_version)
Method Detail

getProtocolVersion

protected byte getProtocolVersion()

receivedRTT

public void receivedRTT(int rtt)

getRTTHistory

public int[] getRTTHistory()
Specified by:
getRTTHistory in interface DHTTransportStats

add

public void add(DHTTransportStatsImpl other)

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 interface DHTTransportStats
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 interface DHTTransportStats

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 interface DHTTransportStats

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 interface DHTTransportStats

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 interface DHTTransportStats

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 interface DHTTransportStats

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 interface DHTTransportStats

outgoingRequestSent

protected void outgoingRequestSent(DHTUDPPacketRequest request)

incomingRequestReceived

public void incomingRequestReceived(DHTUDPPacketRequest request,
                                    boolean alien)

getAliens

public long[] getAliens()
Specified by:
getAliens in interface DHTTransportStats

getIncomingRequests

public long getIncomingRequests()
Specified by:
getIncomingRequests in interface DHTTransportStats

recordSkew

public void recordSkew(InetSocketAddress originator_address,
                       long skew)

getSkewAverage

public long getSkewAverage()
Specified by:
getSkewAverage in interface DHTTransportStats

getString

public String getString()
Specified by:
getString in interface DHTTransportStats

getString

protected String getString(long[] x)