Package com.biglybt.core.dht.control
Interface DHTControl
-
- All Known Implementing Classes:
DHTControlImpl
public interface DHTControl
-
-
Field Summary
Fields Modifier and Type Field Description static int
B_DEFAULT
static int
CACHE_AT_CLOSEST_N_DEFAULT
static int
CACHE_REPUBLISH_INTERVAL_DEFAULT
static int
ENABLE_RANDOM_DEFAULT
static int
ENCODE_KEYS_DEFAULT
static int
K_DEFAULT
static int
LOOKUP_CONCURRENCY_DEFAULT
static int
MAX_REP_PER_NODE_DEFAULT
static int
ORIGINAL_REPUBLISH_INTERVAL_DEFAULT
static int
SEARCH_CONCURRENCY_DEFAULT
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
addListener(DHTControlListener l)
int
compareDistances(byte[] n1, byte[] n2)
int
computeAndCompareDistances(byte[] n1, byte[] n2, byte[] pivot)
byte[]
computeDistance(byte[] n1, byte[] n2)
void
destroy()
void
exportState(java.io.DataOutputStream os, int max)
void
get(byte[] key, java.lang.String description, short flags, int max_values, long timeout, boolean exhaustive, boolean high_priority, DHTOperationListener listener)
DHTControlActivity[]
getActivities()
java.util.List<DHTTransportContact>
getClosestContactsList(byte[] id, int num_to_return, boolean live_only)
java.util.List<DHTTransportContact>
getClosestKContactsList(byte[] id, boolean live_only)
java.util.List<DHTControlContact>
getContacts()
DHTDB
getDataBase()
DHTTransportValue
getLocalValue(byte[] key)
byte[]
getObfuscatedKey(byte[] plain_key)
DHTRouter
getRouter()
DHTControlStats
getStats()
java.util.List<DHTTransportValue>
getStoredValues(byte[] key)
DHTTransport
getTransport()
void
importState(java.io.DataInputStream is)
boolean
isDiversified(byte[] key)
boolean
isSeeded()
boolean
lookup(byte[] id, java.lang.String description, long timeout, DHTOperationListener listener)
boolean
lookupEncoded(byte[] id, java.lang.String description, long timeout, boolean high_priority, DHTOperationListener listener)
void
pingAll()
void
print(boolean full)
void
put(byte[] key, java.lang.String description, byte[] value, short flags, byte life_hours, byte replication_control, boolean high_priority, DHTOperationListener listener)
void
putDirectEncodedKeys(byte[][] keys, java.lang.String description, DHTTransportValue[][] value_sets, DHTTransportContact contact, DHTOperationListener listener)
void
putDirectEncodedKeys(byte[][] keys, java.lang.String description, DHTTransportValue[][] value_sets, java.util.List<DHTTransportContact> contacts)
void
putEncodedKey(byte[] key, java.lang.String description, DHTTransportValue value, long timeout, boolean original_mappings)
byte[]
remove(byte[] key, java.lang.String description, DHTOperationListener listener)
byte[]
remove(DHTTransportContact[] contacts, byte[] key, java.lang.String description, DHTOperationListener listener)
void
removeListener(DHTControlListener l)
void
seed(boolean full_wait)
void
setSeeded()
Manually mark things as seededvoid
setSleeping(boolean asleep)
void
setSuspended(boolean susp)
boolean
verifyContact(DHTTransportContact c, boolean direct)
-
-
-
Field Detail
-
K_DEFAULT
static final int K_DEFAULT
- See Also:
- Constant Field Values
-
B_DEFAULT
static final int B_DEFAULT
- See Also:
- Constant Field Values
-
MAX_REP_PER_NODE_DEFAULT
static final int MAX_REP_PER_NODE_DEFAULT
- See Also:
- Constant Field Values
-
SEARCH_CONCURRENCY_DEFAULT
static final int SEARCH_CONCURRENCY_DEFAULT
- See Also:
- Constant Field Values
-
LOOKUP_CONCURRENCY_DEFAULT
static final int LOOKUP_CONCURRENCY_DEFAULT
- See Also:
- Constant Field Values
-
CACHE_AT_CLOSEST_N_DEFAULT
static final int CACHE_AT_CLOSEST_N_DEFAULT
- See Also:
- Constant Field Values
-
ORIGINAL_REPUBLISH_INTERVAL_DEFAULT
static final int ORIGINAL_REPUBLISH_INTERVAL_DEFAULT
- See Also:
- Constant Field Values
-
CACHE_REPUBLISH_INTERVAL_DEFAULT
static final int CACHE_REPUBLISH_INTERVAL_DEFAULT
- See Also:
- Constant Field Values
-
ENCODE_KEYS_DEFAULT
static final int ENCODE_KEYS_DEFAULT
- See Also:
- Constant Field Values
-
ENABLE_RANDOM_DEFAULT
static final int ENABLE_RANDOM_DEFAULT
- See Also:
- Constant Field Values
-
-
Method Detail
-
seed
void seed(boolean full_wait)
-
isSeeded
boolean isSeeded()
-
setSeeded
void setSeeded()
Manually mark things as seeded
-
setSuspended
void setSuspended(boolean susp)
-
put
void put(byte[] key, java.lang.String description, byte[] value, short flags, byte life_hours, byte replication_control, boolean high_priority, DHTOperationListener listener)
-
isDiversified
boolean isDiversified(byte[] key)
-
getLocalValue
DHTTransportValue getLocalValue(byte[] key)
-
getStoredValues
java.util.List<DHTTransportValue> getStoredValues(byte[] key)
-
get
void get(byte[] key, java.lang.String description, short flags, int max_values, long timeout, boolean exhaustive, boolean high_priority, DHTOperationListener listener)
-
remove
byte[] remove(byte[] key, java.lang.String description, DHTOperationListener listener)
-
remove
byte[] remove(DHTTransportContact[] contacts, byte[] key, java.lang.String description, DHTOperationListener listener)
-
getStats
DHTControlStats getStats()
-
setSleeping
void setSleeping(boolean asleep)
-
getTransport
DHTTransport getTransport()
-
getRouter
DHTRouter getRouter()
-
getDataBase
DHTDB getDataBase()
-
getActivities
DHTControlActivity[] getActivities()
-
exportState
void exportState(java.io.DataOutputStream os, int max) throws java.io.IOException
- Throws:
java.io.IOException
-
importState
void importState(java.io.DataInputStream is) throws java.io.IOException
- Throws:
java.io.IOException
-
getClosestKContactsList
java.util.List<DHTTransportContact> getClosestKContactsList(byte[] id, boolean live_only)
-
getClosestContactsList
java.util.List<DHTTransportContact> getClosestContactsList(byte[] id, int num_to_return, boolean live_only)
-
putEncodedKey
void putEncodedKey(byte[] key, java.lang.String description, DHTTransportValue value, long timeout, boolean original_mappings)
-
putDirectEncodedKeys
void putDirectEncodedKeys(byte[][] keys, java.lang.String description, DHTTransportValue[][] value_sets, java.util.List<DHTTransportContact> contacts)
-
putDirectEncodedKeys
void putDirectEncodedKeys(byte[][] keys, java.lang.String description, DHTTransportValue[][] value_sets, DHTTransportContact contact, DHTOperationListener listener)
-
computeAndCompareDistances
int computeAndCompareDistances(byte[] n1, byte[] n2, byte[] pivot)
-
computeDistance
byte[] computeDistance(byte[] n1, byte[] n2)
-
compareDistances
int compareDistances(byte[] n1, byte[] n2)
-
verifyContact
boolean verifyContact(DHTTransportContact c, boolean direct)
-
lookup
boolean lookup(byte[] id, java.lang.String description, long timeout, DHTOperationListener listener)
-
lookupEncoded
boolean lookupEncoded(byte[] id, java.lang.String description, long timeout, boolean high_priority, DHTOperationListener listener)
-
getObfuscatedKey
byte[] getObfuscatedKey(byte[] plain_key)
-
getContacts
java.util.List<DHTControlContact> getContacts()
-
pingAll
void pingAll()
-
addListener
void addListener(DHTControlListener l)
-
removeListener
void removeListener(DHTControlListener l)
-
destroy
void destroy()
-
print
void print(boolean full)
-
-