1 files changed, 90 insertions, 0 deletions
diff --git a/TAO/performance-tests/CSD_Strategy/TestInf/AppHelper.cpp b/TAO/performance-tests/CSD_Strategy/TestInf/AppHelper.cpp
new file mode 100644
index 00000000000..485aea870d1
--- /dev/null
+++ b/TAO/performance-tests/CSD_Strategy/TestInf/AppHelper.cpp
@@ -0,0 +1,90 @@
+// $Id$
+#include "AppHelper.h"
+
+void
+AppHelper::ref_to_file(CORBA::ORB_ptr    orb,
+                       CORBA::Object_ptr obj,
+                       const char*       filename)
+{
+  CORBA::String_var ior = orb->object_to_string(obj);
+
+  FILE* ior_file = ACE_OS::fopen(filename, "w");
+
+  if (ior_file == 0)
+    {
+      ACE_ERROR((LM_ERROR,
+                 "(%P|%t) Cannot open output file [%s] to write IOR.",
+                 filename));
+      throw TestAppException();
+    }
+
+  ACE_OS::fprintf(ior_file, "%s", ior.in());
+  ACE_OS::fclose(ior_file);
+}
+
+
+PortableServer::POA_ptr
+AppHelper::create_poa(const char*                    name,
+                      PortableServer::POA_ptr        root_poa,
+                      PortableServer::POAManager_ptr mgr,
+                      CORBA::PolicyList&             policies)
+{
+  PortableServer::POA_var child_poa = root_poa->create_POA(name,
+                                                           mgr,
+                                                           policies);
+
+  if (CORBA::is_nil(child_poa.in()))
+    {
+      ACE_ERROR((LM_ERROR,
+                 "(%P|%t) Failed to create child POA: %s.\n", name));
+      throw TestAppException();
+    }
+
+  return child_poa._retn();
+}
+
+
+CORBA::Object_ptr
+AppHelper::activate_servant(PortableServer::POA_ptr poa,
+                            PortableServer::Servant servant)
+{
+  // Activate the servant using the Child POA.
+  PortableServer::ObjectId_var oid
+    = poa->activate_object(servant);
+
+  CORBA::Object_var obj
+    = poa->servant_to_reference(servant);
+
+  if (CORBA::is_nil(obj.in()))
+    {
+      ACE_ERROR((LM_ERROR,
+                 "(%P|%t) Failed to convert servant_to_ref.\n"));
+      throw TestAppException();
+    }
+
+  return obj._retn();
+}
+
+
+bool
+AppHelper::validate_connection (CORBA::Object_ptr obj)
+{
+  for (CORBA::ULong j = 0; j != 100; ++j)
+    {
+      try
+        {
+#if (TAO_HAS_CORBA_MESSAGING == 1)
+          CORBA::PolicyList_var unused;
+          obj->_validate_connection (unused);
+#else
+          obj->_is_a ("Not_An_IDL_Type");
+#endif /* TAO_HAS_MESSAGING == 1 */
+          return true;
+        }
+      catch (const CORBA::Exception&)
+        {
+        }
+    }
+
+  return false;
+}