diff options
Diffstat (limited to 'TAO/tests/NestedUpcall/Reactor/mt_client.cpp')
| -rw-r--r-- | TAO/tests/NestedUpcall/Reactor/mt_client.cpp | 22 |
1 files changed, 21 insertions, 1 deletions
diff --git a/TAO/tests/NestedUpcall/Reactor/mt_client.cpp b/TAO/tests/NestedUpcall/Reactor/mt_client.cpp index c9bbc16ac93..85dd43bc314 100644 --- a/TAO/tests/NestedUpcall/Reactor/mt_client.cpp +++ b/TAO/tests/NestedUpcall/Reactor/mt_client.cpp @@ -97,7 +97,7 @@ NestedUpCalls_MT_Client::svc (void) { ACE_TRY_NEW_ENV { - ACE_DEBUG ((LM_DEBUG, "Running thread (%t)\n")); + ACE_DEBUG ((LM_DEBUG, "Running thread (%t)\n")); // Create an EventHandler servant to hand to the other side... auto_ptr<EventHandler_i> eh_impl (new EventHandler_i); @@ -168,6 +168,26 @@ NestedUpCalls_MT_Client::init (int argc, char *argv[]) ACE_DEBUG ((LM_DEBUG, "Reactor received OK\n")); + + CORBA::Object_var poa_object = + this->orb_->resolve_initial_references("RootPOA", ACE_TRY_ENV); + ACE_TRY_CHECK; + + if (CORBA::is_nil (poa_object.in ())) + ACE_ERROR_RETURN ((LM_ERROR, + " (%P|%t) Unable to initialize the POA.\n"), + 1); + + PortableServer::POA_var root_poa = + PortableServer::POA::_narrow (poa_object.in (), ACE_TRY_ENV); + ACE_TRY_CHECK; + + PortableServer::POAManager_var poa_manager = + root_poa->the_POAManager (ACE_TRY_ENV); + ACE_TRY_CHECK; + + poa_manager->activate (ACE_TRY_ENV); + ACE_TRY_CHECK; } ACE_CATCHANY { |