1 files changed, 44 insertions, 0 deletions
diff --git a/ACE/examples/ASX/Event_Server/Event_Server/Event_Analyzer.h b/ACE/examples/ASX/Event_Server/Event_Server/Event_Analyzer.h
new file mode 100644
index 00000000000..d4f88c8b68d
--- /dev/null
+++ b/ACE/examples/ASX/Event_Server/Event_Server/Event_Analyzer.h
@@ -0,0 +1,44 @@
+/* -*- C++ -*- */
+// $Id$
+
+#ifndef _EVENT_ANALYZER_H
+#define _EVENT_ANALYZER_H
+
+#include "ace/Stream.h"
+
+#if !defined (ACE_LACKS_PRAGMA_ONCE)
+# pragma once
+#endif /* ACE_LACKS_PRAGMA_ONCE */
+
+#include "ace/Module.h"
+#include "ace/Task.h"
+
+class Event_Analyzer : public ACE_Task<ACE_SYNCH>
+{
+  // = TITLE
+  //     This class forwards all the <ACE_Message_Block>s it receives
+  //     onto its neighboring Module in the Stream.
+  //
+  // = DESCRIPTION
+  //     In a "real" event service, application-specific processing
+  //     would be done in the <put> (or <svc>) method in this class.
+public:
+  // = Initialization hooks called by <ACE_Stream> (not used).
+  virtual int open (void *a = 0);
+  virtual int close (u_long flags = 0);
+
+  virtual int put (ACE_Message_Block *msg,
+                   ACE_Time_Value * = 0);
+  // Entry point into this task.
+
+  // Dynamic linking hooks (not used).
+  virtual int init (int argc, ACE_TCHAR *argv[]);
+  virtual int fini (void);
+  virtual int info (ACE_TCHAR **info_string,
+                    size_t length) const;
+private:
+  virtual int control (ACE_Message_Block *);
+  // Implements the watermark control processing.
+};
+
+#endif /* _EVENT_ANALYZER_H */