1 files changed, 96 insertions, 0 deletions
diff --git a/TAO/orbsvcs/orbsvcs/FtRtEvent/ClientORB/FTRT_ClientORB_Loader.cpp b/TAO/orbsvcs/orbsvcs/FtRtEvent/ClientORB/FTRT_ClientORB_Loader.cpp
new file mode 100644
index 00000000000..053c1f1832c
--- /dev/null
+++ b/TAO/orbsvcs/orbsvcs/FtRtEvent/ClientORB/FTRT_ClientORB_Loader.cpp
@@ -0,0 +1,96 @@
+// $Id$
+
+#include "FTRT_ClientORB_Loader.h"
+
+#include "FTRT_ClientORB_Initializer.h"
+
+#include "tao/debug.h"
+
+ACE_RCSID (ClientORB,
+           FTRT_ClientORB_Loader,
+           "$Id$")
+
+
+namespace TAO_FTRT {
+  FTRT_ClientORB_Loader::FTRT_ClientORB_Loader (void)
+  {
+  }
+
+  FTRT_ClientORB_Loader::~FTRT_ClientORB_Loader (void)
+  {
+  }
+
+  int FTRT_ClientORB_Loader::init (int argc,
+    ACE_TCHAR* argv[])
+  {
+    ACE_TRACE ("FTRT_ClientORB_Loader::init");
+
+    static int initialized = 0;
+
+    // Only allow initialization once.
+    if (initialized)
+      return 0;
+
+    initialized = 1;
+
+    // Set defaults.
+    int transaction_depth = 1;
+    int curarg = 0;
+
+    // Parse any service configurator parameters.
+    for (curarg = 0; curarg < argc; curarg++)
+      if (ACE_OS::strcasecmp (argv[curarg],
+        ACE_LIB_TEXT("-ORBTransactionDepth")) == 0)
+      {
+        curarg++;
+        if (curarg < argc)
+          transaction_depth = atoi(argv[curarg]);
+      }
+
+
+      // Register the ORB initializer.
+      ACE_TRY_NEW_ENV
+      {
+        PortableInterceptor::ORBInitializer_ptr temp_orb_initializer =
+          PortableInterceptor::ORBInitializer::_nil ();
+        PortableInterceptor::ORBInitializer_var orb_initializer;
+
+        /// Register the RTCORBA ORBInitializer.
+        ACE_NEW_THROW_EX (temp_orb_initializer,
+          FTRT_ClientORB_Initializer(transaction_depth),
+          CORBA::NO_MEMORY (
+          CORBA::SystemException::_tao_minor_code (
+          TAO_DEFAULT_MINOR_CODE,
+          ENOMEM),
+          CORBA::COMPLETED_NO));
+        ACE_TRY_CHECK;
+        orb_initializer = temp_orb_initializer;
+
+        PortableInterceptor::register_orb_initializer (orb_initializer.in ()
+          ACE_ENV_ARG_PARAMETER);
+        ACE_TRY_CHECK;
+      }
+      ACE_CATCHANY
+      {
+        ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION,
+          "Unexpected exception caught while "
+          "initializing the TransactionDepth");
+        return 1;
+      }
+      ACE_ENDTRY;
+
+      return 0;
+  }
+
+  /////////////////////////////////////////////////////////////////////
+
+  ACE_FACTORY_DEFINE (TAO_FTRT, FTRT_ClientORB_Loader);
+  ACE_STATIC_SVC_DEFINE (FTRT_ClientORB_Loader,
+    ACE_TEXT ("FTRT_ClientORB_Service"),
+    ACE_SVC_OBJ_T,
+    &ACE_SVC_NAME (FTRT_ClientORB_Loader),
+    ACE_Service_Type::DELETE_THIS
+    | ACE_Service_Type::DELETE_OBJ,
+    0);
+}
+