TAO/tao/PI_Server/ServerRequestDetails.cpp

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