Mon Jun 23 12:38:54 2003 Rich Seibel <seibel_r@ociweb.com>

1 files changed, 540 insertions, 0 deletions

diff --git a/TAO/orbsvcs/tests/Redundant_Naming/client.cpp b/TAO/orbsvcs/tests/Redundant_Naming/client.cpp
new file mode 100644
index 00000000000..ddcc664fb6e
--- /dev/null
+++ b/TAO/orbsvcs/tests/Redundant_Naming/client.cpp
@@ -0,0 +1,540 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    TAO/orbsvcs/Naming_Service/
+//
+// = FILENAME
+//    client.cpp
+//
+// = DESCRIPTION
+//      This class implements a CORBA client for a redundant CosNaming
+//      Service using stubs generated by the TAO ORB IDL compiler.
+//
+// = AUTHORS
+//      Rich Seibel <seibel_r@ociweb.com>
+// ============================================================================
+
+#include "test_objectS.h"
+#include "orbsvcs/CosNamingC.h"
+#include "orbsvcs/Naming/Naming_Utils.h"
+#include "tao/corba.h"
+#include "tao/PortableServer/ORB_Manager.h"
+#include "tao/debug.h"
+#include "ace/Get_Opt.h"
+
+ACE_RCSID(Simple_Naming, client, "$Id$")
+
+#if defined (_MSC_VER)
+# pragma warning (disable : 4250)
+#endif /* _MSC_VER */
+
+class My_Test_Object :
+  public virtual PortableServer::RefCountServantBase,
+  public virtual POA_Test_Object
+{
+public:
+  // = Initialization and termination methods.
+  My_Test_Object (CORBA::Short id = 0);
+  // Constructor.
+
+  ~My_Test_Object (void);
+  // Destructor.
+
+  // = Interface implementation accessor methods.
+
+  void id (CORBA::Short id ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+  // Sets id.
+
+  CORBA::Short id (ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+  // Gets id.
+
+private:
+  short id_;
+};
+
+My_Test_Object::My_Test_Object (CORBA::Short id)
+  : id_ (id)
+{
+}
+
+My_Test_Object::~My_Test_Object (void)
+{
+}
+
+CORBA::Short
+My_Test_Object::id (ACE_ENV_SINGLE_ARG_DECL_NOT_USED)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  return id_;
+}
+
+void
+My_Test_Object::id (CORBA::Short id ACE_ENV_ARG_DECL_NOT_USED)
+    ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  id_ = id;
+}
+
+
+// This function runs the test.
+
+int
+main (int argc, ACE_TCHAR **argv)
+{
+  int c_breath = 4;
+  int c_depth = 4;
+  int o_breath = 4;
+  ACE_TCHAR *ns1ref;
+  ACE_TCHAR *ns2ref;
+
+  ACE_Get_Opt get_opts (argc, argv, ACE_LIB_TEXT ("b:d:o:p:q:"));
+  int c;
+  int i;
+
+  while ((c = get_opts ()) != -1)
+    switch (c)
+      {
+      case 'b':
+        i = ACE_OS::atoi(get_opts.opt_arg ());
+        if (i<2)
+        {
+          ACE_ERROR((LM_ERROR, 
+                     ACE_LIB_TEXT ("Invalid breath, must be 2 or more\n")));
+          exit(1);
+        }
+        c_breath = i;
+        break;
+      case 'd':
+        i = ACE_OS::atoi(get_opts.opt_arg ());
+        if (i<2)
+        {
+          ACE_ERROR((LM_ERROR, 
+                     ACE_LIB_TEXT ("Invalid depth, must be 2 or more\n")));
+          exit(1);
+        }
+        c_depth = i;
+        break;
+      case 'o':
+        i = ACE_OS::atoi(get_opts.opt_arg ());
+        if (i<2)
+        {
+          ACE_ERROR((LM_ERROR, 
+                     ACE_LIB_TEXT ("Invalid breath, must be 2 or more\n")));
+          exit(1);
+        }
+        o_breath = i;
+        break;
+      case 'p':
+        ns1ref = get_opts.opt_arg ();
+        break;
+      case 'q':
+        ns2ref = get_opts.opt_arg ();
+        break;
+      default:
+        ACE_ERROR_RETURN ((LM_ERROR,
+                           ACE_LIB_TEXT ("Argument %c \n usage:  %s")
+                           ACE_LIB_TEXT (" [-b <breath of context tree>]")
+                           ACE_LIB_TEXT (" [-d <depth of context tree>]")
+                           ACE_LIB_TEXT (" [-o <breath of object tree>]")
+                           ACE_LIB_TEXT (" -p <ior of first name server>")
+                           ACE_LIB_TEXT (" -q <ior of second name server>")
+                           ACE_LIB_TEXT ("\n")),
+                          -1);
+      }
+
+  CosNaming::NamingContext_var root_context_1;
+  CosNaming::NamingContext_var root_context_2;
+
+  ACE_DECLARE_NEW_CORBA_ENV;
+  ACE_TRY_EX(bl_a)
+  {
+    // Initialize orb
+    CORBA::ORB_var orb = CORBA::ORB_init(argc, argv, 0 ACE_ENV_ARG_PARAMETER);
+
+    // ior's are specified for the name servers through a commandline
+    // option or a file.
+
+    // Resolve the first name server
+
+    CORBA::Object_var ns1obj = orb->string_to_object (
+                            ACE_TEXT_ALWAYS_CHAR (ns1ref) ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_a);
+
+    if (CORBA::is_nil (ns1obj.in ()))
+            ACE_ERROR_RETURN ((LM_ERROR,
+                               ACE_LIB_TEXT ("invalid ior <%s>\n"),
+                               ns1ref),
+                              -1);
+    root_context_1 = CosNaming::NamingContext::_narrow (ns1obj.in ()
+                                                        ACE_ENV_ARG_PARAMETER);
+
+    ACE_TRY_CHECK_EX(bl_a);
+
+    // Resolve the second name server
+
+    CORBA::Object_var ns2obj = orb->string_to_object (
+                            ACE_TEXT_ALWAYS_CHAR (ns2ref) ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_a);
+
+    if (CORBA::is_nil (ns2obj.in ()))
+            ACE_ERROR_RETURN ((LM_ERROR,
+                               ACE_LIB_TEXT ("invalid ior <%s>\n"),
+                               ns2ref),
+                              -1);
+    root_context_2 = CosNaming::NamingContext::_narrow (ns2obj.in ()
+                                                        ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_a);
+
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+                         ACE_LIB_TEXT ("Unable to resolve name servers"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  // Create a bunch of objects in one context
+  // Note: strings to the naming service must be char, not wchar
+  ACE_TRY_EX(bl_b)
+  {
+    // Bind one context level under root.
+    CosNaming::Name level1;
+    level1.length (1);
+    level1[0].id = CORBA::string_dup ("level1_context");
+    CosNaming::NamingContext_var level1_context;
+    level1_context = root_context_1->bind_new_context (level1
+                                                       ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_b);
+    for (i=0; i<o_breath; i++)
+    {
+      // Instantiate a dummy object and bind it under the new context.
+      My_Test_Object *impl1 = new My_Test_Object (i+1);
+      Test_Object_var obj1 = impl1->_this (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK_EX(bl_b);
+      impl1->_remove_ref (ACE_ENV_SINGLE_ARG_PARAMETER);
+      ACE_TRY_CHECK_EX(bl_b);
+
+      CosNaming::Name obj_name;
+      obj_name.length (1);
+      char wide_name[16];
+      ACE_OS::sprintf(wide_name, "obj_%d", i);
+      obj_name[0].id = CORBA::string_dup (wide_name);
+      level1_context->bind (obj_name, obj1.in ()
+                            ACE_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK_EX(bl_b);
+    }
+
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+                         ACE_LIB_TEXT ("Unable to create a lot of objects"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  // Create a deep context tree
+  ACE_TRY_EX(bl_c)
+  {
+    CosNaming::NamingContext_var next_context = root_context_1;
+    for (i=0; i<c_depth; i++)
+    {
+      // Bind level1 context under root.
+      CosNaming::Name deep;
+      deep.length (1);
+      char deep_name[16];
+      ACE_OS::sprintf(deep_name, "deep_%d", i);
+      deep[0].id = CORBA::string_dup (deep_name);
+      CosNaming::NamingContext_var deep_context;
+      deep_context = next_context->bind_new_context (deep
+                                                     ACE_ENV_ARG_PARAMETER);
+      next_context = deep_context;
+    ACE_TRY_CHECK_EX(bl_c);
+    }
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+                         ACE_LIB_TEXT ("Unable to create deep context"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  // Create a wide context tree
+  ACE_TRY_EX(bl_d)
+  {
+    for (i=0; i<c_breath; i++)
+    {
+      // Bind all level of context under root.
+      CosNaming::Name wide;
+      wide.length (1);
+      char wide_name[16];
+      ACE_OS::sprintf(wide_name, "wide_%d", i);
+      wide[0].id = CORBA::string_dup (wide_name);
+      CosNaming::NamingContext_var wide_context;
+      wide_context = root_context_1->bind_new_context (wide
+                                                       ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_d);
+    }
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+                         ACE_LIB_TEXT ("Unable to create wide context"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  // Delete three selected things, one from each tree
+  ACE_TRY_EX(bl_e)
+  {
+    // Remove the second to last object from the Naming Context
+    CosNaming::Name wide1;
+    wide1.length (2);
+    wide1[0].id = CORBA::string_dup ("level1_context");
+    char wide_name[16];
+    ACE_OS::sprintf(wide_name, "obj_%d", o_breath-2);
+    wide1[1].id = CORBA::string_dup (wide_name);
+    root_context_1->unbind (wide1 ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+
+    // Remove the second to last context from the wide root Naming Context
+    CosNaming::Name wide2;
+    wide2.length (1);
+    ACE_OS::sprintf(wide_name, "wide_%d", c_breath-2);
+    wide2[0].id = CORBA::string_dup (wide_name);
+    CORBA::Object_var result_obj_ref = root_context_1->resolve (wide2
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+    CosNaming::NamingContext_var result_object = 
+      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
+                                         ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+    if (CORBA::is_nil (result_object.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+                         ACE_LIB_TEXT ("Problems with resolving wide context ")
+                         ACE_LIB_TEXT ("- nil object ref.\n")),
+                         -1);
+    result_object->destroy(ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+    root_context_1->unbind (wide2 ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+
+    // Remove the last context from the deep Naming Context
+    CosNaming::Name deep;
+    deep.length (c_depth);
+    char deep_name[16];
+    for (i=0; i<c_depth; i++)
+    {
+      ACE_OS::sprintf(deep_name, "deep_%d", i);
+      deep[i].id = CORBA::string_dup (deep_name);
+    }
+    result_obj_ref = root_context_1->resolve (deep ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+    result_object = 
+      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
+                                         ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+    if (CORBA::is_nil (result_object.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+                         ACE_LIB_TEXT ("Problems with resolving deep context ")
+                         ACE_LIB_TEXT ("- nil object ref.\n")),
+                         -1);
+    result_object->destroy(ACE_ENV_SINGLE_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+    root_context_1->unbind (deep ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_e);
+
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+                         ACE_LIB_TEXT ("Unable to delete objects"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  // Now use the other name server to access 3 objects next to the
+  // deleted objects and the 3 deleted objects
+  ACE_TRY_EX(bl_f)
+  {
+    // Access the last object from the Naming Context
+    CosNaming::Name wide;
+    wide.length (2);
+    wide[0].id = CORBA::string_dup ("level1_context");
+    char wide_name[16];
+    ACE_OS::sprintf(wide_name, "obj_%d", o_breath-1);
+    wide[1].id = CORBA::string_dup (wide_name);
+    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_f);
+    Test_Object_var result_object = Test_Object::_narrow (result_obj_ref.in ()
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_f);
+    if (CORBA::is_nil (result_object.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+                         ACE_LIB_TEXT ("Problems with resolving object from ")
+                         ACE_LIB_TEXT ("redundant server - nil object ref.\n")),
+                         -1);
+    ACE_TRY_CHECK_EX(bl_f);
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+      ACE_LIB_TEXT ("Unable to resolve object from redundant server"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  ACE_TRY_EX(bl_g)
+  {
+    // Access the deleted second to last object from the Naming Context
+    CosNaming::Name wide;
+    wide.length (2);
+    wide[0].id = CORBA::string_dup ("level1_context");
+    char wide_name[16];
+    ACE_OS::sprintf(wide_name, "obj_%d", o_breath-2);
+    wide[1].id = CORBA::string_dup (wide_name);
+    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_g);
+    ACE_ERROR_RETURN ((LM_ERROR,
+                    ACE_LIB_TEXT ("Problems with resolving object from ")
+                    ACE_LIB_TEXT ("redundant server - deleted object found.\n")),
+                    -1);
+  }
+  ACE_CATCHANY
+  {
+    //expect exception since the context was deleted
+  }
+  ACE_ENDTRY;
+
+  ACE_TRY_EX(bl_h)
+  {
+    // Access the last context from the wide Naming Context
+    CosNaming::Name wide;
+    wide.length (1);
+    char wide_name[16];
+    ACE_OS::sprintf(wide_name, "wide_%d", c_breath-1);
+    wide[0].id = CORBA::string_dup (wide_name);
+    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_h);
+    CosNaming::NamingContext_var result_object = 
+      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
+                                         ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_h);
+    if (CORBA::is_nil (result_object.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+                      ACE_LIB_TEXT ("Problems with resolving wide context from ")
+                      ACE_LIB_TEXT ("redundant server - nil object ref.\n")),
+                      -1);
+    ACE_TRY_CHECK_EX(bl_h);
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+      ACE_LIB_TEXT ("Unable to resolve wide context from redundant server"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  ACE_TRY_EX(bl_i)
+  {
+    // Access the deleted second to last object from the Naming Context
+    CosNaming::Name wide;
+    wide.length (2);
+    char wide_name[16];
+    ACE_OS::sprintf(wide_name, "wide_%d", c_breath-2);
+    wide[0].id = CORBA::string_dup (wide_name);
+    CORBA::Object_var result_obj_ref = root_context_2->resolve (wide
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_i);
+    ACE_ERROR_RETURN ((LM_ERROR,
+                    ACE_LIB_TEXT ("Problems with resolving wide context from ")
+                    ACE_LIB_TEXT ("redundant server - deleted object found.\n")),
+                    -1);
+  }
+  ACE_CATCHANY
+  {
+    //expect exception since the context was deleted
+  }
+  ACE_ENDTRY;
+
+  ACE_TRY_EX(bl_j)
+  {
+    // Access the deleted last context from the deep Naming Context
+    CosNaming::Name deep;
+    deep.length (c_depth);
+    char deep_name[16];
+    for (i=0; i<c_depth; i++)
+    {
+      ACE_OS::sprintf(deep_name, "deep_%d", i);
+      deep[i].id = CORBA::string_dup (deep_name);
+    }
+    CORBA::Object_var result_obj_ref = root_context_1->resolve (deep
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_j);
+    ACE_ERROR_RETURN ((LM_ERROR,
+                    ACE_LIB_TEXT ("Problems with resolving deep context from ")
+                    ACE_LIB_TEXT ("redundant server - deleted object found.\n")),
+                    -1);
+  }
+  ACE_CATCHANY
+  {
+    //expect exception since the context was deleted
+  }
+  ACE_ENDTRY;
+
+  ACE_TRY_EX(bl_k)
+  {
+    // Access the second to last object from the Naming Context
+    CosNaming::Name deep;
+    deep.length (c_depth-1);
+    char deep_name[16];
+    for (i=0; i<c_depth-1; i++)
+    {
+      ACE_OS::sprintf(deep_name, "deep_%d", i);
+      deep[i].id = CORBA::string_dup (deep_name);
+    }
+    CORBA::Object_var result_obj_ref = root_context_1->resolve (deep
+                                                          ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_k);
+    CosNaming::NamingContext_var result_object = 
+      CosNaming::NamingContext::_narrow (result_obj_ref.in ()
+                                         ACE_ENV_ARG_PARAMETER);
+    ACE_TRY_CHECK_EX(bl_k);
+    if (CORBA::is_nil (result_object.in ()))
+      ACE_ERROR_RETURN ((LM_ERROR,
+                      ACE_LIB_TEXT ("Problems with resolving deep context from ")
+                      ACE_LIB_TEXT ("redundant server - nil object ref.\n")),
+                      -1);
+
+    ACE_TRY_CHECK_EX(bl_k);
+
+  }
+  ACE_CATCHANY
+  {
+    ACE_PRINT_EXCEPTION (ACE_ANY_EXCEPTION, 
+      ACE_LIB_TEXT ("Unable to resolve deep context from redundant server"));
+    return -1;
+  }
+  ACE_ENDTRY;
+  ACE_CHECK_RETURN (-1);
+
+  ACE_DEBUG ((LM_DEBUG, ACE_LIB_TEXT ("Redundancy test OK\n")));
+  return 0;
+
+}