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 an 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