1 files changed, 75 insertions, 0 deletions
diff --git a/ACE/examples/C++NPv1/Logging_Server.cpp b/ACE/examples/C++NPv1/Logging_Server.cpp
new file mode 100644
index 00000000000..74d1eca7c7e
--- /dev/null
+++ b/ACE/examples/C++NPv1/Logging_Server.cpp
@@ -0,0 +1,75 @@
+/*
+** $Id$
+**
+** Copyright 2001 Addison Wesley. All Rights Reserved.
+*/
+
+#include "ace/FILE_Addr.h"
+#include "ace/FILE_Connector.h"
+#include "ace/FILE_IO.h"
+#include "ace/INET_Addr.h"
+#include "ace/SOCK_Stream.h"
+#include "Logging_Server.h"
+#include "ace/OS_NS_string.h"
+#include "ace/OS_NS_stdlib.h"
+#include "ace/os_include/os_netdb.h"
+
+int Logging_Server::run (int argc, char *argv[])
+{
+  if (this->open (argc > 1 ? ACE_OS::atoi (argv[1]) : 0) == -1)
+    return -1;
+
+  for (;;) {
+    if (wait_for_multiple_events () == -1)
+      return -1;
+    if (handle_connections () == -1)
+      return -1;
+    if (handle_data () == -1)
+      return -1;
+  }
+
+  ACE_NOTREACHED (return 0;)
+}
+
+
+int Logging_Server::open (u_short logger_port)
+{
+  ACE_INET_Addr server_addr;
+  int result;
+
+  if (logger_port != 0)
+    result = server_addr.set (logger_port,
+                              (ACE_UINT32) INADDR_ANY);
+  else
+    result = server_addr.set ("ace_logger",
+                              (ACE_UINT32) INADDR_ANY);
+  if (result == -1) return -1;
+
+  // Start listening, enable reuse of listen address for quick restarts.
+  return acceptor_.open (server_addr, 1);
+}
+
+
+int Logging_Server::make_log_file (ACE_FILE_IO &logging_file,
+                                   ACE_SOCK_Stream *logging_peer)
+{
+  char filename[MAXHOSTNAMELEN + sizeof (".log")];
+
+  if (logging_peer != 0) { // Use client's hostname as log file name.
+    ACE_INET_Addr logging_peer_addr;
+    logging_peer->get_remote_addr (logging_peer_addr);
+    logging_peer_addr.get_host_name (filename, MAXHOSTNAMELEN);
+    ACE_OS::strcat (filename, ".log");
+  }
+  else
+    ACE_OS::strcpy (filename, "logging_server.log");
+
+  ACE_FILE_Connector connector;
+  return connector.connect (logging_file,
+                            ACE_FILE_Addr (filename),
+                            0, // No timeout.
+                            ACE_Addr::sap_any, // Ignored.
+                            0, // Don't try to reuse the addr.
+                            O_RDWR|O_CREAT|O_APPEND,
+                            ACE_DEFAULT_FILE_PERMS);
+}