diff options
author | Marc Laukien <marc@zeroc.com> | 2001-09-20 00:30:22 +0000 |
---|---|---|
committer | Marc Laukien <marc@zeroc.com> | 2001-09-20 00:30:22 +0000 |
commit | 8095535e370cd550e0ae51e80a4d901fd61430a9 (patch) | |
tree | e36fbbba41d556547bf6d8c265db2c50262486a0 /cpp/src/Ice/SslTransceiver.cpp | |
parent | simplified demo (diff) | |
download | ice-8095535e370cd550e0ae51e80a4d901fd61430a9.tar.bz2 ice-8095535e370cd550e0ae51e80a4d901fd61430a9.tar.xz ice-8095535e370cd550e0ae51e80a4d901fd61430a9.zip |
fixes
Diffstat (limited to 'cpp/src/Ice/SslTransceiver.cpp')
-rw-r--r-- | cpp/src/Ice/SslTransceiver.cpp | 33 |
1 files changed, 11 insertions, 22 deletions
diff --git a/cpp/src/Ice/SslTransceiver.cpp b/cpp/src/Ice/SslTransceiver.cpp index 90a0fac7bce..93920d5ea81 100644 --- a/cpp/src/Ice/SslTransceiver.cpp +++ b/cpp/src/Ice/SslTransceiver.cpp @@ -30,14 +30,12 @@ IceInternal::SslTransceiver::fd() void IceInternal::SslTransceiver::close() { -#ifndef ICE_NO_TRACE if (_traceLevels->network >= 1) { ostringstream s; s << "closing ssl connection\n" << toString(); _logger->trace(_traceLevels->networkCat, s.str()); } -#endif int fd = _fd; _fd = INVALID_SOCKET; @@ -48,14 +46,12 @@ IceInternal::SslTransceiver::close() void IceInternal::SslTransceiver::shutdown() { -#ifndef ICE_NO_TRACE if (_traceLevels->network >= 2) { ostringstream s; s << "shutting down ssl connection\n" << toString(); _logger->trace(_traceLevels->networkCat, s.str()); } -#endif ::shutdown(_fd, SHUT_WR); // Shutdown socket for writing } @@ -109,17 +105,17 @@ IceInternal::SslTransceiver::write(Buffer& buf, int timeout) { repeatSelect: int ret; - FD_SET(fd, &wFdSet); + FD_SET(fd, &_wFdSet); if (timeout >= 0) { struct timeval tv; tv.tv_sec = timeout / 1000; tv.tv_usec = (timeout - tv.tv_sec * 1000) * 1000; - ret = ::select(fd + 1, 0, &wFdSet, 0, &tv); + ret = ::select(fd + 1, 0, &_wFdSet, 0, &tv); } else { - ret = ::select(fd + 1, 0, &wFdSet, 0, 0); + ret = ::select(fd + 1, 0, &_wFdSet, 0, 0); } if (ret == SOCKET_ERROR) @@ -151,14 +147,12 @@ IceInternal::SslTransceiver::write(Buffer& buf, int timeout) } } -#ifndef ICE_NO_TRACE if (_traceLevels->network >= 3) { ostringstream s; s << "sent " << ret << " of " << packetSize << " bytes via ssl\n" << toString(); _logger->trace(_traceLevels->networkCat, s.str()); } -#endif buf.i += ret; @@ -208,17 +202,17 @@ IceInternal::SslTransceiver::read(Buffer& buf, int timeout) { repeatSelect: int ret; - FD_SET(fd, &rFdSet); + FD_SET(fd, &_rFdSet); if (timeout >= 0) { struct timeval tv; tv.tv_sec = timeout / 1000; tv.tv_usec = (timeout - tv.tv_sec * 1000) * 1000; - ret = ::select(fd + 1, &rFdSet, 0, 0, &tv); + ret = ::select(fd + 1, &_rFdSet, 0, 0, &tv); } else { - ret = ::select(fd + 1, &rFdSet, 0, 0, 0); + ret = ::select(fd + 1, &_rFdSet, 0, 0, 0); } if (ret == SOCKET_ERROR) @@ -250,14 +244,12 @@ IceInternal::SslTransceiver::read(Buffer& buf, int timeout) } } -#ifndef ICE_NO_TRACE if (_traceLevels->network >= 3) { ostringstream s; s << "received " << ret << " of " << packetSize << " bytes via ssl\n" << toString(); _logger->trace(_traceLevels->networkCat, s.str()); } -#endif buf.i += ret; @@ -276,15 +268,12 @@ IceInternal::SslTransceiver::toString() const IceInternal::SslTransceiver::SslTransceiver(const InstancePtr& instance, int fd) : _instance(instance), - _fd(fd) + _fd(fd), + _traceLevels(instance->traceLevels()), + _logger(instance->logger()) { - FD_ZERO(&rFdSet); - FD_ZERO(&wFdSet); - -#ifndef ICE_NO_TRACE - _traceLevels = _instance->traceLevels(); - _logger = _instance->logger(); -#endif + FD_ZERO(&_rFdSet); + FD_ZERO(&_wFdSet); } IceInternal::SslTransceiver::~SslTransceiver() |