one.microstream.communication.binary.types.ComBinary

public class ComBinary
extends Object

Method Summary

Modifier and Type	Method	Description
`static long`	`calculateChunkHeaderContentLengthChecksum(ByteBuffer directByteBuffer)`
`static long`	`calculateCRC32Checksum(ByteBuffer buffer, int position, int length)`
`static int`	`chunkHeaderLength()`	The length of the fixed-size chunk header.
`static ComClient<ComConnection>`	`Client()`
`static ComClient<ComConnection>`	`Client(int localHostPort)`
`static ComClient<ComConnection>`	`Client(InetSocketAddress targetAddress)`
`static ComClientChannel<ComConnection>`	`connect()`
`static ComClientChannel<ComConnection>`	`connect(int localHostPort)`
`static ComClientChannel<ComConnection>`	`connect(InetSocketAddress targetAddress)`
`static ComPersistenceAdaptorBinary.Creator.Default`	`DefaultPersistenceAdaptorCreator()`
`static ComFoundation.Default<?>`	`Foundation()`
`static long`	`getChunkHeaderContentLength(ByteBuffer directByteBuffer, boolean switchedByteOrder)`
`static long`	`getChunkHeaderContentLengthChecksum(ByteBuffer directByteBuffer, boolean switchedByteOrder)`
`static ComHost<ComConnection>`	`Host()`
`static ComHost<ComConnection>`	`Host(int localHostPort)`
`static ComHost<ComConnection>`	`Host(int localHostPort, ComHostChannelAcceptor<ComConnection> channelAcceptor)`
`static ComHost<ComConnection>`	`Host(InetSocketAddress targetAddress)`
`static ComHost<ComConnection>`	`Host(InetSocketAddress targetAddress, ComHostChannelAcceptor<ComConnection> channelAcceptor)`
`static ComHost<ComConnection>`	`Host(ComHostChannelAcceptor<ComConnection> channelAcceptor)`
`static int`	`operationTimeout()`
`static ByteBuffer`	`readChunk(ComConnection connection, ByteBuffer defaultBuffer, boolean switchedByteOrder)`
`static void`	`runHost()`
`static void`	`runHost(int localHostPort)`
`static void`	`runHost(int localHostPort, ComHostChannelAcceptor<ComConnection> channelAcceptor)`
`static void`	`runHost(InetSocketAddress targetAddress)`
`static void`	`runHost(InetSocketAddress targetAddress, ComHostChannelAcceptor<ComConnection> channelAcceptor)`
`static void`	`runHost(ComHostChannelAcceptor<ComConnection> channelAcceptor)`
`static ByteBuffer`	`setChunkHeaderContentLength(ByteBuffer directByteBuffer, long contentLength, boolean switchedByteOrder)`
`static ByteBuffer`	`setChunkHeaderContentLengthChecksum(ByteBuffer directByteBuffer, long checksum, boolean switchedByteOrder)`
`static void`	`writeChunk(ComConnection connection, ByteBuffer headerBuffer, ByteBuffer[] buffers)`

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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(). And a crc32 checksum of the chunk content length
  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)
- getChunkHeaderContentLengthChecksum
  
  public static long getChunkHeaderContentLengthChecksum(ByteBuffer directByteBuffer, boolean switchedByteOrder)
- setChunkHeaderContentLength
  
  public static ByteBuffer setChunkHeaderContentLength(ByteBuffer directByteBuffer, long contentLength, boolean switchedByteOrder)
- setChunkHeaderContentLengthChecksum
  
  public static ByteBuffer setChunkHeaderContentLengthChecksum(ByteBuffer directByteBuffer, long checksum, boolean switchedByteOrder)
- calculateChunkHeaderContentLengthChecksum
  
  public static long calculateChunkHeaderContentLengthChecksum(ByteBuffer directByteBuffer)
- calculateCRC32Checksum
  
  public static long calculateCRC32Checksum(ByteBuffer buffer, int position, int length)
- operationTimeout
  
  public static int operationTimeout()
- readChunk
  
  public static ByteBuffer readChunk(ComConnection connection, ByteBuffer defaultBuffer, boolean switchedByteOrder) throws ComException, ComExceptionTimeout
  
  Throws:
  
  ComException
  
  ComExceptionTimeout
- writeChunk
  
  public static void writeChunk(ComConnection connection, ByteBuffer headerBuffer, ByteBuffer[] buffers) throws ComException, ComExceptionTimeout
  
  Throws:
  
  ComException
  
  ComExceptionTimeout
- DefaultPersistenceAdaptorCreator
  
  public static ComPersistenceAdaptorBinary.Creator.Default DefaultPersistenceAdaptorCreator()
- Foundation
  
  public static ComFoundation.Default<?> Foundation()
- Host
  
  public static final ComHost<ComConnection> Host()
- Host
  
  public static final ComHost<ComConnection> Host(int localHostPort)
- Host
  
  public static final ComHost<ComConnection> Host(InetSocketAddress targetAddress)
- Host
  
  public static final ComHost<ComConnection> Host(ComHostChannelAcceptor<ComConnection> channelAcceptor)
- Host
  
  public static final ComHost<ComConnection> Host(int localHostPort, ComHostChannelAcceptor<ComConnection> channelAcceptor)
- Host
  
  public static final ComHost<ComConnection> Host(InetSocketAddress targetAddress, ComHostChannelAcceptor<ComConnection> channelAcceptor)
- runHost
  
  public static final void runHost()
- runHost
  
  public static final void runHost(int localHostPort)
- runHost
  
  public static final void runHost(InetSocketAddress targetAddress)
- runHost
  
  public static final void runHost(ComHostChannelAcceptor<ComConnection> channelAcceptor)
- runHost
  
  public static final void runHost(int localHostPort, ComHostChannelAcceptor<ComConnection> channelAcceptor)
- runHost
  
  public static final void runHost(InetSocketAddress targetAddress, ComHostChannelAcceptor<ComConnection> channelAcceptor)
- Client
  
  public static final ComClient<ComConnection> Client()
- Client
  
  public static final ComClient<ComConnection> Client(int localHostPort)
- Client
  
  public static final ComClient<ComConnection> Client(InetSocketAddress targetAddress)
- connect
  
  public static final ComClientChannel<ComConnection> connect()
- connect
  
  public static final ComClientChannel<ComConnection> connect(int localHostPort)
- connect
  
  public static final ComClientChannel<ComConnection> connect(InetSocketAddress targetAddress)

Class ComBinary

Method Summary

Methods inherited from class java.lang.Object

Method Details