com.aelitis.azureus.plugins.net.netstatus
Class NetStatusProtocolTester

java.lang.Object
  com.aelitis.azureus.plugins.net.netstatus.NetStatusProtocolTester

All Implemented Interfaces:

DistributedDatabaseTransferHandler

public class NetStatusProtocolTester
extends java.lang.Object
implements DistributedDatabaseTransferHandler

Nested Class Summary

protected static class

NetStatusProtocolTester.testXferType

Constructor Summary

protected

NetStatusProtocolTester(NetStatusPlugin _plugin, PluginInterface _plugin_interface)

Method Summary

protected void	addToActive(NetStatusProtocolTesterBT tester)
protected java.net.InetSocketAddress	adjustLoopback(java.net.InetSocketAddress address)
void	log(java.lang.String str)
void	log(java.lang.String str, java.lang.Throwable e)
DistributedDatabaseValue	read(DistributedDatabaseContact contact, DistributedDatabaseTransferType type, DistributedDatabaseKey ddb_key)
protected java.util.Map	receiveRequest(java.net.InetSocketAddress originator, java.util.Map request)
protected void	removeFromActive(NetStatusProtocolTesterBT tester)
NetStatusProtocolTesterBT	runTest(NetStatusProtocolTesterListener listener)
NetStatusProtocolTesterBT	runTest(java.lang.String test_address, NetStatusProtocolTesterListener listener)
protected java.util.Map	sendRequest(DistributedDatabaseContact contact, java.util.Map request)
protected boolean	tryTest(NetStatusProtocolTesterBT bt_tester, DistributedDatabaseContact contact)
DistributedDatabaseValue	write(DistributedDatabaseContact contact, DistributedDatabaseTransferType type, DistributedDatabaseKey key, DistributedDatabaseValue value)

Methods inherited from class java.lang.Object

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

Constructor Detail

NetStatusProtocolTester

protected NetStatusProtocolTester(NetStatusPlugin _plugin,
                                  PluginInterface _plugin_interface)

Method Detail

runTest

public NetStatusProtocolTesterBT runTest(NetStatusProtocolTesterListener listener)

runTest

public NetStatusProtocolTesterBT runTest(java.lang.String test_address,
                                         NetStatusProtocolTesterListener listener)

tryTest

protected boolean tryTest(NetStatusProtocolTesterBT bt_tester,
                          DistributedDatabaseContact contact)

adjustLoopback

protected java.net.InetSocketAddress adjustLoopback(java.net.InetSocketAddress address)

sendRequest

protected java.util.Map sendRequest(DistributedDatabaseContact contact,
                                    java.util.Map request)

receiveRequest

protected java.util.Map receiveRequest(java.net.InetSocketAddress originator,
                                       java.util.Map request)

addToActive

protected void addToActive(NetStatusProtocolTesterBT tester)

removeFromActive

protected void removeFromActive(NetStatusProtocolTesterBT tester)

read

public DistributedDatabaseValue read(DistributedDatabaseContact contact,
                                     DistributedDatabaseTransferType type,
                                     DistributedDatabaseKey ddb_key)
                              throws DistributedDatabaseException

Specified by:

read in interface DistributedDatabaseTransferHandler

Throws:

DistributedDatabaseException

write

public DistributedDatabaseValue write(DistributedDatabaseContact contact,
                                      DistributedDatabaseTransferType type,
                                      DistributedDatabaseKey key,
                                      DistributedDatabaseValue value)
                               throws DistributedDatabaseException

Specified by:

write in interface DistributedDatabaseTransferHandler

Throws:

DistributedDatabaseException

log

public void log(java.lang.String str)

log

public void log(java.lang.String str,
                java.lang.Throwable e)