TAO/tao/PI/ClientRequestDetails.cpp

   1 #include "tao/PI/ClientRequestDetails.h"
   2 #include "tao/SystemException.h"
   3
   4 #if TAO_HAS_INTERCEPTORS == 1
   5
   6 #if !defined (__ACE_INLINE__)
   7 #include "tao/PI/ClientRequestDetails.inl"
   8 #endif /* defined INLINE */
   9
  10 TAO_BEGIN_VERSIONED_NAMESPACE_DECL
  11
  12 namespace TAO
  13 {
  14   void
  15   ClientRequestDetails::apply_policies (const CORBA::PolicyList &policies)
  16   {
  17     // Flag to check for duplicate ProcessingModePolicy objects in the list.
  18     bool processing_mode_applied = false;
  19
  20     const CORBA::ULong plen = policies.length ();
  21
  22     for (CORBA::ULong i = 0; i < plen; ++i)
  23       {
  24         CORBA::Policy_var policy = CORBA::Policy::_duplicate (policies[i]);
  25
  26         if (CORBA::is_nil (policy.in ()))
  27           {
  28             // Just ignore nil policies...
  29             continue;
  30           }
  31
  32         // Obtain the PolicyType from the current Policy object.
  33         const CORBA::PolicyType policy_type =
  34           policy->policy_type ();
  35
  36         if (policy_type == PortableInterceptor::PROCESSING_MODE_POLICY_TYPE)
  37           {
  38             if (processing_mode_applied)
  39               {
  40                 // This is the second time we have run into this policy type,
  41                 // and that is not allowed.
  42                 throw ::CORBA::INV_POLICY ();
  43               }
  44
  45             // Flip the flag to true in order to trap any dupes.
  46             processing_mode_applied = true;
  47
  48             // Narrow the Policy to the ProcessingModePolicy interface.
  49             PortableInterceptor::ProcessingModePolicy_var pm_policy =
  50                     PortableInterceptor::ProcessingModePolicy::_narrow (
  51                                                  policy.in ());
  52
  53             // Save the value of the ProcessingModePolicy in our data member.
  54             this->processing_mode_ = pm_policy->processing_mode ();
  55           }
  56         else
  57           {
  58             // We don't support the current policy type.
  59             throw ::CORBA::INV_POLICY ();
  60           }
  61       }
  62   }
  63 }
  64
  65 TAO_END_VERSIONED_NAMESPACE_DECL
  66
  67 #endif  /* TAO_HAS_INTERCEPTORS == 1 */