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

Class BlockingSocketAbstractCodec

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.BlockingSocketAbstractCodec

All Implemented Interfaces:

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

Direct Known Subclasses:

BlockingTCPTransport

public abstract class BlockingSocketAbstractCodec
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

Modifier and Type	Field	Description
protected SocketChannel	channel
protected InetSocketAddress	socketAddress

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
BlockingSocketAbstractCodec(boolean serverFlag, SocketChannel channel, ByteBuffer receiveBuffer, ByteBuffer sendBuffer, Logger logger)

Method Summary

Modifier and Type	Method	Description
InetSocketAddress	getLastReadBufferSocketAddress()
protected void	internalDestroy()
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

Field Detail

channel

protected final SocketChannel channel

socketAddress

protected final InetSocketAddress socketAddress

Constructor Detail

BlockingSocketAbstractCodec

public BlockingSocketAbstractCodec(boolean serverFlag,
                                   SocketChannel 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

internalDestroy

protected void internalDestroy()

getLastReadBufferSocketAddress

public InetSocketAddress getLastReadBufferSocketAddress()

Specified by:

getLastReadBufferSocketAddress in class AbstractCodec

invalidDataStreamHandler

public void invalidDataStreamHandler()

Specified by:

invalidDataStreamHandler in class AbstractCodec