Package org.epics.pvaccess.impl.remote.codec.impl

Class BlockingDatagramAbstractCodec

java.lang.Object

org.epics.pvaccess.impl.remote.codec.AbstractCodec

org.epics.pvaccess.impl.remote.codec.impl.BlockingAbstractCodec

org.epics.pvaccess.impl.remote.codec.impl.BlockingDatagramAbstractCodec

All Implemented Interfaces:

Closeable, AutoCloseable, Channel, ReadableByteChannel, WritableByteChannel, TransportSendControl, org.epics.pvdata.pv.SerializableControl

public abstract class BlockingDatagramAbstractCodec
extends BlockingAbstractCodec

Author:

msekoranja

Nested Class Summary

Nested classes/interfaces inherited from class org.epics.pvaccess.impl.remote.codec.AbstractCodec

AbstractCodec.ReadMode, AbstractCodec.WriteMode

Field Summary

Fields inherited from class org.epics.pvaccess.impl.remote.codec.AbstractCodec

blockingProcessQueue, command, flags, logger, MAX_ENSURE_BUFFER_SIZE, MAX_ENSURE_DATA_SIZE, MAX_ENSURE_SIZE, MAX_MESSAGE_PROCESS, MAX_MESSAGE_SEND, payloadSize, readMode, remoteTransportSocketReceiveBufferSize, sendBuffer, sendQueue, sendTo, socketBuffer, totalBytesSent, version, writeMode, writeOpReady

Constructor Summary

Constructors

Constructor	Description
BlockingDatagramAbstractCodec(boolean serverFlag, DatagramChannel channel, ByteBuffer receiveBuffer, ByteBuffer sendBuffer, Logger logger)

Method Summary

Modifier and Type	Method	Description
InetSocketAddress	getLastReadBufferSocketAddress()
void	invalidDataStreamHandler()
int	read(ByteBuffer dst)
int	write(ByteBuffer src)

Methods inherited from class org.epics.pvaccess.impl.remote.codec.impl.BlockingAbstractCodec

close, isOpen, readPollOne, receiveThread, scheduleSend, sendBufferFull, sendCompleted, sendThread, start, terminated, writePollOne

Methods inherited from class org.epics.pvaccess.impl.remote.codec.AbstractCodec

alignBuffer, alignData, alignedValue, clearSendQueue, endMessage, enqueueSendRequest, enqueueSendRequest, ensureBuffer, ensureData, flush, flushSerializeBuffer, processApplicationMessage, processControlMessage, processRead, processSendQueue, processWrite, putControlMessage, send, setByteOrder, setRecipient, setSenderThread, startMessage

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.epics.pvdata.pv.SerializableControl

cachedSerialize

Constructor Detail

BlockingDatagramAbstractCodec

public BlockingDatagramAbstractCodec(boolean serverFlag,
                                     DatagramChannel channel,
                                     ByteBuffer receiveBuffer,
                                     ByteBuffer sendBuffer,
                                     Logger logger)
                              throws SocketException

Throws:

SocketException

Method Detail

read

public int read(ByteBuffer dst)
         throws IOException

Throws:

IOException

write

public int write(ByteBuffer src)
          throws IOException

Throws:

IOException

getLastReadBufferSocketAddress

public InetSocketAddress getLastReadBufferSocketAddress()

Specified by:

getLastReadBufferSocketAddress in class AbstractCodec

invalidDataStreamHandler

public void invalidDataStreamHandler()

Specified by:

invalidDataStreamHandler in class AbstractCodec