Changeset 22724 in vbox for trunk/src/libs/xpcom18a4

Timestamp:

Sep 2, 2009 3:20:30 PM (15 years ago)

Author:

vboxsync

svn:sync-xref-src-repo-rev:

51850

Message:

VBoxPython: com::EventQueue::processThreadEventQueue version of the code.

File:

• trunk/src/libs/xpcom18a4/python/src/module/_xpcom.cpp (modified) (5 diffs)

trunk/src/libs/xpcom18a4/python/src/module/_xpcom.cpp

@@ -493 +493 @@
 
 #ifdef VBOX
-# include <iprt/cdefs.h>
+#define USE_EVENTQUEUE  1
+
+# ifdef USE_EVENTQUEUE
+#  include <VBox/com/EventQueue.h>
+#  include <iprt/err.h>
+# else
+#  include <iprt/cdefs.h>
+# endif
 
 static nsIEventQueue* g_mainEventQ = nsnull;
 
+# ifndef USE_EVENTQUEUE /** @todo Make USE_EVENTQUEUE default. */
 // Wrapper that checks if the queue has pending events.
 DECLINLINE(bool)
@@ -616 +624 @@
 
 # endif /* RT_OS_DARWIN */
+# endif /* !USE_EVENTQUEUE */
 
 static PyObject*
@@ -623 +632 @@
 
   if (!PyArg_ParseTuple(args, "i", &aTimeout))
-    return NULL;
+    return NULL; /** @todo throw exception */
 
   nsIEventQueue* q = g_mainEventQ;
   if (q == nsnull)
-    return NULL;
-
+    return NULL; /** @todo throw exception */
+
+# ifdef USE_EVENTQUEUE
+  int rc = com::EventQueue::processThreadEventQueue(aTimeout < 0 ? RT_INDEFINITE_WAIT : (uint32_t)aTimeout);
+  if (RT_SUCCESS(rc))
+      return PyInt_FromLong(0);
+  if (   rc == VERR_TIMEOUT
+      || rc == VERR_INTERRUPTED)
+      return PyInt_FromLong(1);
+  return NULL; /** @todo throw exception */
+
+# else  /* !USE_EVENTQUEUE */
   NS_WARN_IF_FALSE(isEventQueueNative(q), "The event queue must be native!");
 
   PRInt32 result = 0;
-# ifdef RT_OS_DARWIN
+#  ifdef RT_OS_DARWIN
   if (aTimeout != 0 && !hasEventQueuePendingEvents(q))
     result = waitForEventsOnDarwin(q, aTimeout);
@@ -638 +657 @@
     q->ProcessPendingEvents();
 
-# else  /* !RT_OS_DARWIN */
+#  else  /* !RT_OS_DARWIN */
 
   PRBool hasEvents = PR_FALSE;
@@ -693 +712 @@
  ok:
   q->ProcessPendingEvents();
-# endif /* !RT_OS_DARWIN */
-
+#  endif /* !RT_OS_DARWIN */
   return PyInt_FromLong(result);
+# endif /* !USE_EVENTQUEUE */
 }