summaryrefslogtreecommitdiff
path: root/TAO/orbsvcs/Logging_Service/Basic_Logging_Service/Basic_Logging_Service.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'TAO/orbsvcs/Logging_Service/Basic_Logging_Service/Basic_Logging_Service.cpp')
-rw-r--r--TAO/orbsvcs/Logging_Service/Basic_Logging_Service/Basic_Logging_Service.cpp191
1 files changed, 191 insertions, 0 deletions
diff --git a/TAO/orbsvcs/Logging_Service/Basic_Logging_Service/Basic_Logging_Service.cpp b/TAO/orbsvcs/Logging_Service/Basic_Logging_Service/Basic_Logging_Service.cpp
new file mode 100644
index 00000000000..7461018c144
--- /dev/null
+++ b/TAO/orbsvcs/Logging_Service/Basic_Logging_Service/Basic_Logging_Service.cpp
@@ -0,0 +1,191 @@
+/* -*- C++ -*- $Id$ */
+#include "Basic_Logging_Service.h"
+#include "ace/Get_Opt.h"
+#include "orbsvcs/Log/BasicLogFactory_i.h"
+
+Basic_Logging_Service::Basic_Logging_Service (void)
+ : basic_log_factory_name_ ("BasicLogFactory")
+{
+ // No-Op.
+}
+
+Basic_Logging_Service::~Basic_Logging_Service (void)
+{
+ // No-Op.
+}
+
+void
+Basic_Logging_Service::init_ORB (int& argc, char *argv []
+ ACE_ENV_ARG_DECL)
+{
+ this->orb_ = CORBA::ORB_init (argc,
+ argv,
+ ""
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ CORBA::Object_var poa_object =
+ this->orb_->resolve_initial_references("RootPOA"
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ this->poa_ =
+ PortableServer::POA::_narrow (poa_object.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ PortableServer::POAManager_var poa_manager =
+ this->poa_->the_POAManager (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_CHECK;
+
+ poa_manager->activate (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_CHECK;
+}
+
+int
+Basic_Logging_Service::startup (int argc, char *argv[]
+ ACE_ENV_ARG_DECL)
+{
+ ACE_DEBUG ((LM_DEBUG,
+ "\nStarting up the Telecom Log Service...\n"));
+
+ // initalize the ORB.
+ this->init_ORB (argc, argv
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ // Resolve the naming service.
+ this->resolve_naming_service (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_CHECK;
+
+ // Activate the basic log factory
+ // CORBA::Object_var obj =
+ DsLogAdmin::BasicLogFactory_var obj =
+ this->basic_log_factory_.activate (this->poa_.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+ ACE_ASSERT (!CORBA::is_nil (obj.in ()));
+
+ CORBA::String_var str =
+ this->orb_->object_to_string (obj.in () ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ ACE_DEBUG ((LM_DEBUG,
+ "The Basic Log Factory IOR is <%s>\n", str.in ()));
+
+ // Register the Basic Log Factory.
+ ACE_ASSERT(!CORBA::is_nil (this->naming_.in ()));
+
+ CosNaming::Name name (1);
+ name.length (1);
+ name[0].id = CORBA::string_dup (this->basic_log_factory_name_);
+
+ this->naming_->rebind (name,
+ obj.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ ACE_DEBUG ((LM_DEBUG,
+ "Registered with the naming service as: %s\n",
+ this->basic_log_factory_name_));
+ return 0;
+}
+
+void
+Basic_Logging_Service::resolve_naming_service (ACE_ENV_SINGLE_ARG_DECL)
+{
+ CORBA::Object_var naming_obj =
+ this->orb_->resolve_initial_references ("NameService"
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ // Need to check return value for errors.
+ if (CORBA::is_nil (naming_obj.in ()))
+ ACE_THROW (CORBA::UNKNOWN ());
+
+ this->naming_ =
+ CosNaming::NamingContext::_narrow (naming_obj.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+}
+
+int
+Basic_Logging_Service::run (void)
+{
+ ACE_DEBUG ((LM_DEBUG, "%s: Running the Telecom Log Service\n", __FILE__));
+
+ ACE_DECLARE_NEW_CORBA_ENV;
+ ACE_TRY
+ {
+ this->orb_->run (ACE_ENV_SINGLE_ARG_PARAMETER);
+ ACE_TRY_CHECK;
+ }
+ ACE_CATCHANY
+ {
+ return -1;
+ }
+ ACE_ENDTRY;
+
+ return 0;
+}
+
+void
+Basic_Logging_Service::shutdown (ACE_ENV_SINGLE_ARG_DECL)
+{
+ // Deactivate.
+ PortableServer::ObjectId_var oid =
+ this->poa_->servant_to_id (&this->basic_log_factory_
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ // Deactivate from the poa.
+ this->poa_->deactivate_object (oid.in ()
+ ACE_ENV_ARG_PARAMETER);
+ ACE_CHECK;
+
+ // Unbind from the naming service.
+ CosNaming::Name name (1);
+ name.length (1);
+ name[0].id = CORBA::string_dup (this->basic_log_factory_name_);
+
+ this->naming_->unbind (name
+ ACE_ENV_ARG_PARAMETER);
+
+ // Shutdown the ORB.
+ if (!CORBA::is_nil (this->orb_.in ()))
+ this->orb_->shutdown ();
+}
+
+int
+main (int argc, char *argv[])
+{
+ Basic_Logging_Service service;
+
+ if (service.startup (argc, argv ACE_ENV_ARG_PARAMETER) == -1)
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "Failed to start the Basic Logging Service.\n"),
+ 1);
+
+ ACE_TRY_NEW_ENV
+ {
+ if (service.run () == -1)
+ {
+ service.shutdown ();
+ ACE_ERROR_RETURN ((LM_ERROR,
+ "Failed to run the Telecom Log Service.\n"),
+ 1);
+ }
+ }
+ ACE_CATCHANY
+ {
+ ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+ "Failed to start the Telecom Log Service\n");
+ return 1;
+ }
+ ACE_ENDTRY;
+
+ service.shutdown ();
+
+ return 0;
+}
+