com.aelitis.azureus.core.networkmanager.impl.tcp
Class TCPTransportHelper
java.lang.Object
com.aelitis.azureus.core.networkmanager.impl.tcp.TCPTransportHelper
- All Implemented Interfaces:
- TransportHelper
public class TCPTransportHelper
- extends Object
- implements TransportHelper
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
READ_TIMEOUT
public static final int READ_TIMEOUT
- See Also:
- Constant Field Values
CONNECT_TIMEOUT
public static final int CONNECT_TIMEOUT
- See Also:
- Constant Field Values
MAX_PARTIAL_WRITE_RETAIN
public static final int MAX_PARTIAL_WRITE_RETAIN
- See Also:
- Constant Field Values
TCPTransportHelper
public TCPTransportHelper(SocketChannel _channel)
getAddress
public InetSocketAddress getAddress()
- Specified by:
getAddress
in interface TransportHelper
getName
public String getName(boolean verbose)
- Specified by:
getName
in interface TransportHelper
minimiseOverheads
public boolean minimiseOverheads()
- Specified by:
minimiseOverheads
in interface TransportHelper
getConnectTimeout
public int getConnectTimeout()
- Specified by:
getConnectTimeout
in interface TransportHelper
getReadTimeout
public int getReadTimeout()
- Specified by:
getReadTimeout
in interface TransportHelper
delayWrite
public boolean delayWrite(ByteBuffer buffer)
- Specified by:
delayWrite
in interface TransportHelper
hasDelayedWrite
public boolean hasDelayedWrite()
- Specified by:
hasDelayedWrite
in interface TransportHelper
write
public int write(ByteBuffer buffer,
boolean partial_write)
throws IOException
- Specified by:
write
in interface TransportHelper
- Throws:
IOException
write
public long write(ByteBuffer[] buffers,
int array_offset,
int length)
throws IOException
- Specified by:
write
in interface TransportHelper
- Throws:
IOException
read
public int read(ByteBuffer buffer)
throws IOException
- Specified by:
read
in interface TransportHelper
- Throws:
IOException
read
public long read(ByteBuffer[] buffers,
int array_offset,
int length)
throws IOException
- Specified by:
read
in interface TransportHelper
- Throws:
IOException
registerForReadSelects
public void registerForReadSelects(TransportHelper.selectListener listener,
Object attachment)
- Specified by:
registerForReadSelects
in interface TransportHelper
registerForWriteSelects
public void registerForWriteSelects(TransportHelper.selectListener listener,
Object attachment)
- Specified by:
registerForWriteSelects
in interface TransportHelper
cancelReadSelects
public void cancelReadSelects()
- Specified by:
cancelReadSelects
in interface TransportHelper
cancelWriteSelects
public void cancelWriteSelects()
- Specified by:
cancelWriteSelects
in interface TransportHelper
resumeReadSelects
public void resumeReadSelects()
- Specified by:
resumeReadSelects
in interface TransportHelper
resumeWriteSelects
public void resumeWriteSelects()
- Specified by:
resumeWriteSelects
in interface TransportHelper
pauseReadSelects
public void pauseReadSelects()
- Specified by:
pauseReadSelects
in interface TransportHelper
pauseWriteSelects
public void pauseWriteSelects()
- Specified by:
pauseWriteSelects
in interface TransportHelper
isClosed
public boolean isClosed()
- Specified by:
isClosed
in interface TransportHelper
close
public void close(String reason)
- Specified by:
close
in interface TransportHelper
failed
public void failed(Throwable reason)
- Specified by:
failed
in interface TransportHelper
getSocketChannel
public SocketChannel getSocketChannel()
setUserData
public void setUserData(Object key,
Object data)
- Specified by:
setUserData
in interface TransportHelper
getUserData
public Object getUserData(Object key)
- Specified by:
getUserData
in interface TransportHelper
setTrace
public void setTrace(boolean on)
- Specified by:
setTrace
in interface TransportHelper
setScatteringMode
public void setScatteringMode(long forBytes)
- Specified by:
setScatteringMode
in interface TransportHelper