1 files changed, 104 insertions, 0 deletions
diff --git a/ACE/examples/C++NPv2/Select_Reactor_Logging_Server.cpp b/ACE/examples/C++NPv2/Select_Reactor_Logging_Server.cpp
new file mode 100644
index 00000000000..322127670a4
--- /dev/null
+++ b/ACE/examples/C++NPv2/Select_Reactor_Logging_Server.cpp
@@ -0,0 +1,104 @@
+/*
+** $Id$
+**
+** Copyright 2002 Addison Wesley. All Rights Reserved.
+*/
+
+// FUZZ: disable check_for_streams_include
+#include "ace/streams.h"
+
+#include "ace/Reactor.h"
+#include "ace/Select_Reactor.h"
+#include "ace/Thread_Manager.h"
+
+#if defined (ACE_WIN32) && (!defined (ACE_HAS_STANDARD_CPP_LIBRARY) || \
+                            (ACE_HAS_STANDARD_CPP_LIBRARY == 0) || \
+                            defined (ACE_USES_OLD_IOSTREAMS))
+#  include <stdio.h>
+#else
+#  include <string>
+#endif
+
+#include "Reactor_Logging_Server_T.h"
+#include "Logging_Acceptor_Ex.h"
+
+typedef Reactor_Logging_Server<Logging_Acceptor_Ex>
+        Server_Logging_Daemon;
+
+
+class Quit_Handler : public ACE_Event_Handler {
+public:
+  Quit_Handler (ACE_Reactor *r) : ACE_Event_Handler (r) {}
+
+  virtual int handle_exception (ACE_HANDLE) {
+    reactor ()->end_reactor_event_loop ();
+    return -1; // Trigger call to handle_close() method.
+  }
+
+  virtual int handle_close (ACE_HANDLE, ACE_Reactor_Mask)
+  { delete this; return 0; }
+
+protected:
+
+  // Protected destructor ensures dynamic allocation.
+  virtual ~Quit_Handler () {}
+};
+
+
+static ACE_THR_FUNC_RETURN event_loop (void *arg) {
+  ACE_Reactor *reactor = static_cast<ACE_Reactor *> (arg);
+
+  reactor->owner (ACE_OS::thr_self ());
+  reactor->run_reactor_event_loop ();
+  return 0;
+}
+
+
+static ACE_THR_FUNC_RETURN controller (void *arg) {
+  ACE_Reactor *reactor = static_cast<ACE_Reactor *> (arg);
+
+  Quit_Handler *quit_handler = 0;
+  ACE_NEW_RETURN (quit_handler, Quit_Handler (reactor), 0);
+
+#if defined (ACE_WIN32) && (!defined (ACE_HAS_STANDARD_CPP_LIBRARY) || \
+                            (ACE_HAS_STANDARD_CPP_LIBRARY == 0) || \
+                            defined (ACE_USES_OLD_IOSTREAMS))
+  for (;;) {
+    char user_input[80];
+    ACE_OS::fgets (user_input, sizeof (user_input), stdin);
+    if (ACE_OS::strcmp (user_input, "quit") == 0) {
+      reactor->notify (quit_handler);
+      break;
+    }
+  }
+#else
+  for (;;) {
+    std::string user_input;
+    std::getline (cin, user_input, '\n');
+    if (user_input == "quit") {
+      reactor->notify (quit_handler);
+      break;
+    }
+  }
+#endif
+
+  return 0;
+}
+
+
+int ACE_TMAIN (int argc, ACE_TCHAR *argv[])
+{
+  ACE_Select_Reactor select_reactor;
+  ACE_Reactor reactor (&select_reactor);
+
+  Server_Logging_Daemon *server;
+  // Ignore argv[0]...
+  --argc; ++argv;
+  ACE_NEW_RETURN (server,
+                  Server_Logging_Daemon (argc, argv, &reactor),
+                  1);
+  ACE_Thread_Manager::instance ()->spawn (event_loop, &reactor);
+  ACE_Thread_Manager::instance ()->spawn (controller, &reactor);
+  return ACE_Thread_Manager::instance ()->wait ();
+}
+