|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Objectcom.aelitis.azureus.core.networkmanager.impl.TransportImpl
com.aelitis.azureus.core.networkmanager.impl.tcp.TCPTransportImpl
public class TCPTransportImpl
Represents a peer TCP transport connection (eg. a network socket).
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface com.aelitis.azureus.core.networkmanager.Transport |
---|
Transport.ConnectListener |
Field Summary | |
---|---|
boolean |
has_been_closed
|
Fields inherited from interface com.aelitis.azureus.core.networkmanager.Transport |
---|
TRANSPORT_MODE_FAST, TRANSPORT_MODE_NORMAL, TRANSPORT_MODE_TURBO |
Constructor Summary | |
---|---|
TCPTransportImpl(ProtocolEndpointTCP endpoint,
boolean use_crypto,
boolean allow_fallback,
byte[][] _shared_secrets)
Constructor for disconnected (outbound) transport. |
|
TCPTransportImpl(ProtocolEndpointTCP endpoint,
TransportHelperFilter filter)
Constructor for connected (inbound) transport. |
Method Summary | |
---|---|
void |
close(java.lang.String reason)
Close the transport connection. |
protected void |
close(TransportHelper helper,
java.lang.String reason)
|
protected void |
connectedOutbound(java.nio.ByteBuffer remaining_initial_data,
Transport.ConnectListener listener)
|
void |
connectOutbound(java.nio.ByteBuffer initial_data,
Transport.ConnectListener listener,
int priority)
Request the transport connection be established. |
java.lang.String |
getDescription()
Get a textual description for this transport. |
int |
getMssSize()
|
java.lang.String |
getProtocol()
|
java.nio.channels.SocketChannel |
getSocketChannel()
Get the socket channel used by the transport. |
TransportEndpointTCP |
getTransportEndpoint()
Get the socket channel used by the transport. |
int |
getTransportMode()
Get the transport's speed mode. |
TransportStartpoint |
getTransportStartpoint()
|
protected void |
handleCrypto(java.net.InetSocketAddress address,
java.nio.channels.SocketChannel channel,
java.nio.ByteBuffer initial_data,
int priority,
Transport.ConnectListener listener)
|
boolean |
isSOCKS()
|
boolean |
isTCP()
|
void |
setTransportMode(int mode)
Set the transport to the given speed mode. |
Methods inherited from class com.aelitis.azureus.core.networkmanager.impl.TransportImpl |
---|
bindConnection, connectedInbound, connectedOutbound, getEncryption, getFilter, isEncrypted, isReadyForRead, isReadyForWrite, read, readFailed, readyForRead, readyForWrite, setAlreadyRead, setFilter, setReadyForRead, setTrace, unbindConnection, write, writeFailed |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Methods inherited from interface com.aelitis.azureus.core.networkmanager.Transport |
---|
bindConnection, connectedInbound, getEncryption, isEncrypted, read, setAlreadyRead, setReadyForRead, setTrace, unbindConnection, write |
Methods inherited from interface com.aelitis.azureus.core.networkmanager.TransportBase |
---|
isReadyForRead, isReadyForWrite |
Field Detail |
---|
public volatile boolean has_been_closed
Constructor Detail |
---|
public TCPTransportImpl(ProtocolEndpointTCP endpoint, boolean use_crypto, boolean allow_fallback, byte[][] _shared_secrets)
public TCPTransportImpl(ProtocolEndpointTCP endpoint, TransportHelperFilter filter)
channel
- connectionalready_read
- bytes from the channelMethod Detail |
---|
public java.nio.channels.SocketChannel getSocketChannel()
public TransportEndpointTCP getTransportEndpoint()
Transport
getTransportEndpoint
in interface Transport
public TransportStartpoint getTransportStartpoint()
getTransportStartpoint
in interface Transport
getTransportStartpoint
in class TransportImpl
public int getMssSize()
getMssSize
in interface Transport
public boolean isTCP()
isTCP
in interface TransportBase
public boolean isSOCKS()
isSOCKS
in interface Transport
isSOCKS
in class TransportImpl
public java.lang.String getProtocol()
getProtocol
in interface Transport
getProtocol
in class TransportImpl
public java.lang.String getDescription()
getDescription
in interface TransportBase
public void connectOutbound(java.nio.ByteBuffer initial_data, Transport.ConnectListener listener, int priority)
connectOutbound
in interface Transport
address
- remote peer address to connect tolistener
- establishment failure/success listenerprotected void handleCrypto(java.net.InetSocketAddress address, java.nio.channels.SocketChannel channel, java.nio.ByteBuffer initial_data, int priority, Transport.ConnectListener listener)
public void setTransportMode(int mode)
setTransportMode
in interface Transport
mode
- to change toprotected void connectedOutbound(java.nio.ByteBuffer remaining_initial_data, Transport.ConnectListener listener)
public int getTransportMode()
getTransportMode
in interface Transport
protected void close(TransportHelper helper, java.lang.String reason)
public void close(java.lang.String reason)
close
in interface Transport
|
|||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | ||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |