public class TransportTCP extends Transport
Modifier and Type | Field and Description |
---|---|
static int |
DEFAULT_CONNECTION_TIMEOUT_MS |
static int |
DEFAULT_RECONNECTION_LIMIT |
BLOCK_SIZE, DEFAULT_FREE_BLOCKS_RESERVE, DEFAULT_TOTAL_BLOCKS_LIMIT, NETWORK_BYTE_ORDER
Modifier and Type | Method and Description |
---|---|
java.lang.String |
getConnectionError()
Get the connect error message.
|
boolean |
isConnected()
Check if transport connection is fully established and connected
|
boolean |
isValid()
Check if the transport connection is valid (may not be connected)
|
void |
run() |
boolean |
transmitDataBlock(java.nio.ByteBuffer block,
int usedBufferSize)
2.
|
addAgentCommandListener, getOrAllocateNextFreeDataBlock, getTransportQSize, isTransportQEmpty, removeAgentCommandListener, resetTransport
activeCount, checkAccess, countStackFrames, currentThread, destroy, dumpStack, enumerate, getAllStackTraces, getContextClassLoader, getDefaultUncaughtExceptionHandler, getId, getName, getPriority, getStackTrace, getState, getThreadGroup, getUncaughtExceptionHandler, holdsLock, interrupt, interrupted, isAlive, isDaemon, isInterrupted, join, join, join, resume, setContextClassLoader, setDaemon, setDefaultUncaughtExceptionHandler, setName, setPriority, setUncaughtExceptionHandler, sleep, sleep, start, stop, stop, suspend, toString, yield
public static final int DEFAULT_CONNECTION_TIMEOUT_MS
public static final int DEFAULT_RECONNECTION_LIMIT
public java.lang.String getConnectionError()
Transport
getConnectionError
in class Transport
public boolean isConnected()
Transport
isConnected
in class Transport
public boolean isValid()
Transport
public void run()
run
in interface java.lang.Runnable
run
in class java.lang.Thread
public boolean transmitDataBlock(java.nio.ByteBuffer block, int usedBufferSize)
Transport
transmitDataBlock
in class Transport
block
- (ByteBuffer) finished built data block - ready to be transmitted over transport layerusedBufferSize
- (int) number of bytes actually used in bufferCopyright (c) Fabasoft R&D GmbH, Linz, Austria, 1988-2015.