diff options
Diffstat (limited to 'cpp/src/Ice/UdpEndpointI.cpp')
-rw-r--r-- | cpp/src/Ice/UdpEndpointI.cpp | 29 |
1 files changed, 7 insertions, 22 deletions
diff --git a/cpp/src/Ice/UdpEndpointI.cpp b/cpp/src/Ice/UdpEndpointI.cpp index b13e3fa89f3..26d5cd83640 100644 --- a/cpp/src/Ice/UdpEndpointI.cpp +++ b/cpp/src/Ice/UdpEndpointI.cpp @@ -25,13 +25,11 @@ using namespace IceInternal; IceUtil::Shared* IceInternal::upCast(UdpEndpointI* p) { return p; } IceInternal::UdpEndpointI::UdpEndpointI(const ProtocolInstancePtr& instance, const string& host, Int port, - const Address& sourceAddr, const string& mcastInterface, Int mttl, - Int sndBufSize, Int rcvBufSize, bool conn, const string& conId, bool co) : + const Address& sourceAddr, const string& mcastInterface, Int mttl, bool conn, + const string& conId, bool co) : IPEndpointI(instance, host, port, sourceAddr, conId), _mcastTtl(mttl), _mcastInterface(mcastInterface), - _sndBufSize(sndBufSize), - _rcvBufSize(rcvBufSize), _connect(conn), _compress(co) { @@ -40,8 +38,6 @@ IceInternal::UdpEndpointI::UdpEndpointI(const ProtocolInstancePtr& instance, con IceInternal::UdpEndpointI::UdpEndpointI(const ProtocolInstancePtr& instance) : IPEndpointI(instance), _mcastTtl(-1), - _sndBufSize(-1), - _rcvBufSize(-1), _connect(false), _compress(false) { @@ -50,8 +46,6 @@ IceInternal::UdpEndpointI::UdpEndpointI(const ProtocolInstancePtr& instance) : IceInternal::UdpEndpointI::UdpEndpointI(const ProtocolInstancePtr& instance, BasicStream* s) : IPEndpointI(instance, s), _mcastTtl(-1), - _sndBufSize(-1), - _rcvBufSize(-1), _connect(false), _compress(false) { @@ -134,8 +128,8 @@ IceInternal::UdpEndpointI::compress(bool compress) const } else { - return new UdpEndpointI(_instance, _host, _port, _sourceAddr, _mcastInterface, _mcastTtl, _sndBufSize, - _rcvBufSize, _connect, _connectionId, compress); + return new UdpEndpointI(_instance, _host, _port, _sourceAddr, _mcastInterface, _mcastTtl, _connect, + _connectionId, compress); } } @@ -167,14 +161,7 @@ UdpEndpointIPtr IceInternal::UdpEndpointI::endpoint(const UdpTransceiverPtr& transceiver) const { return new UdpEndpointI(_instance, _host, transceiver->effectivePort(), _sourceAddr, _mcastInterface, _mcastTtl, - transceiver->sndBufSize(), transceiver->rcvBufSize(), _connect, _connectionId, _compress); -} - -void -IceInternal::UdpEndpointI::setBufSize(int sndSize, int rcvSize) -{ - const_cast<int&>(_sndBufSize) = sndSize; - const_cast<int&>(_rcvBufSize) = rcvSize; + _connect, _connectionId, _compress); } string @@ -348,8 +335,6 @@ IceInternal::UdpEndpointI::fillEndpointInfo(IPEndpointInfo* info) const udpInfo->compress = _compress; udpInfo->mcastTtl = _mcastTtl; udpInfo->mcastInterface = _mcastInterface; - udpInfo->sndBufSize = _sndBufSize; - udpInfo->rcvBufSize = _rcvBufSize; } } @@ -447,8 +432,8 @@ IceInternal::UdpEndpointI::createConnector(const Address& address, const Network IPEndpointIPtr IceInternal::UdpEndpointI::createEndpoint(const string& host, int port, const string& connectionId) const { - return new UdpEndpointI(_instance, host, port, _sourceAddr, _mcastInterface, _mcastTtl, _sndBufSize, _rcvBufSize, - _connect, connectionId, _compress); + return new UdpEndpointI(_instance, host, port, _sourceAddr, _mcastInterface, _mcastTtl, _connect, connectionId, + _compress); } IceInternal::UdpEndpointFactory::UdpEndpointFactory(const ProtocolInstancePtr& instance) : _instance(instance) |