Class DHTUDPUtils

java.lang.Object

com.biglybt.core.dht.transport.udp.impl.DHTUDPUtils

public class DHTUDPUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private static final List<DHTTransportAlternativeNetwork>	alt_networks
private static final int	CALC_PERIOD
protected static final int	CT_UDP
static final int	DHTTRANSPORTCONTACT_SIZE
static final int	DHTTRANSPORTVALUE_SIZE_WITHOUT_VALUE
private static GlobalManagerStats	gm_stats
private static final SHA1Simple	hasher
static final int	INETSOCKETADDRESS_IPV4_SIZE
static final int	INETSOCKETADDRESS_IPV6_SIZE
static final IOException	INVALID_PROTOCOL_VERSION_EXCEPTION
private static long	last_calc
private static GlobalManagerStats.CountryDetails[]	last_details_recv
private static long	last_details_recv_total
private static GlobalManagerStats.CountryDetails[]	last_details_sent
private static long	last_details_sent_total
private static long	last_upload_stats
private static final int	MAX_CC_STATS
private static final Map<String,byte[]>	node_id_history
private static final List<DHTTransportUDPImpl>	transports

Constructor Summary

Constructors

Constructor	Description
DHTUDPUtils()

Method Summary

Modifier and Type	Method	Description
protected static InetSocketAddress	deserialiseAddress(DataInputStream is)
protected static DHTTransportAlternativeContactImpl	deserialiseAltContact(DataInputStream is)
protected static void	deserialiseAltContactRequest(DHTUDPPacketRequestPing ping, DataInputStream is)
protected static DHTTransportAlternativeContact[]	deserialiseAltContacts(DataInputStream is)
protected static byte[]	deserialiseByteArray(DataInputStream is, int max_length)
protected static byte[][]	deserialiseByteArrayArray(DataInputStream is, int max_length)
protected static DHTTransportUDPContactImpl	deserialiseContact(DHTTransportUDPImpl transport, DataInputStream is)
protected static DHTTransportContact[]	deserialiseContacts(DHTTransportUDPImpl transport, DataInputStream is)
protected static int	deserialiseLength(DataInputStream is, int max_length)
protected static DHTTransportFullStats	deserialiseStats(int version, DataInputStream is)
protected static DHTTransportValue	deserialiseTransportValue(DHTUDPPacket packet, DataInputStream is, long skew)
protected static DHTTransportValue[]	deserialiseTransportValues(DHTUDPPacket packet, DataInputStream is, long skew)
protected static DHTTransportValue[][]	deserialiseTransportValuesArray(DHTUDPPacket packet, DataInputStream is, long skew, int max_length)
protected static Object	deserialiseUploadStats(DataInputStream is)
protected static void	deserialiseVivaldi(DHTUDPPacketReply reply, DataInputStream is)
static List<DHTTransportAlternativeContact>	getAlternativeContacts(int network, int max)
static DHTTransportAlternativeNetwork	getAlternativeNetwork(int type)
protected static byte[]	getBogusNodeID()
protected static byte[]	getNodeID(InetSocketAddress address, byte protocol_version)
protected static void	receiveUploadStats(DHTTransportUDPContactImpl contact, Object _stats)
static void	registerAlternativeNetwork(DHTTransportAlternativeNetwork net)
protected static void	registerTransport(DHTTransportUDPImpl transport)
protected static void	serialiseAddress(DataOutputStream os, InetSocketAddress address)
protected static void	serialiseAltContact(DataOutputStream os, DHTTransportAlternativeContact contact)
protected static void	serialiseAltContactRequest(DHTUDPPacketRequestPing ping, DataOutputStream os)
protected static void	serialiseAltContacts(DataOutputStream os, DHTTransportAlternativeContact[] contacts)
protected static void	serialiseByteArray(DataOutputStream os, byte[] data, int max_length)
protected static void	serialiseByteArray(DataOutputStream os, byte[] data, int start, int length, int max_length)
protected static void	serialiseByteArrayArray(DataOutputStream os, byte[][] data, int max_length)
protected static void	serialiseContact(DataOutputStream os, DHTTransportContact contact)
protected static void	serialiseContacts(DataOutputStream os, DHTTransportContact[] contacts)
protected static void	serialiseLength(DataOutputStream os, int len, int max_length)
protected static void	serialiseStats(int version, DataOutputStream os, DHTTransportFullStats stats)
protected static void	serialiseTransportValue(DHTUDPPacket packet, DataOutputStream os, DHTTransportValue value, long skew)
protected static void	serialiseTransportValues(DHTUDPPacket packet, DataOutputStream os, DHTTransportValue[] values, long skew)
protected static void	serialiseTransportValuesArray(DHTUDPPacket packet, DataOutputStream os, DHTTransportValue[][] values, long skew, int max_length)
protected static void	serialiseUploadStats(int protocol_version, int packet_type, DataOutputStream os)
protected static void	serialiseVivaldi(DHTUDPPacketReply reply, DataOutputStream os)
static void	unregisterAlternativeNetwork(DHTTransportAlternativeNetwork net)

Methods inherited from class Object

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

Field Details

INVALID_PROTOCOL_VERSION_EXCEPTION

public static final IOException INVALID_PROTOCOL_VERSION_EXCEPTION

CT_UDP

protected static final int CT_UDP

See Also:

• Constant Field Values

node_id_history

private static final Map<String,byte[]> node_id_history

hasher

private static final SHA1Simple hasher

INETSOCKETADDRESS_IPV4_SIZE

public static final int INETSOCKETADDRESS_IPV4_SIZE

See Also:

• Constant Field Values

INETSOCKETADDRESS_IPV6_SIZE

public static final int INETSOCKETADDRESS_IPV6_SIZE

See Also:

• Constant Field Values

DHTTRANSPORTCONTACT_SIZE

public static final int DHTTRANSPORTCONTACT_SIZE

See Also:

• Constant Field Values

DHTTRANSPORTVALUE_SIZE_WITHOUT_VALUE

public static final int DHTTRANSPORTVALUE_SIZE_WITHOUT_VALUE

See Also:

• Constant Field Values

transports

private static final List<DHTTransportUDPImpl> transports

alt_networks

private static final List<DHTTransportAlternativeNetwork> alt_networks

MAX_CC_STATS

private static final int MAX_CC_STATS

See Also:

• Constant Field Values

CALC_PERIOD

private static final int CALC_PERIOD

See Also:

• Constant Field Values

last_calc

private static volatile long last_calc

last_details_recv

private static volatile GlobalManagerStats.CountryDetails[] last_details_recv

last_details_sent

private static volatile GlobalManagerStats.CountryDetails[] last_details_sent

last_details_recv_total

private static volatile long last_details_recv_total

last_details_sent_total

private static volatile long last_details_sent_total

gm_stats

private static volatile GlobalManagerStats gm_stats

last_upload_stats

private static volatile long last_upload_stats

Constructor Details

DHTUDPUtils

public DHTUDPUtils()

Method Details

getNodeID

protected static byte[] getNodeID(InetSocketAddress address,
 byte protocol_version)
                           throws DHTTransportException

Throws:

DHTTransportException

getBogusNodeID

protected static byte[] getBogusNodeID()

serialiseLength

protected static void serialiseLength(DataOutputStream os,
 int len,
 int max_length)
                               throws IOException

Throws:

IOException

deserialiseLength

protected static int deserialiseLength(DataInputStream is,
 int max_length)
                                throws IOException

Throws:

IOException

deserialiseByteArray

protected static byte[] deserialiseByteArray(DataInputStream is,
 int max_length)
                                      throws IOException

Throws:

IOException

serialiseByteArray

protected static void serialiseByteArray(DataOutputStream os,
 byte[] data,
 int max_length)
                                  throws IOException

Throws:

IOException

serialiseByteArray

protected static void serialiseByteArray(DataOutputStream os,
 byte[] data,
 int start,
 int length,
 int max_length)
                                  throws IOException

Throws:

IOException

serialiseByteArrayArray

protected static void serialiseByteArrayArray(DataOutputStream os,
 byte[][] data,
 int max_length)
                                       throws IOException

Throws:

IOException

deserialiseByteArrayArray

protected static byte[][] deserialiseByteArrayArray(DataInputStream is,
 int max_length)
                                             throws IOException

Throws:

IOException

serialiseAddress

protected static void serialiseAddress(DataOutputStream os,
 InetSocketAddress address)
                                throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

deserialiseAddress

protected static InetSocketAddress deserialiseAddress(DataInputStream is)
                                               throws IOException

Throws:

IOException

deserialiseTransportValuesArray

protected static DHTTransportValue[][] deserialiseTransportValuesArray(DHTUDPPacket packet,
 DataInputStream is,
 long skew,
 int max_length)
                                                                throws IOException

Throws:

IOException

serialiseTransportValuesArray

protected static void serialiseTransportValuesArray(DHTUDPPacket packet,
 DataOutputStream os,
 DHTTransportValue[][] values,
 long skew,
 int max_length)
                                             throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

serialiseContact

protected static void serialiseContact(DataOutputStream os,
 DHTTransportContact contact)
                                throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

deserialiseContact

protected static DHTTransportUDPContactImpl deserialiseContact(DHTTransportUDPImpl transport,
 DataInputStream is)
                                                        throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

serialiseAltContact

protected static void serialiseAltContact(DataOutputStream os,
 DHTTransportAlternativeContact contact)
                                   throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

deserialiseAltContact

protected static DHTTransportAlternativeContactImpl deserialiseAltContact(DataInputStream is)
                                                                   throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

deserialiseTransportValues

protected static DHTTransportValue[] deserialiseTransportValues(DHTUDPPacket packet,
 DataInputStream is,
 long skew)
                                                         throws IOException

Throws:

IOException

serialiseTransportValues

protected static void serialiseTransportValues(DHTUDPPacket packet,
 DataOutputStream os,
 DHTTransportValue[] values,
 long skew)
                                        throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

deserialiseTransportValue

protected static DHTTransportValue deserialiseTransportValue(DHTUDPPacket packet,
 DataInputStream is,
 long skew)
                                                      throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

serialiseTransportValue

protected static void serialiseTransportValue(DHTUDPPacket packet,
 DataOutputStream os,
 DHTTransportValue value,
 long skew)
                                       throws IOException,
DHTTransportException

Throws:

IOException

DHTTransportException

serialiseContacts

protected static void serialiseContacts(DataOutputStream os,
 DHTTransportContact[] contacts)
                                 throws IOException

Throws:

IOException

deserialiseContacts

protected static DHTTransportContact[] deserialiseContacts(DHTTransportUDPImpl transport,
 DataInputStream is)
                                                    throws IOException

Throws:

IOException

serialiseAltContacts

protected static void serialiseAltContacts(DataOutputStream os,
 DHTTransportAlternativeContact[] contacts)
                                    throws IOException

Throws:

IOException

deserialiseAltContacts

protected static DHTTransportAlternativeContact[] deserialiseAltContacts(DataInputStream is)
                                                                  throws IOException

Throws:

IOException

serialiseAltContactRequest

protected static void serialiseAltContactRequest(DHTUDPPacketRequestPing ping,
 DataOutputStream os)
                                          throws IOException

Throws:

IOException

deserialiseAltContactRequest

protected static void deserialiseAltContactRequest(DHTUDPPacketRequestPing ping,
 DataInputStream is)
                                            throws IOException

Throws:

IOException

serialiseVivaldi

protected static void serialiseVivaldi(DHTUDPPacketReply reply,
 DataOutputStream os)
                                throws IOException

Throws:

IOException

deserialiseVivaldi

protected static void deserialiseVivaldi(DHTUDPPacketReply reply,
 DataInputStream is)
                                  throws IOException

Throws:

IOException

serialiseStats

protected static void serialiseStats(int version,
 DataOutputStream os,
 DHTTransportFullStats stats)
                              throws IOException

Throws:

IOException

deserialiseStats

protected static DHTTransportFullStats deserialiseStats(int version,
 DataInputStream is)
                                                 throws IOException

Throws:

IOException

registerTransport

protected static void registerTransport(DHTTransportUDPImpl transport)

registerAlternativeNetwork

public static void registerAlternativeNetwork(DHTTransportAlternativeNetwork net)

getAlternativeNetwork

public static DHTTransportAlternativeNetwork getAlternativeNetwork(int type)

unregisterAlternativeNetwork

public static void unregisterAlternativeNetwork(DHTTransportAlternativeNetwork net)

getAlternativeContacts

public static List<DHTTransportAlternativeContact> getAlternativeContacts(int network,
 int max)

serialiseUploadStats

protected static void serialiseUploadStats(int protocol_version,
 int packet_type,
 DataOutputStream os)
                                    throws IOException

Throws:

IOException

deserialiseUploadStats

protected static Object deserialiseUploadStats(DataInputStream is)
                                        throws IOException

Throws:

IOException

receiveUploadStats

protected static void receiveUploadStats(DHTTransportUDPContactImpl contact,
 Object _stats)