diff options
author | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-06-18 18:53:27 +0000 |
---|---|---|
committer | nobody <nobody@ae88bc3d-4319-0410-8dbf-d08b4c9d3795> | 2005-06-18 18:53:27 +0000 |
commit | 152c0f5c127eac99b5c9097aa4db2b34e14e6dd0 (patch) | |
tree | 0d399a92623e98588cd34e4fe0c2cf7fed880173 /examples/C++NPv2/TP_Logging_Server.cpp | |
parent | 7e7f4a5d3e77a42e648b7dd2e1b9cf23a3780955 (diff) | |
download | ATCD-MyACE.tar.gz |
This commit was manufactured by cvs2svn to create branch 'MyACE'.MyACE
Diffstat (limited to 'examples/C++NPv2/TP_Logging_Server.cpp')
-rw-r--r-- | examples/C++NPv2/TP_Logging_Server.cpp | 74 |
1 files changed, 0 insertions, 74 deletions
diff --git a/examples/C++NPv2/TP_Logging_Server.cpp b/examples/C++NPv2/TP_Logging_Server.cpp deleted file mode 100644 index b591ef425b7..00000000000 --- a/examples/C++NPv2/TP_Logging_Server.cpp +++ /dev/null @@ -1,74 +0,0 @@ -/* -** $Id$ -** -** Copyright 2002 Addison Wesley. All Rights Reserved. -*/ - -#include "ace/OS_Memory.h" -#include "ace/Guard_T.h" -#include "ace/Message_Block.h" -#include "TP_Logging_Server.h" - -int TP_Logging_Handler::handle_input (ACE_HANDLE) { - ACE_Message_Block *mblk = 0; - if (logging_handler_.recv_log_record (mblk) != -1) { - ACE_Message_Block *log_blk = 0; - ACE_NEW_RETURN - (log_blk, ACE_Message_Block - (reinterpret_cast<char *> (this)), -1); - log_blk->cont (mblk); - ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, lock_, -1); - if (TP_LOGGING_TASK::instance ()->put (log_blk) == -1) - { log_blk->release (); return -1; } - ++queued_count_; - return 0; - } else return -1; -} - - -int -TP_Logging_Handler::handle_close (ACE_HANDLE handle, - ACE_Reactor_Mask) { - int close_now = 0; - if (handle != ACE_INVALID_HANDLE) { - ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, lock_, -1); - if (queued_count_ == 0) - close_now = 1; - else - deferred_close_ = 1; - } else { - ACE_GUARD_RETURN (ACE_SYNCH_MUTEX, guard, lock_, -1); - queued_count_--; - if (queued_count_ == 0) close_now = deferred_close_; - } - - if (close_now) - return Logging_Event_Handler::handle_close (); - return 0; -} - - -int TP_Logging_Task::svc () { - for (ACE_Message_Block *log_blk; getq (log_blk) != -1; ) { - TP_Logging_Handler *tp_handler = reinterpret_cast<TP_Logging_Handler *> (log_blk->rd_ptr ()); - Logging_Handler logging_handler (tp_handler->log_file ()); - logging_handler.write_log_record (log_blk->cont ()); - - log_blk->release (); - tp_handler->handle_close (ACE_INVALID_HANDLE, 0); - } - return 0; -} - -ACE_FACTORY_DEFINE (TPLS, TP_Logging_Server) - -#if defined (ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION) -template class Reactor_Logging_Server<TP_Logging_Acceptor>; -#elif defined (ACE_HAS_TEMPLATE_INSTANTIATION_PRAGMA) -#pragma instantiate Reactor_Logging_Server<TP_Logging_Acceptor> -#elif defined (ACE_HAS_EXPLICIT_STATIC_TEMPLATE_MEMBER_INSTANTIATION) -template ACE_Singleton<TP_Logging_Task, ACE_Null_Mutex> * - ACE_Singleton<TP_Logging_Task, ACE_Null_Mutex>::singleton_; -template ACE_Unmanaged_Singleton<TP_Logging_Task, ACE_Null_Mutex> * - ACE_Unmanaged_Singleton<TP_Logging_Task, ACE_Null_Mutex>::singleton_; -#endif /* ACE_HAS_EXPLICIT_TEMPLATE_INSTANTIATION */ |