summaryrefslogtreecommitdiff
path: root/examples/C++NPv2/TP_Logging_Server.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'examples/C++NPv2/TP_Logging_Server.cpp')
-rw-r--r--examples/C++NPv2/TP_Logging_Server.cpp74
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 */