Class GenericMessageConnectionIndirect

java.lang.Object

com.biglybt.pifimpl.local.messaging.GenericMessageConnectionIndirect

All Implemented Interfaces:

GenericMessageConnectionAdapter

public class GenericMessageConnectionIndirect
extends Object
implements GenericMessageConnectionAdapter

Nested Class Summary

Nested classes/interfaces inherited from interface GenericMessageConnectionAdapter

GenericMessageConnectionAdapter.ConnectionListener

Field Summary

Fields

Modifier and Type	Field	Description
private boolean	closed
private long	connection_id
private static long	connection_id_next
private GenericMessageEndpoint	endpoint
private boolean	incoming
private static final int	KEEP_ALIVE_CHECK_PERIOD
private static final int	KEEP_ALIVE_CHECK_TICKS
private boolean	keep_alive_in_progress
private static final int	KEEP_ALIVE_MIN
private static ThreadPool	keep_alive_pool
private long	last_message_received
private long	last_message_sent
private static Map	local_connections
private static final LogIDs	LOGID
static final int	MAX_MESSAGE_SIZE
private static final int	MAX_REMOTE_CONNECTIONS
private static final int	MAX_REMOTE_CONNECTIONS_PER_IP
private MessageManagerImpl	message_manager
private static final int	MESSAGE_TYPE_CONNECT
private static final int	MESSAGE_TYPE_DATA
private static final int	MESSAGE_TYPE_DISCONNECT
private static final int	MESSAGE_TYPE_ERROR
private String	msg_desc
private String	msg_id
private NATTraverser	nat_traverser
private GenericMessageConnectionImpl	owner
private static Map	remote_connections
private InetSocketAddress	rendezvous
private LinkedList<byte[]>	send_queue
private AESemaphore	send_queue_sem
private static final int	STATS_PERIOD
private static final int	STATS_TICKS
private InetSocketAddress	target
private static final int	TICK_PERIOD
private static final boolean	TRACE

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GenericMessageConnectionIndirect(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpoint _endpoint, long _connection_id)
protected	GenericMessageConnectionIndirect(MessageManagerImpl _message_manager, String _msg_id, String _msg_desc, GenericMessageEndpoint _endpoint, InetSocketAddress _rendezvous, InetSocketAddress _target)

Method Summary

Modifier and Type	Method	Description
void	accepted()
void	addInboundRateLimiter(RateLimiter limiter)
void	addOutboundRateLimiter(RateLimiter limiter)
void	close()
protected void	close(Throwable close_cause)
void	connect(ByteBuffer initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
Connection	getConnection()
protected static String	getConnectionStatus(Map connections)
GenericMessageEndpoint	getEndpoint()
long	getLastMessageReceivedTime()
protected static String	getLocalConnectionStatus()
int	getMaximumMessageSize()
protected static String	getRemoteConnectionStatus()
GenericMessageStartpoint	getStartpoint()
int	getTransportType()
String	getType()
protected boolean	isClosed()
protected void	keepAlive()
protected static void	log(String str)
protected boolean	prepareForKeepAlive(boolean force)
protected static Map	receive(MessageManagerImpl message_manager, InetSocketAddress originator, Map message)
protected List<byte[]>	receive(List<byte[]> messages)
protected boolean	receiveIncomplete()
void	removeInboundRateLimiter(RateLimiter limiter)
void	removeOutboundRateLimiter(RateLimiter limiter)
void	send(PooledByteBuffer pbb)
protected void	send(List messages)
void	setOwner(GenericMessageConnectionImpl _owner)
protected void	trace(String str)

Methods inherited from class Object

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

Field Details

LOGID

private static final LogIDs LOGID

TRACE

private static final boolean TRACE

See Also:

• Constant Field Values

MAX_MESSAGE_SIZE

public static final int MAX_MESSAGE_SIZE

See Also:

• Constant Field Values

MESSAGE_TYPE_CONNECT

private static final int MESSAGE_TYPE_CONNECT

See Also:

• Constant Field Values

MESSAGE_TYPE_ERROR

private static final int MESSAGE_TYPE_ERROR

See Also:

• Constant Field Values

MESSAGE_TYPE_DATA

private static final int MESSAGE_TYPE_DATA

See Also:

• Constant Field Values

MESSAGE_TYPE_DISCONNECT

private static final int MESSAGE_TYPE_DISCONNECT

See Also:

• Constant Field Values

TICK_PERIOD

private static final int TICK_PERIOD

See Also:

• Constant Field Values

KEEP_ALIVE_CHECK_PERIOD

private static final int KEEP_ALIVE_CHECK_PERIOD

See Also:

• Constant Field Values

KEEP_ALIVE_MIN

private static final int KEEP_ALIVE_MIN

See Also:

• Constant Field Values

STATS_PERIOD

private static final int STATS_PERIOD

See Also:

• Constant Field Values

KEEP_ALIVE_CHECK_TICKS

private static final int KEEP_ALIVE_CHECK_TICKS

See Also:

• Constant Field Values

STATS_TICKS

private static final int STATS_TICKS

See Also:

• Constant Field Values

MAX_REMOTE_CONNECTIONS

private static final int MAX_REMOTE_CONNECTIONS

See Also:

• Constant Field Values

MAX_REMOTE_CONNECTIONS_PER_IP

private static final int MAX_REMOTE_CONNECTIONS_PER_IP

See Also:

• Constant Field Values

connection_id_next

private static long connection_id_next

local_connections

private static Map local_connections

remote_connections

private static Map remote_connections

keep_alive_pool

private static ThreadPool keep_alive_pool

message_manager

private MessageManagerImpl message_manager

msg_id

private String msg_id

msg_desc

private String msg_desc

endpoint

private GenericMessageEndpoint endpoint

nat_traverser

private NATTraverser nat_traverser

owner

private GenericMessageConnectionImpl owner

rendezvous

private InetSocketAddress rendezvous

target

private InetSocketAddress target

connection_id

private long connection_id

incoming

private boolean incoming

closed

private boolean closed

send_queue

private LinkedList<byte[]> send_queue

send_queue_sem

private AESemaphore send_queue_sem

last_message_sent

private volatile long last_message_sent

last_message_received

private volatile long last_message_received

keep_alive_in_progress

private volatile boolean keep_alive_in_progress

Constructor Details

GenericMessageConnectionIndirect

protected GenericMessageConnectionIndirect(MessageManagerImpl _message_manager,
 String _msg_id,
 String _msg_desc,
 GenericMessageEndpoint _endpoint,
 InetSocketAddress _rendezvous,
 InetSocketAddress _target)

GenericMessageConnectionIndirect

protected GenericMessageConnectionIndirect(MessageManagerImpl _message_manager,
 String _msg_id,
 String _msg_desc,
 GenericMessageEndpoint _endpoint,
 long _connection_id)

Method Details

receive

protected static Map receive(MessageManagerImpl message_manager,
 InetSocketAddress originator,
 Map message)

getRemoteConnectionStatus

protected static String getRemoteConnectionStatus()

getLocalConnectionStatus

protected static String getLocalConnectionStatus()

getConnectionStatus

protected static String getConnectionStatus(Map connections)

setOwner

public void setOwner(GenericMessageConnectionImpl _owner)

Specified by:

setOwner in interface GenericMessageConnectionAdapter

getMaximumMessageSize

public int getMaximumMessageSize()

Specified by:

getMaximumMessageSize in interface GenericMessageConnectionAdapter

getType

public String getType()

Specified by:

getType in interface GenericMessageConnectionAdapter

getTransportType

public int getTransportType()

Specified by:

getTransportType in interface GenericMessageConnectionAdapter

getLastMessageReceivedTime

public long getLastMessageReceivedTime()

getEndpoint

public GenericMessageEndpoint getEndpoint()

Specified by:

getEndpoint in interface GenericMessageConnectionAdapter

getStartpoint

public GenericMessageStartpoint getStartpoint()

Specified by:

getStartpoint in interface GenericMessageConnectionAdapter

getConnection

public Connection getConnection()

Specified by:

getConnection in interface GenericMessageConnectionAdapter

addInboundRateLimiter

public void addInboundRateLimiter(RateLimiter limiter)

Specified by:

addInboundRateLimiter in interface GenericMessageConnectionAdapter

removeInboundRateLimiter

public void removeInboundRateLimiter(RateLimiter limiter)

Specified by:

removeInboundRateLimiter in interface GenericMessageConnectionAdapter

addOutboundRateLimiter

public void addOutboundRateLimiter(RateLimiter limiter)

Specified by:

addOutboundRateLimiter in interface GenericMessageConnectionAdapter

removeOutboundRateLimiter

public void removeOutboundRateLimiter(RateLimiter limiter)

Specified by:

removeOutboundRateLimiter in interface GenericMessageConnectionAdapter

connect

public void connect(ByteBuffer initial_data,
 GenericMessageConnectionAdapter.ConnectionListener listener)

Specified by:

connect in interface GenericMessageConnectionAdapter

accepted

public void accepted()

Specified by:

accepted in interface GenericMessageConnectionAdapter

send

public void send(PooledByteBuffer pbb)
          throws MessageException

Specified by:

send in interface GenericMessageConnectionAdapter

Throws:

MessageException

send

protected void send(List messages)

receive

protected List<byte[]> receive(List<byte[]> messages)

receiveIncomplete

protected boolean receiveIncomplete()

close

public void close()
           throws MessageException

Specified by:

close in interface GenericMessageConnectionAdapter

Throws:

MessageException

close

protected void close(Throwable close_cause)
              throws MessageException

Throws:

MessageException

isClosed

protected boolean isClosed()

prepareForKeepAlive

protected boolean prepareForKeepAlive(boolean force)

keepAlive

protected void keepAlive()

log

protected static void log(String str)

trace

protected void trace(String str)