1 files changed, 93 insertions, 0 deletions
diff --git a/trunk/TAO/orbsvcs/examples/Notify/Federation/Gate/Gate.h b/trunk/TAO/orbsvcs/examples/Notify/Federation/Gate/Gate.h
new file mode 100644
index 00000000000..312bb6b5a20
--- /dev/null
+++ b/trunk/TAO/orbsvcs/examples/Notify/Federation/Gate/Gate.h
@@ -0,0 +1,93 @@
+// file      : Gate.h
+// author    : Boris Kolpackov <boris@dre.vanderbilt.edu>
+// cvs-id    : $Id$
+
+#ifndef GATE_H
+#define GATE_H
+
+#include "ace/OS.h"
+#include "ace/INET_Addr.h"
+#include "ace/UUID.h"
+
+#include "ace/Thread_Mutex.h"
+#include "ace/Thread_Manager.h"
+
+#include "tao/corba.h"
+
+#include "orbsvcs/CosNotificationC.h"
+#include "orbsvcs/CosNotifyChannelAdminC.h"
+#include "orbsvcs/CosNotifyCommC.h"
+#include "orbsvcs/CosNotifyCommS.h"
+
+#include "ace/RMCast/Socket.h"
+
+#include "Export.h"
+
+class Gate_Export Gate : public POA_CosNotifyComm::StructuredPushConsumer
+{
+public:
+  virtual
+  ~Gate ();
+
+  Gate (ACE_INET_Addr const& group,
+        CosNotifyChannelAdmin::EventChannel_ptr ch);
+
+  Gate (ACE_INET_Addr const& group,
+        CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin,
+        CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin);
+
+private:
+  void
+  init (CosNotifyChannelAdmin::ConsumerAdmin_ptr consumer_admin,
+        CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin);
+
+  static ACE_THR_FUNC_RETURN
+  tracker_thunk (void* arg);
+
+  void
+  tracker ();
+
+private:
+  // NotifyPublish interface.
+  //
+  virtual void
+  offer_change (CosNotification::EventTypeSeq const&,
+                CosNotification::EventTypeSeq const&
+                ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException,
+                     CosNotifyComm::InvalidEventType));
+
+  // StructuredPushSupplier interface.
+  //
+  virtual void
+  push_structured_event (CosNotification::StructuredEvent const& e
+                         ACE_ENV_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException,
+                     CosEventComm::Disconnected));
+
+
+  virtual void
+  disconnect_structured_push_consumer (ACE_ENV_SINGLE_ARG_DECL)
+    ACE_THROW_SPEC ((CORBA::SystemException));
+
+private:
+  ACE_thread_t thread_;
+
+  CosNotifyChannelAdmin::ProxyID consumer_id_;
+  CosNotifyChannelAdmin::StructuredProxyPushConsumer_var consumer_;
+
+  CosNotifyChannelAdmin::ProxyID supplier_id_;
+  CosNotifyChannelAdmin::StructuredProxyPushSupplier_var supplier_;
+
+  ACE_RMCast::Socket socket_;
+  CORBA::String_var id_;
+
+  typedef ACE_SYNCH_MUTEX Mutex;
+  typedef ACE_Guard<Mutex> Lock;
+
+  bool stop_;
+  Mutex mutex_;
+  ACE_Thread_Manager thread_mgr_;
+};
+
+#endif // GATE_H