1 files changed, 225 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/Notify/Structured_Filter/Structured_Supplier.cpp b/TAO/orbsvcs/tests/Notify/Structured_Filter/Structured_Supplier.cpp
new file mode 100644
index 00000000000..90c355b6eaa
--- /dev/null
+++ b/TAO/orbsvcs/tests/Notify/Structured_Filter/Structured_Supplier.cpp
@@ -0,0 +1,225 @@
+// $Id$
+
+// ******************************************************************
+// Include Section
+// ******************************************************************
+
+#include "orbsvcs/CosNotifyChannelAdminS.h"
+#include "orbsvcs/CosNotifyCommC.h"
+#include "orbsvcs/CosNamingC.h"
+#include "Notify_StructuredPushSupplier.h"
+#include "controlS.h"
+#include "Notify_Test_Client.h"
+
+// ******************************************************************
+// Data Section
+// ******************************************************************
+
+static const int max_events = 100;
+static CORBA::Boolean go = 0;
+static CORBA::Short n_events = 1;
+static const char* ior_file = "supplier.ior";
+static TAO_Notify_StructuredPushSupplier* supplier = 0;
+
+// ******************************************************************
+// Subroutine Section
+// ******************************************************************
+
+class supplier_ctrl_i : public POA_supplier_ctrl
+{
+public:
+  void ctrl (CORBA::Boolean flag,
+             CORBA::Short num_events
+             TAO_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+};
+
+
+void
+supplier_ctrl_i::ctrl (CORBA::Boolean flag,
+                       CORBA::Short num_events
+                       TAO_ENV_ARG_DECL_NOT_USED /*TAO_ENV_SINGLE_ARG_PARAMETER*/)
+  ACE_THROW_SPEC ((CORBA::SystemException))
+{
+  go = flag;
+  n_events = num_events;
+}
+
+
+static CosNotifyChannelAdmin::SupplierAdmin_ptr
+create_supplieradmin (CosNotifyChannelAdmin::EventChannel_ptr ec
+                      TAO_ENV_ARG_DECL)
+{
+  CosNotifyChannelAdmin::AdminID adminid = 0;
+  CosNotifyChannelAdmin::SupplierAdmin_var admin =
+    ec->new_for_suppliers (CosNotifyChannelAdmin::AND_OP,
+                           adminid
+                           TAO_ENV_ARG_PARAMETER);
+  ACE_CHECK_RETURN (0);
+
+  return CosNotifyChannelAdmin::SupplierAdmin::_duplicate (admin.in ());
+}
+
+int
+setup_event ()
+{
+  static int count = 0;
+
+  CosNotification::StructuredEvent event;
+
+   event.header.fixed_header.event_type.domain_name =
+     CORBA::string_dup ("TAO Test Suite");
+   event.header.fixed_header.event_type.type_name =
+     CORBA::string_dup ("Filtered Structured Event Notification Svc test");
+
+   if (count % 3 == 0)
+    {
+      event.header.fixed_header.event_name = CORBA::string_dup ("String test event");
+      event.header.variable_header.length (1);
+
+      event.filterable_data.length (2);
+      event.filterable_data[0].name = CORBA::string_dup ("String");
+      event.filterable_data[0].value <<= "One Hundred";
+      event.filterable_data[1].name = CORBA::string_dup ("seq");
+      event.filterable_data[1].value <<= (CORBA::Short) count;
+    }
+   else if (count % 3 == 1)
+    {
+      event.header.fixed_header.event_name = CORBA::string_dup ("Short test event");
+      event.header.variable_header.length (1);
+
+      event.filterable_data.length (2);
+      event.filterable_data[0].name = CORBA::string_dup ("Number");
+      event.filterable_data[0].value <<= (CORBA::Short) 100;
+      event.filterable_data[1].name = CORBA::string_dup ("seq");
+      event.filterable_data[1].value <<= (CORBA::Short) count;
+    }
+   else
+    {
+      event.header.fixed_header.event_name = CORBA::string_dup ("Short test event");
+      event.header.variable_header.length (1);
+
+      event.filterable_data.length (2);
+      event.filterable_data[0].name = CORBA::string_dup ("Number");
+      event.filterable_data[0].value <<= (CORBA::Short) 50;
+      event.filterable_data[1].name = CORBA::string_dup ("seq");
+      event.filterable_data[1].value <<= (CORBA::Short) count;
+    }
+
+  count++;
+
+  ACE_TRY_NEW_ENV
+    {
+      ACE_DEBUG ((LM_DEBUG, "%d sent \n", count));
+      supplier->send_event (event TAO_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+    }
+  ACE_CATCH (CORBA::Exception, e)
+    {
+      ACE_PRINT_EXCEPTION (e, "Supplier Signal Exception: ");
+    }
+  ACE_ENDTRY;
+
+  return 0;
+}
+
+static void create_supplier (CosNotifyChannelAdmin::SupplierAdmin_ptr admin,
+                             PortableServer::POA_ptr poa
+                             TAO_ENV_ARG_DECL)
+{
+  ACE_NEW_THROW_EX (supplier,
+                    TAO_Notify_StructuredPushSupplier (),
+                    CORBA::NO_MEMORY ());
+
+  supplier->init (poa TAO_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+
+  supplier->connect (admin TAO_ENV_ARG_PARAMETER);
+  ACE_CHECK;
+}
+
+// ******************************************************************
+// Main Section
+// ******************************************************************
+
+int main (int argc, char * argv[])
+{
+  int status = 0;
+
+  ACE_TRY_NEW_ENV;
+    {
+      Notify_Test_Client client;
+      client.init (argc, argv TAO_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      PortableServer::POA_ptr poa = client.root_poa ();
+
+      CosNotifyChannelAdmin::EventChannel_var ec =
+               client.create_event_channel ("NotifyEventChannelFactory",
+                                            0
+                                            TAO_ENV_ARG_PARAMETER);
+      ACE_TRY_CHECK;
+
+      // register control with naming service
+      supplier_ctrl_i controller;
+
+      CosNaming::Name ctrl_name (1);
+      ctrl_name.length (1);
+      ctrl_name[0].id = CORBA::string_dup ("Supplier");
+
+      PortableServer::ObjectId_var oid =
+        poa->activate_object (&controller);
+
+      CosNaming::NamingContext_ptr naming_context =
+                                      client.naming_context ();
+
+      CORBA::Object_var controller_obj = poa->id_to_reference (oid.in ());
+      naming_context->bind (ctrl_name, controller_obj.in ());
+
+      int done = 0;
+
+      CosNotifyChannelAdmin::SupplierAdmin_var admin =
+        create_supplieradmin (ec.in () TAO_ENV_ARG_PARAMETER);
+
+      if (!CORBA::is_nil (admin.in ()))
+        {
+          create_supplier (admin.in (), client.root_poa () TAO_ENV_ARG_PARAMETER);
+
+          // Ready. So Write ior to file
+          CORBA::ORB_ptr orb = client.orb ();
+          CORBA::String_var ior = orb->object_to_string (controller_obj.in ());
+          FILE *fd = ACE_OS::fopen (ior_file, "w");
+          if (fd == 0)
+            ACE_ERROR_RETURN ((LM_ERROR,
+                               "Cannot open output file for "
+                               "writing IOR: %s",
+                               ior_file),
+                               1);
+          ACE_OS::fprintf (fd, "%s", ior.in ());
+          ACE_OS::fclose (fd);
+          ACE_DEBUG ((LM_DEBUG, "Supplier Ready.\n"));
+
+          while ((!done) && (n_events > 0))
+            {
+              if (go)
+                {
+                  done = setup_event ();
+                  n_events--;
+                }
+
+              if (orb->work_pending ())
+                orb->perform_work ();
+            }
+
+          orb->destroy ();
+        }
+    }
+  ACE_CATCH (CORBA::Exception, e)
+    {
+      ACE_PRINT_EXCEPTION (e, "Supplier Exception: ");
+      status =  1;
+    }
+  ACE_ENDTRY;
+
+ return status;
+}