summaryrefslogtreecommitdiff
path: root/cpp/src/Ice/SslTransceiver.cpp
diff options
context:
space:
mode:
authorMarc Laukien <marc@zeroc.com>2001-11-21 14:04:20 +0000
committerMarc Laukien <marc@zeroc.com>2001-11-21 14:04:20 +0000
commitde7b946e476e3dbb24ccd0cbb246777ffc776b2a (patch)
tree069c894ad902ce8c8abb7c2d23c74e9dbfbd4719 /cpp/src/Ice/SslTransceiver.cpp
parentSwitched the protocol back to tcp for default. (diff)
downloadice-de7b946e476e3dbb24ccd0cbb246777ffc776b2a.tar.bz2
ice-de7b946e476e3dbb24ccd0cbb246777ffc776b2a.tar.xz
ice-de7b946e476e3dbb24ccd0cbb246777ffc776b2a.zip
fixes
Diffstat (limited to 'cpp/src/Ice/SslTransceiver.cpp')
-rw-r--r--cpp/src/Ice/SslTransceiver.cpp100
1 files changed, 50 insertions, 50 deletions
diff --git a/cpp/src/Ice/SslTransceiver.cpp b/cpp/src/Ice/SslTransceiver.cpp
index 47fc85a627e..03186976538 100644
--- a/cpp/src/Ice/SslTransceiver.cpp
+++ b/cpp/src/Ice/SslTransceiver.cpp
@@ -7,22 +7,22 @@
// All Rights Reserved
//
// **********************************************************************
-
-#include <Ice/Security.h>
-#include <Ice/SslConnection.h>
-#include <Ice/SslTransceiver.h>
+
+#include <Ice/Security.h>
+#include <Ice/SslConnection.h>
+#include <Ice/SslTransceiver.h>
#include <Ice/Instance.h>
#include <Ice/TraceLevels.h>
#include <Ice/Logger.h>
#include <Ice/Buffer.h>
#include <Ice/Network.h>
#include <Ice/Exception.h>
-#include <sstream>
+#include <sstream>
using namespace std;
using namespace Ice;
using namespace IceInternal;
-
+
int
IceInternal::SslTransceiver::fd()
{
@@ -32,8 +32,8 @@ IceInternal::SslTransceiver::fd()
void
IceInternal::SslTransceiver::close()
{
- ICE_METHOD_INV("SslTransceiver::close()");
-
+ ICE_METHOD_INV("SslTransceiver::close()");
+
if (_traceLevels->network >= 1)
{
ostringstream s;
@@ -42,19 +42,19 @@ IceInternal::SslTransceiver::close()
}
int fd = _fd;
- cleanUpSSL();
+ cleanUpSSL();
_fd = INVALID_SOCKET;
::shutdown(fd, SHUT_RDWR); // helps to unblock threads in recv()
closeSocket(fd);
-
- ICE_METHOD_RET("SslTransceiver::close()");
+
+ ICE_METHOD_RET("SslTransceiver::close()");
}
void
IceInternal::SslTransceiver::shutdown()
{
- ICE_METHOD_INV("SslTransceiver::shutdown()");
-
+ ICE_METHOD_INV("SslTransceiver::shutdown()");
+
if (_traceLevels->network >= 2)
{
ostringstream s;
@@ -63,31 +63,31 @@ IceInternal::SslTransceiver::shutdown()
}
::shutdown(_fd, SHUT_WR); // Shutdown socket for writing
-
- ICE_METHOD_RET("SslTransceiver::shutdown()");
+
+ ICE_METHOD_RET("SslTransceiver::shutdown()");
}
void
IceInternal::SslTransceiver::write(Buffer& buf, int timeout)
-{
- ICE_METHOD_INV("SslTransceiver::write()")
- _sslConnection->write(buf, timeout);
- ICE_METHOD_RET("SslTransceiver::write()");
+{
+ ICE_METHOD_INV("SslTransceiver::write()")
+ _sslConnection->write(buf, timeout);
+ ICE_METHOD_RET("SslTransceiver::write()");
}
void
IceInternal::SslTransceiver::read(Buffer& buf, int timeout)
{
- ICE_METHOD_INV("SslTransceiver::read()");
-
- if (!_sslConnection->read(buf, timeout))
- {
- ConnectionLostException clEx(__FILE__, __LINE__);
- clEx.error = 0;
- throw clEx;
- }
-
- ICE_METHOD_RET("SslTransceiver::read()");
+ ICE_METHOD_INV("SslTransceiver::read()");
+
+ if (!_sslConnection->read(buf, timeout))
+ {
+ ConnectionLostException clEx(__FILE__, __LINE__);
+ clEx.error = 0;
+ throw clEx;
+ }
+
+ ICE_METHOD_RET("SslTransceiver::read()");
}
string
@@ -96,15 +96,15 @@ IceInternal::SslTransceiver::toString() const
return fdToString(_fd);
}
-IceInternal::SslTransceiver::SslTransceiver(const InstancePtr& instance, int fd, Connection* sslConnection) :
- _instance(instance),
- _fd(fd),
- _traceLevels(instance->traceLevels()),
- _logger(instance->logger()),
- _sslConnection(sslConnection)
+IceInternal::SslTransceiver::SslTransceiver(const InstancePtr& instance, int fd, Connection* sslConnection) :
+ _instance(instance),
+ _fd(fd),
+ _traceLevels(instance->traceLevels()),
+ _logger(instance->logger()),
+ _sslConnection(sslConnection)
{
- assert(sslConnection != 0);
-
+ assert(sslConnection != 0);
+
FD_ZERO(&_rFdSet);
FD_ZERO(&_wFdSet);
}
@@ -112,17 +112,17 @@ IceInternal::SslTransceiver::SslTransceiver(const InstancePtr& instance, int fd,
IceInternal::SslTransceiver::~SslTransceiver()
{
assert(_fd == INVALID_SOCKET);
-
- cleanUpSSL();
+
+ cleanUpSSL();
+}
+
+void
+IceInternal::SslTransceiver::cleanUpSSL()
+{
+ if (_sslConnection != 0)
+ {
+ _sslConnection->shutdown();
+ delete _sslConnection;
+ _sslConnection = 0;
+ }
}
-
-void
-IceInternal::SslTransceiver::cleanUpSSL()
-{
- if (_sslConnection != 0)
- {
- _sslConnection->shutdown();
- delete _sslConnection;
- _sslConnection = 0;
- }
-}