ACE/apps/JAWS3/jaws3/Concurrency_T.cpp

   1 #include "ace/Message_Block.h"
   2 #include "ace/Singleton.h"
   3 #include "ace/Synch_Traits.h"
   4 #include "ace/Null_Mutex.h"
   5
   6 #include "jaws3/Concurrency_T.h"
   7
   8 typedef ACE_Singleton<ACE_Message_Block, ACE_SYNCH_NULL_MUTEX>
   9         JAWS_Empty_Message_Block;
  10
  11
  12 template <class CONCURRENCY_IMPL>
  13 JAWS_Concurrency_Bridge<CONCURRENCY_IMPL>
  14 ::JAWS_Concurrency_Bridge (CONCURRENCY_IMPL *impl)
  15   : impl_ (impl)
  16 {
  17   if (this->impl_ == 0)
  18     this->impl_ = CONCURRENCY_IMPL::instance ();
  19 }
  20
  21
  22 template <class CONCURRENCY_IMPL> int
  23 JAWS_Concurrency_Bridge<CONCURRENCY_IMPL>::putq (JAWS_Protocol_Handler *ph)
  24 {
  25   return this->impl_->putq (ph);
  26 }
  27
  28
  29 template <class CONCURRENCY_IMPL> int
  30 JAWS_Concurrency_Bridge<CONCURRENCY_IMPL>::getq (JAWS_Protocol_Handler *&ph)
  31 {
  32   return this->impl_->getq (ph);
  33 }
  34
  35
  36 template <class CONCURRENCY_IMPL> void
  37 JAWS_Concurrency_Bridge<CONCURRENCY_IMPL>::shutdown ()
  38 {
  39   ACE_Message_Block *empty_mb = JAWS_Empty_Message_Block::instance ();
  40   JAWS_CONCURRENCY_TASK *task;
  41
  42   task = this->impl_;
  43   task->putq (empty_mb);
  44   task->wait ();
  45 }