diff options
Diffstat (limited to 'examples/C++NPv1/Thread_Per_Connection_Logging_Server.cpp')
-rw-r--r-- | examples/C++NPv1/Thread_Per_Connection_Logging_Server.cpp | 99 |
1 files changed, 0 insertions, 99 deletions
diff --git a/examples/C++NPv1/Thread_Per_Connection_Logging_Server.cpp b/examples/C++NPv1/Thread_Per_Connection_Logging_Server.cpp deleted file mode 100644 index ec4389110f0..00000000000 --- a/examples/C++NPv1/Thread_Per_Connection_Logging_Server.cpp +++ /dev/null @@ -1,99 +0,0 @@ -/* -** $Id$ -** -** Copyright 2001 Addison Wesley. All Rights Reserved. -*/ - -#include "ace/Auto_Ptr.h" -#include "ace/FILE_IO.h" -#include "ace/Log_Msg.h" -#include "ace/Signal.h" -#include "ace/Thread_Manager.h" - -#include "Thread_Per_Connection_Logging_Server.h" -#include "Logging_Handler.h" - -#include <errno.h> - -namespace { - extern "C" void sigterm_handler (int /* signum */) { /* No-op. */ } -} - - -ACE_THR_FUNC_RETURN Thread_Per_Connection_Logging_Server::run_svc (void *arg) -{ - auto_ptr<Thread_Args> thread_args (ACE_static_cast (Thread_Args *, arg)); - - thread_args->this_->handle_data (&thread_args->logging_peer_); - thread_args->logging_peer_.close (); - return 0; // Return value is ignored -} - - -int -Thread_Per_Connection_Logging_Server::handle_connections () -{ - auto_ptr<Thread_Args> thread_args (new Thread_Args (this)); - - if (acceptor ().accept (thread_args->logging_peer_) == -1) - return -1; - if (ACE_Thread_Manager::instance ()->spawn ( - // Pointer to function entry point. - Thread_Per_Connection_Logging_Server::run_svc, - // <run_svc> parameter. - ACE_static_cast (void *, thread_args.get ()), - THR_DETACHED | THR_SCOPE_SYSTEM) == -1) - return -1; - thread_args.release (); // Spawned thread now owns memory - return 0; -} - - -int -Thread_Per_Connection_Logging_Server::handle_data (ACE_SOCK_Stream *client) -{ - ACE_FILE_IO log_file; - // Client's hostname is logfile name. - make_log_file (log_file, client); - - // Place the connection into blocking mode since this - // thread isn't doing anything except handling this client. - client->disable (ACE_NONBLOCK); - - Logging_Handler logging_handler (log_file, *client); - - // Keep handling log records until client closes connection - // or this thread is asked to cancel itself. - ACE_Thread_Manager *mgr = ACE_Thread_Manager::instance (); - ACE_thread_t me = ACE_Thread::self (); - while (!mgr->testcancel (me) && - logging_handler.log_record () != -1) - continue; - - log_file.close (); - return 0; -} - - -int main (int argc, char *argv[]) -{ - // Register to receive the <SIGTERM> signal. - ACE_Sig_Action sa ((ACE_SignalHandler) sigterm_handler, - SIGTERM); - - Thread_Per_Connection_Logging_Server server; - - if (server.run (argc, argv) == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "server.run()"), 1); - - // Cooperative thread cancellation and barrier synchronization. - ACE_Thread_Manager::instance ()->cancel_all (); - return ACE_Thread_Manager::instance ()->wait (); -} - - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class auto_ptr<Thread_Per_Connection_Logging_Server::Thread_Args>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate auto_ptr<Thread_Per_Connection_Logging_Server::Thread_Args> -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |