Class DHTImpl

java.lang.Object

com.biglybt.core.dht.impl.DHTImpl

All Implemented Interfaces:

DHT, AERunStateHandler.RunStateChangeListener

public class DHTImpl
extends Object
implements DHT, AERunStateHandler.RunStateChangeListener

Field Summary

Fields

Modifier and Type	Field	Description
private final DHTControl	control
private final CopyOnWriteList<DHTListener>	listeners
private final DHTLogger	logger
private DHTNATPuncherAdapter	nat_adapter
private DHTNATPuncher	nat_puncher
private final Properties	properties
private boolean	runstate_startup
private boolean	sleeping
private DHTSpeedTester	speed_tester
(package private) final DHTStorageAdapter	storage_adapter

Fields inherited from interface DHT

DT_FREQUENCY, DT_NONE, DT_SIZE, DT_STRINGS, FLAG_ANON, FLAG_BRIDGED, FLAG_DOWNLOADING, FLAG_HIGH_PRIORITY, FLAG_LOOKUP_FOR_STORE, FLAG_MULTI_VALUE, FLAG_NONE, FLAG_OBFUSCATE_LOOKUP, FLAG_PRECIOUS, FLAG_PUT_AND_FORGET, FLAG_SEEDING, FLAG_SINGLE_VALUE, FLAG_STATS, MAX_VALUE_SIZE, NW_AZ_CVS, NW_AZ_MAIN, NW_AZ_MAIN_V6, NW_BIGLYBT_MAIN, NW_MAIN, PR_CACHE_AT_CLOSEST_N, PR_CACHE_REPUBLISH_INTERVAL, PR_CONTACTS_PER_NODE, PR_ENABLE_RANDOM_LOOKUP, PR_ENCODE_KEYS, PR_LOOKUP_CONCURRENCY, PR_MAX_REPLACEMENTS_PER_NODE, PR_NODE_SPLIT_FACTOR, PR_ORIGINAL_REPUBLISH_INTERVAL, PR_SEARCH_CONCURRENCY, REP_FACT_DEFAULT, REP_FACT_NONE

Constructor Summary

Constructors

Constructor	Description
DHTImpl(DHTTransport _transport, DHTRouter _router, DHTDB _database, Properties _properties, DHTStorageAdapter _storage_adapter, DHTLogger _logger)
DHTImpl(DHTTransport _transport, Properties _properties, DHTStorageAdapter _storage_adapter, DHTNATPuncherAdapter _nat_adapter, DHTLogger _logger)

Method Summary

Modifier and Type	Method	Description
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()
protected int	getProp(String name, int def)
DHTRouter	getRouter()
DHTSpeedTester	getSpeedTester()
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, 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	runStateChanged(long run_state)
void	setLogging(boolean on)
void	setSuspended(boolean susp)

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

storage_adapter

final DHTStorageAdapter storage_adapter

nat_adapter

private DHTNATPuncherAdapter nat_adapter

control

private final DHTControl control

nat_puncher

private DHTNATPuncher nat_puncher

speed_tester

private DHTSpeedTester speed_tester

properties

private final Properties properties

logger

private final DHTLogger logger

listeners

private final CopyOnWriteList<DHTListener> listeners

runstate_startup

private boolean runstate_startup

sleeping

private boolean sleeping

Constructor Details

DHTImpl

public DHTImpl(DHTTransport _transport,
 Properties _properties,
 DHTStorageAdapter _storage_adapter,
 DHTNATPuncherAdapter _nat_adapter,
 DHTLogger _logger)

DHTImpl

public DHTImpl(DHTTransport _transport,
 DHTRouter _router,
 DHTDB _database,
 Properties _properties,
 DHTStorageAdapter _storage_adapter,
 DHTLogger _logger)

Method Details

runStateChanged

public void runStateChanged(long run_state)

Specified by:

runStateChanged in interface AERunStateHandler.RunStateChangeListener

isSleeping

public boolean isSleeping()

Specified by:

isSleeping in interface DHT

setSuspended

public void setSuspended(boolean susp)

Specified by:

setSuspended in interface DHT

getProp

protected int getProp(String name,
 int def)

getIntProperty

public int getIntProperty(String name)

Specified by:

getIntProperty in interface DHT

isDiversified

public boolean isDiversified(byte[] key)

Specified by:

isDiversified in interface DHT

put

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

Specified by:

put in interface DHT

put

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

Description copied from interface: DHT

default is HIGH PRIORITY. if you change to low priority then do so consistently as operations can get out of order otherwise

Specified by:

put in interface DHT

Parameters:

key -

description -

value -

flags -

high_priority -

listener -

put

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

Specified by:

put in interface DHT

put

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

Specified by:

put in interface DHT

getLocalValue

public DHTTransportValue getLocalValue(byte[] key)

Description copied from interface: DHT

Returns value if originated from here for key

Specified by:

getLocalValue in interface DHT

Parameters:

key -

Returns:

getStoredValues

public List<DHTTransportValue> getStoredValues(byte[] key)

Specified by:

getStoredValues in interface DHT

get

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

Specified by:

get in interface DHT

Parameters:

key -

max_values -

timeout -

listener -

remove

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

Specified by:

remove in interface DHT

remove

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

Specified by:

remove in interface DHT

remove

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

Specified by:

remove in interface DHT

getTransport

public DHTTransport getTransport()

Specified by:

getTransport in interface DHT

getRouter

public DHTRouter getRouter()

Specified by:

getRouter in interface DHT

getControl

public DHTControl getControl()

Specified by:

getControl in interface DHT

getDataBase

public DHTDB getDataBase()

Specified by:

getDataBase in interface DHT

getNATPuncher

public DHTNATPuncher getNATPuncher()

Specified by:

getNATPuncher in interface DHT

getSpeedTester

public DHTSpeedTester getSpeedTester()

getStorageAdapter

public DHTStorageAdapter getStorageAdapter()

Specified by:

getStorageAdapter in interface DHT

integrate

public void integrate(boolean full_wait)

Description copied from interface: DHT

Integrate the node into the DHT Can be invoked more than once if additional state is imported

Specified by:

integrate in interface DHT

destroy

public void destroy()

Specified by:

destroy in interface DHT

exportState

public void exportState(DataOutputStream os,
 int max)
                 throws IOException

Description copied from interface: DHT

externalises information that allows the DHT to be recreated at a later date and populated via the import method

Specified by:

exportState in interface DHT

Parameters:

os -

max - maximum to export, 0 -> all

Throws:

IOException

importState

public void importState(DataInputStream is)
                 throws IOException

Description copied from interface: DHT

populate the DHT with previously exported state

Specified by:

importState in interface DHT

Parameters:

is -

Throws:

IOException

setLogging

public void setLogging(boolean on)

Specified by:

setLogging in interface DHT

getLogger

public DHTLogger getLogger()

Specified by:

getLogger in interface DHT

print

public void print(boolean full)

Specified by:

print in interface DHT

addListener

public void addListener(DHTListener listener)

Specified by:

addListener in interface DHT

removeListener

public void removeListener(DHTListener listener)

Specified by:

removeListener in interface DHT