TAO/tests/POA/Policies/Policies.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file     Policies.cpp
   5  *
   6  *   This program tests the construction of POA policies, both
   7  *   through the generic ORB::create_policy interface and the
   8  *   PortableServer specific interfaces.
   9  *
  10  *  @author  Irfan Pyarali
  11  */
  12 //=============================================================================
  13
  14
  15 #include "tao/ORB.h"
  16 #include "tao/AnyTypeCode/Any.h"
  17 #include "tao/PortableServer/PortableServer.h"
  18 #include "tao/PI_Server/PI_Server.h"
  19
  20 #include "ace/Log_Msg.h"
  21
  22 int
  23 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
  24 {
  25
  26   try
  27     {
  28       // Initialize the ORB first.
  29       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
  30
  31       // Obtain the RootPOA.
  32       CORBA::Object_var obj =
  33         orb->resolve_initial_references ("RootPOA");
  34
  35       // Narrow to POA.
  36       PortableServer::POA_var root_poa =
  37         PortableServer::POA::_narrow (obj.in ());
  38
  39       // Get the POAManager of the POA.
  40       PortableServer::POAManager_var poa_manager =
  41         root_poa->the_POAManager ();
  42
  43       poa_manager->activate ();
  44
  45 #if (TAO_HAS_MINIMUM_POA == 0) && !defined (CORBA_E_COMPACT)
  46
  47       {
  48         PortableServer::ThreadPolicy_var policy1 =
  49           root_poa->create_thread_policy (PortableServer::ORB_CTRL_MODEL);
  50
  51         CORBA::Any policy_value;
  52         policy_value <<= PortableServer::ORB_CTRL_MODEL;
  53
  54         CORBA::Policy_var policy =
  55           orb->create_policy (PortableServer::THREAD_POLICY_ID,
  56                               policy_value);
  57
  58         PortableServer::ThreadPolicy_var policy2 =
  59           PortableServer::ThreadPolicy::_narrow (policy.in ());
  60
  61         ACE_ASSERT (policy1->value () == policy2->value ());
  62       }
  63
  64 #endif /* TAO_HAS_MINIMUM_POA == 0 */
  65
  66       {
  67         PortableServer::LifespanPolicy_var policy1 =
  68           root_poa->create_lifespan_policy (PortableServer::TRANSIENT);
  69
  70         CORBA::Any policy_value;
  71         policy_value <<= PortableServer::TRANSIENT;
  72
  73         CORBA::Policy_var policy =
  74           orb->create_policy (PortableServer::LIFESPAN_POLICY_ID,
  75                               policy_value);
  76
  77         PortableServer::LifespanPolicy_var policy2 =
  78           PortableServer::LifespanPolicy::_narrow (policy.in ());
  79
  80         ACE_ASSERT (policy1->value () == policy2->value ());
  81       }
  82
  83       {
  84         PortableServer::IdUniquenessPolicy_var policy1 =
  85           root_poa->create_id_uniqueness_policy (PortableServer::UNIQUE_ID);
  86
  87         CORBA::Any policy_value;
  88         policy_value <<= PortableServer::UNIQUE_ID;
  89
  90         CORBA::Policy_var policy =
  91           orb->create_policy (PortableServer::ID_UNIQUENESS_POLICY_ID,
  92                               policy_value);
  93
  94         PortableServer::IdUniquenessPolicy_var policy2 =
  95           PortableServer::IdUniquenessPolicy::_narrow (policy.in ());
  96
  97         ACE_ASSERT (policy1->value () == policy2->value ());
  98       }
  99
 100       {
 101         PortableServer::IdAssignmentPolicy_var policy1 =
 102           root_poa->create_id_assignment_policy (PortableServer::USER_ID);
 103
 104         CORBA::Any policy_value;
 105         policy_value <<= PortableServer::USER_ID;
 106
 107         CORBA::Policy_var policy =
 108           orb->create_policy (PortableServer::ID_ASSIGNMENT_POLICY_ID,
 109                               policy_value);
 110
 111         PortableServer::IdAssignmentPolicy_var policy2 =
 112           PortableServer::IdAssignmentPolicy::_narrow (policy.in ());
 113
 114         ACE_ASSERT (policy1->value () == policy2->value ());
 115       }
 116
 117 #if (TAO_HAS_MINIMUM_POA == 0) && !defined (CORBA_E_COMPACT)
 118
 119       {
 120         PortableServer::ImplicitActivationPolicy_var policy1 =
 121           root_poa->create_implicit_activation_policy (PortableServer::IMPLICIT_ACTIVATION);
 122
 123         CORBA::Any policy_value;
 124         policy_value <<= PortableServer::IMPLICIT_ACTIVATION;
 125
 126         CORBA::Policy_var policy =
 127           orb->create_policy (PortableServer::IMPLICIT_ACTIVATION_POLICY_ID,
 128                               policy_value);
 129
 130         PortableServer::ImplicitActivationPolicy_var policy2 =
 131           PortableServer::ImplicitActivationPolicy::_narrow (policy.in ());
 132
 133         ACE_ASSERT (policy1->value () == policy2->value ());
 134       }
 135
 136       {
 137         PortableServer::ServantRetentionPolicy_var policy1 =
 138           root_poa->create_servant_retention_policy (PortableServer::RETAIN);
 139
 140         CORBA::Any policy_value;
 141         policy_value <<= PortableServer::RETAIN;
 142
 143         CORBA::Policy_var policy =
 144           orb->create_policy (PortableServer::SERVANT_RETENTION_POLICY_ID,
 145                               policy_value);
 146
 147         PortableServer::ServantRetentionPolicy_var policy2 =
 148           PortableServer::ServantRetentionPolicy::_narrow (policy.in ());
 149
 150         ACE_ASSERT (policy1->value () == policy2->value ());
 151       }
 152
 153       {
 154         PortableServer::RequestProcessingPolicy_var policy1 =
 155           root_poa->create_request_processing_policy (PortableServer::USE_ACTIVE_OBJECT_MAP_ONLY);
 156
 157         CORBA::Any policy_value;
 158         policy_value <<= PortableServer::USE_ACTIVE_OBJECT_MAP_ONLY;
 159
 160         CORBA::Policy_var policy =
 161           orb->create_policy (PortableServer::REQUEST_PROCESSING_POLICY_ID,
 162                               policy_value);
 163
 164         PortableServer::RequestProcessingPolicy_var policy2 =
 165           PortableServer::RequestProcessingPolicy::_narrow (policy.in ());
 166
 167         ACE_ASSERT (policy1->value () == policy2->value ());
 168       }
 169
 170 #endif /* TAO_HAS_MINIMUM_POA == 0 */
 171
 172       orb->destroy ();
 173
 174       ACE_DEBUG ((LM_DEBUG,
 175                   "%s successful\n",
 176                   argv[0]));
 177     }
 178   catch (const CORBA::Exception& ex)
 179     {
 180       ex._tao_print_exception ("Exception caught");
 181       return -1;
 182     }
 183
 184   return 0;
 185 }