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)