TAO/tao/Connector_Impl.cpp

   1 #ifndef TAO_CONNECTOR_IMPL_CPP
   2 #define TAO_CONNECTOR_IMPL_CPP
   3
   4 #include "tao/Connector_Impl.h"
   5 #include "tao/Transport.h"
   6 #include "tao/ORB_Core.h"
   7
   8 #if !defined (ACE_LACKS_PRAGMA_ONCE)
   9 # pragma once
  10 #endif /* ACE_LACKS_PRAGMA_ONCE */
  11
  12 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  13
  14 template <class SVC_HANDLER>
  15 TAO_Connect_Creation_Strategy<SVC_HANDLER>::
  16     TAO_Connect_Creation_Strategy (ACE_Thread_Manager* t,
  17                                    TAO_ORB_Core *orb_core)
  18     : ACE_Creation_Strategy <SVC_HANDLER> (t, orb_core->reactor ()),
  19       orb_core_ (orb_core)
  20 {
  21 }
  22
  23 template <class SVC_HANDLER> int
  24 TAO_Connect_Creation_Strategy<SVC_HANDLER>::make_svc_handler (SVC_HANDLER *&sh)
  25 {
  26   if (sh == 0)
  27     ACE_NEW_RETURN (sh,
  28                     SVC_HANDLER (this->orb_core_),
  29                     -1);
  30
  31   sh->transport ()->opened_as (TAO::TAO_CLIENT_ROLE);
  32
  33   // At this point, the #REFCOUNT# is one.
  34
  35   return 0;
  36 }
  37
  38
  39 ////////////////////////////////////////////////////////////////
  40
  41 template <class SVC_HANDLER>
  42 TAO_Connect_Concurrency_Strategy<SVC_HANDLER>::
  43     TAO_Connect_Concurrency_Strategy (TAO_ORB_Core *orb_core)
  44     : orb_core_ (orb_core)
  45 {
  46 }
  47
  48 template <class SVC_HANDLER> int
  49 TAO_Connect_Concurrency_Strategy<SVC_HANDLER>::
  50     activate_svc_handler (SVC_HANDLER *sh, void *arg)
  51 {
  52   return ACE_Concurrency_Strategy<SVC_HANDLER>::activate_svc_handler (sh, arg);
  53 }
  54
  55 TAO_END_VERSIONED_NAMESPACE_DECL
  56
  57 #endif  /* TAO_CONNECTOR_IMPL_CPP */