Connect_Strategy.cpp

Go to the documentation of this file.

#include "tao/Connect_Strategy.h"
#include "tao/Transport.h"
#include "tao/Connection_Handler.h"
#include "tao/LF_Multi_Event.h"

ACE_RCSID (tao,
           Connect_Strategy,
           "Connect_Strategy.cpp,v 1.10 2006/04/26 17:12:47 mesnier_p Exp")

TAO_BEGIN_VERSIONED_NAMESPACE_DECL

TAO_Connect_Strategy::TAO_Connect_Strategy (TAO_ORB_Core *orb_core)
  : orb_core_ (orb_core)
{
}


TAO_Connect_Strategy::~TAO_Connect_Strategy (void)
{
}

int
TAO_Connect_Strategy::wait (TAO_Connection_Handler *ch,
                            ACE_Time_Value *max_wait_time)
{
  if (ch == 0)
    return -1;

  return this->wait_i (ch, ch->transport (),max_wait_time);
}

int
TAO_Connect_Strategy::wait (TAO_Transport *t,
                            ACE_Time_Value *max_wait_time)
{
  // Basically the connection was EINPROGRESS, but before we could
  // wait for it some other thread detected a failure and cleaned up
  // the connection handler.
  if (t == 0)
    return -1;

  return this->wait_i (t->connection_handler(),t,max_wait_time);
}

int
TAO_Connect_Strategy::wait (TAO_LF_Multi_Event *mev,
                            ACE_Time_Value *max_wait_time)
{
  return this->wait_i (mev, mev->base_transport(), max_wait_time);
}

int
TAO_Connect_Strategy::poll (TAO_LF_Multi_Event *mev)
{
  ACE_Time_Value zero(ACE_Time_Value::zero);
  return this->wait_i (mev, mev->base_transport(), &zero);
}

TAO_END_VERSIONED_NAMESPACE_DECL

---