AbstractCodec cleanup
This commit is contained in:
@@ -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
|
||||
|
||||
@@ -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;
|
||||
|
||||
|
||||
Reference in New Issue
Block a user