1 files changed, 109 insertions, 0 deletions
diff --git a/TAO/orbsvcs/tests/Notify/lib/Periodic_Supplier.h b/TAO/orbsvcs/tests/Notify/lib/Periodic_Supplier.h
new file mode 100644
index 00000000000..f492038635d
--- /dev/null
+++ b/TAO/orbsvcs/tests/Notify/lib/Periodic_Supplier.h
@@ -0,0 +1,109 @@
+/* -*- C++ -*- */
+/**
+ *  @file NS_Periodic_Supplier.h
+ *
+ *  $Id$
+ *
+ *  @author Pradeep Gore <pradeep@oomworks.com>
+ *
+ *
+ */
+
+#ifndef TAO_NS_PERIODIC_SUPPLIER_H
+#define TAO_NS_PERIODIC_SUPPLIER_H
+#include "ace/pre.h"
+
+#include "notify_test_export.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ace/Task.h"
+#include "Notify_StructuredPushSupplier.h"
+#include "Task_Stats.h"
+#include "StructuredEvent.h"
+
+class TAO_NS_Task_Callback;
+class ACE_Barrier;
+class ACE_Arg_Shifter;
+
+/**
+ * @class TAO_NS_Periodic_Supplier
+ *
+ * @brief A Periodic Supplier.
+ *
+ */
+class TAO_NOTIFY_TEST_Export TAO_NS_Periodic_Supplier : public TAO_Notify_StructuredPushSupplier, public ACE_Task <ACE_SYNCH>
+{
+public:
+  /// Constuctor
+  TAO_NS_Periodic_Supplier (void);
+
+  /// Destructor
+  ~TAO_NS_Periodic_Supplier ();
+
+  /// set the helper callback
+  void task_callback(TAO_NS_Task_Callback* client);
+
+  /// Init the state of this object.
+  int init_state (ACE_Arg_Shifter& arg_shifter);
+
+  /// Activate this task, synch on the given barrier.
+  virtual int activate (ACE_Barrier* barrier);
+
+  /// Connect.
+  void connect (CosNotifyChannelAdmin::StructuredProxyPushConsumer_ptr proxy, CosNotifyChannelAdmin::ProxyID proxy_id ACE_ENV_ARG_DECL);
+
+  /// Connect.
+  virtual void connect (CosNotifyChannelAdmin::SupplierAdmin_ptr supplier_admin ACE_ENV_ARG_DECL);
+
+  /// task svc
+  virtual int svc (void);
+
+  /// Dump stats.
+  void dump_stats (ACE_TCHAR* msg);
+
+  /// Offer change.
+  void offer_change (CosNotification::EventTypeSeq &added, CosNotification::EventTypeSeq& removed ACE_ENV_ARG_DECL);
+
+  /// Get the name of the proxy
+  const char* proxy_name (void);
+
+protected:
+  /// The name of the proxy we connect to.
+  ACE_CString proxy_name_;
+
+  /// All tasks synch at this barrier.
+  ACE_Barrier* barrier_;
+
+  /// The event to send.
+  TAO_NS_StructuredEvent event_;
+
+  /// The priority of this task.
+  CORBA::Short priority_;
+
+  /// Period
+  long period_;
+
+  /// Worst case exec. time.
+  unsigned long exec_time_;
+
+  /// Phase
+  long phase_;
+
+  /// Number of times to exec. Job
+  int iter_;
+
+  /// A load factor supplied to each Job.
+  int load_;
+
+  /// Stats house keeping
+  Task_Stats stats_;
+
+  /// Client
+  TAO_NS_Task_Callback* client_;
+};
+
+#include "ace/post.h"
+#endif /* TAO_NS_PERIODIC_SUPPLIER_H */