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 Object implements DHTTransportStats

  • 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

      private final BloomFilter 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 interface DHTTransportStats

    • 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 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)