Interface DHTTransport

All Known Subinterfaces:

DHTTransportUDP

All Known Implementing Classes:

DHTTransportLoopbackImpl, DHTTransportUDPImpl

public interface DHTTransport

Field Summary

Fields

Modifier and Type	Field	Description
static final byte	GF_DHT_SLEEPING
static final byte	GF_NONE

Method Summary

Modifier and Type	Method	Description
void	addListener(DHTTransportListener l)
default InetAddress	getCurrentBindAddress()
default InetAddress	getExplicitBindAddress()
byte	getGenericFlags()
DHTTransportContact	getLocalContact()	Gives access to the node ID for this transport
byte	getMinimumProtocolVersion()
int	getNetwork()
int	getPort()
byte	getProtocolVersion()
DHTTransportContact[]	getReachableContacts()
DHTTransportContact[]	getRecentContacts()
DHTTransportStats	getStats()
long	getTimeout()
DHTTransportContact	importContact(DataInputStream is, boolean is_bootstrap)
boolean	isIPV6()
boolean	isReachable()
byte[]	readTransfer(DHTTransportProgressListener listener, DHTTransportContact target, byte[] handler_key, byte[] key, long timeout)
void	registerTransferHandler(byte[] handler_key, DHTTransportTransferHandler handler)
void	registerTransferHandler(byte[] handler_key, DHTTransportTransferHandler handler, Map<String,Object> options)
void	removeListener(DHTTransportListener l)
default void	setExplicitBindAddress(InetAddress address, boolean autoDelegate)
void	setGenericFlag(byte flag, boolean value)
void	setPort(int port)
void	setRequestHandler(DHTTransportRequestHandler receiver)	Set the handler for incoming requests
void	setSuspended(boolean susp)
void	setTimeout(long millis)
boolean	supportsStorage()
void	unregisterTransferHandler(byte[] handler_key, DHTTransportTransferHandler handler)
byte[]	writeReadTransfer(DHTTransportProgressListener listener, DHTTransportContact target, byte[] handler_key, byte[] data, long timeout)
void	writeTransfer(DHTTransportProgressListener listener, DHTTransportContact target, byte[] handler_key, byte[] key, byte[] data, long timeout)

Field Details

GF_NONE

static final byte GF_NONE

See Also:

• Constant Field Values

GF_DHT_SLEEPING

static final byte GF_DHT_SLEEPING

See Also:

• Constant Field Values

Method Details

getProtocolVersion

byte getProtocolVersion()

getMinimumProtocolVersion

byte getMinimumProtocolVersion()

getNetwork

int getNetwork()

isIPV6

boolean isIPV6()

getGenericFlags

byte getGenericFlags()

setGenericFlag

void setGenericFlag(byte flag,
 boolean value)

setSuspended

void setSuspended(boolean susp)

getLocalContact

DHTTransportContact getLocalContact()

Gives access to the node ID for this transport

Returns:

getPort

int getPort()

setPort

void setPort(int port)
      throws DHTTransportException

Throws:

DHTTransportException

getCurrentBindAddress

default InetAddress getCurrentBindAddress()

getExplicitBindAddress

default InetAddress getExplicitBindAddress()

setExplicitBindAddress

default void setExplicitBindAddress(InetAddress address,
 boolean autoDelegate)

getTimeout

long getTimeout()

setTimeout

void setTimeout(long millis)

importContact

DHTTransportContact importContact(DataInputStream is,
 boolean is_bootstrap)
                           throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

setRequestHandler

void setRequestHandler(DHTTransportRequestHandler receiver)

Set the handler for incoming requests

Parameters:

receiver -

getStats

DHTTransportStats getStats()

registerTransferHandler

void registerTransferHandler(byte[] handler_key,
 DHTTransportTransferHandler handler)

registerTransferHandler

void registerTransferHandler(byte[] handler_key,
 DHTTransportTransferHandler handler,
 Map<String,Object> options)

unregisterTransferHandler

void unregisterTransferHandler(byte[] handler_key,
 DHTTransportTransferHandler handler)

readTransfer

byte[] readTransfer(DHTTransportProgressListener listener,
 DHTTransportContact target,
 byte[] handler_key,
 byte[] key,
 long timeout)
             throws DHTTransportException

Throws:

DHTTransportException

writeTransfer

void writeTransfer(DHTTransportProgressListener listener,
 DHTTransportContact target,
 byte[] handler_key,
 byte[] key,
 byte[] data,
 long timeout)
            throws DHTTransportException

Throws:

DHTTransportException

writeReadTransfer

byte[] writeReadTransfer(DHTTransportProgressListener listener,
 DHTTransportContact target,
 byte[] handler_key,
 byte[] data,
 long timeout)
                  throws DHTTransportException

Throws:

DHTTransportException

supportsStorage

boolean supportsStorage()

isReachable

boolean isReachable()

getReachableContacts

DHTTransportContact[] getReachableContacts()

getRecentContacts

DHTTransportContact[] getRecentContacts()

addListener

void addListener(DHTTransportListener l)

removeListener

void removeListener(DHTTransportListener l)