1 files changed, 114 insertions, 0 deletions
diff --git a/TAO/tests/CSD_Strategy_Tests/TP_Common/AppHelper.h b/TAO/tests/CSD_Strategy_Tests/TP_Common/AppHelper.h
new file mode 100644
index 00000000000..06a6ac721a2
--- /dev/null
+++ b/TAO/tests/CSD_Strategy_Tests/TP_Common/AppHelper.h
@@ -0,0 +1,114 @@
+// $Id$
+#ifndef APPHELPER_H
+#define APPHELPER_H
+
+#include "CSD_TP_Test_Export.h"
+#include "TestAppExceptionC.h"
+#include "tao/PortableServer/PortableServer.h"
+#include "tao/ORB.h"
+#include "ace/OS.h"
+#include "ace/Log_Msg.h"
+
+
+template <typename T>
+struct RefHelper
+{
+  typedef typename T::_ptr_type T_ptr;
+  typedef typename T::_var_type T_var;
+
+  static T_ptr string_to_ref(CORBA::ORB_ptr orb, 
+                             const char* ior 
+                             ACE_ENV_ARG_DECL)
+  {
+    CORBA::Object_var obj = orb->string_to_object(ior ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN(T::_nil ());
+
+    if (CORBA::is_nil(obj.in()))
+      {
+        ACE_ERROR((LM_ERROR,
+                   "(%P|%t) Failed to convert IOR string to obj ref.\n"));
+        ACE_THROW_RETURN (TestAppException(), T::_nil ());
+      }
+
+    T_var t_obj = T::_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN(T::_nil ());
+
+    if (CORBA::is_nil(t_obj.in()))
+      {
+        ACE_ERROR((LM_ERROR,
+                   "(%P|%t) Failed to narrow obj ref to T interface.\n"));
+        ACE_THROW_RETURN (TestAppException(), T::_nil ());
+      }
+
+    return t_obj._retn();
+  }
+
+  static T_ptr resolve_initial_ref(CORBA::ORB_ptr orb, 
+                                   const char* name
+                                   ACE_ENV_ARG_DECL)
+  {
+    CORBA::Object_var obj 
+      = orb->resolve_initial_references(name ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (T::_nil ());
+
+    if (CORBA::is_nil(obj.in()))
+      {
+        ACE_ERROR((LM_ERROR,
+                   "(%P|%t) Failed to resolve initial ref for '%s'.\n",
+                   name));
+        ACE_THROW_RETURN (TestAppException(), T::_nil ());
+      }
+
+    T_var t_obj = T::_narrow(obj.in() ACE_ENV_ARG_PARAMETER);
+    ACE_CHECK_RETURN (T::_nil ());
+
+
+    if (CORBA::is_nil(t_obj.in()))
+      {
+        ACE_ERROR((LM_ERROR,
+                   "(%P|%t) Failed to narrow resolved initial ref '%s'.\n",
+                   name));
+        ACE_THROW_RETURN (TestAppException(), T::_nil ());
+      }
+
+    return t_obj._retn();
+  }
+
+};
+
+struct CSD_TP_Test_Export AppHelper
+{
+
+  static void ref_to_file(CORBA::ORB_ptr    orb,
+                          CORBA::Object_ptr obj,
+                          const char*       filename
+                          ACE_ENV_ARG_DECL);
+
+  static PortableServer::POA_ptr create_poa
+                              (const char*                    name,
+                               PortableServer::POA_ptr        root_poa,
+                               PortableServer::POAManager_ptr mgr,
+                               CORBA::PolicyList&             policies
+                               ACE_ENV_ARG_DECL);
+
+  static CORBA::Object_ptr activate_servant(PortableServer::POA_ptr poa,
+                                            PortableServer::Servant servant
+                                            ACE_ENV_ARG_DECL);
+
+  // This helper method is used because there is a chance that the
+  // initial CORBA request made to the target ORB will fail during
+  // connection establishment with a TRANSIENT CORBA SystemException.
+  // This occurs for some platforms (ie, windows) when several clients
+  // make their initial CORBA request to the same ORB at the same time,
+  // causing the ORB to attempt to handle several connection establishments
+  // at one time.  Apparently, under certain conditions, it will throw the
+  // TRANSIENT exception to tell the client application to "try again later".
+  // The analogy is making a phone call.  Sometimes you get a busy tone.
+  // This means "try again later".
+  // This helper function will retry until the connection establishment
+  // works - or until it decides that enough is enough.
+  static bool validate_connection (CORBA::Object_ptr obj);
+};
+
+#endif
+