1 files changed, 131 insertions, 0 deletions
diff --git a/ACE/examples/C++NPv2/TP_Logging_Server.h b/ACE/examples/C++NPv2/TP_Logging_Server.h
new file mode 100644
index 00000000000..9c4869cdcee
--- /dev/null
+++ b/ACE/examples/C++NPv2/TP_Logging_Server.h
@@ -0,0 +1,131 @@
+/*
+** $Id$
+**
+** Copyright 2002 Addison Wesley. All Rights Reserved.
+*/
+
+#ifndef _TP_LOGGING_SERVER_H
+#define _TP_LOGGING_SERVER_H
+
+#include "ace/Auto_Ptr.h"
+#include "ace/Singleton.h"
+#include "ace/Synch.h"
+#include "ace/Task.h"
+#include "Logging_Acceptor.h"
+#include "Logging_Event_Handler.h"
+#include "Reactor_Logging_Server_T.h"
+#include "TPLS_export.h"
+
+class TP_Logging_Task : public ACE_Task<ACE_SYNCH> {
+         // Instantiated with an MT synchronization trait.
+public:
+  enum { MAX_THREADS = 4 };
+
+  virtual int open (void * = 0)
+  { return activate (THR_NEW_LWP, MAX_THREADS); }
+
+  virtual int put (ACE_Message_Block *mblk,
+                   ACE_Time_Value *timeout = 0)
+  { return putq (mblk, timeout); }
+
+  virtual int svc (void);
+};
+
+typedef ACE_Unmanaged_Singleton<TP_Logging_Task, ACE_Null_Mutex>
+        TP_LOGGING_TASK;
+
+/*******************************************************/
+
+class TP_Logging_Acceptor;
+
+class TP_Logging_Handler : public Logging_Event_Handler {
+  friend class TP_Logging_Acceptor;
+protected:
+  virtual ~TP_Logging_Handler () {} // No-op destructor.
+
+  // Number of pointers to this class instance that currently
+  // reside in the <TP_LOGGING_TASK> singleton's message queue.
+  int queued_count_;
+
+  // Indicates whether <Logging_Event_Handler::handle_close()>
+  // must be called to cleanup and delete this object.
+  int deferred_close_;
+
+  // Serialize access to <queued_count_> and <deferred_close_>.
+  ACE_SYNCH_MUTEX lock_;
+
+public:
+  TP_Logging_Handler (ACE_Reactor *reactor)
+    : Logging_Event_Handler (reactor),
+      queued_count_ (0),
+      deferred_close_ (0) {}
+
+  // Called when input events occur, e.g., connection or data.
+  virtual int handle_input (ACE_HANDLE);
+
+  // Called when this object is destroyed, e.g., when it's
+  // removed from a reactor.
+  virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask);
+};
+
+/*******************************************************/
+
+class TP_Logging_Acceptor : public Logging_Acceptor {
+public:
+  TP_Logging_Acceptor (ACE_Reactor *r = ACE_Reactor::instance ())
+    : Logging_Acceptor (r) {}
+
+  virtual int handle_input (ACE_HANDLE) {
+    TP_Logging_Handler *peer_handler = 0;
+    ACE_NEW_RETURN (peer_handler,
+                    TP_Logging_Handler (reactor ()), -1);
+    if (acceptor_.accept (peer_handler->peer ()) == -1) {
+      delete peer_handler;
+      return -1;
+    } else if (peer_handler->open () == -1)
+      peer_handler->handle_close (ACE_INVALID_HANDLE, 0);
+    return 0;
+  }
+};
+
+/*******************************************************/
+
+class TP_Logging_Server : public ACE_Service_Object {
+protected:
+  // Contains the reactor, acceptor, and handlers.
+  typedef Reactor_Logging_Server<TP_Logging_Acceptor>
+          LOGGING_DISPATCHER;
+  LOGGING_DISPATCHER *logging_dispatcher_;
+
+public:
+  TP_Logging_Server (): logging_dispatcher_ (0) {}
+
+  virtual int init (int argc, ACE_TCHAR *argv[]) {
+    int i;
+    char **array = 0;
+    ACE_NEW_RETURN (array, char*[argc], -1);
+    ACE_Auto_Array_Ptr<char *> char_argv (array);
+
+    for (i = 0; i < argc; ++i)
+      char_argv[i] = ACE::strnew (ACE_TEXT_ALWAYS_CHAR (argv[i]));
+    ACE_NEW_NORETURN
+      (logging_dispatcher_,
+       TP_Logging_Server::LOGGING_DISPATCHER
+       (i, char_argv.get (), ACE_Reactor::instance ()));
+    for (i = 0; i < argc; ++i) ACE::strdelete (char_argv[i]);
+    if (logging_dispatcher_ == 0) return -1;
+    else return TP_LOGGING_TASK::instance ()->open ();
+  }
+
+  virtual int fini () {
+    TP_LOGGING_TASK::instance ()->flush ();
+    TP_LOGGING_TASK::instance ()->wait ();
+    TP_LOGGING_TASK::close ();
+    delete logging_dispatcher_;
+    return 0;
+  }
+};
+
+ACE_FACTORY_DECLARE (TPLS, TP_Logging_Handler)
+
+#endif /* _TP_LOGGING_SERVER_H */