diff options
Diffstat (limited to 'ACE/ace/Msg_WFMO_Reactor.cpp')
-rw-r--r-- | ACE/ace/Msg_WFMO_Reactor.cpp | 85 |
1 files changed, 0 insertions, 85 deletions
diff --git a/ACE/ace/Msg_WFMO_Reactor.cpp b/ACE/ace/Msg_WFMO_Reactor.cpp deleted file mode 100644 index bbc95b948fa..00000000000 --- a/ACE/ace/Msg_WFMO_Reactor.cpp +++ /dev/null @@ -1,85 +0,0 @@ -// $Id$ - -#include "ace/Msg_WFMO_Reactor.h" - -ACE_RCSID(ace, Msg_WFMO_Reactor, "$Id$") - -#if defined (ACE_WIN32) && !defined (ACE_LACKS_MSG_WFMO) - -#if !defined (__ACE_INLINE__) -#include "ace/Msg_WFMO_Reactor.inl" -#endif /* __ACE_INLINE__ */ - -ACE_BEGIN_VERSIONED_NAMESPACE_DECL - -ACE_Msg_WFMO_Reactor::ACE_Msg_WFMO_Reactor (ACE_Sig_Handler *sh, - ACE_Timer_Queue *tq) - : ACE_WFMO_Reactor (sh, tq) -{ -} - -ACE_Msg_WFMO_Reactor::ACE_Msg_WFMO_Reactor (size_t size, - int unused, - ACE_Sig_Handler *sh, - ACE_Timer_Queue *tq) - : ACE_WFMO_Reactor (size, unused, sh, tq) -{ -} - -ACE_Msg_WFMO_Reactor::~ACE_Msg_WFMO_Reactor (void) -{ -} - -DWORD -ACE_Msg_WFMO_Reactor::wait_for_multiple_events (int timeout, - int alertable) -{ - // Wait for any of handles_ to be active, or until timeout expires. - // If <alertable> is enabled allow asynchronous completion of - // ReadFile and WriteFile operations. QS_ALLINPUT allows - // <MsgWaitForMultipleObjectsEx> to wait for any message is in the - // queue. - return ::MsgWaitForMultipleObjectsEx (this->handler_rep_.max_handlep1 (), - this->handler_rep_.handles (), - timeout, - QS_ALLINPUT, - alertable); -} - -int -ACE_Msg_WFMO_Reactor::dispatch_window_messages (void) -{ - int number_of_messages = 0; - MSG msg; - - // Process all pending message from this thread's message queue - while (::PeekMessage (&msg, 0, 0, 0, PM_REMOVE)) - { - ::TranslateMessage (&msg); - if (msg.message == WM_QUIT) - { - // Should inform the main thread - ::PostQuitMessage (LOWORD (msg.wParam)); - return -1; - } - - ::DispatchMessage (&msg); - ++number_of_messages; - } - - return number_of_messages; -} - -DWORD -ACE_Msg_WFMO_Reactor::poll_remaining_handles (DWORD slot) -{ - return ::MsgWaitForMultipleObjects (this->handler_rep_.max_handlep1 () - slot, - this->handler_rep_.handles () + slot, - FALSE, - 0, - QS_ALLINPUT); -} - -ACE_END_VERSIONED_NAMESPACE_DECL - -#endif /* ACE_WIN32 && !ACE_LACKS_MSG_WFMO */ |