diff --git a/src/remote/codec.cpp b/src/remote/codec.cpp index 19d5975..424b4db 100644 --- a/src/remote/codec.cpp +++ b/src/remote/codec.cpp @@ -94,7 +94,7 @@ AbstractCodec::AbstractCodec( _remoteTransportSocketReceiveBufferSize(MAX_TCP_RECV), _totalBytesSent(0), _senderThread(0), _writeMode(PROCESS_SEND_QUEUE), - _writeOpReady(false),_lowLatency(false), + _writeOpReady(false), _socketBuffer(bufSizeSelect(receiveBufferSize)), _sendBuffer(bufSizeSelect(sendBufferSize)), //PRIVATE @@ -920,10 +920,7 @@ void AbstractCodec::enqueueSendRequest( processSender(sender); if (_sendBuffer.getPosition() > 0) { - if (_lowLatency) - flush(true); - else - scheduleSend(); + scheduleSend(); } } else diff --git a/src/remote/pv/codec.h b/src/remote/pv/codec.h index f3b4aaa..3772e8f 100644 --- a/src/remote/pv/codec.h +++ b/src/remote/pv/codec.h @@ -265,7 +265,6 @@ protected: epicsThreadId _senderThread; WriteMode _writeMode; bool _writeOpReady; - bool _lowLatency; epics::pvData::ByteBuffer _socketBuffer; epics::pvData::ByteBuffer _sendBuffer; @@ -296,7 +295,7 @@ private: epics::pvData::int8 _byteOrderFlag; protected: - epics::pvData::int8 _clientServerFlag; + const epics::pvData::int8 _clientServerFlag; private: const size_t _socketSendBufferSize;