diff options
Diffstat (limited to 'ACE/apps/JAWS2/JAWS/Reaper.cpp')
-rw-r--r-- | ACE/apps/JAWS2/JAWS/Reaper.cpp | 45 |
1 files changed, 0 insertions, 45 deletions
diff --git a/ACE/apps/JAWS2/JAWS/Reaper.cpp b/ACE/apps/JAWS2/JAWS/Reaper.cpp deleted file mode 100644 index 6d1d5845cba..00000000000 --- a/ACE/apps/JAWS2/JAWS/Reaper.cpp +++ /dev/null @@ -1,45 +0,0 @@ -// $Id$ - -#include "JAWS/Reaper.h" -#include "JAWS/Concurrency.h" -#include "JAWS/IO_Acceptor.h" - -ACE_RCSID(JAWS, Reaper, "$Id$") - -JAWS_Reaper::JAWS_Reaper (JAWS_Concurrency_Base *concurrency) - : concurrency_ (concurrency), - waiting_ (0) -{ -} - -JAWS_Reaper::~JAWS_Reaper (void) -{ -} - -int -JAWS_Reaper::open (void *) -{ - if (this->waiting_ == 0) - { - ACE_Guard<ACE_SYNCH_MUTEX> g (this->lock_); - if (this->waiting_ == 0) - { - if (this->activate () == -1) - ACE_ERROR_RETURN ((LM_ERROR, "%p\n", "JAWS_Reaper::activate"), - -1); - this->waiting_ = 1; - } - } - return 0; -} - -int -JAWS_Reaper::svc (void) -{ - ACE_TRACE ("JAWS_Reaper::svc"); - int result = this->concurrency_->thr_mgr ()->wait (); - JAWS_IO_Synch_Acceptor_Singleton::instance ()->close (); - JAWS_IO_Asynch_Acceptor_Singleton::instance ()->close (); - ACE_DEBUG ((LM_DEBUG, "(%t) Leaving REAPER\n")); - return result; -} |