ACE/ace/Msg_WFMO_Reactor.cpp

   1 #include "ace/Msg_WFMO_Reactor.h"
   2
   3 #if defined (ACE_WIN32)
   4
   5 #if !defined (__ACE_INLINE__)
   6 #include "ace/Msg_WFMO_Reactor.inl"
   7 #endif /* __ACE_INLINE__ */
   8
   9 ACE_BEGIN_VERSIONED_NAMESPACE_DECL
  10
  11 ACE_Msg_WFMO_Reactor::ACE_Msg_WFMO_Reactor (ACE_Sig_Handler *sh,
  12                                             ACE_Timer_Queue *tq)
  13   : ACE_WFMO_Reactor (sh, tq)
  14 {
  15 }
  16
  17 ACE_Msg_WFMO_Reactor::ACE_Msg_WFMO_Reactor (size_t size,
  18                                             int unused,
  19                                             ACE_Sig_Handler *sh,
  20                                             ACE_Timer_Queue *tq)
  21   : ACE_WFMO_Reactor (size, unused, sh, tq)
  22 {
  23 }
  24
  25 ACE_Msg_WFMO_Reactor::~ACE_Msg_WFMO_Reactor ()
  26 {
  27 }
  28
  29 DWORD
  30 ACE_Msg_WFMO_Reactor::wait_for_multiple_events (int timeout,
  31                                                 int alertable)
  32 {
  33   // Wait for any of handles_ to be active, or until timeout expires.
  34   // If <alertable> is enabled allow asynchronous completion of
  35   // ReadFile and WriteFile operations. QS_ALLINPUT allows
  36   // <MsgWaitForMultipleObjectsEx> to wait for any message is in the
  37   // queue.
  38   return ::MsgWaitForMultipleObjectsEx (this->handler_rep_.max_handlep1 (),
  39                                         this->handler_rep_.handles (),
  40                                         timeout,
  41                                         QS_ALLINPUT,
  42                                         alertable);
  43 }
  44
  45 int
  46 ACE_Msg_WFMO_Reactor::dispatch_window_messages ()
  47 {
  48   int number_of_messages = 0;
  49   MSG msg;
  50
  51   // Process all pending message from this thread's message queue
  52   while (::PeekMessage (&msg, 0, 0, 0, PM_REMOVE))
  53     {
  54       ::TranslateMessage (&msg);
  55       if (msg.message == WM_QUIT)
  56         {
  57           // Should inform the main thread
  58           ::PostQuitMessage (LOWORD (msg.wParam));
  59           return -1;
  60         }
  61
  62       ::DispatchMessage (&msg);
  63       ++number_of_messages;
  64     }
  65
  66   return number_of_messages;
  67 }
  68
  69 DWORD
  70 ACE_Msg_WFMO_Reactor::poll_remaining_handles (DWORD slot)
  71 {
  72   return ::MsgWaitForMultipleObjects (this->handler_rep_.max_handlep1 () - slot,
  73                                       this->handler_rep_.handles () + slot,
  74                                       FALSE,
  75                                       0,
  76                                       QS_ALLINPUT);
  77 }
  78
  79 ACE_END_VERSIONED_NAMESPACE_DECL
  80
  81 #endif /* ACE_WIN32 */