Class ComBinary
java.lang.Object
one.microstream.communication.binary.types.ComBinary
public class ComBinary extends Object
-
Method Summary
-
Method Details
-
chunkHeaderLength
public static int chunkHeaderLength()The length of the fixed-size chunk header.So far, the header only consists of one field holding the length of the chunk content. See
Binary.lengthLength()
. In the future, the header might contain validation values like protocol name, version, byte order, etc.
Maybe, the consequence will be a dynamically sized header, meaning there- Returns:
- The length of the fixed-size chunk header.
-
getChunkHeaderContentLength
public static long getChunkHeaderContentLength(ByteBuffer directByteBuffer, boolean switchedByteOrder) -
setChunkHeaderContentLength
public static ByteBuffer setChunkHeaderContentLength(ByteBuffer directByteBuffer, long contentLength, boolean switchedByteOrder) -
operationTimeout
public static int operationTimeout() -
readChunk
public static ByteBuffer readChunk(SocketChannel channel, ByteBuffer defaultBuffer, boolean switchedByteOrder) throws ComException, ComExceptionTimeout- Throws:
ComException
ComExceptionTimeout
-
writeChunk
public static void writeChunk(SocketChannel channel, ByteBuffer headerBuffer, ByteBuffer[] buffers) throws ComException, ComExceptionTimeout- Throws:
ComException
ComExceptionTimeout
-
DefaultPersistenceAdaptorCreator
-
Foundation
-
Host
-
Host
-
Host
-
Host
public static final ComHost<SocketChannel> Host(ComHostChannelAcceptor<SocketChannel> channelAcceptor) -
Host
public static final ComHost<SocketChannel> Host(int localHostPort, ComHostChannelAcceptor<SocketChannel> channelAcceptor) -
Host
public static final ComHost<SocketChannel> Host(InetSocketAddress targetAddress, ComHostChannelAcceptor<SocketChannel> channelAcceptor) -
runHost
public static final void runHost() -
runHost
public static final void runHost(int localHostPort) -
runHost
-
runHost
-
runHost
public static final void runHost(int localHostPort, ComHostChannelAcceptor<SocketChannel> channelAcceptor) -
runHost
public static final void runHost(InetSocketAddress targetAddress, ComHostChannelAcceptor<SocketChannel> channelAcceptor) -
Client
-
Client
-
Client
-
connect
-
connect
-
connect
-