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