Class PeerForeignNetworkConnection

java.lang.Object

com.biglybt.core.networkmanager.NetworkConnectionHelper

com.biglybt.pifimpl.local.peers.PeerForeignNetworkConnection

All Implemented Interfaces:

ControllerAllocationManagement, NetworkConnectionBase

public class PeerForeignNetworkConnection
extends NetworkConnectionHelper

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected class	PeerForeignNetworkConnection.imq
protected class	PeerForeignNetworkConnection.omq
protected class	PeerForeignNetworkConnection.tp

Field Summary

Fields

Modifier and Type	Field	Description
private final PeerForeignDelegate	delegate
private IncomingMessageQueue	incoming_message_queue
private OutgoingMessageQueue	outgoing_message_queue
private final Peer	peer
private TransportBase	transport_base

Fields inherited from interface ControllerAllocationManagement

UNALLOCATED_PARTITION

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	PeerForeignNetworkConnection(PeerForeignDelegate _delegate, Peer _peer)

Method Summary

Modifier and Type	Method	Description
void	close(String reason)
ConnectionEndpoint	getEndpoint()
IncomingMessageQueue	getIncomingMessageQueue()	Get the connection's incoming message queue.
int	getMssSize()
OutgoingMessageQueue	getOutgoingMessageQueue()	Get the connection's outgoing message queue.
String	getString()
TransportBase	getTransportBase()	Get the connection's data transport interface.
boolean	isClosed()
boolean	isIncoming()
boolean	isLANLocal()	Is the connection within the local LAN network.
void	notifyOfException(Throwable error)	Inform connection of a thrown exception.
void	resetLANLocalStatus()

Methods inherited from class NetworkConnectionHelper

activeReadControllerRelease, activeWriteControllerRelease, addRateLimiter, getDownloadLimit, getPartitionID, getRateLimiters, getUploadLimit, isReadControllerActive, isWriteControllerActive, removeRateLimiter, setDownloadLimit, setReadControllerInactive, setTargetReadControllerPartition, setTargetWriteControllerPartition, setUploadLimit, setWriteControllerInactive

Methods inherited from class Object

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

Field Details

delegate

private final PeerForeignDelegate delegate

peer

private final Peer peer

outgoing_message_queue

private OutgoingMessageQueue outgoing_message_queue

incoming_message_queue

private IncomingMessageQueue incoming_message_queue

transport_base

private TransportBase transport_base

Constructor Details

PeerForeignNetworkConnection

protected PeerForeignNetworkConnection(PeerForeignDelegate _delegate,
 Peer _peer)

Method Details

getEndpoint

public ConnectionEndpoint getEndpoint()

notifyOfException

public void notifyOfException(Throwable error)

Description copied from interface: NetworkConnectionBase

Inform connection of a thrown exception.

Parameters:

error - exception

getOutgoingMessageQueue

public OutgoingMessageQueue getOutgoingMessageQueue()

Description copied from interface: NetworkConnectionBase

Get the connection's outgoing message queue.

Returns:

outbound message queue

getIncomingMessageQueue

public IncomingMessageQueue getIncomingMessageQueue()

Description copied from interface: NetworkConnectionBase

Get the connection's incoming message queue.

Returns:

inbound message queue

getTransportBase

public TransportBase getTransportBase()

Description copied from interface: NetworkConnectionBase

Get the connection's data transport interface.

Returns:

the transport - MAY BE NULL if not yet fully connected

getMssSize

public int getMssSize()

isIncoming

public boolean isIncoming()

isLANLocal

public boolean isLANLocal()

Description copied from interface: NetworkConnectionBase

Is the connection within the local LAN network.

Returns:

true if within LAN, false of outside the LAN segment

resetLANLocalStatus

public void resetLANLocalStatus()

close

public void close(String reason)

Specified by:

close in class NetworkConnectionHelper

isClosed

public boolean isClosed()

getString

public String getString()