//============================================================================= /** * @file client.cpp * * $Id$ * * This class implements a simple CORBA client for the CosNaming * example using stubs generated by the TAO ORB IDL compiler. * * * @author Sergio Flores-Gaitan * @author Marina Spivak * @author and Douglas C. Schmidt */ //============================================================================= #include "client.h" #include "tao/debug.h" #include "ace/Get_Opt.h" #if defined (_MSC_VER) # pragma warning (disable : 4250) #endif /* _MSC_VER */ class My_Test_Object : public virtual POA_Test_Object { public: // = Initialization and termination methods. /// Constructor. My_Test_Object (CORBA::Short id = 0); /// Destructor. ~My_Test_Object (void); // = Interface implementation accessor methods. /// Sets id. void id (CORBA::Short id); /// Gets id. CORBA::Short id (void); private: short id_; }; My_Test_Object::My_Test_Object (CORBA::Short id) : id_ (id) { } My_Test_Object::~My_Test_Object (void) { } CORBA::Short My_Test_Object::id (void) { return id_; } void My_Test_Object::id (CORBA::Short id) { id_ = id; } // Constructor. CosNaming_Client::CosNaming_Client (void) : argc_ (0), argv_ (0), test_ (0) { } // Parses the command line arguments and returns an error status. int CosNaming_Client::parse_args (void) { ACE_Get_Opt get_opts (argc_, argv_, ACE_TEXT("p:dstieym:c:l")); int c; while ((c = get_opts ()) != -1) switch (c) { case 'd': // debug flag TAO_debug_level++; break; case 's': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Simple_Test (this->orbmgr_.root_poa ()), -1); break; case 'm': if (this->test_ == 0) { int size = ACE_OS::atoi (get_opts.opt_arg ()); if (size <= 0) size = 10; ACE_NEW_RETURN (this->test_, MT_Test (this->orbmgr_.orb (), this->orbmgr_.root_poa (), size), -1); } break; case 't': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Tree_Test (this->orbmgr_.root_poa ()), -1); break; case 'i': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Iterator_Test (this->orbmgr_.root_poa ()), -1); break; case 'e': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Exceptions_Test (this->orbmgr_.root_poa ()), -1); break; case 'y': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Destroy_Test (this->orbmgr_.root_poa ()), -1); break; case 'p': if (this->test_ == 0) { FILE * ior_output_file = ACE_OS::fopen (get_opts.opt_arg (), "w"); if (ior_output_file == 0) ACE_ERROR_RETURN ((LM_ERROR, "Unable to open %s for writing: %p\n", get_opts.opt_arg ()), -1); ACE_NEW_RETURN (this->test_, Persistent_Test_Begin (this->orbmgr_.orb (), this->orbmgr_.root_poa (), ior_output_file), -1); } break; case 'c': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Persistent_Test_End (this->orbmgr_.orb (), this->orbmgr_.root_poa (), get_opts.opt_arg ()), -1); break; case 'l': if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Persistent_List_Test (this->orbmgr_.orb (), this->orbmgr_.root_poa ()), -1); break; default: ACE_ERROR_RETURN ((LM_ERROR, "Argument %c \n usage: %s" " [-d]" " [-s or -e or -t or -i or -y or -p or -c or -l or -m]" "\n", c, this->argv_ [0]), -1); } if (this->test_ == 0) ACE_NEW_RETURN (this->test_, Simple_Test (this->orbmgr_.root_poa ()), -1); // Indicates successful parsing of command line. return 0; } // Execute client example code. int CosNaming_Client::run (void) { return test_->execute (naming_client_); } CosNaming_Client::~CosNaming_Client (void) { delete test_; } int CosNaming_Client::init (int argc, ACE_TCHAR **argv) { this->argc_ = argc; this->argv_ = argv; try { // Initialize ORB. this->orbmgr_.init (this->argc_, this->argv_); this->orbmgr_.activate_poa_manager (); // Parse command line and verify parameters. if (this->parse_args () == -1) return -1; CORBA::ORB_var orb = this->orbmgr_.orb (); return this->naming_client_.init (orb.in ()); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ("init"); // and return -1 below . . . } return -1; } Naming_Test::Naming_Test (PortableServer::POA_ptr poa) : poa_ (poa) { } Naming_Test::~Naming_Test (void) { } MT_Test::MT_Test (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa, int size) : Naming_Test (poa), size_ (size), orb_ (orb), name_service_ior_ () { } int MT_Test::svc (void) { // Obtain object reference to the Naming Service (create new stub.) CosNaming::NamingContext_var name_service; try { CORBA::Object_var name_service_obj = orb_->string_to_object (name_service_ior_.in ()); name_service = CosNaming::NamingContext::_narrow (name_service_obj.in ()); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in MT test setup"); return -1; } if (name_service.in () == 0) { ACE_ERROR ((LM_ERROR, "ERROR: Unable to narrow naming IOR to a NamingContext.\n")); return -1; } // Bind the object. try { name_service->bind (test_name_, test_ref_.in ()); ACE_DEBUG ((LM_DEBUG, "Bound name OK in thread %t\n")); } catch (const CosNaming::NamingContext::AlreadyBound&) { ACE_DEBUG ((LM_DEBUG, "Unable to bind in thread %t\n")); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in MT test bind"); // This debug statement works around a IRIX/MIPSPro 7.3 bug (it // fails with optimize=1 debug=0; but works with any other // settings for those flags). ACE_DEBUG ((LM_DEBUG, "MT_Test(%t) - bind[3] %d\n", test_name_.length ())); return -1; } // Resolve the object from the Naming Context. try { CORBA::Object_var result_obj_ref = name_service->resolve (test_name_); Test_Object_var result_object = Test_Object::_narrow (result_obj_ref.in ()); if (!CORBA::is_nil (result_object.in ())) { CORBA::Short id = result_object->id (); if (id == CosNaming_Client::OBJ1_ID) ACE_DEBUG ((LM_DEBUG, "Resolved name OK in thread %t\n")); } } catch (const CosNaming::NamingContext::NotFound&) { ACE_DEBUG ((LM_DEBUG, "Unable to resolve in thread %t\n")); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in MT test resolve"); return -1; } // Unbind the object from the Naming Context. try { name_service->unbind (test_name_); ACE_DEBUG ((LM_DEBUG, "Unbound name OK in thread %t\n")); } catch (const CosNaming::NamingContext::NotFound&) { ACE_DEBUG ((LM_DEBUG, "Unable to unbind in thread %t\n")); return -1; } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in MT test unbind"); return -1; } return 0; } int MT_Test::execute (TAO_Naming_Client &root_context) { if (CORBA::is_nil (this->orb_.in ())) return -1; // Create data which will be used by all threads. // Dummy object instantiation. My_Test_Object *test_obj_impl = new My_Test_Object (CosNaming_Client::OBJ1_ID); try { PortableServer::ObjectId_var id_act = this->poa_->activate_object (test_obj_impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); test_ref_ = Test_Object::_narrow (object_act.in ()); test_obj_impl->_remove_ref (); // Get the IOR for the Naming Service. Each thread can use it // in to create its own stub for the Naming // Service. This 'trick' is necessary, because multiple threads // cannot be using the same stub - bad things happen... This is // just a way to give each thread its own stub. CosNaming::NamingContext_var context = root_context.get_context (); name_service_ior_ = orb_->object_to_string (context.in ()); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception while instantiating dummy"); return -1; } // Create a name for dummy. test_name_.length (1); test_name_[0].id = CORBA::string_dup ("Foo"); // Spawn threads, each of which will be executing svc (). int status = this->activate (THR_NEW_LWP | THR_JOINABLE, size_); if (status == -1) return -1; status = this->wait (); return status; } Simple_Test::Simple_Test(PortableServer::POA_ptr poa) : Naming_Test (poa) { } int Simple_Test::execute (TAO_Naming_Client &root_context) { try { // Dummy object instantiation. My_Test_Object *test_obj_impl = new My_Test_Object (CosNaming_Client::OBJ1_ID); PortableServer::ObjectId_var id_act = this->poa_->activate_object (test_obj_impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var test_obj_ref = Test_Object::_narrow (object_act.in ()); // Give ownership of this object to POA. test_obj_impl->_remove_ref (); // Bind an object to the Naming Context. CosNaming::Name test_name; test_name.length (1); test_name[0].id = CORBA::string_dup ("Foo"); root_context->bind (test_name, test_obj_ref.in ()); ACE_DEBUG ((LM_DEBUG, "Bound name OK\n")); // Resolve the object from the Naming Context. CORBA::Object_var result_obj_ref = root_context->resolve (test_name); Test_Object_var result_object = Test_Object::_narrow (result_obj_ref.in ()); if (!CORBA::is_nil (result_object.in ())) { CORBA::Short id = result_object->id (); if (id == CosNaming_Client::OBJ1_ID) ACE_DEBUG ((LM_DEBUG, "Resolved name OK\n")); } // Unbind the object from the Naming Context. root_context->unbind (test_name); ACE_DEBUG ((LM_DEBUG, "Unbound name OK\n")); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Simple test"); return -1; } return 0; } Tree_Test::Tree_Test(PortableServer::POA_ptr poa) : Naming_Test (poa) { } int Tree_Test::execute (TAO_Naming_Client &root_context) { try { // Create a tree of contexts: root->level1->level2. Bind object // foo under context level2. // Bind level1 context under root. CosNaming::Name level1; level1.length (1); level1[0].id = CORBA::string_dup ("level1_context"); CosNaming::NamingContext_var level1_context; level1_context = root_context->bind_new_context (level1); // Create a new context. CosNaming::NamingContext_var level2_context; level2_context = root_context->new_context (); // Instantiate a dummy object and bind it under the new context. My_Test_Object *impl1 = new My_Test_Object (CosNaming_Client::OBJ1_ID); PortableServer::ObjectId_var id_act = this->poa_->activate_object (impl1); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj1 = Test_Object::_narrow (object_act.in ()); impl1->_remove_ref (); CosNaming::Name obj_name; obj_name.length (1); obj_name[0].id = CORBA::string_dup ("foo"); level2_context->bind (obj_name, obj1.in ()); // Bind the context we just created under level1. CosNaming::Name level2 (level1); level2.length (2); level2[1].id = CORBA::string_dup ("level2_context"); root_context->bind_context (level2, level2_context.in ()); // Resolve and unbind level1/level2/foo, and bind it back. CosNaming::Name test_name (level2); test_name.length (3); test_name[2].id = obj_name[0].id; CORBA::Object_var result_obj_ref = root_context->resolve (test_name); Test_Object_var result_object = Test_Object::_narrow (result_obj_ref.in ()); if (CORBA::is_nil (result_object.in ())) ACE_ERROR_RETURN ((LM_ERROR, "Problems with resolving foo in Tree Test - nil object ref.\n"), -1); CORBA::Short id = result_object->id (); if (id != CosNaming_Client::OBJ1_ID) ACE_ERROR_RETURN ((LM_ERROR, "Problems with resolving foo in Tree Test - wrong id.\n"), -1); // Unbind the object from the Naming Context and bind it back // in. root_context->unbind (test_name); root_context->bind (test_name, obj1.in ()); // Create new context and rebind under the name level1/level2. CosNaming::NamingContext_var new_level2_context; new_level2_context = root_context->new_context (); root_context->rebind_context (level2, new_level2_context.in ()); // Bind, resolve, rebind, and resolve foo under level1/level2. root_context->bind (test_name, obj1.in ()); result_obj_ref = root_context->resolve (test_name); result_object = Test_Object::_narrow (result_obj_ref.in ()); CORBA::Short obj_id = result_object->id (); if (CORBA::is_nil (result_object.in ()) || !(obj_id == CosNaming_Client::OBJ1_ID)) ACE_ERROR_RETURN ((LM_ERROR, "Problems in the Tree Test\n"), -1); My_Test_Object *impl2 = new My_Test_Object (CosNaming_Client::OBJ2_ID); id_act = this->poa_->activate_object (impl2); object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj2 = Test_Object::_narrow (object_act.in ()); impl2->_remove_ref (); root_context->rebind (test_name, obj2.in ()); result_obj_ref = root_context->resolve (test_name); result_object = Test_Object::_narrow (result_obj_ref.in ()); obj_id = result_object->id (); if (CORBA::is_nil (result_object.in ()) || !( obj_id == CosNaming_Client::OBJ2_ID)) ACE_ERROR_RETURN ((LM_ERROR, "Problems with rebind in Tree Test\n"), -1); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Tree test"); return -1; } ACE_DEBUG ((LM_DEBUG, "All functions work properly\n")); return 0; } Exceptions_Test::Exceptions_Test(PortableServer::POA_ptr poa) : Naming_Test (poa) { } int Exceptions_Test::execute (TAO_Naming_Client &root_context) { try { // Set things up. // Create a tree of contexts root->level1->level2. CosNaming::Name context_name; context_name.length (1); context_name[0].id = CORBA::string_dup ("level1_context"); CosNaming::NamingContext_var level1_context; level1_context = root_context->bind_new_context (context_name); context_name[0].id = CORBA::string_dup ("level2_context"); CosNaming::NamingContext_var level2_context; level2_context = level1_context->bind_new_context (context_name); // Bind a dummy object foo under each context. My_Test_Object *impl = new My_Test_Object; PortableServer::ObjectId_var id_act = this->poa_->activate_object (impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj = Test_Object::_narrow (object_act.in ()); impl->_remove_ref (); CosNaming::Name object_name; object_name.length (1); object_name[0].id = CORBA::string_dup ("foo"); root_context->bind (object_name, obj.in ()); level1_context->bind (object_name, obj.in ()); level2_context->bind (object_name, obj.in ()); // Run exceptions tests. invalid_name_test (root_context); already_bound_test (root_context); already_bound_test2 (root_context); not_found_test (root_context); not_found_test2 (root_context); not_found_test3 (root_context); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Exceptions test"); return -1; } return 0; } void Exceptions_Test::invalid_name_test (TAO_Naming_Client &root_context) { try { CosNaming::Name test_name; test_name.length (0); root_context->resolve (test_name); ACE_DEBUG ((LM_DEBUG, "Invalid name test failed\n")); } catch (const CosNaming::NamingContext::InvalidName&) { ACE_DEBUG ((LM_DEBUG, "InvalidName exception works properly\n")); } catch (const CORBA::Exception&) { ACE_DEBUG ((LM_DEBUG, "Invalid name test failed\n")); throw; } } void Exceptions_Test::already_bound_test (TAO_Naming_Client &root_context) { try { CosNaming::Name test_name; test_name.length (1); test_name[0].id = CORBA::string_dup ("foo"); My_Test_Object *impl = new My_Test_Object; PortableServer::ObjectId_var id_act = this->poa_->activate_object (impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj = Test_Object::_narrow (object_act.in ()); impl->_remove_ref (); root_context->bind (test_name, obj.in ()); ACE_DEBUG ((LM_DEBUG, "Already bound (case 1) test failed\n")); } catch (const CosNaming::NamingContext::AlreadyBound&) { ACE_DEBUG ((LM_DEBUG, "AlreadyBound exception (case 1) works properly\n")); } catch (const CORBA::Exception&) { ACE_DEBUG ((LM_DEBUG, "Already bound (case 1) test failed\n")); throw; } } void Exceptions_Test::already_bound_test2 (TAO_Naming_Client &root_context) { try { CosNaming::Name test_name; test_name.length (2); test_name[0].id = CORBA::string_dup ("level1_context"); test_name[1].id = CORBA::string_dup ("foo"); My_Test_Object *impl = new My_Test_Object; PortableServer::ObjectId_var id_act = this->poa_->activate_object (impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj = Test_Object::_narrow (object_act.in ()); impl->_remove_ref (); root_context->bind (test_name, obj.in ()); ACE_DEBUG ((LM_DEBUG, "Already bound (case 2) test failed\n")); } catch (const CosNaming::NamingContext::AlreadyBound&) { ACE_DEBUG ((LM_DEBUG, "AlreadyBound exception (case 2) works properly\n")); } catch (const CORBA::Exception&) { ACE_DEBUG ((LM_DEBUG, "Already bound (case 2) test failed\n")); throw; } } void Exceptions_Test::not_found_test (TAO_Naming_Client &root_context) { try { CosNaming::Name test_name; test_name.length (3); test_name[0].id = CORBA::string_dup ("level1_context"); test_name[1].id = CORBA::string_dup ("level2_context"); test_name[2].id = CORBA::string_dup ("bar"); root_context->unbind (test_name); ACE_DEBUG ((LM_DEBUG, "Not found test failed\n")); } catch (const CosNaming::NamingContext::NotFound& ex) { if (ex.why == CosNaming::NamingContext::missing_node && ex.rest_of_name.length () == 1 && ACE_OS::strcmp (ex.rest_of_name[0].id.in (), "bar") == 0) ACE_DEBUG ((LM_DEBUG, "NotFound exception (case 1) works properly\n")); else ACE_DEBUG ((LM_DEBUG, "NotFound exception (case 1)" " - parameters aren't set correctly\n")); } catch (const CORBA::Exception&) { ACE_DEBUG ((LM_DEBUG, "Not found test failed\n")); throw; } } void Exceptions_Test::not_found_test2 (TAO_Naming_Client &root_context) { try { CosNaming::Name test_name; test_name.length (3); test_name[0].id = CORBA::string_dup ("level1_context"); test_name[1].id = CORBA::string_dup ("level3_context"); test_name[2].id = CORBA::string_dup ("foo"); root_context->unbind (test_name); ACE_DEBUG ((LM_DEBUG, "Unbind test failed\n")); } catch (const CosNaming::NamingContext::NotFound& ex) { if (ex.why == CosNaming::NamingContext::missing_node && ex.rest_of_name.length () == 2 && ACE_OS::strcmp (ex.rest_of_name[0].id.in (), "level3_context") == 0 && ACE_OS::strcmp (ex.rest_of_name[1].id.in (), "foo") == 0) ACE_DEBUG ((LM_DEBUG, "NotFound exception (case 2) works properly\n")); else ACE_DEBUG ((LM_DEBUG, "NotFound exception (case 2)" " - parameters aren't set correctly\n")); } catch (const CORBA::Exception&) { ACE_DEBUG ((LM_DEBUG, "Unbind test failed\n")); throw; } } void Exceptions_Test::not_found_test3 (TAO_Naming_Client &root_context) { try { CosNaming::Name test_name; test_name.length (3); test_name[0].id = CORBA::string_dup ("level1_context"); test_name[1].id = CORBA::string_dup ("foo"); test_name[2].id = CORBA::string_dup ("foo"); root_context->unbind (test_name); ACE_DEBUG ((LM_DEBUG, "Not found (case 3) test failed - no exception was thrown\n")); } catch (const CosNaming::NamingContext::NotFound& ex) { if (ex.why == CosNaming::NamingContext::not_context && ex.rest_of_name.length () == 2 && ACE_OS::strcmp (ex.rest_of_name[0].id.in (), "foo") == 0 && ACE_OS::strcmp (ex.rest_of_name[1].id.in (), "foo") == 0) ACE_DEBUG ((LM_DEBUG, "NotFound exception (case 3) works properly\n")); else ACE_DEBUG ((LM_DEBUG, "NotFound exception (case 3)" " - parameters aren't set correctly\n")); } catch (const CORBA::Exception&) { ACE_DEBUG ((LM_DEBUG, "Not found (case 3) test failed\n")); throw; } } Iterator_Test::Iterator_Test(PortableServer::POA_ptr poa) : Naming_Test (poa) { } int Iterator_Test::execute (TAO_Naming_Client &root_context) { try { // Instantiate four dummy objects. My_Test_Object *impl = new My_Test_Object; PortableServer::ObjectId_var id_act = this->poa_->activate_object (impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj = Test_Object::_narrow (object_act.in ()); impl->_remove_ref (); // Bind objects to the naming context. CosNaming::Name name1; name1.length (1); name1[0].id = CORBA::string_dup ("foo1"); CosNaming::Name name2; name2.length (1); name2[0].id = CORBA::string_dup ("foo2"); CosNaming::Name name3; name3.length (1); name3[0].id = CORBA::string_dup ("foo3"); CosNaming::Name name4; name4.length (1); name4[0].id = CORBA::string_dup ("foo4"); root_context->bind (name1, obj.in ()); root_context->bind (name2, obj.in ()); root_context->bind (name3, obj.in ()); root_context->bind (name4, obj.in ()); // List the content of the Naming Context. CosNaming::BindingIterator_var iter; CosNaming::BindingList_var bindings_list; root_context->list (1, bindings_list.out (), iter.out ()); if (CORBA::is_nil (iter.in ()) || bindings_list->length () != 1 || bindings_list[0u].binding_type != CosNaming::nobject) ACE_ERROR_RETURN ((LM_ERROR, "Iterator_Test -> CosNaming::list does not function properly. \ Should have returned one CosNaming::nobject element in bindings_list. Length = %d, \ Binding Type = %d\n", bindings_list->length (), bindings_list[0u].binding_type), -1); ACE_DEBUG ((LM_DEBUG, "First binding: %C\n", bindings_list[0u].binding_name[0u].id.in ())); // Invoke operations on the iterator. CosNaming::Binding_var binding; iter->next_one (binding.out ()); if (binding->binding_type != CosNaming::nobject) ACE_ERROR_RETURN ((LM_ERROR, "CosNaming::next_one does not function properly\n"), -1); ACE_DEBUG ((LM_DEBUG, "Second binding: %C\n", binding->binding_name[0].id.in ())); iter->next_n (2, bindings_list.out ()); if (bindings_list->length () != 2 || bindings_list[0u].binding_type != CosNaming::nobject || bindings_list[1u].binding_type != CosNaming::nobject) ACE_ERROR_RETURN ((LM_ERROR, "CosNaming::BindingIterator does not function properly\n"), -1); ACE_DEBUG ((LM_DEBUG, "Third binding: %C\n" "Fourth binding: %C\n", bindings_list[0u].binding_name[0].id.in (), bindings_list[1u].binding_name[0].id.in ())); // We already iterated over all the bindings, so the following // should return false. CORBA::Boolean result = iter->next_one (binding.out ()); if (result) ACE_ERROR_RETURN ((LM_ERROR, "CosNaming::BindingIterator does not function properly\n"), -1); iter->destroy (); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Iterator test"); return -1; } return 0; } Destroy_Test::Destroy_Test(PortableServer::POA_ptr poa) : Naming_Test (poa) { } int Destroy_Test::execute (TAO_Naming_Client &root_context) { try { // Create a context and bind an object under it. CosNaming::NamingContext_var my_context; my_context = root_context->new_context (); // Bind a dummy object foo under my_context. My_Test_Object *impl = new My_Test_Object; PortableServer::ObjectId_var id_act = this->poa_->activate_object (impl); CORBA::Object_var object_act = this->poa_->id_to_reference (id_act.in ()); Test_Object_var obj = Test_Object::_narrow (object_act.in ()); impl->_remove_ref (); CosNaming::Name object_name; object_name.length (1); object_name[0].id = CORBA::string_dup ("foo"); my_context->bind (object_name, obj.in ()); // Do the testing. not_empty_test (my_context); my_context->unbind (object_name); my_context->destroy (); not_exist_test (my_context); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Destroy test"); return -1; } return 0; } void Destroy_Test::not_empty_test (CosNaming::NamingContext_var &ref) { try { ref->destroy (); } catch (const CosNaming::NamingContext::NotEmpty&) { ACE_DEBUG ((LM_DEBUG, "NotEmpty exception works properly\n")); } } void Destroy_Test::not_exist_test (CosNaming::NamingContext_var &ref) { try { ref->destroy (); } catch (const CORBA::OBJECT_NOT_EXIST&) { ACE_DEBUG ((LM_DEBUG, "Destroy works properly\n")); } } Persistent_Test_Begin::Persistent_Test_Begin (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa, FILE * ior_output_file) : Naming_Test (poa), orb_ (orb), file_ (ior_output_file) { } Persistent_Test_Begin::~Persistent_Test_Begin (void) { } int Persistent_Test_Begin::execute (TAO_Naming_Client &root_context) { try { // Create a name structure we will reuse. CosNaming::Name test_name; test_name.length (1); test_name[0].id = CORBA::string_dup ("level1"); // Create and bind a naming context under the context. CosNaming::NamingContext_var level1_context = root_context->bind_new_context (test_name); // Create and bind a naming context under context. test_name[0].id = CORBA::string_dup ("level2"); CosNaming::NamingContext_var level2_context = level1_context->bind_new_context (test_name); // Log the ior of for use by . CORBA::String_var ior = orb_->object_to_string (level1_context.in ()); ACE_OS::fprintf (this->file_, "%s", ior.in ()); ACE_OS::fclose (this->file_); ACE_DEBUG ((LM_DEBUG, "Persistent Naming test (part 1) OK.\n")); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Persistent Test (part 1)"); return -1; } return 0; } Persistent_Test_End::Persistent_Test_End (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa, const ACE_TCHAR *ior) : Naming_Test (poa), orb_ (orb), ior_ (ior) { } Persistent_Test_End::~Persistent_Test_End (void) { } int Persistent_Test_End::execute (TAO_Naming_Client &root_context) { try { // Create a name structure we will reuse. CosNaming::Name test_name; test_name.length (1); test_name[0].id = CORBA::string_dup ("level2"); // Convert stringified ior we got from // for Naming Context to Naming Context reference. CORBA::Object_var obj = orb_->string_to_object (ior_); CosNaming::NamingContext_var level1_context = CosNaming::NamingContext::_narrow (obj.in ()); if (CORBA::is_nil (level1_context.in ())) ACE_ERROR_RETURN ((LM_ERROR, "Cannot narrow object to Naming Context\n"), -1); // Resolve for context through the persistent ior we // got from part 1 of this test. obj = level1_context->resolve (test_name); // Now, resolve for context using the context // reference which we obtained through . test_name.length (2); test_name[0].id = CORBA::string_dup ("level1"); test_name[1].id = CORBA::string_dup ("level2"); CORBA::Object_var obj2 = root_context->resolve (test_name); // Make sure we got the same answer through both methods. if (obj2->_is_equivalent (obj.in ())) ACE_DEBUG ((LM_DEBUG, "Persistent Naming test (part 2) OK.\n")); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Persistent Test (part 2)"); return -1; } return 0; } Persistent_List_Test::Persistent_List_Test (CORBA::ORB_ptr orb, PortableServer::POA_ptr poa) : Naming_Test (poa), orb_ (orb) { } Persistent_List_Test::~Persistent_List_Test (void) { } /** * @brief Verify functionality of a Naming Service's list() iterator * when dealing with a flat-file persistent NS. * * Uses information stored in the NS in prior tests, then adds its * own bindings and runs additional tests iterating through them. */ int Persistent_List_Test::execute (TAO_Naming_Client &root_context) { try { // Create a name structure we will reuse. CosNaming::Name test_name; test_name.length (1); test_name[0].id = CORBA::string_dup ("level1"); CORBA::Object_var obj1 = root_context->resolve (test_name); CosNaming::NamingContext_var level1_context = CosNaming::NamingContext::_narrow (obj1.in ()); // Resolve for context through level1 test_name.length (1); test_name[0].id = CORBA::string_dup ("level2"); CORBA::Object_var obj2 = level1_context->resolve (test_name); CosNaming::NamingContext_var level2_context = CosNaming::NamingContext::_narrow (obj2.in ()); // List the content of the Naming Context. CosNaming::BindingIterator_var iter; CosNaming::BindingList_var bindings_list; CosNaming::Binding_var binding; unsigned int objects_found = 0; unsigned int contexts_found = 0; root_context->list (0, bindings_list.out (), iter.out ()); if (CORBA::is_nil (iter.in ()) || bindings_list->length () != 0) ACE_ERROR_RETURN ((LM_ERROR, "Persistent_List_Test -> CosNaming::list does not function properly. Should have returned an iterator.\n"), -1); while (iter->next_one (binding.out ())) { if (binding->binding_type == CosNaming::nobject) ++objects_found; if (binding->binding_type == CosNaming::ncontext) ++contexts_found; } if (objects_found != 0 && contexts_found != 1) { ACE_ERROR_RETURN ((LM_ERROR, "CosNaming::next_one does not function properly\n"), -1); } iter->destroy (); contexts_found = 0; // Instantiate four dummy objects. My_Test_Object *impl = new My_Test_Object; Test_Object_var obj = impl->_this (); impl->_remove_ref (); // Bind objects to the naming context. CosNaming::Name name1; name1.length (1); name1[0].id = CORBA::string_dup ("foo1"); CosNaming::Name name2; name2.length (1); name2[0].id = CORBA::string_dup ("foo2"); CosNaming::Name name3; name3.length (1); name3[0].id = CORBA::string_dup ("foo3"); CosNaming::Name name4; name4.length (1); name4[0].id = CORBA::string_dup ("foo4"); level1_context->bind (name1, obj.in ()); level1_context->bind (name2, obj.in ()); level1_context->bind (name3, obj.in ()); level1_context->bind (name4, obj.in ()); level1_context->list (0, bindings_list.out (), iter.out ()); if (CORBA::is_nil (iter.in ()) || bindings_list->length () != 0) ACE_ERROR_RETURN ((LM_ERROR, "Persistent_List_Test -> CosNaming::list does not function properly. Should have returned an iterator.\n"), -1); while (iter->next_one (binding.out ())) { if (binding->binding_type == CosNaming::nobject) ++objects_found; if (binding->binding_type == CosNaming::ncontext) ++contexts_found; } if (objects_found != 4 && contexts_found != 1) { ACE_ERROR_RETURN ((LM_ERROR, "CosNaming::next_one does not function properly\n"), -1); } iter->destroy (); ACE_DEBUG ((LM_DEBUG, "Persistent Naming test (part 3) OK.\n")); } catch (const CORBA::Exception& ex) { ex._tao_print_exception ( "Unexpected exception in Persistent Test (part 3)"); return -1; } return 0; } // This function runs the test. int ACE_TMAIN(int argc, ACE_TCHAR *argv[]) { CosNaming_Client cosnaming_client; if (cosnaming_client.init (argc, argv) == -1) return 1; return cosnaming_client.run (); }