Class DDBaseContactImpl

java.lang.Object

com.biglybt.pifimpl.local.ddb.DDBaseContactImpl

All Implemented Interfaces:

DistributedDatabaseContact

public class DDBaseContactImpl
extends Object
implements DistributedDatabaseContact

Field Summary

Fields

Modifier and Type	Field	Description
private DHTPluginContact	contact
private DDBaseImpl	ddb

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	DDBaseContactImpl(DDBaseImpl _ddb, DHTPluginContact _contact)

Method Summary

Modifier and Type	Method	Description
DistributedDatabaseValue	call(DistributedDatabaseProgressListener listener, DistributedDatabaseTransferType type, DistributedDatabaseValue data, long timeout)
Map<String,Object>	exportToMap()
InetSocketAddress	getAddress()
protected DHTPluginContact	getContact()
byte[]	getID()
String	getName()
int	getNetwork()
int	getVersion()
boolean	isAlive(long timeout)
void	isAlive(long timeout, DistributedDatabaseListener listener)
boolean	isOrHasBeenLocal()
boolean	openTunnel()	Tries to open a NAT tunnel to the contact.
DistributedDatabaseValue	read(DistributedDatabaseProgressListener listener, DistributedDatabaseTransferType type, DistributedDatabaseKey key, long timeout)
void	write(DistributedDatabaseProgressListener listener, DistributedDatabaseTransferType type, DistributedDatabaseKey key, DistributedDatabaseValue value, long timeout)

Methods inherited from class Object

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

Field Details

ddb

private DDBaseImpl ddb

contact

private DHTPluginContact contact

Constructor Details

DDBaseContactImpl

protected DDBaseContactImpl(DDBaseImpl _ddb,
 DHTPluginContact _contact)

Method Details

getID

public byte[] getID()

Specified by:

getID in interface DistributedDatabaseContact

getName

public String getName()

Specified by:

getName in interface DistributedDatabaseContact

getVersion

public int getVersion()

Specified by:

getVersion in interface DistributedDatabaseContact

getAddress

public InetSocketAddress getAddress()

Specified by:

getAddress in interface DistributedDatabaseContact

getNetwork

public int getNetwork()

Specified by:

getNetwork in interface DistributedDatabaseContact

isAlive

public boolean isAlive(long timeout)

Specified by:

isAlive in interface DistributedDatabaseContact

isAlive

public void isAlive(long timeout,
 DistributedDatabaseListener listener)

Specified by:

isAlive in interface DistributedDatabaseContact

isOrHasBeenLocal

public boolean isOrHasBeenLocal()

Specified by:

isOrHasBeenLocal in interface DistributedDatabaseContact

exportToMap

public Map<String,Object> exportToMap()

Specified by:

exportToMap in interface DistributedDatabaseContact

openTunnel

public boolean openTunnel()

Description copied from interface: DistributedDatabaseContact

Tries to open a NAT tunnel to the contact. Should only be used if direct contact fails

Specified by:

openTunnel in interface DistributedDatabaseContact

Returns:

call

public DistributedDatabaseValue call(DistributedDatabaseProgressListener listener,
 DistributedDatabaseTransferType type,
 DistributedDatabaseValue data,
 long timeout)
                              throws DistributedDatabaseException

Specified by:

call in interface DistributedDatabaseContact

Throws:

DistributedDatabaseException

write

public void write(DistributedDatabaseProgressListener listener,
 DistributedDatabaseTransferType type,
 DistributedDatabaseKey key,
 DistributedDatabaseValue value,
 long timeout)
           throws DistributedDatabaseException

Specified by:

write in interface DistributedDatabaseContact

Throws:

DistributedDatabaseException

read

public DistributedDatabaseValue read(DistributedDatabaseProgressListener listener,
 DistributedDatabaseTransferType type,
 DistributedDatabaseKey key,
 long timeout)
                              throws DistributedDatabaseException

Specified by:

read in interface DistributedDatabaseContact

Throws:

DistributedDatabaseException

getContact

protected DHTPluginContact getContact()