diff options
Diffstat (limited to 'cpp/src/Ice/TcpConnector.cpp')
-rw-r--r-- | cpp/src/Ice/TcpConnector.cpp | 70 |
1 files changed, 70 insertions, 0 deletions
diff --git a/cpp/src/Ice/TcpConnector.cpp b/cpp/src/Ice/TcpConnector.cpp new file mode 100644 index 00000000000..3e595be4bc4 --- /dev/null +++ b/cpp/src/Ice/TcpConnector.cpp @@ -0,0 +1,70 @@ +// ********************************************************************** +// +// Copyright (c) 2001 +// MutableRealms, Inc. +// Huntsville, AL, USA +// +// All Rights Reserved +// +// ********************************************************************** + +#include <Ice/TcpConnector.h> +#include <Ice/TcpTransceiver.h> +#include <Ice/Instance.h> +#include <Ice/TraceLevels.h> +#include <Ice/Logger.h> +#include <Ice/Network.h> +#include <Ice/LocalException.h> +#include <sstream> + +using namespace std; +using namespace Ice; +using namespace IceInternal; + +TransceiverPtr +IceInternal::TcpConnector::connect(int timeout) +{ +#ifndef ICE_NO_TRACE + if (_traceLevels->network >= 2) + { + ostringstream s; + s << "trying to connect to " << toString(); + _logger->trace(_traceLevels->networkCat, s.str()); + } +#endif + + int fd = createSocket(false); + doConnect(fd, _addr, timeout); + +#ifndef ICE_NO_TRACE + if (_traceLevels->network >= 1) + { + ostringstream s; + s << "connection established\n" << fdToString(fd); + _logger->trace(_traceLevels->networkCat, s.str()); + } +#endif + + return new TcpTransceiver(_instance, fd); +} + +string +IceInternal::TcpConnector::toString() const +{ + return addrToString(_addr); +} + +IceInternal::TcpConnector::TcpConnector(const InstancePtr& instance, const string& host, int port) : + _instance(instance) +{ +#ifndef ICE_NO_TRACE + _traceLevels = _instance->traceLevels(); + _logger = _instance->logger(); +#endif + + getAddress(host.c_str(), port, _addr); +} + +IceInternal::TcpConnector::~TcpConnector() +{ +} |