com.aelitis.azureus.core.dht.transport
Interface DHTTransport

All Known Subinterfaces:
DHTTransportUDP
All Known Implementing Classes:
DHTTransportLoopbackImpl, DHTTransportUDPImpl

public interface DHTTransport


Field Summary
static byte GF_DHT_SLEEPING
           
static byte GF_NONE
           
 
Method Summary
 void addListener(DHTTransportListener l)
           
 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(java.io.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, java.util.Map<java.lang.String,java.lang.Object> options)
           
 void removeListener(DHTTransportListener l)
           
 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 Detail

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 Detail

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

getTimeout

long getTimeout()

setTimeout

void setTimeout(long millis)

importContact

DHTTransportContact importContact(java.io.DataInputStream is,
                                  boolean is_bootstrap)
                                  throws java.io.IOException,
                                         DHTTransportException
Throws:
java.io.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,
                             java.util.Map<java.lang.String,java.lang.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)