cpp/src/Ice/TcpConnector.cpp

   1 // **********************************************************************
   2 //
   3 // Copyright (c) 2003-2011 ZeroC, Inc. All rights reserved.
   4 //
   5 // This copy of Ice is licensed to you under the terms described in the
   6 // ICE_LICENSE file included in this distribution.
   7 //
   8 // **********************************************************************
   9
  10 #include <Ice/TcpConnector.h>
  11 #include <Ice/TcpTransceiver.h>
  12 #include <Ice/TcpEndpointI.h>
  13 #include <Ice/Instance.h>
  14 #include <Ice/TraceLevels.h>
  15 #include <Ice/LoggerUtil.h>
  16 #include <Ice/Network.h>
  17 #include <Ice/Exception.h>
  18
  19 using namespace std;
  20 using namespace Ice;
  21 using namespace IceInternal;
  22
  23 TransceiverPtr
  24 IceInternal::TcpConnector::connect()
  25 {
  26     if(_traceLevels->network >= 2)
  27     {
  28         Trace out(_logger, _traceLevels->networkCat);
  29         out << "trying to establish tcp connection to " << toString();
  30     }
  31
  32     try
  33     {
  34         TransceiverPtr transceiver = new TcpTransceiver(_instance, createSocket(false, _addr.ss_family), false);
  35         dynamic_cast<TcpTransceiver*>(transceiver.get())->connect(_addr);
  36         return transceiver;
  37     }
  38     catch(const Ice::LocalException& ex)
  39     {
  40         if(_traceLevels->network >= 2)
  41         {
  42             Trace out(_logger, _traceLevels->networkCat);
  43             out << "failed to establish tcp connection to " << toString() << "\n" << ex;
  44         }
  45         throw;
  46     }
  47 }
  48
  49 Short
  50 IceInternal::TcpConnector::type() const
  51 {
  52     return TCPEndpointType;
  53 }
  54
  55 string
  56 IceInternal::TcpConnector::toString() const
  57 {
  58     return addrToString(_addr);
  59 }
  60
  61 bool
  62 IceInternal::TcpConnector::operator==(const Connector& r) const
  63 {
  64     const TcpConnector* p = dynamic_cast<const TcpConnector*>(&r);
  65     if(!p)
  66     {
  67         return false;
  68     }
  69
  70     if(compareAddress(_addr, p->_addr) != 0)
  71     {
  72         return false;
  73     }
  74
  75     if(_timeout != p->_timeout)
  76     {
  77         return false;
  78     }
  79
  80     if(_connectionId != p->_connectionId)
  81     {
  82         return false;
  83     }
  84
  85     return true;
  86 }
  87
  88 bool
  89 IceInternal::TcpConnector::operator!=(const Connector& r) const
  90 {
  91     return !operator==(r);
  92 }
  93
  94 bool
  95 IceInternal::TcpConnector::operator<(const Connector& r) const
  96 {
  97     const TcpConnector* p = dynamic_cast<const TcpConnector*>(&r);
  98     if(!p)
  99     {
 100         return type() < r.type();
 101     }
 102
 103     if(_timeout < p->_timeout)
 104     {
 105         return true;
 106     }
 107     else if(p->_timeout < _timeout)
 108     {
 109         return false;
 110     }
 111
 112     if(_connectionId < p->_connectionId)
 113     {
 114         return true;
 115     }
 116     else if(p->_connectionId < _connectionId)
 117     {
 118         return false;
 119     }
 120     return compareAddress(_addr, p->_addr) == -1;
 121 }
 122
 123 IceInternal::TcpConnector::TcpConnector(const InstancePtr& instance, const struct sockaddr_storage& addr,
 124                                         Ice::Int timeout, const string& connectionId) :
 125     _instance(instance),
 126     _traceLevels(instance->traceLevels()),
 127     _logger(instance->initializationData().logger),
 128     _addr(addr),
 129     _timeout(timeout),
 130     _connectionId(connectionId)
 131 {
 132 }
 133
 134 IceInternal::TcpConnector::~TcpConnector()
 135 {
 136 }