TAO/tao/RTPortableServer/RT_POA.inl

   1 // -*- C++ -*-
   2 // Exception macros
   3 #include "tao/PortableServer/poa_macros.h"
   4 #include "tao/PortableServer/POA_Guard.h"
   5
   6 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
   7
   8 ACE_INLINE CORBA::Object_ptr
   9 TAO_RT_POA::create_reference_with_priority (const char * intf,
  10                                             RTCORBA::Priority priority)
  11 {
  12   // Check that this method can be used based on this POA's policies.
  13   this->validate_policies ();
  14
  15   this->validate_priority (priority);
  16
  17   // Lock access for the duration of this transaction.
  18   TAO_POA_GUARD_RETURN (0);
  19
  20   return this->create_reference_i (intf, priority);
  21 }
  22
  23 #if !defined (CORBA_E_MICRO)
  24 ACE_INLINE CORBA::Object_ptr
  25 TAO_RT_POA::create_reference_with_id_and_priority (const PortableServer::ObjectId & oid,
  26                                                    const char * intf,
  27                                                    RTCORBA::Priority priority)
  28 {
  29   // Check that this method can be used based on this POA's policies.
  30   this->validate_policies ();
  31
  32   this->validate_priority (priority);
  33
  34   // Lock access for the duration of this transaction.
  35   TAO_POA_GUARD_RETURN (0);
  36
  37   return this->create_reference_with_id_i (oid, intf, priority);
  38 }
  39 #endif
  40
  41 ACE_INLINE PortableServer::ObjectId *
  42 TAO_RT_POA::activate_object_with_priority (PortableServer::Servant servant,
  43                                            RTCORBA::Priority priority)
  44 {
  45   // Check that this method can be used based on this POA's policies.
  46   this->validate_policies ();
  47
  48   this->validate_priority (priority);
  49
  50   while (true)
  51     {
  52       bool wait_occurred_restart_call = false;
  53
  54       // Lock access for the duration of this transaction.
  55       TAO_POA_GUARD_RETURN (0);
  56
  57       PortableServer::ObjectId *result =
  58         this->activate_object_i (servant, priority, wait_occurred_restart_call);
  59
  60       // If we ended up waiting on a condition variable, the POA state
  61       // may have changed while we are waiting.  Therefore, we need to
  62       // restart this call.
  63       if (wait_occurred_restart_call)
  64         continue;
  65       else
  66         return result;
  67     }
  68 }
  69
  70 #if !defined (CORBA_E_MICRO)
  71 ACE_INLINE void
  72 TAO_RT_POA::activate_object_with_id_and_priority (const PortableServer::ObjectId & oid,
  73                                                   PortableServer::Servant servant,
  74                                                   RTCORBA::Priority priority)
  75 {
  76   // Check that this method can be used based on this POA's policies.
  77   this->validate_policies ();
  78
  79   this->validate_priority (priority);
  80
  81   while (true)
  82     {
  83       bool wait_occurred_restart_call = false;
  84
  85       // Lock access for the duration of this transaction.
  86       TAO_POA_GUARD;
  87
  88       this->activate_object_with_id_i (oid,
  89                                        servant,
  90                                        priority,
  91                                        wait_occurred_restart_call);
  92
  93       // If we ended up waiting on a condition variable, the POA state
  94       // may have changed while we are waiting.  Therefore, we need to
  95       // restart this call.
  96       if (wait_occurred_restart_call)
  97         continue;
  98       else
  99         return;
 100     }
 101 }
 102 #endif
 103
 104 ACE_INLINE void *
 105 TAO_RT_POA::thread_pool () const
 106 {
 107   return this->thread_pool_;
 108 }
 109
 110 TAO_END_VERSIONED_NAMESPACE_DECL