TAO/tests/POA/Identity/Identity.cpp

   1
   2 //=============================================================================
   3 /**
   4  *  @file    Identity.cpp
   5  *
   6  *  This program demonstrates and tests how to move between id,
   7  *  reference, and servants.
   8  *
   9  *  @author Irfan Pyarali
  10  */
  11 //=============================================================================
  12
  13
  14 #include "testS.h"
  15 #include "tao/ORB_Core.h"
  16 #include "tao/Server_Strategy_Factory.h"
  17
  18 class test_i : public POA_test
  19 {
  20 public:
  21   test_i (PortableServer::POA_ptr poa)
  22     : poa_ (PortableServer::POA::_duplicate (poa))
  23     {
  24     }
  25
  26   PortableServer::POA_ptr _default_POA ()
  27     {
  28       return PortableServer::POA::_duplicate (this->poa_.in ());
  29     }
  30
  31 protected:
  32   PortableServer::POA_var poa_;
  33 };
  34
  35 void
  36 create_poas (PortableServer::POA_ptr root_poa,
  37              PortableServer::LifespanPolicyValue lifespan_policy,
  38              PortableServer::POA_out first_poa,
  39              PortableServer::POA_out second_poa,
  40              PortableServer::POA_out third_poa,
  41              PortableServer::POA_out forth_poa)
  42 {
  43   // Policies for the new POAs
  44   CORBA::PolicyList policies (3);
  45   policies.length (3);
  46
  47   policies[0] = root_poa->create_lifespan_policy (lifespan_policy);
  48
  49   policies[1] = root_poa->create_id_uniqueness_policy (PortableServer::MULTIPLE_ID);
  50
  51   policies[2] = root_poa->create_id_assignment_policy (PortableServer::SYSTEM_ID);
  52
  53   // Creation of the firstPOA
  54   ACE_CString name = "firstPOA";
  55   first_poa = root_poa->create_POA (name.c_str (),
  56                                     PortableServer::POAManager::_nil (),
  57                                     policies);
  58
  59   policies[1]->destroy ();
  60
  61   policies[1] = root_poa->create_id_uniqueness_policy (PortableServer::UNIQUE_ID);
  62
  63   // Creation of the secondPOA
  64   name = "secondPOA";
  65   second_poa = root_poa->create_POA (name.c_str (),
  66                                      PortableServer::POAManager::_nil (),
  67                                      policies);
  68
  69   policies[2]->destroy ();
  70
  71   policies[2] = root_poa->create_id_assignment_policy (PortableServer::USER_ID);
  72
  73   // Creation of the thirdPOA
  74   name = "thirdPOA";
  75   third_poa = root_poa->create_POA (name.c_str (),
  76                                     PortableServer::POAManager::_nil (),
  77                                     policies);
  78
  79   policies[1]->destroy ();
  80
  81   policies[1] = root_poa->create_id_uniqueness_policy (PortableServer::MULTIPLE_ID);
  82
  83   // Creation of the forthPOA
  84   name = "forthPOA";
  85   forth_poa = root_poa->create_POA (name.c_str (),
  86                                     PortableServer::POAManager::_nil (),
  87                                     policies);
  88
  89   // Creation of the new POAs over, so destroy the policies
  90   for (CORBA::ULong i = 0;
  91        i < policies.length ();
  92        ++i)
  93     {
  94       policies[i]->destroy ();
  95     }
  96 }
  97
  98 void
  99 test_poas (CORBA::ORB_ptr orb,
 100            PortableServer::POA_ptr root_poa,
 101            PortableServer::POA_ptr first_poa,
 102            PortableServer::POA_ptr second_poa,
 103            PortableServer::POA_ptr third_poa,
 104            PortableServer::POA_ptr forth_poa,
 105            int perform_deactivation_test)
 106 {
 107   {
 108     test_i servant (root_poa);
 109
 110     CORBA::Object_var obj = root_poa->create_reference ("IDL:test:1.0");
 111
 112     CORBA::String_var string = orb->object_to_string (obj.in ());
 113
 114     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 115
 116     PortableServer::ObjectId_var id = root_poa->reference_to_id (obj.in ());
 117
 118     root_poa->activate_object_with_id (id.in (),
 119                                        &servant);
 120
 121     obj = root_poa->id_to_reference (id.in ());
 122
 123     string = orb->object_to_string (obj.in ());
 124
 125     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 126
 127     PortableServer::ServantBase_var servant_from_reference =
 128       root_poa->reference_to_servant (obj.in ());
 129
 130     PortableServer::ServantBase_var servant_from_id =
 131       root_poa->id_to_servant (id.in ());
 132
 133     if (servant_from_reference.in () != servant_from_id.in ()
 134         || servant_from_reference.in () != &servant)
 135       {
 136         ACE_ERROR ((LM_ERROR,
 137                     "Mismatched servant_from_reference, "
 138                     "servant_from_id and &servant\n"));
 139       }
 140
 141     obj = root_poa->servant_to_reference (&servant);
 142
 143     string = orb->object_to_string (obj.in ());
 144
 145     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 146
 147     obj = servant._this ();
 148
 149     string = orb->object_to_string (obj.in ());
 150
 151     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 152
 153     PortableServer::ObjectId_var id_from_servant = root_poa->servant_to_id (&servant);
 154
 155     ACE_ASSERT (id_from_servant.in () == id.in ());
 156
 157     root_poa->deactivate_object (id.in ());
 158
 159     if (perform_deactivation_test)
 160       {
 161         root_poa->activate_object_with_id (id.in (),
 162                                            &servant);
 163
 164         servant_from_reference = root_poa->reference_to_servant (obj.in ());
 165
 166         ACE_ASSERT (servant_from_reference.in () == &servant);
 167
 168         root_poa->deactivate_object (id.in ());
 169       }
 170   }
 171
 172   {
 173     test_i servant (root_poa);
 174
 175     PortableServer::ObjectId_var id = root_poa->activate_object (&servant);
 176
 177     CORBA::Object_var obj = root_poa->id_to_reference (id.in ());
 178
 179     CORBA::String_var string = orb->object_to_string (obj.in ());
 180
 181     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 182
 183     obj = root_poa->create_reference_with_id (id.in (),
 184                                               "IDL:test:1.0");
 185
 186     string = orb->object_to_string (obj.in ());
 187
 188     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 189
 190     root_poa->deactivate_object (id.in ());
 191   }
 192
 193   {
 194     test_i servant (first_poa);
 195
 196     CORBA::Object_var obj = first_poa->create_reference ("IDL:test:1.0");
 197
 198     CORBA::String_var string = orb->object_to_string (obj.in ());
 199
 200     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 201
 202     PortableServer::ObjectId_var id = first_poa->reference_to_id (obj.in ());
 203
 204     first_poa->activate_object_with_id (id.in (),
 205                                         &servant);
 206
 207     obj = first_poa->id_to_reference (id.in ());
 208
 209     string = orb->object_to_string (obj.in ());
 210
 211     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 212
 213     PortableServer::ServantBase_var servant_from_reference =
 214       first_poa->reference_to_servant (obj.in ());
 215
 216     PortableServer::ServantBase_var servant_from_id =
 217       first_poa->id_to_servant (id.in ());
 218
 219     if (servant_from_reference .in () != servant_from_id.in ()
 220         || servant_from_reference.in () != &servant)
 221       {
 222         ACE_ERROR ((LM_ERROR,
 223                     "Mismatched servant_from_reference, "
 224                     "servant_from_id and &servant\n"));
 225       }
 226
 227     first_poa->deactivate_object (id.in ());
 228
 229     if (perform_deactivation_test)
 230       {
 231         first_poa->activate_object_with_id (id.in (),
 232                                             &servant);
 233
 234         servant_from_reference = first_poa->reference_to_servant (obj.in ());
 235
 236         ACE_ASSERT (servant_from_reference.in () == &servant);
 237
 238         first_poa->deactivate_object (id.in ());
 239       }
 240   }
 241
 242   {
 243     test_i servant (first_poa);
 244
 245     PortableServer::ObjectId_var id = first_poa->activate_object (&servant);
 246
 247     CORBA::Object_var obj = first_poa->id_to_reference (id.in ());
 248
 249     CORBA::String_var string = orb->object_to_string (obj.in ());
 250
 251     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 252
 253     obj = first_poa->create_reference_with_id (id.in (),
 254                                                "IDL:test:1.0");
 255
 256     string = orb->object_to_string (obj.in ());
 257
 258     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 259
 260     first_poa->deactivate_object (id.in ());
 261   }
 262
 263   {
 264     test_i servant (second_poa);
 265
 266     CORBA::Object_var obj = second_poa->create_reference ("IDL:test:1.0");
 267
 268     CORBA::String_var string = orb->object_to_string (obj.in ());
 269
 270     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 271
 272     PortableServer::ObjectId_var id = second_poa->reference_to_id (obj.in ());
 273
 274     second_poa->activate_object_with_id (id.in (),
 275                                          &servant);
 276
 277     obj = second_poa->id_to_reference (id.in ());
 278
 279     string = orb->object_to_string (obj.in ());
 280
 281     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 282
 283     PortableServer::ServantBase_var servant_from_reference =
 284       second_poa->reference_to_servant (obj.in ());
 285
 286     PortableServer::ServantBase_var servant_from_id =
 287       second_poa->id_to_servant (id.in ());
 288
 289     if (servant_from_reference.in () != servant_from_id.in ()
 290         || servant_from_reference.in () != &servant)
 291       {
 292         ACE_ERROR ((LM_ERROR,
 293                     "Mismatched servant_from_reference, "
 294                     "servant_from_id and &servant\n"));
 295       }
 296
 297     obj = second_poa->servant_to_reference (&servant);
 298
 299     string = orb->object_to_string (obj.in ());
 300
 301     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 302
 303     obj = servant._this ();
 304
 305     string = orb->object_to_string (obj.in ());
 306
 307     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 308
 309     PortableServer::ObjectId_var id_from_servant = second_poa->servant_to_id (&servant);
 310
 311     ACE_ASSERT (id_from_servant.in () == id.in ());
 312
 313     second_poa->deactivate_object (id.in ());
 314
 315     if (perform_deactivation_test)
 316       {
 317         second_poa->activate_object_with_id (id.in (),
 318                                              &servant);
 319
 320         servant_from_reference = second_poa->reference_to_servant (obj.in ());
 321
 322         ACE_ASSERT (servant_from_reference.in () == &servant);
 323
 324         second_poa->deactivate_object (id.in ());
 325       }
 326   }
 327
 328   {
 329     test_i servant (second_poa);
 330
 331     PortableServer::ObjectId_var id = second_poa->activate_object (&servant);
 332
 333     CORBA::Object_var obj = second_poa->id_to_reference (id.in ());
 334
 335     CORBA::String_var string = orb->object_to_string (obj.in ());
 336
 337     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 338
 339     obj = second_poa->create_reference_with_id (id.in (),
 340                                                 "IDL:test:1.0");
 341
 342     string = orb->object_to_string (obj.in ());
 343
 344     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 345
 346     second_poa->deactivate_object (id.in ());
 347   }
 348
 349   {
 350     test_i servant (third_poa);
 351     PortableServer::ObjectId_var id = PortableServer::string_to_ObjectId ("hello");
 352
 353     CORBA::Object_var obj = third_poa->create_reference_with_id (id.in (),
 354                                                                  "IDL:test:1.0");
 355
 356     CORBA::String_var string = orb->object_to_string (obj.in ());
 357
 358     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 359
 360     PortableServer::ObjectId_var id_from_reference = third_poa->reference_to_id (obj.in ());
 361
 362     string = PortableServer::ObjectId_to_string (id_from_reference.in ());
 363     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 364
 365     ACE_ASSERT (id_from_reference.in () == id.in ());
 366
 367     third_poa->activate_object_with_id (id.in (),
 368                                         &servant);
 369
 370     obj = third_poa->id_to_reference (id.in ());
 371
 372     string = orb->object_to_string (obj.in ());
 373
 374     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 375
 376     PortableServer::ServantBase_var servant_from_reference =
 377       third_poa->reference_to_servant (obj.in ());
 378
 379     PortableServer::ServantBase_var servant_from_id =
 380       third_poa->id_to_servant (id.in ());
 381
 382     if (servant_from_reference.in () != servant_from_id.in ()
 383         || servant_from_reference.in () != &servant)
 384       {
 385         ACE_ERROR ((LM_ERROR,
 386                     "Mismatched servant_from_reference, "
 387                     "servant_from_id and &servant\n"));
 388       }
 389
 390     obj = third_poa->servant_to_reference (&servant);
 391
 392     string = orb->object_to_string (obj.in ());
 393
 394     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 395
 396     obj = servant._this ();
 397
 398     string = orb->object_to_string (obj.in ());
 399
 400     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 401
 402     PortableServer::ObjectId_var id_from_servant = third_poa->servant_to_id (&servant);
 403
 404     string = PortableServer::ObjectId_to_string (id_from_servant.in ());
 405     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 406
 407     ACE_ASSERT (id_from_servant.in () == id.in ());
 408
 409     third_poa->deactivate_object (id.in ());
 410
 411     if (perform_deactivation_test)
 412       {
 413         third_poa->activate_object_with_id (id.in (),
 414                                             &servant);
 415
 416         servant_from_reference = third_poa->reference_to_servant (obj.in ());
 417
 418         ACE_ASSERT (servant_from_reference.in () == &servant);
 419
 420         third_poa->deactivate_object (id.in ());
 421       }
 422   }
 423
 424   {
 425     test_i servant (forth_poa);
 426     PortableServer::ObjectId_var id = PortableServer::string_to_ObjectId ("hello");
 427
 428     CORBA::Object_var obj = forth_poa->create_reference_with_id (id.in (),
 429                                                                  "IDL:test:1.0");
 430
 431     CORBA::String_var string = orb->object_to_string (obj.in ());
 432
 433     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 434
 435     PortableServer::ObjectId_var id_from_reference = forth_poa->reference_to_id (obj.in ());
 436
 437     string = PortableServer::ObjectId_to_string (id_from_reference.in ());
 438     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 439
 440     ACE_ASSERT (id_from_reference.in () == id.in ());
 441
 442     forth_poa->activate_object_with_id (id.in (),
 443                                         &servant);
 444
 445     obj = forth_poa->id_to_reference (id.in ());
 446
 447     string = orb->object_to_string (obj.in ());
 448
 449     ACE_DEBUG ((LM_DEBUG, "%C\n", string.in ()));
 450
 451     PortableServer::ServantBase_var servant_from_reference =
 452       forth_poa->reference_to_servant (obj.in ());
 453
 454     PortableServer::ServantBase_var servant_from_id =
 455       forth_poa->id_to_servant (id.in ());
 456
 457     if (servant_from_reference.in () != servant_from_id.in ()
 458         || servant_from_reference.in () != &servant)
 459       {
 460         ACE_ERROR ((LM_ERROR,
 461                     "Mismatched servant_from_reference, "
 462                     "servant_from_id and &servant\n"));
 463       }
 464
 465     forth_poa->deactivate_object (id.in ());
 466
 467     if (perform_deactivation_test)
 468       {
 469         forth_poa->activate_object_with_id (id.in (),
 470                                             &servant);
 471
 472         servant_from_reference = forth_poa->reference_to_servant (obj.in ());
 473
 474         ACE_ASSERT (servant_from_reference.in () == &servant);
 475
 476         forth_poa->deactivate_object (id.in ());
 477       }
 478   }
 479 }
 480
 481 int
 482 ACE_TMAIN(int argc, ACE_TCHAR *argv[])
 483 {
 484   try
 485     {
 486       CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
 487
 488       // Obtain the RootPOA.
 489       CORBA::Object_var obj =
 490         orb->resolve_initial_references ("RootPOA");
 491
 492       PortableServer::POA_var root_poa = PortableServer::POA::_narrow (obj.in ());
 493
 494       const TAO_Server_Strategy_Factory::Active_Object_Map_Creation_Parameters &creation_parameters
 495         = TAO_ORB_Core_instance ()->server_factory ()->active_object_map_creation_parameters ();
 496
 497       int perform_deactivation_test = creation_parameters.allow_reactivation_of_system_ids_;
 498
 499       PortableServer::POA_var first_poa;
 500       PortableServer::POA_var second_poa;
 501       PortableServer::POA_var third_poa;
 502       PortableServer::POA_var forth_poa;
 503
 504       create_poas (root_poa.in (),
 505                    PortableServer::TRANSIENT,
 506                    first_poa.out (),
 507                    second_poa.out (),
 508                    third_poa.out (),
 509                    forth_poa.out ());
 510
 511       test_poas (orb.in (),
 512                  root_poa.in (),
 513                  first_poa.in (),
 514                  second_poa.in (),
 515                  third_poa.in (),
 516                  forth_poa.in (),
 517                  perform_deactivation_test);
 518
 519       first_poa->destroy (1,
 520                           1);
 521
 522       second_poa->destroy (1,
 523                            1);
 524
 525       third_poa->destroy (1,
 526                           1);
 527
 528       forth_poa->destroy (1,
 529                           1);
 530
 531       create_poas (root_poa.in (),
 532                    PortableServer::PERSISTENT,
 533                    first_poa.out (),
 534                    second_poa.out (),
 535                    third_poa.out (),
 536                    forth_poa.out ());
 537
 538       test_poas (orb.in (),
 539                  root_poa.in (),
 540                  first_poa.in (),
 541                  second_poa.in (),
 542                  third_poa.in (),
 543                  forth_poa.in (),
 544                  perform_deactivation_test);
 545
 546       root_poa->destroy (true, true);
 547
 548       orb->destroy ();
 549     }
 550   catch (const CORBA::Exception& ex)
 551     {
 552       ex._tao_print_exception ("Exception!");
 553       return -1;
 554     }
 555
 556   return 0;
 557 }