Class DHTPluginImpl

java.lang.Object

com.biglybt.plugin.dht.impl.DHTPluginImpl

All Implemented Interfaces:

DHTPluginBasicInterface, DHTPluginInterface.DHTInterface

public class DHTPluginImpl
extends Object
implements DHTPluginInterface.DHTInterface, DHTPluginBasicInterface

Field Summary

Fields

Modifier and Type	Field	Description
private DHT	dht
private DHTLogger	dht_log
private final DHTPlugin	dht_plugin
private Map<DHTPluginTransferHandler, DHTTransportTransferHandler>	handler_map
private boolean	healthy
private long	last_root_seed_import_time
private LoggerChannel	log
private static final long	MIN_ROOT_SEED_IMPORT_PERIOD
private int	network
private final PluginInterface	plugin_interface
private int	port
private byte	protocol_version
private ActionParameter	reseed_param
private static final String	SEED_ADDRESS_V4
private static final String	SEED_ADDRESS_V6
private static final int	SEED_PORT
private int	stats_ticks
private int	status
private String	status_text
private DHTPluginStorageManager	storage_manager
private DHTTransportUDP	transport
private boolean	v6
private BooleanParameter	warn_user_param

Constructor Summary

Constructors

Constructor	Description
DHTPluginImpl(DHTPlugin _dht_plugin, PluginInterface _plugin_interface, DHTNATPuncherAdapter _nat_adapter, DHTPluginImplAdapter _adapter, byte _protocol_version, int _network, boolean _v6, String _ip, int _port, ActionParameter _reseed, BooleanParameter _warn_user_param, boolean _logging, LoggerChannel _log, DHTLogger _dht_log)

Method Summary

Modifier and Type	Method	Description
byte[]	call(DHTPluginProgressListener listener, DHTPluginContact target, byte[] handler_key, byte[] data, long timeout)
void	checkForReSeed(boolean force)
private InetSocketAddress	checkResolve(InetSocketAddress isa)
void	closedownInitiated()
DHTPluginKeyStats	decodeStats(DHTPluginValue value)
void	get(byte[] key, String description, byte flags, int max_values, long timeout, boolean exhaustive, boolean high_priority, DHTPluginOperationListener listener)
String	getAENetwork()
long	getClockSkew()
List<DHTPluginContact>	getClosestContacts(byte[] to_id, boolean live_only)
protected File	getDataDir(int network)
DHT	getDHT()
DHTPluginInterface.DHTInterface[]	getDHTInterfaces()
byte[]	getID()
DHTPluginContact	getLocalAddress()
DHTPluginValue	getLocalValue(byte[] key)
int	getNetwork()
int	getPort()
DHTPluginContact[]	getReachableContacts()
DHTPluginContact[]	getRecentContacts()
protected InetSocketAddress	getSeedAddress()
int	getStatus()
String	getStatusText()
List<DHTPluginValue>	getValues()
List<DHTPluginValue>	getValues(byte[] key)
DHTPluginContact	importContact(InetSocketAddress address)
DHTPluginContact	importContact(InetSocketAddress address, byte version)
DHTPluginContact	importContact(Map<String,Object> map)
protected DHTTransportContact	importRootSeed()
DHTTransportContact	importSeed(String ip, int port)
protected DHTTransportContact	importSeed(InetAddress ia, int port)
protected DHTTransportContact	importSeed(InetSocketAddress ia)
void	integrateDHT(boolean first, DHTTransportContact remove_afterwards)
boolean	isDiversified(byte[] key)
boolean	isEnabled()
boolean	isHealthy()
boolean	isInitialising()
boolean	isIPV6()
boolean	isReachable()
boolean	isRecentAddress(String address)
boolean	isSleeping()
void	logStats()
protected DHTPluginValue	mapValue(DHTTransportValue value)
void	put(byte[] key, String description, byte[] value, byte flags, boolean high_priority, DHTPluginOperationListener listener)
void	put(byte[] key, String description, byte[] value, byte flags, DHTPluginOperationListener listener)
void	putEx(byte[] key, String description, byte[] value, short flags, boolean high_priority, DHTPluginOperationListener listener)
byte[]	read(DHTPluginProgressListener listener, DHTPluginContact target, byte[] handler_key, byte[] key, long timeout)
void	registerHandler(byte[] handler_key, DHTPluginTransferHandler handler, Map<String,Object> options)
void	remove(byte[] key, String description, short flags, DHTPluginOperationListener listener)
void	remove(DHTPluginContact[] targets, byte[] key, String description, DHTPluginOperationListener listener)
void	setLogging(boolean l)
void	setPort(int new_port)
void	setSuspended(boolean susp)
void	tick()
void	unregisterHandler(byte[] handler_key, DHTPluginTransferHandler handler)
void	updateStats(int sample_stats_ticks)
void	write(DHTPluginProgressListener listener, DHTPluginContact target, byte[] handler_key, byte[] key, byte[] data, long timeout)

Methods inherited from class Object

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

Methods inherited from interface DHTPluginBasicInterface

put

Field Details

SEED_ADDRESS_V4

private static final String SEED_ADDRESS_V4

See Also:

• Constant Field Values

SEED_ADDRESS_V6

private static final String SEED_ADDRESS_V6

See Also:

• Constant Field Values

SEED_PORT

private static final int SEED_PORT

See Also:

• Constant Field Values

MIN_ROOT_SEED_IMPORT_PERIOD

private static final long MIN_ROOT_SEED_IMPORT_PERIOD

See Also:

• Constant Field Values

dht_plugin

private final DHTPlugin dht_plugin

plugin_interface

private final PluginInterface plugin_interface

status

private int status

status_text

private String status_text

reseed_param

private ActionParameter reseed_param

warn_user_param

private BooleanParameter warn_user_param

dht

private DHT dht

port

private int port

protocol_version

private byte protocol_version

network

private int network

v6

private boolean v6

transport

private DHTTransportUDP transport

storage_manager

private DHTPluginStorageManager storage_manager

last_root_seed_import_time

private long last_root_seed_import_time

healthy

private volatile boolean healthy

log

private LoggerChannel log

dht_log

private DHTLogger dht_log

stats_ticks

private int stats_ticks

handler_map

private Map<DHTPluginTransferHandler, DHTTransportTransferHandler> handler_map

Constructor Details

DHTPluginImpl

public DHTPluginImpl(DHTPlugin _dht_plugin,
 PluginInterface _plugin_interface,
 DHTNATPuncherAdapter _nat_adapter,
 DHTPluginImplAdapter _adapter,
 byte _protocol_version,
 int _network,
 boolean _v6,
 String _ip,
 int _port,
 ActionParameter _reseed,
 BooleanParameter _warn_user_param,
 boolean _logging,
 LoggerChannel _log,
 DHTLogger _dht_log)

Method Details

getAENetwork

public String getAENetwork()

Specified by:

getAENetwork in interface DHTPluginBasicInterface

getDHTInterfaces

public DHTPluginInterface.DHTInterface[] getDHTInterfaces()

Specified by:

getDHTInterfaces in interface DHTPluginBasicInterface

isEnabled

public boolean isEnabled()

Specified by:

isEnabled in interface DHTPluginBasicInterface

isInitialising

public boolean isInitialising()

Specified by:

isInitialising in interface DHTPluginBasicInterface

isSleeping

public boolean isSleeping()

Specified by:

isSleeping in interface DHTPluginBasicInterface

isHealthy

public boolean isHealthy()

updateStats

public void updateStats(int sample_stats_ticks)

getStatus

public int getStatus()

getStatusText

public String getStatusText()

isReachable

public boolean isReachable()

setLogging

public void setLogging(boolean l)

tick

public void tick()

getPort

public int getPort()

setPort

public void setPort(int new_port)

getClockSkew

public long getClockSkew()

logStats

public void logStats()

getDataDir

protected File getDataDir(int network)

integrateDHT

public void integrateDHT(boolean first,
 DHTTransportContact remove_afterwards)

checkForReSeed

public void checkForReSeed(boolean force)

importRootSeed

protected DHTTransportContact importRootSeed()

importSeed

public DHTTransportContact importSeed(String ip,
 int port)

importSeed

protected DHTTransportContact importSeed(InetAddress ia,
 int port)

importSeed

protected DHTTransportContact importSeed(InetSocketAddress ia)

getSeedAddress

protected InetSocketAddress getSeedAddress()

checkResolve

private InetSocketAddress checkResolve(InetSocketAddress isa)

isDiversified

public boolean isDiversified(byte[] key)

put

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

Specified by:

put in interface DHTPluginBasicInterface

put

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

putEx

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

getLocalValue

public DHTPluginValue getLocalValue(byte[] key)

getValues

public List<DHTPluginValue> getValues()

Specified by:

getValues in interface DHTPluginBasicInterface

getValues

public List<DHTPluginValue> getValues(byte[] key)

get

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

Specified by:

get in interface DHTPluginBasicInterface

remove

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

remove

public void remove(DHTPluginContact[] targets,
 byte[] key,
 String description,
 DHTPluginOperationListener listener)

getLocalAddress

public DHTPluginContact getLocalAddress()

importContact

public DHTPluginContact importContact(Map<String,Object> map)

importContact

public DHTPluginContact importContact(InetSocketAddress address)

importContact

public DHTPluginContact importContact(InetSocketAddress address,
 byte version)

registerHandler

public void registerHandler(byte[] handler_key,
 DHTPluginTransferHandler handler,
 Map<String,Object> options)

unregisterHandler

public void unregisterHandler(byte[] handler_key,
 DHTPluginTransferHandler handler)

read

public byte[] read(DHTPluginProgressListener listener,
 DHTPluginContact target,
 byte[] handler_key,
 byte[] key,
 long timeout)

write

public void write(DHTPluginProgressListener listener,
 DHTPluginContact target,
 byte[] handler_key,
 byte[] key,
 byte[] data,
 long timeout)

call

public byte[] call(DHTPluginProgressListener listener,
 DHTPluginContact target,
 byte[] handler_key,
 byte[] data,
 long timeout)

getDHT

public DHT getDHT()

setSuspended

public void setSuspended(boolean susp)

closedownInitiated

public void closedownInitiated()

isRecentAddress

public boolean isRecentAddress(String address)

mapValue

protected DHTPluginValue mapValue(DHTTransportValue value)

decodeStats

public DHTPluginKeyStats decodeStats(DHTPluginValue value)

getID

public byte[] getID()

Specified by:

getID in interface DHTPluginInterface.DHTInterface

isIPV6

public boolean isIPV6()

Specified by:

isIPV6 in interface DHTPluginInterface.DHTInterface

getNetwork

public int getNetwork()

Specified by:

getNetwork in interface DHTPluginInterface.DHTInterface

getReachableContacts

public DHTPluginContact[] getReachableContacts()

Specified by:

getReachableContacts in interface DHTPluginInterface.DHTInterface

getRecentContacts

public DHTPluginContact[] getRecentContacts()

Specified by:

getRecentContacts in interface DHTPluginInterface.DHTInterface

getClosestContacts

public List<DHTPluginContact> getClosestContacts(byte[] to_id,
 boolean live_only)

Specified by:

getClosestContacts in interface DHTPluginInterface.DHTInterface