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,
           "$Id: Connect_Strategy.cpp 77641 2007-03-09 13:01:34Z johnnyw $")

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

---