Package com.biglybt.core.dht.transport
Interface DHTTransport
-
- All Known Subinterfaces:
DHTTransportUDP
- All Known Implementing Classes:
DHTTransportLoopbackImpl
,DHTTransportUDPImpl
public interface DHTTransport
-
-
Field Summary
Fields Modifier and Type Field Description static byte
GF_DHT_SLEEPING
static byte
GF_NONE
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
addListener(DHTTransportListener l)
default java.net.InetAddress
getCurrentBindAddress()
default java.net.InetAddress
getExplicitBindAddress()
byte
getGenericFlags()
DHTTransportContact
getLocalContact()
Gives access to the node ID for this transportbyte
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)
default void
setExplicitBindAddress(java.net.InetAddress address, boolean autoDelegate)
void
setGenericFlag(byte flag, boolean value)
void
setPort(int port)
void
setRequestHandler(DHTTransportRequestHandler receiver)
Set the handler for incoming requestsvoid
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
-
getCurrentBindAddress
default java.net.InetAddress getCurrentBindAddress()
-
getExplicitBindAddress
default java.net.InetAddress getExplicitBindAddress()
-
setExplicitBindAddress
default void setExplicitBindAddress(java.net.InetAddress address, boolean autoDelegate)
-
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)
-
-