Class DHTTransportUDPContactImpl
java.lang.Object
com.biglybt.core.dht.transport.udp.impl.DHTTransportUDPContactImpl
- All Implemented Interfaces:
DHTTransportContact
,DHTTransportUDPContact
-
Field Summary
FieldsModifier and TypeFieldDescriptionprivate InetSocketAddress
private byte
private byte[]
private int
private DHTNetworkPosition[]
private int
static final int
static final int
private byte
private int
private final long
(package private) final DHTTransportUDPImpl
private InetSocketAddress
Fields inherited from interface com.biglybt.core.dht.transport.DHTTransportContact
RANDOM_ID_TYPE1, RANDOM_ID_TYPE2
-
Constructor Summary
ConstructorsModifierConstructorDescriptionprotected
DHTTransportUDPContactImpl
(boolean _is_local, DHTTransportUDPImpl _transport, InetSocketAddress _transport_address, InetSocketAddress _external_address, byte _protocol_version, int _instance_id, long _skew, byte _generic_flags) -
Method Summary
Modifier and TypeMethodDescriptionprotected boolean
void
createNetworkPositions
(boolean is_local) void
byte[]
long
byte[]
getID()
int
int
int
getName()
getNetworkPosition
(byte position_type) protected int
byte
int
byte[]
int
getStats()
boolean
isAlive
(long timeout) void
isAlive
(DHTTransportReplyHandler handler, long timeout) boolean
boolean
isValid()
void
remove()
void
sendFindNode
(DHTTransportReplyHandler handler, byte[] nid, short flags) void
sendFindValue
(DHTTransportReplyHandler handler, byte[] key, int max_values, 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, List<Object[]> key_details) void
sendStats
(DHTTransportReplyHandler handler) void
sendStore
(DHTTransportReplyHandler handler, byte[][] keys, DHTTransportValue[][] value_sets, boolean immediate) protected void
setGenericFlags
(byte flags) protected void
setInstanceIDAndVersion
(int _instance_id, byte _protocol_version) protected void
setNetworkPositions
(DHTNetworkPosition[] positions) protected void
setNodeStatus
(int ns) protected void
setProtocolVersion
(byte v) void
setRandomID
(int _random_id) void
setRandomID2
(byte[] id) void
setTransportAddress
(InetSocketAddress address)
-
Field Details
-
NODE_STATUS_UNKNOWN
public static final int NODE_STATUS_UNKNOWN- See Also:
-
NODE_STATUS_ROUTABLE
public static final int NODE_STATUS_ROUTABLE- See Also:
-
transport
-
external_address
-
transport_address
-
id
private byte[] id -
protocol_version
private byte protocol_version -
instance_id
private int instance_id -
skew
private final long skew -
generic_flags
private byte generic_flags -
random_id
private int random_id -
node_status
private int node_status -
network_positions
-
-
Constructor Details
-
DHTTransportUDPContactImpl
protected DHTTransportUDPContactImpl(boolean _is_local, DHTTransportUDPImpl _transport, InetSocketAddress _transport_address, InetSocketAddress _external_address, byte _protocol_version, int _instance_id, long _skew, byte _generic_flags) throws DHTTransportException - Throws:
DHTTransportException
-
-
Method Details
-
getTransport
- Specified by:
getTransport
in interfaceDHTTransportContact
-
getProtocolVersion
public byte getProtocolVersion()- Specified by:
getProtocolVersion
in interfaceDHTTransportContact
-
setProtocolVersion
protected void setProtocolVersion(byte v) -
getClockSkew
public long getClockSkew()- Specified by:
getClockSkew
in interfaceDHTTransportContact
-
getRandomIDType
public int getRandomIDType()- Specified by:
getRandomIDType
in interfaceDHTTransportContact
-
setRandomID
public void setRandomID(int _random_id) - Specified by:
setRandomID
in interfaceDHTTransportContact
-
getRandomID
public int getRandomID()- Specified by:
getRandomID
in interfaceDHTTransportContact
-
setRandomID2
public void setRandomID2(byte[] id) - Specified by:
setRandomID2
in interfaceDHTTransportContact
-
getRandomID2
public byte[] getRandomID2()- Specified by:
getRandomID2
in interfaceDHTTransportContact
-
getNodeStatus
protected int getNodeStatus() -
setNodeStatus
protected void setNodeStatus(int ns) -
isValid
public boolean isValid()- Specified by:
isValid
in interfaceDHTTransportContact
-
isSleeping
public boolean isSleeping()- Specified by:
isSleeping
in interfaceDHTTransportContact
-
setGenericFlags
protected void setGenericFlags(byte flags) -
addressMatchesID
protected boolean addressMatchesID() -
getTransportAddress
- Specified by:
getTransportAddress
in interfaceDHTTransportContact
-
setTransportAddress
- Specified by:
setTransportAddress
in interfaceDHTTransportUDPContact
-
getExternalAddress
- Specified by:
getExternalAddress
in interfaceDHTTransportContact
-
getName
- Specified by:
getName
in interfaceDHTTransportContact
-
getBloomKey
public byte[] getBloomKey()- Specified by:
getBloomKey
in interfaceDHTTransportContact
-
getAddress
- Specified by:
getAddress
in interfaceDHTTransportContact
-
getMaxFailForLiveCount
public int getMaxFailForLiveCount()- Specified by:
getMaxFailForLiveCount
in interfaceDHTTransportContact
-
getMaxFailForUnknownCount
public int getMaxFailForUnknownCount()- Specified by:
getMaxFailForUnknownCount
in interfaceDHTTransportContact
-
getInstanceID
public int getInstanceID()- Specified by:
getInstanceID
in interfaceDHTTransportContact
-
setInstanceIDAndVersion
protected void setInstanceIDAndVersion(int _instance_id, byte _protocol_version) -
isAlive
public boolean isAlive(long timeout) - Specified by:
isAlive
in interfaceDHTTransportContact
-
isAlive
- Specified by:
isAlive
in interfaceDHTTransportContact
-
sendPing
- Specified by:
sendPing
in interfaceDHTTransportContact
-
sendImmediatePing
- Specified by:
sendImmediatePing
in interfaceDHTTransportContact
-
sendStats
- 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, List<Object[]> key_details) - Specified by:
sendQueryStore
in interfaceDHTTransportContact
-
sendFindNode
- Specified by:
sendFindNode
in interfaceDHTTransportContact
-
sendFindValue
public void sendFindValue(DHTTransportReplyHandler handler, byte[] key, int max_values, short flags) - Specified by:
sendFindValue
in interfaceDHTTransportContact
-
sendKeyBlock
- Specified by:
sendKeyBlock
in interfaceDHTTransportContact
-
getStats
- Specified by:
getStats
in interfaceDHTTransportContact
-
getID
public byte[] getID()- Specified by:
getID
in interfaceDHTTransportContact
-
exportContact
- Specified by:
exportContact
in interfaceDHTTransportContact
- Throws:
IOException
DHTTransportException
-
exportContactToMap
- Specified by:
exportContactToMap
in interfaceDHTTransportContact
-
remove
public void remove()- Specified by:
remove
in interfaceDHTTransportContact
-
setNetworkPositions
-
createNetworkPositions
public void createNetworkPositions(boolean is_local) - Specified by:
createNetworkPositions
in interfaceDHTTransportContact
-
getNetworkPositions
- Specified by:
getNetworkPositions
in interfaceDHTTransportContact
-
getNetworkPosition
- Specified by:
getNetworkPosition
in interfaceDHTTransportContact
-
getString
- Specified by:
getString
in interfaceDHTTransportContact
-