Package | Description |
---|---|
com.aquenos.epics.jackie.common.io |
Classes for dealing with I/O operations.
|
com.aquenos.epics.jackie.common.protocol |
Classes for encoding and decoding the Channel Access (v4) protocol.
|
com.aquenos.epics.jackie.common.value |
Classes representing values send over the Channel Access (v4) protocol.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractByteSink
Abstract base class for
ByteSink implementations. |
class |
ByteBufferByteSink
Byte sink that is backed by a list of byte buffers.
|
Modifier and Type | Method and Description |
---|---|
protected ByteSink |
AbstractSocketChannelConnection.getSendSink()
Returns the byte sink that can be used to send data over this connection.
|
ByteSink |
AbstractByteSink.putByte(byte b) |
ByteSink |
ByteSink.putByte(byte b)
Writes a single byte to this byte sink.
|
ByteSink |
AbstractByteSink.putByteArray(byte[] source) |
ByteSink |
ByteSink.putByteArray(byte[] source)
Writes a complete array of bytes to this byte sink.
|
ByteSink |
ByteSink.putByteArray(byte[] source,
int offset,
int length)
Writes a slice of an array of bytes to this byte sink.
|
ByteSink |
AbstractByteSink.putDouble(double value) |
ByteSink |
ByteSink.putDouble(double value)
Writes a single double value to this byte sink.
|
ByteSink |
AbstractByteSink.putDoubleArray(double[] source) |
ByteSink |
ByteSink.putDoubleArray(double[] source)
Writes a complete array of double values to this byte sink.
|
ByteSink |
ByteBufferByteSink.putDoubleArray(double[] source,
int offset,
int length) |
ByteSink |
AbstractByteSink.putDoubleArray(double[] source,
int offset,
int length) |
ByteSink |
ByteSink.putDoubleArray(double[] source,
int offset,
int length)
Writes a slice of an array of double values to this byte sink.
|
ByteSink |
AbstractByteSink.putFloat(float value) |
ByteSink |
ByteSink.putFloat(float value)
Writes a single float value to this byte sink.
|
ByteSink |
AbstractByteSink.putFloatArray(float[] source) |
ByteSink |
ByteSink.putFloatArray(float[] source)
Writes a complete array of float values to this byte sink.
|
ByteSink |
ByteBufferByteSink.putFloatArray(float[] source,
int offset,
int length) |
ByteSink |
AbstractByteSink.putFloatArray(float[] source,
int offset,
int length) |
ByteSink |
ByteSink.putFloatArray(float[] source,
int offset,
int length)
Writes a slice of an array of float values to this byte sink.
|
ByteSink |
AbstractByteSink.putInt(int value) |
ByteSink |
ByteSink.putInt(int value)
Writes a single int value to this byte sink.
|
ByteSink |
AbstractByteSink.putIntArray(int[] source) |
ByteSink |
ByteSink.putIntArray(int[] source)
Writes a complete array of int values to this byte sink.
|
ByteSink |
ByteBufferByteSink.putIntArray(int[] source,
int offset,
int length) |
ByteSink |
AbstractByteSink.putIntArray(int[] source,
int offset,
int length) |
ByteSink |
ByteSink.putIntArray(int[] source,
int offset,
int length)
Writes a slice of an array of int values to this byte sink.
|
ByteSink |
AbstractByteSink.putLong(long value) |
ByteSink |
ByteSink.putLong(long value)
Writes a single long value to this byte sink.
|
ByteSink |
AbstractByteSink.putLongArray(long[] source) |
ByteSink |
ByteSink.putLongArray(long[] source)
Writes a complete array of long values to this byte sink.
|
ByteSink |
ByteBufferByteSink.putLongArray(long[] source,
int offset,
int length) |
ByteSink |
AbstractByteSink.putLongArray(long[] source,
int offset,
int length) |
ByteSink |
ByteSink.putLongArray(long[] source,
int offset,
int length)
Writes a slice of an array of long values to this byte sink.
|
ByteSink |
AbstractByteSink.putShort(short value) |
ByteSink |
ByteSink.putShort(short value)
Writes a single short value to this byte sink.
|
ByteSink |
AbstractByteSink.putShortArray(short[] source) |
ByteSink |
ByteSink.putShortArray(short[] source)
Writes a complete array of short values to this byte sink.
|
ByteSink |
ByteBufferByteSink.putShortArray(short[] source,
int offset,
int length) |
ByteSink |
AbstractByteSink.putShortArray(short[] source,
int offset,
int length) |
ByteSink |
ByteSink.putShortArray(short[] source,
int offset,
int length)
Writes a slice of an array of short values to this byte sink.
|
Modifier and Type | Method and Description |
---|---|
void |
ChannelAccessMessageCodec.encodeMessageFromRepeater(ByteSink byteSink,
ChannelAccessMessage message,
ChannelAccessVersion version)
Encodes a message that shall be sent from a repeater to a client via UDP.
|
void |
ChannelAccessMessageCodec.encodeMessageToRepeater(ByteSink byteSink,
ChannelAccessMessage message,
ChannelAccessVersion version)
Encodes a message that shall be sent from a server or a client to a
repeater via UDP.
|
void |
ChannelAccessMessageCodec.encodeMessageToTCPClient(ByteSink byteSink,
ChannelAccessMessage message,
ChannelAccessVersion version)
Encodes a message that shall be sent from a server to a client via TCP
Only messages of type
ChannelAccessVersionTCPServerMessage ,
ChannelAccessSubscriptionServerMessage ,
ChannelAccessCancelSubscriptionServerMessage ,
ChannelAccessReadServerMessage ,
ChannelAccessReadSyncMessage , ChannelAccessErrorMessage ,
ChannelAccessDisconnectChannelMessage ,
ChannelAccessReadNotifyServerMessage ,
ChannelAccessConnectChannelServerMessage ,
ChannelAccessWriteNotifyServerMessage ,
ChannelAccessAccessRightsMessage ,
ChannelAccessEchoMessage ,
ChannelAccessConnectChannelFailedMessage ,
ChannelAccessChannelDisconnectedByServerMessage ,
ChannelAccessSearchTCPServerMessage , and
ChannelAccessNotFoundMessage can be sent via this protocol. |
void |
ChannelAccessMessageCodec.encodeMessageToTCPServer(ByteSink byteSink,
ChannelAccessMessage message,
ChannelAccessVersion version)
Encodes a message that shall be sent from a client to a server via TCP
Only messages of type
ChannelAccessVersionTCPClientMessage ,
ChannelAccessSubscriptionClientMessage ,
ChannelAccessCancelSubscriptionClientMessage ,
ChannelAccessReadClientMessage , ChannelAccessWriteMessage
, ChannelAccessEventsOffMessage ,
ChannelAccessEventsOnMessage ,
ChannelAccessReadSyncMessage ,
ChannelAccessDisconnectChannelMessage ,
ChannelAccessReadNotifyClientMessage ,
ChannelAccessConnectChannelClientMessage ,
ChannelAccessWriteNotifyClientMessage ,
ChannelAccessUserNameMessage ,
ChannelAccessHostNameMessage , ChannelAccessEchoMessage ,
and ChannelAccessSearchClientMessage can be sent via this
protocol. |
void |
ChannelAccessMessageCodec.encodeMessageToUDPClient(ByteSink byteSink,
ChannelAccessMessage message,
ChannelAccessVersion version)
Encodes a message that shall be sent from a server to a client via UDP.
|
void |
ChannelAccessMessageCodec.encodeMessageToUDPServer(ByteSink byteSink,
ChannelAccessMessage message,
ChannelAccessVersion version)
Encodes a message that shall be sent from a client to a server via UDP.
|
protected void |
ChannelAccessRepeaterRegisterMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessAccessRightsMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessBeaconMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessChannelDisconnectedByServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessEventsOffMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessWriteNotifyServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessReadSyncMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessWriteNotifyClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessConnectChannelFailedMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessSearchClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessSubscriptionServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessEventsOnMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessSubscriptionClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessWriteMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessRepeaterConfirmMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessNotFoundMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessSearchUDPServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessVersionUDPMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessVersionTCPServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessReadClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessReadServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessVersionTCPClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessUserNameMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessDisconnectChannelMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessReadBuildMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected abstract void |
ChannelAccessMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset)
Serializes this message to a byte sink.
|
protected void |
ChannelAccessHostNameMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessErrorMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessConnectChannelClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessReadNotifyClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessReadNotifyServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessConnectChannelServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessEchoMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessSearchTCPServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessCancelSubscriptionServerMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessCancelSubscriptionClientMessage.serialize(ByteSink byteSink,
ChannelAccessVersion version,
int maxPayloadSize,
java.nio.charset.Charset charset) |
protected void |
ChannelAccessMessage.serializeHeader(ByteSink byteSink,
int payloadSize,
short dataType,
int count,
int cid,
int contextSpecific,
ChannelAccessVersion version,
int maxPayloadSize)
Serializes the header of the message.
|
Modifier and Type | Method and Description |
---|---|
static void |
ChannelAccessValueCodec.encodeGettableValue(ByteSink byteSink,
ChannelAccessGettableValue<?> value,
int count)
Encodes a gettable ChannelAccess value into its serialized form.
|
static void |
ChannelAccessValueCodec.encodePuttableValue(ByteSink byteSink,
ChannelAccessPuttableValue<?> value,
int count)
Encodes a puttable ChannelAccess value into its serialized form.
|
static void |
ChannelAccessValueCodec.encodeValue(ByteSink byteSink,
ChannelAccessValue<?> value,
int count)
Encodes a ChannelAccess value into its serialized form.
|
Copyright © 2014–2018 aquenos GmbH. All rights reserved.