1 files changed, 126 insertions, 0 deletions
diff --git a/TAO/tests/SHMIOP/shmiop_test.cpp b/TAO/tests/SHMIOP/shmiop_test.cpp
new file mode 100644
index 00000000000..dfbd3699508
--- /dev/null
+++ b/TAO/tests/SHMIOP/shmiop_test.cpp
@@ -0,0 +1,126 @@
+#include "TestS.h"
+
+#include "tao/Strategies/advanced_resource.h"
+
+#include "ace/Get_Opt.h"
+#include "ace/OS_NS_stdio.h"
+#include "ace/SString.h"
+#include "ace/Task.h"
+
+struct Servant : virtual POA_Test::Hello
+{
+  explicit Servant (const CORBA::ORB_var &orb)
+    : orb_ (orb)
+  {}
+
+  char *get_string ()
+  {
+    CORBA::String_var str ("hello");
+    return str._retn ();
+  }
+
+  void shutdown ()
+  {
+    this->orb_->shutdown (0);
+  }
+
+  CORBA::ORB_var orb_;
+};
+
+struct ORBTask : ACE_Task_Base
+{
+  explicit ORBTask (const CORBA::ORB_var &orb)
+    : orb_ (orb)
+  {}
+
+  int svc ()
+  {
+    try
+      {
+        this->orb_->run ();
+        return 0;
+      }
+    catch (const CORBA::Exception &e)
+      {
+        e._tao_print_exception ("Exception caught from ORB::run:");
+      }
+    catch (...)
+      {
+        ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR unknown exception caught ")
+                              ACE_TEXT ("from ORB::run\n")));
+      }
+    return 1;
+  }
+
+  CORBA::ORB_var orb_;
+};
+
+int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+  try
+    {
+      CORBA::ORB_var orb = CORBA::ORB_init (argc, argv);
+
+      ACE_Get_Opt opts (argc, argv, ACE_TEXT ("s:c:"));
+      const ACE_TCHAR *server = 0, *client = 0;
+      for (int o; (o = opts ()) != -1;)
+        {
+          switch (o)
+            {
+            case 's':
+              server = opts.opt_arg ();
+              break;
+            case 'c':
+              client = opts.opt_arg ();
+              break;
+            }
+        }
+
+      Servant srv (orb);
+      ORBTask task (orb);
+
+      if (server)
+        {
+          CORBA::Object_var obj = orb->resolve_initial_references ("RootPOA");
+          PortableServer::POA_var poa = PortableServer::POA::_narrow (obj);
+          PortableServer::POAManager_var pm = poa->the_POAManager ();
+          pm->activate ();
+          Test::Hello_var srv_obj = srv._this ();
+          CORBA::String_var srv_str = orb->object_to_string (srv_obj);
+          FILE *f = ACE_OS::fopen (server, "w");
+          ACE_OS::fputs (srv_str, f);
+          ACE_OS::fclose (f);
+          if (!client)
+            task.activate();
+        }
+
+      if (client)
+        {
+          ACE_CString ior ("file://");
+          ior += ACE_TEXT_ALWAYS_CHAR (client);
+          CORBA::Object_var obj = orb->string_to_object (ior.c_str ());
+          Test::Hello_var hello = Test::Hello::_narrow (obj);
+          CORBA::String_var str = hello->get_string ();
+          ACE_DEBUG ((LM_DEBUG, ACE_TEXT ("(%P|%t) - returned <%C>\n"),
+                      str.in ()));
+          hello->shutdown ();
+        }
+      else if (server)
+        {
+          task.wait ();
+        }
+
+      orb->destroy ();
+      return 0;
+    }
+  catch (const CORBA::Exception &e)
+    {
+      e._tao_print_exception ("Exception caught:");
+    }
+  catch (...)
+    {
+      ACE_ERROR ((LM_ERROR, ACE_TEXT ("ERROR unknown exception ")
+                            ACE_TEXT ("caught in main\n")));
+    }
+  return 1;
+}