diff options
Diffstat (limited to 'ace/Msg_WFMO_Reactor.cpp')
-rw-r--r-- | ace/Msg_WFMO_Reactor.cpp | 86 |
1 files changed, 0 insertions, 86 deletions
diff --git a/ace/Msg_WFMO_Reactor.cpp b/ace/Msg_WFMO_Reactor.cpp deleted file mode 100644 index 7fe67de05c5..00000000000 --- a/ace/Msg_WFMO_Reactor.cpp +++ /dev/null @@ -1,86 +0,0 @@ -// $Id$ - -#define ACE_BUILD_DLL - -#include "ace/Msg_WFMO_Reactor.h" - -#if defined (ACE_WIN32) - -#if !defined (__ACE_INLINE__) -#include "ace/Msg_WFMO_Reactor.i" -#endif /* __ACE_INLINE__ */ - -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) -{ -} - -int -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. -#if defined (_WIN32_WINNT) && (_WIN32_WINNT >= 0x0400) - return ::MsgWaitForMultipleObjectsEx (this->handler_rep_.max_handlep1 (), - this->handler_rep_.handles (), - timeout, - QS_ALLINPUT, - alertable); -#else - ACE_UNUSED_ARG (alertable); - return ::MsgWaitForMultipleObjects (this->handler_rep_.max_handlep1 (), - this->handler_rep_.handles (), - FALSE, - timeout, - QS_ALLINPUT) -#endif /* (_WIN32_WINNT) && (_WIN32_WINNT >= 0x0400) */ -} - -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, NULL, 0, 0, PM_REMOVE)) - { - ::TranslateMessage (&msg); - if (msg.message == WM_QUIT) - return -1; - - ::DispatchMessage (&msg); - number_of_messages++; - } - - return number_of_messages; -} - -DWORD -ACE_Msg_WFMO_Reactor::poll_remaining_handles (size_t index) -{ - return ::MsgWaitForMultipleObjects (this->handler_rep_.max_handlep1 () - index, - this->handler_rep_.handles () + index, - FALSE, - 0, - QS_ALLINPUT); -} - -#endif /* ACE_WIN32 */ |