diff options
Diffstat (limited to 'cpp/src/Ice/TcpTransceiver.cpp')
-rw-r--r-- | cpp/src/Ice/TcpTransceiver.cpp | 37 |
1 files changed, 11 insertions, 26 deletions
diff --git a/cpp/src/Ice/TcpTransceiver.cpp b/cpp/src/Ice/TcpTransceiver.cpp index 6b75ab5f32b..9d7c47d7fda 100644 --- a/cpp/src/Ice/TcpTransceiver.cpp +++ b/cpp/src/Ice/TcpTransceiver.cpp @@ -25,7 +25,7 @@ IceInternal::TcpTransceiver::getNativeInfo() } SocketOperation -IceInternal::TcpTransceiver::initialize(Buffer& readBuffer, Buffer& writeBuffer, bool&) +IceInternal::TcpTransceiver::initialize(Buffer& readBuffer, Buffer& writeBuffer) { return _stream->connect(readBuffer, writeBuffer); } @@ -51,12 +51,12 @@ IceInternal::TcpTransceiver::write(Buffer& buf) } SocketOperation -IceInternal::TcpTransceiver::read(Buffer& buf, bool&) +IceInternal::TcpTransceiver::read(Buffer& buf) { return _stream->read(buf); } -#ifdef ICE_USE_IOCP +#if defined(ICE_USE_IOCP) || defined(ICE_OS_UWP) bool IceInternal::TcpTransceiver::startWrite(Buffer& buf) { @@ -76,7 +76,7 @@ IceInternal::TcpTransceiver::startRead(Buffer& buf) } void -IceInternal::TcpTransceiver::finishRead(Buffer& buf, bool&) +IceInternal::TcpTransceiver::finishRead(Buffer& buf) { _stream->finishRead(buf); } @@ -103,17 +103,13 @@ IceInternal::TcpTransceiver::toDetailedString() const Ice::ConnectionInfoPtr IceInternal::TcpTransceiver::getInfo() const { - TCPConnectionInfoPtr info = new TCPConnectionInfo(); - fillConnectionInfo(info); - return info; -} - -Ice::ConnectionInfoPtr -IceInternal::TcpTransceiver::getWSInfo(const Ice::HeaderDict& headers) const -{ - WSConnectionInfoPtr info = new WSConnectionInfo(); - fillConnectionInfo(info); - info->headers = headers; + TCPConnectionInfoPtr info = ICE_MAKE_SHARED(TCPConnectionInfo); + fdToAddressAndPort(_stream->fd(), info->localAddress, info->localPort, info->remoteAddress, info->remotePort); + if(_stream->fd() != INVALID_SOCKET) + { + info->rcvSize = getRecvBufferSize(_stream->fd()); + info->sndSize = getSendBufferSize(_stream->fd()); + } return info; } @@ -137,14 +133,3 @@ IceInternal::TcpTransceiver::TcpTransceiver(const ProtocolInstancePtr& instance, IceInternal::TcpTransceiver::~TcpTransceiver() { } - -void -IceInternal::TcpTransceiver::fillConnectionInfo(const TCPConnectionInfoPtr& info) const -{ - fdToAddressAndPort(_stream->fd(), info->localAddress, info->localPort, info->remoteAddress, info->remotePort); - if(_stream->fd() != INVALID_SOCKET) - { - info->rcvSize = getRecvBufferSize(_stream->fd()); - info->sndSize = getSendBufferSize(_stream->fd()); - } -} |