1 files changed, 125 insertions, 0 deletions
diff --git a/ACE/TAO/orbsvcs/tests/FtRtEvent/supplier.cpp b/ACE/TAO/orbsvcs/tests/FtRtEvent/supplier.cpp
new file mode 100644
index 00000000000..a17ddeb4ba1
--- /dev/null
+++ b/ACE/TAO/orbsvcs/tests/FtRtEvent/supplier.cpp
@@ -0,0 +1,125 @@
+// $Id$
+#include "orbsvcs/CosNamingC.h"
+#include "orbsvcs/FtRtecEventChannelAdminC.h"
+#include "PushSupplier.h"
+#include "ace/Get_Opt.h"
+#include "ace/Auto_Ptr.h"
+#include "ace/OS_NS_stdlib.h"
+#include "orbsvcs/FtRtEvent/Utils/resolve_init.h"
+#include "orbsvcs/FtRtEvent/Utils/FTEC_Gateway.h"
+
+/// include this file to statically linked with FT ORB
+#include "orbsvcs/FaultTolerance/FT_ClientService_Activate.h"
+
+/// include this file to statically linked with Transaction Depth
+#include "orbsvcs/FtRtEvent/ClientORB/FTRT_ClientORB_Loader.h"
+
+ACE_RCSID (FtRtEvent,
+           supplier,
+           "$Id$")
+
+ACE_Time_Value timer_interval(1,0);
+CORBA::ORB_var orb;
+auto_ptr<TAO_FTRTEC::FTEC_Gateway> gateway;
+
+RtecEventChannelAdmin::EventChannel_ptr
+get_event_channel(int argc, ACE_TCHAR** argv)
+{
+    FtRtecEventChannelAdmin::EventChannel_var channel;
+    ACE_Get_Opt get_opt (argc, argv, ACE_TEXT("hi:nt:?"));
+    int opt;
+    int use_gateway = 1;
+
+    while ((opt = get_opt ()) != EOF)
+    {
+      switch (opt)
+      {
+      case 'i':
+        {
+          CORBA::Object_var obj = orb->string_to_object(get_opt.opt_arg ());
+          channel = FtRtecEventChannelAdmin::EventChannel::_narrow(obj.in());
+        }
+        break;
+      case 'n':
+        use_gateway = 0;
+        break;
+      case 't':
+        timer_interval.set(ACE_OS::atof(get_opt.opt_arg ()));
+      case 'h':
+      case '?':
+        ACE_DEBUG((LM_DEBUG,
+                   ACE_TEXT("Usage: %s ")
+                   ACE_TEXT("-i ftrt_eventchannel_ior\n")
+                   ACE_TEXT("-n       do not use gateway\n")
+                   ACE_TEXT("-t time  Time interval in seconds between events (default 1.0)\n")
+                   ACE_TEXT("\n"),
+                      argv[0]));
+        return 0;
+
+      }
+    }
+
+
+    if (CORBA::is_nil(channel.in()))
+    {
+      /// Find the FTRTEC from the Naming Service
+      CosNaming::Name name(1);
+      name.length(1);
+      name[0].id = CORBA::string_dup("FT_EventService");
+
+      CosNaming::NamingContext_var naming_context =
+        resolve_init<CosNaming::NamingContext>(orb.in(), "NameService");
+
+      channel  = resolve<FtRtecEventChannelAdmin::EventChannel> (naming_context.in (),
+        name);
+    }
+
+    if (use_gateway)
+    {
+      // use local gateway to communicate with FTRTEC
+      ACE_AUTO_PTR_RESET (gateway, new TAO_FTRTEC::FTEC_Gateway (orb.in (), channel.in ()), TAO_FTRTEC::FTEC_Gateway);
+      return gateway->_this ();
+    }
+    else
+      return channel._retn ();
+}
+
+
+int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+  try{
+    orb = CORBA::ORB_init (argc, argv);
+
+
+    RtecEventChannelAdmin::EventChannel_var channel
+      = get_event_channel (argc, argv);
+
+
+    if (CORBA::is_nil (channel.in ()))
+       return -1;
+
+    PortableServer::POA_var poa =
+      resolve_init<PortableServer::POA> (orb.in (), "RootPOA");
+
+    PortableServer::POAManager_var mgr = poa->the_POAManager ();
+
+    mgr->activate ();
+
+    PushSupplier_impl push_supplier(orb.in ());
+    if (push_supplier.init(channel.in ()) == -1)
+      return -1;
+
+    RtecEventComm::PushSupplier_var
+      supplier = push_supplier._this();
+
+
+    orb->run();
+
+  }
+  catch (const CORBA::Exception& ex){
+      ex._tao_print_exception ("A CORBA Exception occurred.");
+  }
+
+
+  return 0;
+}