Class GenericMessageConnectionDirect

java.lang.Object

com.biglybt.pifimpl.local.messaging.GenericMessageConnectionDirect

All Implemented Interfaces:

GenericMessageConnectionAdapter

public class GenericMessageConnectionDirect
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 boolean	connected
private NetworkConnection	connection
private static AsyncDispatcher	dispatcher
private GenericMessageEndpointImpl	endpoint
private List<LimitedRateGroup>	inbound_rls
static final int	MAX_MESSAGE_SIZE
private String	msg_desc
private String	msg_id
private List<LimitedRateGroup>	outbound_rls
private GenericMessageConnectionImpl	owner
private ConnectionImpl	plugin_connection
private boolean	processing
private byte[][]	shared_secrets
private int	stream_crypto

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	GenericMessageConnectionDirect(String _msg_id, String _msg_desc, GenericMessageEndpointImpl _endpoint, int _stream_crypto, byte[][] _shared_secrets)

Method Summary

Modifier and Type	Method	Description
void	accepted()
void	addInboundRateLimiter(RateLimiter _limiter)
void	addOutboundRateLimiter(RateLimiter _limiter)
void	close()
protected void	connect(NetworkConnection _connection)	Incoming connect call
void	connect(ByteBuffer upper_initial_data, GenericMessageConnectionAdapter.ConnectionListener listener)
Connection	getConnection()
GenericMessageEndpoint	getEndpoint()
int	getMaximumMessageSize()
GenericMessageStartpoint	getStartpoint()
int	getTransportType()
String	getType()
protected static GenericMessageConnectionDirect	receive(GenericMessageEndpointImpl endpoint, String msg_id, String msg_desc, int stream_crypto, byte[][] shared_secrets)
void	removeInboundRateLimiter(RateLimiter _limiter)
void	removeOutboundRateLimiter(RateLimiter _limiter)
void	send(PooledByteBuffer data)
void	setOwner(GenericMessageConnectionImpl _owner)
protected void	startProcessing()

Methods inherited from class Object

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

Field Details

MAX_MESSAGE_SIZE

public static final int MAX_MESSAGE_SIZE

See Also:

• Constant Field Values

dispatcher

private static AsyncDispatcher dispatcher

owner

private GenericMessageConnectionImpl owner

msg_id

private String msg_id

msg_desc

private String msg_desc

stream_crypto

private int stream_crypto

shared_secrets

private byte[][] shared_secrets

endpoint

private GenericMessageEndpointImpl endpoint

connection

private NetworkConnection connection

plugin_connection

private ConnectionImpl plugin_connection

connected

private volatile boolean connected

processing

private boolean processing

closed

private volatile boolean closed

inbound_rls

private List<LimitedRateGroup> inbound_rls

outbound_rls

private List<LimitedRateGroup> outbound_rls

Constructor Details

GenericMessageConnectionDirect

protected GenericMessageConnectionDirect(String _msg_id,
 String _msg_desc,
 GenericMessageEndpointImpl _endpoint,
 int _stream_crypto,
 byte[][] _shared_secrets)

Method Details

receive

protected static GenericMessageConnectionDirect receive(GenericMessageEndpointImpl endpoint,
 String msg_id,
 String msg_desc,
 int stream_crypto,
 byte[][] shared_secrets)

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

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

protected void connect(NetworkConnection _connection)

Incoming connect call

Parameters:

_connection -

accepted

public void accepted()

Specified by:

accepted in interface GenericMessageConnectionAdapter

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

connect

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

Specified by:

connect in interface GenericMessageConnectionAdapter

startProcessing

protected void startProcessing()

send

public void send(PooledByteBuffer data)
          throws MessageException

Specified by:

send in interface GenericMessageConnectionAdapter

Throws:

MessageException

close

public void close()
           throws MessageException

Specified by:

close in interface GenericMessageConnectionAdapter

Throws:

MessageException