Class DHTTransportLoopbackContactImpl

java.lang.Object

com.biglybt.core.dht.transport.loopback.DHTTransportLoopbackContactImpl

All Implemented Interfaces:

DHTTransportContact

public class DHTTransportLoopbackContactImpl
extends Object
implements DHTTransportContact

Field Summary

Fields

Modifier and Type	Field	Description
private final byte[]	id
private int	random_id
private final DHTTransportLoopbackImpl	transport

Fields inherited from interface DHTTransportContact

RANDOM_ID_TYPE1, RANDOM_ID_TYPE2

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DHTTransportLoopbackContactImpl(DHTTransportLoopbackImpl _transport, byte[] _id)

Method Summary

Modifier and Type	Method	Description
void	createNetworkPositions(boolean is_local)
void	exportContact(DataOutputStream os)
Map<String,Object>	exportContactToMap()
InetSocketAddress	getAddress()
byte[]	getBloomKey()
long	getClockSkew()
InetSocketAddress	getExternalAddress()
byte[]	getID()
int	getInstanceID()
int	getMaxFailForLiveCount()
int	getMaxFailForUnknownCount()
String	getName()
DHTNetworkPosition	getNetworkPosition(byte type)
DHTNetworkPosition[]	getNetworkPositions()
byte	getProtocolVersion()
int	getRandomID()
byte[]	getRandomID2()
int	getRandomIDType()
DHTTransportFullStats	getStats()
String	getString()
DHTTransport	getTransport()
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, List<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)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

transport

private final DHTTransportLoopbackImpl transport

id

private final byte[] id

random_id

private int random_id

Constructor Details

DHTTransportLoopbackContactImpl

protected DHTTransportLoopbackContactImpl(DHTTransportLoopbackImpl _transport,
 byte[] _id)

Method Details

getTransport

public DHTTransport getTransport()

Specified by:

getTransport in interface DHTTransportContact

getInstanceID

public int getInstanceID()

Specified by:

getInstanceID in interface DHTTransportContact

getProtocolVersion

public byte getProtocolVersion()

Specified by:

getProtocolVersion in interface DHTTransportContact

getClockSkew

public long getClockSkew()

Specified by:

getClockSkew in interface DHTTransportContact

getRandomIDType

public int getRandomIDType()

Specified by:

getRandomIDType in interface DHTTransportContact

getRandomID

public int getRandomID()

Specified by:

getRandomID in interface DHTTransportContact

setRandomID

public void setRandomID(int _random_id)

Specified by:

setRandomID in interface DHTTransportContact

setRandomID2

public void setRandomID2(byte[] id)

Specified by:

setRandomID2 in interface DHTTransportContact

getRandomID2

public byte[] getRandomID2()

Specified by:

getRandomID2 in interface DHTTransportContact

isValid

public boolean isValid()

Specified by:

isValid in interface DHTTransportContact

isSleeping

public boolean isSleeping()

Specified by:

isSleeping in interface DHTTransportContact

getMaxFailForLiveCount

public int getMaxFailForLiveCount()

Specified by:

getMaxFailForLiveCount in interface DHTTransportContact

getMaxFailForUnknownCount

public int getMaxFailForUnknownCount()

Specified by:

getMaxFailForUnknownCount in interface DHTTransportContact

getName

public String getName()

Specified by:

getName in interface DHTTransportContact

getBloomKey

public byte[] getBloomKey()

Specified by:

getBloomKey in interface DHTTransportContact

getAddress

public InetSocketAddress getAddress()

Specified by:

getAddress in interface DHTTransportContact

getTransportAddress

public InetSocketAddress getTransportAddress()

Specified by:

getTransportAddress in interface DHTTransportContact

getExternalAddress

public InetSocketAddress getExternalAddress()

Specified by:

getExternalAddress in interface DHTTransportContact

isAlive

public boolean isAlive(long timeout)

Specified by:

isAlive in interface DHTTransportContact

isAlive

public void isAlive(DHTTransportReplyHandler handler,
 long timeout)

Specified by:

isAlive in interface DHTTransportContact

sendPing

public void sendPing(DHTTransportReplyHandler handler)

Specified by:

sendPing in interface DHTTransportContact

sendImmediatePing

public void sendImmediatePing(DHTTransportReplyHandler handler,
 long timeout)

Specified by:

sendImmediatePing in interface DHTTransportContact

sendKeyBlock

public void sendKeyBlock(DHTTransportReplyHandler handler,
 byte[] request,
 byte[] signature)

Specified by:

sendKeyBlock in interface DHTTransportContact

sendStats

public void sendStats(DHTTransportReplyHandler handler)

Specified by:

sendStats in interface DHTTransportContact

sendStore

public void sendStore(DHTTransportReplyHandler handler,
 byte[][] keys,
 DHTTransportValue[][] value_sets,
 boolean immediate)

Specified by:

sendStore in interface DHTTransportContact

sendQueryStore

public void sendQueryStore(DHTTransportReplyHandler handler,
 int header_length,
 List<Object[]> key_details)

Specified by:

sendQueryStore in interface DHTTransportContact

sendFindNode

public void sendFindNode(DHTTransportReplyHandler handler,
 byte[] nid,
 short flags)

Specified by:

sendFindNode in interface DHTTransportContact

sendFindValue

public void sendFindValue(DHTTransportReplyHandler handler,
 byte[] key,
 int max,
 short flags)

Specified by:

sendFindValue in interface DHTTransportContact

getStats

public DHTTransportFullStats getStats()

Specified by:

getStats in interface DHTTransportContact

getID

public byte[] getID()

Specified by:

getID in interface DHTTransportContact

exportContact

public void exportContact(DataOutputStream os)
                   throws IOException

Specified by:

exportContact in interface DHTTransportContact

Throws:

IOException

exportContactToMap

public Map<String,Object> exportContactToMap()

Specified by:

exportContactToMap in interface DHTTransportContact

remove

public void remove()

Specified by:

remove in interface DHTTransportContact

createNetworkPositions

public void createNetworkPositions(boolean is_local)

Specified by:

createNetworkPositions in interface DHTTransportContact

getNetworkPositions

public DHTNetworkPosition[] getNetworkPositions()

Specified by:

getNetworkPositions in interface DHTTransportContact

getNetworkPosition

public DHTNetworkPosition getNetworkPosition(byte type)

Specified by:

getNetworkPosition in interface DHTTransportContact

getString

public String getString()

Specified by:

getString in interface DHTTransportContact