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

Class BlockingAbstractCodec

java.lang.Object

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

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

All Implemented Interfaces:

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

Direct Known Subclasses:

BlockingDatagramAbstractCodec, BlockingSocketAbstractCodec

public abstract class BlockingAbstractCodec
extends AbstractCodec

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
BlockingAbstractCodec(boolean serverFlag, ByteBuffer receiveBuffer, ByteBuffer sendBuffer, int socketSendBufferSize, Logger logger)

Method Summary

Modifier and Type	Method	Description
void	close()
boolean	isOpen()
void	readPollOne()
void	receiveThread()
void	scheduleSend()
protected void	sendBufferFull(int tries)
void	sendCompleted()
void	sendThread()
void	start()
boolean	terminated()
void	writePollOne()

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

alignBuffer, alignData, alignedValue, clearSendQueue, endMessage, enqueueSendRequest, enqueueSendRequest, ensureBuffer, ensureData, flush, flushSerializeBuffer, getLastReadBufferSocketAddress, invalidDataStreamHandler, 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 java.nio.channels.ReadableByteChannel

read

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

cachedSerialize

Methods inherited from interface java.nio.channels.WritableByteChannel

write

Constructor Detail

BlockingAbstractCodec

public BlockingAbstractCodec(boolean serverFlag,
                             ByteBuffer receiveBuffer,
                             ByteBuffer sendBuffer,
                             int socketSendBufferSize,
                             Logger logger)

Method Detail

readPollOne

public void readPollOne()
                 throws IOException

Specified by:

readPollOne in class AbstractCodec

Throws:

IOException

writePollOne

public void writePollOne()
                  throws IOException

Specified by:

writePollOne in class AbstractCodec

Throws:

IOException

sendBufferFull

protected void sendBufferFull(int tries)
                       throws IOException

Specified by:

sendBufferFull in class AbstractCodec

Throws:

IOException

scheduleSend

public void scheduleSend()

Specified by:

scheduleSend in class AbstractCodec

sendCompleted

public void sendCompleted()

Specified by:

sendCompleted in class AbstractCodec

close

public void close()
           throws IOException

Throws:

IOException

terminated

public boolean terminated()

Specified by:

terminated in class AbstractCodec

isOpen

public boolean isOpen()

start

public void start()

receiveThread

public void receiveThread()

sendThread

public void sendThread()