Package com.biglybt.pifimpl.local.peers
Class PeerForeignNetworkConnection
- java.lang.Object
-
- com.biglybt.core.networkmanager.NetworkConnectionHelper
-
- com.biglybt.pifimpl.local.peers.PeerForeignNetworkConnection
-
- All Implemented Interfaces:
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 PeerForeignDelegate
delegate
private IncomingMessageQueue
incoming_message_queue
private OutgoingMessageQueue
outgoing_message_queue
private Peer
peer
private TransportBase
transport_base
-
Constructor Summary
Constructors Modifier Constructor Description protected
PeerForeignNetworkConnection(PeerForeignDelegate _delegate, Peer _peer)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description ConnectionEndpoint
getEndpoint()
IncomingMessageQueue
getIncomingMessageQueue()
Get the connection's incoming message queue.int
getMssSize()
OutgoingMessageQueue
getOutgoingMessageQueue()
Get the connection's outgoing message queue.java.lang.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(java.lang.Throwable error)
Inform connection of a thrown exception.void
resetLANLocalStatus()
-
Methods inherited from class com.biglybt.core.networkmanager.NetworkConnectionHelper
addRateLimiter, getDownloadLimit, getRateLimiters, getUploadLimit, removeRateLimiter, setDownloadLimit, setUploadLimit
-
-
-
-
Field Detail
-
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 Detail
-
PeerForeignNetworkConnection
protected PeerForeignNetworkConnection(PeerForeignDelegate _delegate, Peer _peer)
-
-
Method Detail
-
getEndpoint
public ConnectionEndpoint getEndpoint()
-
notifyOfException
public void notifyOfException(java.lang.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()
-
isClosed
public boolean isClosed()
-
getString
public java.lang.String getString()
-
-