diff --git a/src/remote/blockingUDPTransport.cpp b/src/remote/blockingUDPTransport.cpp index b276a2b..f0fca62 100644 --- a/src/remote/blockingUDPTransport.cpp +++ b/src/remote/blockingUDPTransport.cpp @@ -494,25 +494,6 @@ bool BlockingUDPTransport::send(ByteBuffer* buffer, InetAddressType target) { return allOK; } -size_t BlockingUDPTransport::getSocketReceiveBufferSize() const { - // Get value of the SO_RCVBUF option for this DatagramSocket, - // that is the buffer size used by the platform for input on - // this DatagramSocket. - - int sockBufSize = -1; - osiSocklen_t intLen = sizeof(int); - - int retval = getsockopt(_channel, SOL_SOCKET, SO_RCVBUF, (char *)&sockBufSize, &intLen); - if(unlikely(retval<0)) - { - char errStr[64]; - epicsSocketConvertErrnoToString(errStr, sizeof(errStr)); - LOG(logLevelError, "Socket getsockopt SO_RCVBUF error: %s.", errStr); - } - - return (size_t)sockBufSize; -} - void BlockingUDPTransport::join(const osiSockAddr & mcastAddr, const osiSockAddr & nifAddr) { diff --git a/src/remote/codec.cpp b/src/remote/codec.cpp index b1e55ef..b0ff177 100644 --- a/src/remote/codec.cpp +++ b/src/remote/codec.cpp @@ -1289,27 +1289,6 @@ int BlockingTCPTransportCodec::write( } -std::size_t BlockingTCPTransportCodec::getSocketReceiveBufferSize() -const { - - osiSocklen_t intLen = sizeof(int); - int socketRecvBufferSize; - int retval = getsockopt(_channel, SOL_SOCKET, SO_RCVBUF, - (char *)&socketRecvBufferSize, &intLen); - - if(retval<0) { - if (IS_LOGGABLE(logLevelDebug)) - { - char strBuffer[64]; - epicsSocketConvertErrnoToString(strBuffer, sizeof(strBuffer)); - LOG(logLevelDebug, "Error getting SO_SNDBUF: %s", strBuffer); - } - } - - return socketRecvBufferSize; -} - - int BlockingTCPTransportCodec::read(epics::pvData::ByteBuffer* dst) { std::size_t remaining; diff --git a/src/remote/pv/blockingUDP.h b/src/remote/pv/blockingUDP.h index ea0aeb1..f1c560f 100644 --- a/src/remote/pv/blockingUDP.h +++ b/src/remote/pv/blockingUDP.h @@ -83,8 +83,6 @@ public: return _receiveBuffer.getSize(); } - virtual std::size_t getSocketReceiveBufferSize() const OVERRIDE FINAL; - virtual epics::pvData::int16 getPriority() const OVERRIDE FINAL { return PVA_DEFAULT_PRIORITY; } diff --git a/src/remote/pv/codec.h b/src/remote/pv/codec.h index 5607582..c8138dc 100644 --- a/src/remote/pv/codec.h +++ b/src/remote/pv/codec.h @@ -335,7 +335,6 @@ public: return &_socketAddress; } virtual void invalidDataStreamHandler() OVERRIDE FINAL; - virtual std::size_t getSocketReceiveBufferSize() const OVERRIDE FINAL; virtual std::string getType() const OVERRIDE FINAL { return std::string("tcp"); diff --git a/src/remote/pv/remote.h b/src/remote/pv/remote.h index c549d65..b096008 100644 --- a/src/remote/pv/remote.h +++ b/src/remote/pv/remote.h @@ -197,12 +197,6 @@ public: */ virtual std::size_t getReceiveBufferSize() const = 0; - /** - * Get socket receive buffer size. - * @return socket receive buffer size. - */ - virtual std::size_t getSocketReceiveBufferSize() const = 0; - /** * Transport priority. * @return protocol priority. diff --git a/testApp/remote/testCodec.cpp b/testApp/remote/testCodec.cpp index 8b8678a..74cb62c 100644 --- a/testApp/remote/testCodec.cpp +++ b/testApp/remote/testCodec.cpp @@ -366,11 +366,6 @@ public: return 0; } - std::size_t getSocketReceiveBufferSize() const - { - return 16384; - } - void setRemoteTransportSocketReceiveBufferSize( std::size_t socketReceiveBufferSize) {}