ACE/apps/JAWS2/JAWS/Waiter.cpp

   1 #include "ace/Proactor.h"
   2
   3 #include "JAWS/Waiter.h"
   4 #include "JAWS/IO_Handler.h"
   5
   6
   7
   8 JAWS_Waiter::JAWS_Waiter (void)
   9   : iter_ (*this)
  10 {
  11 }
  12
  13 JAWS_Waiter::~JAWS_Waiter (void)
  14 {
  15 }
  16
  17 JAWS_Waiter_Base_Iterator &
  18 JAWS_Waiter::iter (void)
  19 {
  20   return this->iter_;
  21 }
  22
  23 int
  24 JAWS_Waiter::index (void)
  25 {
  26 #if 0
  27   // A future version of ACE will support this.
  28   ACE_Thread_ID tid = ACE_OS::thr_self ();
  29 #else
  30   // Do it this way for now
  31   ACE_thread_t thr_name;
  32   thr_name = ACE_OS::thr_self ();
  33
  34   JAWS_Thread_ID tid (thr_name);
  35 #endif /* 0 */
  36
  37   return JAWS_Waiter_Base::index (tid);
  38 }
  39
  40 JAWS_IO_Handler *
  41 JAWS_Waiter::wait_for_completion (int i)
  42 {
  43   JAWS_IO_Handler *ioh;
  44   JAWS_IO_Handler **iohptr;
  45
  46   iohptr = (i >= 0) ? this->find_by_index (i) : this->find_by_index (this->index ());
  47
  48   while (*iohptr == 0)
  49     if (ACE_Proactor::instance ()->handle_events () == -1)
  50       {
  51         ACE_ERROR ((LM_ERROR, "%p\n", "JAWS_Waiter::wait_for_completion"));
  52         return 0;
  53       }
  54
  55   ioh = *iohptr;
  56   *iohptr = 0;
  57
  58   ioh->lock ();
  59   ioh->release ();
  60   return ioh;
  61 }
  62