summaryrefslogtreecommitdiff
path: root/TAO/tao/Utils/ORB_Manager.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/tao/Utils/ORB_Manager.cpp')
-rw-r--r--TAO/tao/Utils/ORB_Manager.cpp366
1 files changed, 0 insertions, 366 deletions
diff --git a/TAO/tao/Utils/ORB_Manager.cpp b/TAO/tao/Utils/ORB_Manager.cpp
deleted file mode 100644
index 08618700659..00000000000
--- a/TAO/tao/Utils/ORB_Manager.cpp
+++ /dev/null
@@ -1,366 +0,0 @@
-// $Id$
-
-// ============================================================================
-//
-// = LIBRARY
-// tao
-//
-// = AUTHOR
-// Sumedh Mungee <sumedh@cs.wustl.edu>
-//
-// ============================================================================
-
-#include "ORB_Manager.h"
-
-#include "tao/PortableServer/POAManagerC.h"
-#include "tao/PortableServer/IdAssignmentPolicyC.h"
-#include "tao/PortableServer/LifespanPolicyC.h"
-
-#include "tao/Environment.h"
-#include "tao/ORBInitializer_Registry.h"
-
-#include "ace/Log_Msg.h"
-
-ACE_RCSID (PortableServer,
- ORB_Manager,
- "$Id$")
-
-// constructor
-TAO_ORB_Manager::TAO_ORB_Manager (CORBA::ORB_ptr orb,
- PortableServer::POA_ptr poa,
- PortableServer::POAManager_ptr poa_manager)
- : orb_ (orb),
- poa_ (poa),
- poa_manager_ (poa_manager)
-{
-}
-
-int
-TAO_ORB_Manager::init (int &argc,
- char **argv
- ACE_ENV_ARG_DECL)
-{
- return this->init (argc,
- argv,
- 0
- ACE_ENV_ARG_PARAMETER);
-}
-
-int
-TAO_ORB_Manager::init (int &argc,
- char **argv,
- const char *orb_name
- ACE_ENV_ARG_DECL)
-{
- if (CORBA::is_nil (this->orb_.in ()))
- {
- this->orb_ = CORBA::ORB_init (argc,
- argv,
- orb_name
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- }
-
- if (CORBA::is_nil (this->poa_.in ()))
- {
- // Get the POA from the ORB.
- CORBA::Object_var poa_object =
- this->orb_->resolve_initial_references (TAO_OBJID_ROOTPOA
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- if (CORBA::is_nil (poa_object.in ()))
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT (" (%P|%t) Unable to initialize the POA.\n")),
- -1);
-
- // Get the POA object.
- this->poa_ =
- PortableServer::POA::_narrow (poa_object.in ()
- ACE_ENV_ARG_PARAMETER);
-
- ACE_CHECK_RETURN (-1);
- }
-
- if (CORBA::is_nil (this->poa_manager_.in ()))
- {
- // Get the POA_Manager.
- this->poa_manager_ =
- this->poa_->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
-
- ACE_CHECK_RETURN (-1);
- }
-
- return 0;
-}
-
-int
-TAO_ORB_Manager::init_child_poa (int& argc,
- char **argv,
- const char *poa_name
- ACE_ENV_ARG_DECL)
-{
- return this->init_child_poa (argc,
- argv,
- poa_name,
- 0
- ACE_ENV_ARG_PARAMETER);
-}
-
-int
-TAO_ORB_Manager::init_child_poa (int& argc,
- char **argv,
- const char *poa_name,
- const char *orb_name
- ACE_ENV_ARG_DECL)
-{
- int init_result;
-
- // check to see if root poa has to be created.
- init_result = this->init (argc,
- argv,
- orb_name
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- if (init_result == -1)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT (" (%P|%t) Error in init.\n")),
- -1);
-
- // Create the default policies - user-supplied ID, and persistent
- // objects.
- CORBA::PolicyList policies (2);
- policies.length (2);
-
- // Id Assignment policy
- policies[0] =
- this->poa_->create_id_assignment_policy (PortableServer::USER_ID
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- // Lifespan policy
- policies[1] =
- this->poa_->create_lifespan_policy (PortableServer::PERSISTENT
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- // We use a different POA, otherwise the user would have to change
- // the object key each time it invokes the server.
-
- this->child_poa_ =
- this->poa_->create_POA (poa_name,
- this->poa_manager_.in (),
- policies
- ACE_ENV_ARG_PARAMETER);
- // Warning! If create_POA fails, then the policies won't be
- // destroyed and there will be hell to pay in memory leaks!
- ACE_CHECK_RETURN (-1);
-
- // Creation of the new POAs over, so destroy the Policy_ptr's.
- for (CORBA::ULong i = 0;
- i < policies.length ();
- ++i)
- {
- CORBA::Policy_ptr policy = policies[i];
- policy->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- }
- return 0;
-}
-
-// Activate POA manager.
-
-int
-TAO_ORB_Manager::activate_poa_manager (ACE_ENV_SINGLE_ARG_DECL)
-{
- this->poa_manager_->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
- return 0;
-}
-
-// Activate servant in the POA.
-
-char *
-TAO_ORB_Manager::activate (PortableServer::Servant servant
- ACE_ENV_ARG_DECL)
-{
- PortableServer::ObjectId_var id =
- this->poa_->activate_object (servant
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- CORBA::Object_var obj =
- this->poa_->id_to_reference (id.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- CORBA::String_var str =
- this->orb_->object_to_string (obj.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- return str._retn ();
-}
-
-void
-TAO_ORB_Manager::deactivate (const char *id
- ACE_ENV_ARG_DECL)
-{
- CORBA::Object_var object =
- this->orb_->string_to_object (id
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- PortableServer::ObjectId_var object_id =
- this->poa_->reference_to_id (object.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- this->poa_->deactivate_object (object_id.in ()
- ACE_ENV_ARG_PARAMETER);
-}
-
-// Activate the object with the object_name under the child POA.
-
-char *
-TAO_ORB_Manager::activate_under_child_poa (const char *object_name,
- PortableServer::Servant servant
- ACE_ENV_ARG_DECL)
-{
- if (object_name == 0)
- ACE_ERROR_RETURN ((LM_ERROR,
- ACE_TEXT ("\n(%P|%t) TAO_ORB_Manager::register: ")
- ACE_TEXT ("object_name is null!")),
- 0);
-
- PortableServer::ObjectId_var id =
- PortableServer::string_to_ObjectId (object_name);
-
- this->child_poa_->activate_object_with_id (id.in (),
- servant
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- CORBA::Object_var obj =
- this->child_poa_->id_to_reference (id.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (0);
-
- char * str =
- this->orb_->object_to_string (obj.in ()
- ACE_ENV_ARG_PARAMETER);
-
- ACE_CHECK_RETURN (0);
-
- return str;
-}
-
-void
-TAO_ORB_Manager::deactivate_under_child_poa (const char *id
- ACE_ENV_ARG_DECL)
-{
- CORBA::Object_var object =
- this->orb_->string_to_object (id
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- PortableServer::ObjectId_var object_id =
- this->child_poa_->reference_to_id (object.in ()
- ACE_ENV_ARG_PARAMETER);
- ACE_CHECK;
-
- this->child_poa_->deactivate_object (object_id.in ()
- ACE_ENV_ARG_PARAMETER);
-}
-
-// Enter the ORB event loop.
-
-int
-TAO_ORB_Manager::run (ACE_Time_Value &tv
- ACE_ENV_ARG_DECL)
-{
- this->poa_manager_->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- this->orb_->run (tv ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- return 0;
-}
-
-int
-TAO_ORB_Manager::fini (ACE_ENV_SINGLE_ARG_DECL)
-{
- this->poa_->destroy (1, 1 ACE_ENV_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- this->poa_ = 0;
-
- this->orb_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- this->orb_ = 0;
- return 0;
-}
-
-int
-TAO_ORB_Manager::run (ACE_ENV_SINGLE_ARG_DECL)
-{
- this->poa_manager_->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- this->orb_->run (ACE_ENV_SINGLE_ARG_PARAMETER);
- ACE_CHECK_RETURN (-1);
-
- return 0;
-}
-
-// Return the corba orb reference.
-
-CORBA::ORB_ptr
-TAO_ORB_Manager::orb (void)
-{
- return CORBA::ORB::_duplicate (this->orb_.in ());
-}
-
-// Return the root POA reference
-PortableServer::POA_ptr
-TAO_ORB_Manager::root_poa (void)
-{
- return PortableServer::POA::_duplicate (this->poa_.in ());
-}
-
-// Return the child POA reference
-PortableServer::POA_ptr
-TAO_ORB_Manager::child_poa (void)
-{
- return PortableServer::POA::_duplicate (this->child_poa_.in ());
-}
-
-PortableServer::POAManager_ptr
-TAO_ORB_Manager::poa_manager (void)
-{
- return PortableServer::POAManager::_duplicate (this->poa_manager_.in ());
-}
-
-// Destructor.
-
-TAO_ORB_Manager::~TAO_ORB_Manager (void)
-{
- ACE_TRY_NEW_ENV
- {
- if (!CORBA::is_nil (this->poa_.in ()))
- {
- this->poa_->destroy (1,
- 1
- ACE_ENV_ARG_PARAMETER);
- ACE_TRY_CHECK;
- }
- }
- ACE_CATCHANY
- {
- // ignore any exceptions..
- }
- ACE_ENDTRY;
-}
View Lorry Controller Status