1 files changed, 102 insertions, 0 deletions
diff --git a/trunk/TAO/tests/CSD_Strategy_Tests/TP_Common/AppHelper.cpp b/trunk/TAO/tests/CSD_Strategy_Tests/TP_Common/AppHelper.cpp
new file mode 100644
index 00000000000..db2d1ec202e
--- /dev/null
+++ b/trunk/TAO/tests/CSD_Strategy_Tests/TP_Common/AppHelper.cpp
@@ -0,0 +1,102 @@
+// $Id$
+#include "AppHelper.h"
+
+void
+AppHelper::ref_to_file(CORBA::ORB_ptr    orb,
+                       CORBA::Object_ptr obj,
+                       const char*       filename
+                       ACE_ENV_ARG_DECL)
+{
+  CORBA::String_var ior = orb->object_to_string(obj);
+
+  FILE* ior_file = ACE_OS::fopen(filename, (const ACE_TCHAR *)("w"));
+
+  if (ior_file == 0)
+    {
+      ACE_ERROR((LM_ERROR,
+                 "(%P|%t) Cannot open output file [%s] to write IOR.",
+                 filename));
+      ACE_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
+                      ACE_ENV_ARG_DECL)
+{
+  PortableServer::POA_var child_poa = root_poa->create_POA(name,
+                                                           mgr,
+                                                           policies
+                                                           ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK_RETURN (PortableServer::POA::_nil ());
+
+  if (CORBA::is_nil(child_poa.in()))
+    {
+      ACE_ERROR((LM_ERROR,
+                 "(%P|%t) Failed to create child POA: %s.\n", name));
+      ACE_THROW_RETURN (TestAppException(), PortableServer::POA::_nil ());
+    }
+
+  return child_poa._retn();
+}
+
+
+CORBA::Object_ptr
+AppHelper::activate_servant(PortableServer::POA_ptr poa,
+                            PortableServer::Servant servant
+                            ACE_ENV_ARG_DECL)
+{
+  // Activate the servant using the Child POA.
+  PortableServer::ObjectId_var oid 
+    = poa->activate_object(servant ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK_RETURN (CORBA::Object::_nil ());
+ 
+  CORBA::Object_var obj 
+    = poa->servant_to_reference(servant ACE_ENV_ARG_PARAMETER);
+  ACE_CHECK_RETURN (CORBA::Object::_nil ());
+
+  if (CORBA::is_nil(obj.in()))
+    {
+      ACE_ERROR((LM_ERROR,
+                 "(%P|%t) Failed to convert servant_to_ref.\n"));
+      ACE_THROW_RETURN (TestAppException(), CORBA::Object::_nil ());
+    }
+
+  return obj._retn();
+}
+
+
+bool
+AppHelper::validate_connection (CORBA::Object_ptr obj)
+{
+  for (CORBA::ULong j = 0; j != 100; ++j)
+    {
+      ACE_TRY_NEW_ENV
+        {
+#if (TAO_HAS_CORBA_MESSAGING == 1)
+          CORBA::PolicyList_var unused;
+          obj->_validate_connection (unused
+                                     ACE_ENV_ARG_PARAMETER);
+          ACE_TRY_CHECK;
+#else
+          obj->_is_a ("Not_An_IDL_Type"
+                      ACE_ENV_ARG_PARAMETER);
+          ACE_TRY_CHECK;
+#endif /* TAO_HAS_MESSAGING == 1 */
+          return true;
+        }
+      ACE_CATCHANY
+        {
+        }
+      ACE_ENDTRY;
+    }
+
+  return false;
+}