Class DHTTransportLoopbackContactImpl
- java.lang.Object
-
- com.biglybt.core.dht.transport.loopback.DHTTransportLoopbackContactImpl
-
- All Implemented Interfaces:
DHTTransportContact
public class DHTTransportLoopbackContactImpl extends java.lang.Object implements DHTTransportContact
-
-
Field Summary
Fields Modifier and Type Field Description private byte[]
id
private int
random_id
private DHTTransportLoopbackImpl
transport
-
Fields inherited from interface com.biglybt.core.dht.transport.DHTTransportContact
RANDOM_ID_TYPE1, RANDOM_ID_TYPE2
-
-
Constructor Summary
Constructors Modifier Constructor Description protected
DHTTransportLoopbackContactImpl(DHTTransportLoopbackImpl _transport, byte[] _id)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
createNetworkPositions(boolean is_local)
void
exportContact(java.io.DataOutputStream os)
java.util.Map<java.lang.String,java.lang.Object>
exportContactToMap()
java.net.InetSocketAddress
getAddress()
byte[]
getBloomKey()
long
getClockSkew()
java.net.InetSocketAddress
getExternalAddress()
byte[]
getID()
int
getInstanceID()
int
getMaxFailForLiveCount()
int
getMaxFailForUnknownCount()
java.lang.String
getName()
DHTNetworkPosition
getNetworkPosition(byte type)
DHTNetworkPosition[]
getNetworkPositions()
byte
getProtocolVersion()
int
getRandomID()
byte[]
getRandomID2()
int
getRandomIDType()
DHTTransportFullStats
getStats()
java.lang.String
getString()
DHTTransport
getTransport()
java.net.InetSocketAddress
getTransportAddress()
boolean
isAlive(long timeout)
void
isAlive(DHTTransportReplyHandler handler, long timeout)
boolean
isSleeping()
boolean
isValid()
void
remove()
void
sendFindNode(DHTTransportReplyHandler handler, byte[] nid, short flags)
void
sendFindValue(DHTTransportReplyHandler handler, byte[] key, int max, short flags)
void
sendImmediatePing(DHTTransportReplyHandler handler, long timeout)
void
sendKeyBlock(DHTTransportReplyHandler handler, byte[] request, byte[] signature)
void
sendPing(DHTTransportReplyHandler handler)
void
sendQueryStore(DHTTransportReplyHandler handler, int header_length, java.util.List<java.lang.Object[]> key_details)
void
sendStats(DHTTransportReplyHandler handler)
void
sendStore(DHTTransportReplyHandler handler, byte[][] keys, DHTTransportValue[][] value_sets, boolean immediate)
void
setRandomID(int _random_id)
void
setRandomID2(byte[] id)
-
-
-
Field Detail
-
transport
private final DHTTransportLoopbackImpl transport
-
id
private final byte[] id
-
random_id
private int random_id
-
-
Constructor Detail
-
DHTTransportLoopbackContactImpl
protected DHTTransportLoopbackContactImpl(DHTTransportLoopbackImpl _transport, byte[] _id)
-
-
Method Detail
-
getTransport
public DHTTransport getTransport()
- Specified by:
getTransport
in interfaceDHTTransportContact
-
getInstanceID
public int getInstanceID()
- Specified by:
getInstanceID
in interfaceDHTTransportContact
-
getProtocolVersion
public byte getProtocolVersion()
- Specified by:
getProtocolVersion
in interfaceDHTTransportContact
-
getClockSkew
public long getClockSkew()
- Specified by:
getClockSkew
in interfaceDHTTransportContact
-
getRandomIDType
public int getRandomIDType()
- Specified by:
getRandomIDType
in interfaceDHTTransportContact
-
getRandomID
public int getRandomID()
- Specified by:
getRandomID
in interfaceDHTTransportContact
-
setRandomID
public void setRandomID(int _random_id)
- Specified by:
setRandomID
in interfaceDHTTransportContact
-
setRandomID2
public void setRandomID2(byte[] id)
- Specified by:
setRandomID2
in interfaceDHTTransportContact
-
getRandomID2
public byte[] getRandomID2()
- Specified by:
getRandomID2
in interfaceDHTTransportContact
-
isValid
public boolean isValid()
- Specified by:
isValid
in interfaceDHTTransportContact
-
isSleeping
public boolean isSleeping()
- Specified by:
isSleeping
in interfaceDHTTransportContact
-
getMaxFailForLiveCount
public int getMaxFailForLiveCount()
- Specified by:
getMaxFailForLiveCount
in interfaceDHTTransportContact
-
getMaxFailForUnknownCount
public int getMaxFailForUnknownCount()
- Specified by:
getMaxFailForUnknownCount
in interfaceDHTTransportContact
-
getName
public java.lang.String getName()
- Specified by:
getName
in interfaceDHTTransportContact
-
getBloomKey
public byte[] getBloomKey()
- Specified by:
getBloomKey
in interfaceDHTTransportContact
-
getAddress
public java.net.InetSocketAddress getAddress()
- Specified by:
getAddress
in interfaceDHTTransportContact
-
getTransportAddress
public java.net.InetSocketAddress getTransportAddress()
- Specified by:
getTransportAddress
in interfaceDHTTransportContact
-
getExternalAddress
public java.net.InetSocketAddress getExternalAddress()
- Specified by:
getExternalAddress
in interfaceDHTTransportContact
-
isAlive
public boolean isAlive(long timeout)
- Specified by:
isAlive
in interfaceDHTTransportContact
-
isAlive
public void isAlive(DHTTransportReplyHandler handler, long timeout)
- Specified by:
isAlive
in interfaceDHTTransportContact
-
sendPing
public void sendPing(DHTTransportReplyHandler handler)
- Specified by:
sendPing
in interfaceDHTTransportContact
-
sendImmediatePing
public void sendImmediatePing(DHTTransportReplyHandler handler, long timeout)
- Specified by:
sendImmediatePing
in interfaceDHTTransportContact
-
sendKeyBlock
public void sendKeyBlock(DHTTransportReplyHandler handler, byte[] request, byte[] signature)
- Specified by:
sendKeyBlock
in interfaceDHTTransportContact
-
sendStats
public void sendStats(DHTTransportReplyHandler handler)
- Specified by:
sendStats
in interfaceDHTTransportContact
-
sendStore
public void sendStore(DHTTransportReplyHandler handler, byte[][] keys, DHTTransportValue[][] value_sets, boolean immediate)
- Specified by:
sendStore
in interfaceDHTTransportContact
-
sendQueryStore
public void sendQueryStore(DHTTransportReplyHandler handler, int header_length, java.util.List<java.lang.Object[]> key_details)
- Specified by:
sendQueryStore
in interfaceDHTTransportContact
-
sendFindNode
public void sendFindNode(DHTTransportReplyHandler handler, byte[] nid, short flags)
- Specified by:
sendFindNode
in interfaceDHTTransportContact
-
sendFindValue
public void sendFindValue(DHTTransportReplyHandler handler, byte[] key, int max, short flags)
- Specified by:
sendFindValue
in interfaceDHTTransportContact
-
getStats
public DHTTransportFullStats getStats()
- Specified by:
getStats
in interfaceDHTTransportContact
-
getID
public byte[] getID()
- Specified by:
getID
in interfaceDHTTransportContact
-
exportContact
public void exportContact(java.io.DataOutputStream os) throws java.io.IOException
- Specified by:
exportContact
in interfaceDHTTransportContact
- Throws:
java.io.IOException
-
exportContactToMap
public java.util.Map<java.lang.String,java.lang.Object> exportContactToMap()
- Specified by:
exportContactToMap
in interfaceDHTTransportContact
-
remove
public void remove()
- Specified by:
remove
in interfaceDHTTransportContact
-
createNetworkPositions
public void createNetworkPositions(boolean is_local)
- Specified by:
createNetworkPositions
in interfaceDHTTransportContact
-
getNetworkPositions
public DHTNetworkPosition[] getNetworkPositions()
- Specified by:
getNetworkPositions
in interfaceDHTTransportContact
-
getNetworkPosition
public DHTNetworkPosition getNetworkPosition(byte type)
- Specified by:
getNetworkPosition
in interfaceDHTTransportContact
-
getString
public java.lang.String getString()
- Specified by:
getString
in interfaceDHTTransportContact
-
-