Interface TransportHelper
-
- All Known Implementing Classes:
TCPTransportHelper
,UDPTransportHelper
public interface TransportHelper
-
-
Nested Class Summary
Nested Classes Modifier and Type Interface Description static interface
TransportHelper.selectListener
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
cancelReadSelects()
void
cancelWriteSelects()
void
close(java.lang.String reason)
boolean
delayWrite(java.nio.ByteBuffer buffer)
void
failed(java.lang.Throwable reason)
java.net.InetSocketAddress
getAddress()
int
getConnectTimeout()
java.lang.String
getName(boolean verbose)
int
getReadTimeout()
java.lang.Object
getUserData(java.lang.Object key)
boolean
hasDelayedWrite()
boolean
isClosed()
boolean
minimiseOverheads()
void
pauseReadSelects()
void
pauseWriteSelects()
int
read(java.nio.ByteBuffer buffer)
long
read(java.nio.ByteBuffer[] buffers, int array_offset, int length)
void
registerForReadSelects(TransportHelper.selectListener listener, java.lang.Object attachment)
void
registerForWriteSelects(TransportHelper.selectListener listener, java.lang.Object attachment)
void
resumeReadSelects()
void
resumeWriteSelects()
void
setScatteringMode(long forBytes)
void
setTrace(boolean on)
void
setUserData(java.lang.Object key, java.lang.Object data)
long
write(java.nio.ByteBuffer[] buffers, int array_offset, int length)
int
write(java.nio.ByteBuffer buffer, boolean partial_write)
-
-
-
Method Detail
-
getAddress
java.net.InetSocketAddress getAddress()
-
getName
java.lang.String getName(boolean verbose)
-
minimiseOverheads
boolean minimiseOverheads()
-
getConnectTimeout
int getConnectTimeout()
-
getReadTimeout
int getReadTimeout()
-
delayWrite
boolean delayWrite(java.nio.ByteBuffer buffer)
-
hasDelayedWrite
boolean hasDelayedWrite()
-
write
int write(java.nio.ByteBuffer buffer, boolean partial_write) throws java.io.IOException
- Throws:
java.io.IOException
-
write
long write(java.nio.ByteBuffer[] buffers, int array_offset, int length) throws java.io.IOException
- Throws:
java.io.IOException
-
read
int read(java.nio.ByteBuffer buffer) throws java.io.IOException
- Throws:
java.io.IOException
-
read
long read(java.nio.ByteBuffer[] buffers, int array_offset, int length) throws java.io.IOException
- Throws:
java.io.IOException
-
pauseReadSelects
void pauseReadSelects()
-
pauseWriteSelects
void pauseWriteSelects()
-
resumeReadSelects
void resumeReadSelects()
-
resumeWriteSelects
void resumeWriteSelects()
-
registerForReadSelects
void registerForReadSelects(TransportHelper.selectListener listener, java.lang.Object attachment)
-
registerForWriteSelects
void registerForWriteSelects(TransportHelper.selectListener listener, java.lang.Object attachment)
-
cancelReadSelects
void cancelReadSelects()
-
cancelWriteSelects
void cancelWriteSelects()
-
isClosed
boolean isClosed()
-
close
void close(java.lang.String reason)
-
failed
void failed(java.lang.Throwable reason)
-
setUserData
void setUserData(java.lang.Object key, java.lang.Object data)
-
getUserData
java.lang.Object getUserData(java.lang.Object key)
-
setTrace
void setTrace(boolean on)
-
setScatteringMode
void setScatteringMode(long forBytes)
-
-