Package org.epics.pvaccess.client.pvms

Class PVMSCodec

java.lang.Object

org.epics.pvaccess.client.pvms.PVMSCodec

public class PVMSCodec
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	PVMSCodec.PacketPosition

Constructor Summary

Constructors

Constructor	Description
PVMSCodec()

Method Summary

Modifier and Type	Method	Description
protected void	handleControlPacket(ByteBuffer buffer, InetSocketAddress socketAddress, int typeReserved, int additionalInfo, long id)
protected void	handleKeepAlive(InetSocketAddress socketAddress, long id, int expirationTimeSec)
protected void	handleShutdown(InetSocketAddress socketAddress, long id)
protected void	handleSubscribe(InetSocketAddress socketAddress, long id, int expirationTimeSec, String topicId)
int	incrementMessageSeqNum()	Atomically increments message (29-bit) sequence number.
int	incrementPacketSeqNum()	Atomically increments packet (31-bit) sequence number.
protected void	pmsKeepAliveControlMessage(ByteBuffer buffer, int expirationTimeSec)
protected void	pmsShutdownControlMessage(ByteBuffer buffer)
protected void	pmsSubscribeControlMessage(ByteBuffer buffer, int expirationTimeSec, String topicID)
protected void	udtDataHeader(ByteBuffer buffer, int messageSeqNumber, PVMSCodec.PacketPosition packetPosition)

Methods inherited from class java.lang.Object

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

Constructor Detail

PVMSCodec

public PVMSCodec()

Method Detail

incrementPacketSeqNum

public final int incrementPacketSeqNum()

Atomically increments packet (31-bit) sequence number.

Returns:

the previous value

incrementMessageSeqNum

public final int incrementMessageSeqNum()

Atomically increments message (29-bit) sequence number.

Returns:

the previous value

udtDataHeader

protected void udtDataHeader(ByteBuffer buffer,
                             int messageSeqNumber,
                             PVMSCodec.PacketPosition packetPosition)

pmsShutdownControlMessage

protected void pmsShutdownControlMessage(ByteBuffer buffer)

pmsKeepAliveControlMessage

protected void pmsKeepAliveControlMessage(ByteBuffer buffer,
                                          int expirationTimeSec)

pmsSubscribeControlMessage

protected void pmsSubscribeControlMessage(ByteBuffer buffer,
                                          int expirationTimeSec,
                                          String topicID)

handleControlPacket

protected void handleControlPacket(ByteBuffer buffer,
                                   InetSocketAddress socketAddress,
                                   int typeReserved,
                                   int additionalInfo,
                                   long id)

handleKeepAlive

protected void handleKeepAlive(InetSocketAddress socketAddress,
                               long id,
                               int expirationTimeSec)

handleShutdown

protected void handleShutdown(InetSocketAddress socketAddress,
                              long id)

handleSubscribe

protected void handleSubscribe(InetSocketAddress socketAddress,
                               long id,
                               int expirationTimeSec,
                               String topicId)