summaryrefslogtreecommitdiff
path: root/ace/WFMO_Reactor.cpp
diff options
context:
space:
mode:
authorspark <spark@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2002-03-08 23:12:08 +0000
committerspark <spark@ae88bc3d-4319-0410-8dbf-d08b4c9d3795>2002-03-08 23:12:08 +0000
commitaffaeef791874c59738e601f357700393f1c755b (patch)
tree4f6d3ad1af0ec112e73b545c9bb2c1c54c831769 /ace/WFMO_Reactor.cpp
parent10a5ebbb6675856088140ee38ded9f55aad79ebb (diff)
downloadATCD-affaeef791874c59738e601f357700393f1c755b.tar.gz
Updated to support WinCE.
Diffstat (limited to 'ace/WFMO_Reactor.cpp')
-rw-r--r--ace/WFMO_Reactor.cpp19
1 files changed, 16 insertions, 3 deletions
diff --git a/ace/WFMO_Reactor.cpp b/ace/WFMO_Reactor.cpp
index b6a41d2e9d3..1e9d076e9d8 100644
--- a/ace/WFMO_Reactor.cpp
+++ b/ace/WFMO_Reactor.cpp
@@ -13,7 +13,7 @@
ACE_RCSID(ace, WFMO_Reactor, "$Id$")
-#if defined (ACE_WIN32) && !defined (ACE_HAS_WINCE)
+#if defined (ACE_WIN32)
#include "ace/Auto_Ptr.h"
@@ -1674,16 +1674,27 @@ ACE_WFMO_Reactor::ok_to_wait (ACE_Time_Value *max_wait_time,
this->atomic_wait_array_,
TRUE,
timeout);
+
+ if (result != WAIT_IO_COMPLETION)
+ break;
+
+#elif defined (ACE_HAS_WINCE)
+ result = ::WaitForMultipleObjects (sizeof this->atomic_wait_array_ / sizeof (ACE_HANDLE),
+ this->atomic_wait_array_,
+ TRUE,
+ timeout);
+ break; // CE does not have WAIT_IO_COMPLETION defined.
#else
result = ::WaitForMultipleObjectsEx (sizeof this->atomic_wait_array_ / sizeof (ACE_HANDLE),
this->atomic_wait_array_,
TRUE,
timeout,
alertable);
-#endif /* ACE_HAS_PHARLAP */
if (result != WAIT_IO_COMPLETION)
break;
+
+#endif /* ACE_HAS_PHARLAP */
}
switch (result)
@@ -1710,7 +1721,7 @@ ACE_WFMO_Reactor::wait_for_multiple_events (int timeout,
// Wait for any of handles_ to be active, or until timeout expires.
// If <alertable> is enabled allow asynchronous completion of
// ReadFile and WriteFile operations.
-#if defined (ACE_HAS_PHARLAP)
+#if defined (ACE_HAS_PHARLAP) || defined (ACE_HAS_WINCE)
// PharLap doesn't do async I/O and doesn't implement
// WaitForMultipleObjectsEx, so use WaitForMultipleObjects.
ACE_UNUSED_ARG (alertable);
@@ -1783,8 +1794,10 @@ ACE_WFMO_Reactor::dispatch (int wait_status)
errno = ETIME;
return handlers_dispatched;
+#ifndef ACE_HAS_WINCE
case WAIT_IO_COMPLETION: // APC.
return handlers_dispatched;
+#endif // ACE_HAS_WINCE
default: // Dispatch.
// We'll let dispatch worry about abandoned mutes.