1 files changed, 322 insertions, 0 deletions
diff --git a/ACE/tests/Naming_Test.cpp b/ACE/tests/Naming_Test.cpp
new file mode 100644
index 00000000000..1a905291184
--- /dev/null
+++ b/ACE/tests/Naming_Test.cpp
@@ -0,0 +1,322 @@
+// $Id$
+
+// ============================================================================
+//
+// = LIBRARY
+//    tests
+//
+// = FILENAME
+//    Naming_Test.cpp
+//
+// = DESCRIPTION
+//      This is a test to illustrate the Naming Services. The test
+//      does binds, rebinds, finds, and unbinds on name bindings using
+//      the local naming context.
+//
+// = AUTHOR
+//    Prashant Jain <pjain@cs.wustl.edu> and Irfan Pyarali <irfan@cs.wustl.edu>
+//
+// ============================================================================
+
+#include "test_config.h"
+#include "randomize.h"
+#include "ace/ACE.h"
+#include "ace/SString.h"
+#include "ace/Naming_Context.h"
+#include "ace/Profile_Timer.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/OS_NS_string.h"
+#include "ace/OS_NS_unistd.h"
+
+ACE_RCSID(tests, Naming_Test, "$Id$")
+
+static char name[BUFSIZ];
+static char value[BUFSIZ];
+static char type[BUFSIZ];
+
+void
+initialize_array (int * array, int size)
+{
+  for (int n = 0; n < size; ++n)
+    array[n] = n;
+}
+
+static void
+print_time (ACE_Profile_Timer &timer,
+            const char *test)
+{
+  ACE_Profile_Timer::ACE_Elapsed_Time et;
+  timer.stop ();
+  timer.elapsed_time (et);
+
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("     *****  %C  *****     \n"), test));
+  ACE_DEBUG ((LM_DEBUG,
+              ACE_TEXT ("real time = %f secs, user time = %f secs, system time = %f secs\n"),
+              et.real_time, et.user_time, et.system_time));
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("time per call = %f usecs\n"),
+              (et.real_time / double (ACE_NS_MAX_ENTRIES)) * 1000000));
+}
+
+static void
+test_bind (ACE_Naming_Context &ns_context)
+{
+  int array [ACE_NS_MAX_ENTRIES];
+
+  initialize_array (array, sizeof (array) / sizeof (array[0]));
+  randomize (array, sizeof (array) / sizeof (array[0]));
+
+  // do the binds
+  for (size_t i = 0; i < ACE_NS_MAX_ENTRIES; i++)
+    {
+      ACE_OS::sprintf (name, "%s%d", "name", array[i]);
+      ACE_NS_WString w_name (name);
+
+      ACE_OS::sprintf (value, "%s%d", "value", array[i]);
+      ACE_NS_WString w_value (value);
+
+      ACE_OS::sprintf (type, "%s%d", "type", array [i]);
+      int bind_result = ns_context.bind (w_name, w_value, type);
+      ACE_ASSERT (bind_result != -1);
+    }
+}
+
+static void
+test_find_failure (ACE_Naming_Context &ns_context)
+{
+  ACE_OS::sprintf (name, "%s", "foo-bar");
+  ACE_NS_WString w_name (name);
+  ACE_NS_WString w_value;
+  char *l_type = 0;
+
+  // Do the finds.
+  for (size_t i = 0; i < ACE_NS_MAX_ENTRIES; i++)
+    {
+      int resolve = ns_context.resolve (w_name, w_value, l_type);
+      ACE_ASSERT (resolve == -1);
+    }
+}
+
+static void
+test_rebind (ACE_Naming_Context &ns_context)
+{
+  int array [ACE_NS_MAX_ENTRIES];
+
+  initialize_array (array, sizeof (array) / sizeof (array[0]));
+  randomize (array, sizeof (array) / sizeof (array[0]));
+
+  // do the rebinds
+  for (size_t i = 0; i < ACE_NS_MAX_ENTRIES; i++)
+    {
+      ACE_OS::sprintf (name, "%s%d", "name", array[i]);
+      ACE_NS_WString w_name (name);
+
+      ACE_OS::sprintf (value, "%s%d", "value", -array[i]);
+      ACE_NS_WString w_value (value);
+
+      ACE_OS::sprintf (type, "%s%d", "type", -array[i]);
+      int rebind = ns_context.rebind (w_name, w_value, type);
+      ACE_ASSERT (rebind != -1);
+    }
+}
+
+static void
+test_unbind (ACE_Naming_Context &ns_context)
+{
+  int array [ACE_NS_MAX_ENTRIES];
+
+  initialize_array (array, sizeof (array) / sizeof (array[0]));
+  randomize (array, sizeof (array) / sizeof (array[0]));
+
+  // do the unbinds
+  for (size_t i = 0; i < ACE_NS_MAX_ENTRIES; i++)
+    {
+      ACE_OS::sprintf (name, "%s%d", "name", array[i]);
+      ACE_NS_WString w_name (name);
+      int unbind = ns_context.unbind (w_name);
+      ACE_ASSERT (unbind != -1);
+    }
+}
+
+static void
+test_find (ACE_Naming_Context &ns_context, int sign, int result)
+{
+  char temp_val[BUFSIZ];
+  char temp_type[BUFSIZ];
+
+  int array [ACE_NS_MAX_ENTRIES];
+
+  initialize_array (array, sizeof (array) / sizeof (array[0]));
+  randomize (array, sizeof (array) / sizeof (array[0]));
+
+  // do the finds
+  for (size_t i = 0; i < ACE_NS_MAX_ENTRIES; i++)
+    {
+      if (sign == 1)
+        {
+          ACE_OS::sprintf (temp_val, "%s%d", "value", array[i]);
+          ACE_OS::sprintf (temp_type, "%s%d", "type", array[i]);
+        }
+      else
+        {
+          ACE_OS::sprintf (temp_val, "%s%d", "value", -array[i]);
+          ACE_OS::sprintf (temp_type, "%s%d", "type", -array[i]);
+        }
+
+      ACE_OS::sprintf (name, "%s%d", "name", array[i]);
+
+      ACE_NS_WString w_name (name);
+      ACE_NS_WString w_value;
+      char *type_out = 0;
+      ACE_NS_WString val (temp_val);
+
+      int const resolve_result = ns_context.resolve (w_name, w_value, type_out);
+      if (resolve_result != result)
+        ACE_ERROR ((LM_ERROR,
+                    ACE_TEXT ("Error, resolve result not equal to resutlt (%d != %d)\n"),
+                    resolve_result, result));
+
+      char *l_value = w_value.char_rep ();
+
+      if (l_value)
+        {
+          ACE_ASSERT (w_value == val);
+          if (ns_context.name_options ()->debug ())
+            {
+              if (type_out)
+                ACE_DEBUG ((LM_DEBUG,
+                            ACE_TEXT ("Name: %C\tValue: %C\tType: %C\n"),
+                            name, l_value, type_out));
+              else
+                ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("Name: %C\tValue: %C\n"),
+                            name, l_value));
+            }
+
+          if (type_out)
+            {
+              ACE_ASSERT (ACE_OS::strcmp (type_out, temp_type) == 0);
+              delete[] type_out;
+            }
+        }
+
+      delete[] l_value;
+    }
+}
+
+
+int
+run_main (int argc, ACE_TCHAR *argv[])
+{
+  ACE_START_TEST (ACE_TEXT ("Naming_Test"));
+  ACE_TCHAR temp_file [BUFSIZ];
+  ACE_Naming_Context *ns_context = 0;
+  ACE_NEW_RETURN (ns_context, ACE_Naming_Context, -1);
+
+  ACE_Name_Options *name_options = ns_context->name_options ();
+
+  name_options->parse_args (argc, argv);
+  /*
+  ** NOTE! This is an experimental value and is not magic in any way. It
+  ** works for me, on one system. It's needed because in the particular
+  ** case here where the underlying mmap will allocate a small area and
+  ** then try to grow it, it always moves it to a new location, which
+  ** totally screws things up. I once tried forcing the realloc to do
+  ** MAP_FIXED but that's not a good solution since it may overwrite other
+  ** mapped areas of memory, like the heap, or the C library, and get very
+  ** unexpected results.    (Steve Huston, 24-August-2007)
+  */
+# if defined (linux) && defined (__x86_64__)
+  name_options->base_address ((char*)0x3c00000000);
+#endif
+  int unicode = 0;
+#if (defined (ACE_WIN32) && defined (ACE_USES_WCHAR))
+  unicode = 1;
+#endif /* ACE_WIN32 && ACE_USES_WCHAR */
+  if (unicode && name_options->use_registry () == 1)
+    {
+      name_options->namespace_dir (ACE_TEXT ("Software\\ACE\\Name Service"));
+      name_options->database (ACE_TEXT ("Version 1"));
+    }
+  else
+    {
+      // Allow the user to determine where the context file will be
+      // located just in case the current directory is not suitable for
+      // locking.  We don't just set namespace_dir () on name_options
+      // because that is not sufficient to work around locking problems
+      // for Tru64 when the current directory is NFS mounted from a
+      // system that does not properly support locking.
+      const char* temp_envs[] = { "TMPDIR", "TEMP", "TMP", 0 };
+      for(const char** temp_env = temp_envs; *temp_env != 0; ++temp_env)
+        {
+          char* temp_dir = ACE_OS::getenv(*temp_env);
+          if (temp_dir != 0)
+            {
+              ACE_OS::chdir (temp_dir);
+              break;
+            }
+        }
+      ACE_OS::strcpy (temp_file, ACE::basename (name_options->process_name (),
+                                                ACE_DIRECTORY_SEPARATOR_CHAR));
+      ACE_OS::strcat (temp_file, ACE_TEXT ("XXXXXX"));
+
+      // Set the database name using mktemp to generate a unique file name
+      name_options->database (ACE_OS::mktemp (temp_file));
+    }
+
+  if (ns_context->open (ACE_Naming_Context::PROC_LOCAL, 1) == -1)
+    {
+      ACE_ERROR_RETURN ((LM_ERROR,
+                         ACE_TEXT ("ns_context->open (PROC_LOCAL) %p\n"),
+                         ACE_TEXT ("failed")),
+                        -1);
+    }
+
+  ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("time to test %d iterations using %s\n"),
+              ACE_NS_MAX_ENTRIES, name_options->use_registry () ?
+              ACE_TEXT ("Registry") : ACE_TEXT ("ACE")));
+
+  ACE_Profile_Timer timer;
+
+  timer.start ();
+  // Add some bindings to the database
+  test_bind (*ns_context);
+  print_time (timer, "Binds");
+
+  timer.start ();
+  // Should find the entries
+  test_find (*ns_context, 1, 0);
+  print_time (timer, "Successful Finds");
+
+  timer.start ();
+  // Rebind with negative values
+  test_rebind (*ns_context);
+  print_time (timer, "Rebinds");
+
+  timer.start ();
+  // Should find the entries
+  test_find (*ns_context,  -1, 0);
+  print_time (timer, "Successful Finds");
+
+  timer.start ();
+  // Should not find the entries
+  test_find_failure (*ns_context);
+  print_time (timer, "UnSuccessful Finds");
+
+  timer.start ();
+  // Remove all bindings from database
+  test_unbind (*ns_context);
+  print_time (timer, "Unbinds");
+
+  ACE_OS::sprintf (temp_file, ACE_TEXT ("%s%s%s"),
+                   name_options->namespace_dir (),
+                   ACE_DIRECTORY_SEPARATOR_STR,
+                   name_options->database ());
+
+  delete ns_context;
+
+  // Remove any existing files.  No need to check return value here
+  // since we don't care if the file doesn't exist.
+  ACE_OS::unlink (temp_file);
+
+  ACE_END_TEST;
+  return 0;
+}