Repo restructuring

1 files changed, 271 insertions, 0 deletions

diff --git a/TAO/orbsvcs/tests/Notify/Basic/LifeCycle.cpp b/TAO/orbsvcs/tests/Notify/Basic/LifeCycle.cpp
new file mode 100644
index 00000000000..0bb420600c7
--- /dev/null
+++ b/TAO/orbsvcs/tests/Notify/Basic/LifeCycle.cpp
@@ -0,0 +1,271 @@
+//$Id$
+
+#include "ace/Arg_Shifter.h"
+#include "ace/Get_Opt.h"
+#include "tao/debug.h"
+#include <orbsvcs/CosNamingC.h>
+#include <orbsvcs/CosNotifyCommC.h>
+#include <orbsvcs/CosNotifyChannelAdminC.h>
+
+#include "LifeCycle.h"
+
+ACE_RCSID (Notify_Tests,
+           LifeCycle,
+           "$Id$")
+
+LifeCycle::LifeCycle (void)
+  : count_ (10)
+{
+}
+
+LifeCycle::~LifeCycle (void)
+{
+}
+
+int
+LifeCycle::parse_args (int argc,
+                           char *argv[])
+{
+    ACE_Arg_Shifter arg_shifter (argc,
+                                 argv);
+
+    const char *current_arg = 0;
+
+    while (arg_shifter.is_anything_left ())
+    {
+      if ((current_arg = arg_shifter.get_the_parameter ("-count")))
+        {
+          this->count_ = ACE_OS::atoi (current_arg);
+          // The number of times to create and destroy.
+          arg_shifter.consume_arg ();
+        }
+      else if (arg_shifter.cur_arg_strncasecmp ("-?") == 0)
+        {
+          ACE_DEBUG ((LM_DEBUG,
+                      "usage: %s "
+                      "-count testcount \n",
+                      argv[0],
+                      argv[0]));
+
+          arg_shifter.consume_arg ();
+
+          return -1;
+        }
+      else
+        {
+          arg_shifter.ignore_arg ();
+        }
+    }
+
+  return 0;
+}
+
+void
+LifeCycle::init (int argc,
+                     char* argv[]
+                     ACE_ENV_ARG_DECL)
+{
+  CORBA::ORB_var orb = CORBA::ORB_init (argc,
+                                        argv,
+                                        ""
+                                        ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  CORBA::Object_var rootObj =
+    orb->resolve_initial_references ("NameService"
+                                     ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (CORBA::is_nil (rootObj.in ()))
+    {
+      ACE_ERROR ((LM_ERROR,
+                  " (%P|%t) Unable to resolve naming service !\n"));
+      return;
+    }
+
+  CosNaming::NamingContext_var rootNC =
+    CosNaming::NamingContext::_narrow (rootObj.in ()
+                                       ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  CosNaming::Name name (1);
+  name.length (1);
+  name[0].id = CORBA::string_dup ("NotifyEventChannelFactory");
+
+  CORBA::Object_var obj = rootNC->resolve (name
+                                           ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  notify_factory_ =
+    CosNotifyChannelAdmin::EventChannelFactory::_narrow (
+        obj.in()
+        ACE_ENV_ARG_PARAMETER
+      );
+  ACE_CHECK;
+
+  if (CORBA::is_nil (notify_factory_.in ()))
+    {
+      ACE_ERROR ((LM_ERROR,
+                  " (%P|%t) Unable to locate Notify_Service \n"));
+
+      return;
+    }
+}
+
+void
+LifeCycle::run_test(ACE_ENV_SINGLE_ARG_DECL)
+{
+  for (int i = 0; i < this->count_; ++i)
+    {
+     this->create_ec (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_CHECK;
+
+     this->create_supplier_admin (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_CHECK;
+
+     this->create_consumer_admin (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_CHECK;
+
+     this->destroy_consumer_admin (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_CHECK;
+
+     this->destroy_supplier_admin (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_CHECK;
+
+     this->destroy_ec (ACE_ENV_SINGLE_ARG_PARAMETER);
+     ACE_CHECK;
+  }
+}
+
+void
+LifeCycle::create_ec (ACE_ENV_SINGLE_ARG_DECL)
+{
+  CosNotifyChannelAdmin::ChannelID id;
+  CosNotification::QoSProperties initial_qos;
+  CosNotification::AdminProperties initial_admin;
+
+  this->ec_ = notify_factory_->create_channel (initial_qos,
+                                               initial_admin,
+                                               id
+                                               ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (CORBA::is_nil (ec_.in ())) {
+    ACE_ERROR ((LM_ERROR,
+                " (%P|%t) Unable to create event channel\n"));
+    return;
+  }
+
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG,
+                "created event channel\n"));
+}
+
+void
+LifeCycle::create_supplier_admin (ACE_ENV_SINGLE_ARG_DECL)
+{
+  CosNotifyChannelAdmin::AdminID adminid;
+  CosNotifyChannelAdmin::InterFilterGroupOperator ifgop =
+          CosNotifyChannelAdmin::OR_OP;
+
+  supplier_admin_ = this->ec_->new_for_suppliers (ifgop,
+                                                  adminid
+                                                  ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (CORBA::is_nil (supplier_admin_.in ()))
+    {
+      ACE_ERROR ((LM_ERROR,
+                  " (%P|%t) Unable to create supplier admin\n"));
+      return;
+    }
+
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG,
+                "created supplier admin\n"));
+}
+
+void
+LifeCycle::create_consumer_admin (ACE_ENV_SINGLE_ARG_DECL)
+{
+  CosNotifyChannelAdmin::AdminID adminid;
+  CosNotifyChannelAdmin::InterFilterGroupOperator ifgop =
+    CosNotifyChannelAdmin::OR_OP;
+
+  consumer_admin_ = ec_->new_for_consumers (ifgop, adminid ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (CORBA::is_nil (consumer_admin_.in()))
+    {
+      ACE_ERROR ((LM_ERROR,
+                         " (%P|%t) Unable to find supplier admin\n"));
+      return;
+    }
+
+  if (TAO_debug_level)
+   ACE_DEBUG ((LM_DEBUG,
+               "created consumer admin\n"));
+}
+
+void
+LifeCycle::destroy_supplier_admin (ACE_ENV_SINGLE_ARG_DECL)
+{
+  this->supplier_admin_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG,
+                "destroyed supplier admin\n"));
+}
+
+void
+LifeCycle::destroy_consumer_admin (ACE_ENV_SINGLE_ARG_DECL)
+{
+  this->consumer_admin_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG,
+                "destroyed consumer admin\n"));
+}
+
+void
+LifeCycle::destroy_ec (ACE_ENV_SINGLE_ARG_DECL)
+{
+  this->ec_->destroy (ACE_ENV_SINGLE_ARG_PARAMETER);
+  ACE_CHECK;
+
+  if (TAO_debug_level)
+    ACE_DEBUG ((LM_DEBUG,
+                "destroyed event channel\n"));
+}
+
+
+int
+main (int argc, char *argv[])
+{
+  ACE_DECLARE_NEW_CORBA_ENV;
+  ACE_TRY
+    {
+      LifeCycle test;
+
+      test.parse_args (argc,
+                       argv);
+
+      test.init (argc,
+                 argv
+                 ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      test.run_test (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+    }
+  ACE_CATCHANY
+    {
+      ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, "Error: ");
+      return 1;
+    }
+  ACE_ENDTRY;
+
+  return 0;
+}