com.aelitis.azureus.core.dht
Interface DHT

All Known Implementing Classes:
DHTImpl

public interface DHT

Author:
parg

Field Summary
static byte DT_FREQUENCY
           
static byte DT_NONE
           
static byte DT_SIZE
           
static String[] DT_STRINGS
           
static short FLAG_ANON
           
static short FLAG_BRIDGED
           
static short FLAG_DOWNLOADING
           
static short FLAG_HIGH_PRIORITY
           
static short FLAG_LOOKUP_FOR_STORE
           
static short FLAG_MULTI_VALUE
           
static short FLAG_NONE
           
static short FLAG_OBFUSCATE_LOOKUP
           
static short FLAG_PRECIOUS
           
static short FLAG_PUT_AND_FORGET
           
static short FLAG_SEEDING
           
static short FLAG_SINGLE_VALUE
           
static short FLAG_STATS
           
static int MAX_VALUE_SIZE
           
static int NW_CVS
           
static int NW_MAIN
           
static int NW_MAIN_V6
           
static String PR_CACHE_AT_CLOSEST_N
           
static String PR_CACHE_REPUBLISH_INTERVAL
           
static String PR_CONTACTS_PER_NODE
           
static String PR_ENABLE_RANDOM_LOOKUP
           
static String PR_ENCODE_KEYS
           
static String PR_LOOKUP_CONCURRENCY
           
static String PR_MAX_REPLACEMENTS_PER_NODE
           
static String PR_NODE_SPLIT_FACTOR
           
static String PR_ORIGINAL_REPUBLISH_INTERVAL
           
static String PR_SEARCH_CONCURRENCY
           
static byte REP_FACT_DEFAULT
           
static byte REP_FACT_NONE
           
 
Method Summary
 void addListener(DHTListener listener)
           
 void destroy()
           
 void exportState(DataOutputStream os, int max)
          externalises information that allows the DHT to be recreated at a later date and populated via the import method
 void get(byte[] key, String description, short flags, int max_values, long timeout, boolean exhaustive, boolean high_priority, DHTOperationListener listener)
           
 DHTControl getControl()
           
 DHTDB getDataBase()
           
 int getIntProperty(String name)
           
 DHTTransportValue getLocalValue(byte[] key)
          Returns value if originated from here for key
 DHTLogger getLogger()
           
 DHTNATPuncher getNATPuncher()
           
 DHTRouter getRouter()
           
 DHTStorageAdapter getStorageAdapter()
           
 List<DHTTransportValue> getStoredValues(byte[] key)
           
 DHTTransport getTransport()
           
 void importState(DataInputStream is)
          populate the DHT with previously exported state
 void integrate(boolean full_wait)
          Integrate the node into the DHT Can be invoked more than once if additional state is imported
 boolean isDiversified(byte[] key)
           
 boolean isSleeping()
           
 void print(boolean full)
           
 void put(byte[] key, String description, byte[] value, short flags, boolean high_priority, DHTOperationListener listener)
          default is HIGH PRIORITY.
 void put(byte[] key, String description, byte[] value, short flags, byte life_hours, boolean high_priority, DHTOperationListener listener)
           
 void put(byte[] key, String description, byte[] value, short flags, byte life_hours, byte replication_control, boolean high_priority, DHTOperationListener listener)
           
 void put(byte[] key, String description, byte[] value, short flags, DHTOperationListener listener)
           
 byte[] remove(byte[] key, String description, DHTOperationListener listener)
           
 byte[] remove(DHTTransportContact[] contacts, byte[] key, String description, DHTOperationListener listener)
           
 void removeListener(DHTListener listener)
           
 void setLogging(boolean on)
           
 void setSuspended(boolean susp)
           
 

Field Detail

PR_CONTACTS_PER_NODE

static final String PR_CONTACTS_PER_NODE
See Also:
Constant Field Values

PR_NODE_SPLIT_FACTOR

static final String PR_NODE_SPLIT_FACTOR
See Also:
Constant Field Values

PR_SEARCH_CONCURRENCY

static final String PR_SEARCH_CONCURRENCY
See Also:
Constant Field Values

PR_LOOKUP_CONCURRENCY

static final String PR_LOOKUP_CONCURRENCY
See Also:
Constant Field Values

PR_MAX_REPLACEMENTS_PER_NODE

static final String PR_MAX_REPLACEMENTS_PER_NODE
See Also:
Constant Field Values

PR_CACHE_AT_CLOSEST_N

static final String PR_CACHE_AT_CLOSEST_N
See Also:
Constant Field Values

PR_ORIGINAL_REPUBLISH_INTERVAL

static final String PR_ORIGINAL_REPUBLISH_INTERVAL
See Also:
Constant Field Values

PR_CACHE_REPUBLISH_INTERVAL

static final String PR_CACHE_REPUBLISH_INTERVAL
See Also:
Constant Field Values

PR_ENCODE_KEYS

static final String PR_ENCODE_KEYS
See Also:
Constant Field Values

PR_ENABLE_RANDOM_LOOKUP

static final String PR_ENABLE_RANDOM_LOOKUP
See Also:
Constant Field Values

FLAG_NONE

static final short FLAG_NONE
See Also:
Constant Field Values

FLAG_SINGLE_VALUE

static final short FLAG_SINGLE_VALUE
See Also:
Constant Field Values

FLAG_DOWNLOADING

static final short FLAG_DOWNLOADING
See Also:
Constant Field Values

FLAG_SEEDING

static final short FLAG_SEEDING
See Also:
Constant Field Values

FLAG_MULTI_VALUE

static final short FLAG_MULTI_VALUE
See Also:
Constant Field Values

FLAG_STATS

static final short FLAG_STATS
See Also:
Constant Field Values

FLAG_ANON

static final short FLAG_ANON
See Also:
Constant Field Values

FLAG_PRECIOUS

static final short FLAG_PRECIOUS
See Also:
Constant Field Values

FLAG_BRIDGED

static final short FLAG_BRIDGED
See Also:
Constant Field Values

FLAG_PUT_AND_FORGET

static final short FLAG_PUT_AND_FORGET
See Also:
Constant Field Values

FLAG_OBFUSCATE_LOOKUP

static final short FLAG_OBFUSCATE_LOOKUP
See Also:
Constant Field Values

FLAG_LOOKUP_FOR_STORE

static final short FLAG_LOOKUP_FOR_STORE
See Also:
Constant Field Values

FLAG_HIGH_PRIORITY

static final short FLAG_HIGH_PRIORITY
See Also:
Constant Field Values

MAX_VALUE_SIZE

static final int MAX_VALUE_SIZE
See Also:
Constant Field Values

REP_FACT_NONE

static final byte REP_FACT_NONE
See Also:
Constant Field Values

REP_FACT_DEFAULT

static final byte REP_FACT_DEFAULT
See Also:
Constant Field Values

DT_NONE

static final byte DT_NONE
See Also:
Constant Field Values

DT_FREQUENCY

static final byte DT_FREQUENCY
See Also:
Constant Field Values

DT_SIZE

static final byte DT_SIZE
See Also:
Constant Field Values

DT_STRINGS

static final String[] DT_STRINGS

NW_MAIN

static final int NW_MAIN
See Also:
Constant Field Values

NW_CVS

static final int NW_CVS
See Also:
Constant Field Values

NW_MAIN_V6

static final int NW_MAIN_V6
See Also:
Constant Field Values
Method Detail

put

void put(byte[] key,
         String description,
         byte[] value,
         short flags,
         DHTOperationListener listener)

put

void put(byte[] key,
         String description,
         byte[] value,
         short flags,
         boolean high_priority,
         DHTOperationListener listener)
default is HIGH PRIORITY. if you change to low priority then do so consistently as operations can get out of order otherwise

Parameters:
key -
description -
value -
flags -
high_priority -
listener -

put

void put(byte[] key,
         String description,
         byte[] value,
         short flags,
         byte life_hours,
         boolean high_priority,
         DHTOperationListener listener)

put

void put(byte[] key,
         String description,
         byte[] value,
         short flags,
         byte life_hours,
         byte replication_control,
         boolean high_priority,
         DHTOperationListener listener)

getLocalValue

DHTTransportValue getLocalValue(byte[] key)
Returns value if originated from here for key

Parameters:
key -
Returns:

getStoredValues

List<DHTTransportValue> getStoredValues(byte[] key)

get

void get(byte[] key,
         String description,
         short flags,
         int max_values,
         long timeout,
         boolean exhaustive,
         boolean high_priority,
         DHTOperationListener listener)
Parameters:
key -
max_values -
timeout -
listener -

remove

byte[] remove(byte[] key,
              String description,
              DHTOperationListener listener)

remove

byte[] remove(DHTTransportContact[] contacts,
              byte[] key,
              String description,
              DHTOperationListener listener)

isDiversified

boolean isDiversified(byte[] key)

getIntProperty

int getIntProperty(String name)

getTransport

DHTTransport getTransport()

getRouter

DHTRouter getRouter()

getControl

DHTControl getControl()

getDataBase

DHTDB getDataBase()

getNATPuncher

DHTNATPuncher getNATPuncher()

getStorageAdapter

DHTStorageAdapter getStorageAdapter()

exportState

void exportState(DataOutputStream os,
                 int max)
                 throws IOException
externalises information that allows the DHT to be recreated at a later date and populated via the import method

Parameters:
os -
max - maximum to export, 0 -> all
Throws:
IOException

importState

void importState(DataInputStream is)
                 throws IOException
populate the DHT with previously exported state

Parameters:
is -
Throws:
IOException

integrate

void integrate(boolean full_wait)
Integrate the node into the DHT Can be invoked more than once if additional state is imported


setSuspended

void setSuspended(boolean susp)

destroy

void destroy()

isSleeping

boolean isSleeping()

setLogging

void setLogging(boolean on)

getLogger

DHTLogger getLogger()

print

void print(boolean full)

addListener

void addListener(DHTListener listener)

removeListener

void removeListener(DHTListener listener)