com.aelitis.azureus.core.dht.control
Interface DHTControl

All Known Implementing Classes:

DHTControlImpl

public interface DHTControl

Author:

parg

Field Summary

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

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 seeded
void	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)