Process XPCOM events from nested native event loops. b=389931 r+sr=roc a=blocking1.9

This commit is contained in:
mats.palmgren@bredband.net 2008-02-26 05:36:40 -08:00
parent 67622f2077
commit 76af2248ae
2 changed files with 48 additions and 29 deletions

View File

@ -20,6 +20,7 @@
*
* Contributor(s):
* Darin Fisher <darin@meer.net> (original author)
* Mats Palmgren <mats.palmgren@bredband.net>
*
* Alternatively, the contents of this file may be used under the terms of
* either the GNU General Public License Version 2 or later (the "GPL"), or
@ -50,14 +51,15 @@ NS_IMPL_THREADSAFE_ISUPPORTS3(nsBaseAppShell, nsIAppShell, nsIThreadObserver,
nsBaseAppShell::nsBaseAppShell()
: mSuspendNativeCount(0)
, mBlockedWait(nsnull)
, mFavorPerf(0)
, mNativeEventPending(PR_FALSE)
, mNativeEventPending(0)
, mStarvationDelay(0)
, mSwitchTime(0)
, mLastNativeEventTime(0)
, mEventloopNestingState(eEventloopNone)
, mRunWasCalled(PR_FALSE)
, mExiting(PR_FALSE)
, mProcessingNextNativeEvent(PR_FALSE)
{
}
@ -89,27 +91,21 @@ nsBaseAppShell::NativeEventCallback()
// If DoProcessNextNativeEvent is on the stack, then we assume that we can
// just unwind and let nsThread::ProcessNextEvent process the next event.
// However, if we are called from a nested native event loop (maybe via some
// plug-in or library function), then we need to eventually process the event
// ourselves. To make that happen, we schedule another call to ourselves and
// unset the flag set by DoProcessNextNativeEvent. This increases the
// workload on the native event queue slightly.
if (mProcessingNextNativeEvent) {
#if 0
// XXX(darin): This causes a hefty Ts and Txul regression. We need some
// sort of solution to handle native event loops spun from native events,
// but we should try to find something better.
mProcessingNextNativeEvent = PR_FALSE;
if (NS_HasPendingEvents(NS_GetCurrentThread()))
OnDispatchedEvent(nsnull);
#endif
// plug-in or library function), then go ahead and process Gecko events now.
if (mEventloopNestingState == eEventloopXPCOM) {
mEventloopNestingState = eEventloopOther;
// XXX there is a tiny risk we will never get a new NativeEventCallback,
// XXX see discussion in bug 389931.
return;
}
// nsBaseAppShell::Run is not being used to pump events, so this may be
// our only opportunity to process pending gecko events.
EventloopNestingState prevVal = mEventloopNestingState;
nsIThread *thread = NS_GetCurrentThread();
NS_ProcessPendingEvents(thread, THREAD_EVENT_STARVATION_LIMIT);
mEventloopNestingState = prevVal;
// Continue processing pending events later (we don't want to starve the
// embedders event loop).
@ -129,13 +125,14 @@ nsBaseAppShell::DoProcessNextNativeEvent(PRBool mayWait)
//
// However, if the next native event is not our NativeEventCallback, but it
// results in another native event loop, then our NativeEventCallback could
// fire and it will see mProcessNextNativeEvent as true.
// fire and it will see mEventloopNestingState as eEventloopOther.
//
PRBool prevVal = mProcessingNextNativeEvent;
EventloopNestingState prevVal = mEventloopNestingState;
mEventloopNestingState = eEventloopXPCOM;
mProcessingNextNativeEvent = PR_TRUE;
PRBool result = ProcessNextNativeEvent(mayWait);
mProcessingNextNativeEvent = prevVal;
mEventloopNestingState = prevVal;
return result;
}
@ -216,6 +213,18 @@ nsBaseAppShell::OnProcessNextEvent(nsIThreadInternal *thr, PRBool mayWait,
PRIntervalTime start = PR_IntervalNow();
PRIntervalTime limit = THREAD_EVENT_STARVATION_LIMIT;
// Unblock outer nested wait loop (below).
if (mBlockedWait)
*mBlockedWait = PR_FALSE;
PRBool *oldBlockedWait = mBlockedWait;
mBlockedWait = &mayWait;
// When mayWait is true, we need to make sure that there is an event in the
// thread's event queue before we return. Otherwise, the thread will block
// on its event queue waiting for an event.
PRBool needEvent = mayWait;
if (mFavorPerf <= 0 && start > mSwitchTime + mStarvationDelay) {
// Favor pending native events
PRIntervalTime now = start;
@ -232,15 +241,11 @@ nsBaseAppShell::OnProcessNextEvent(nsIThreadInternal *thr, PRBool mayWait,
}
}
// When mayWait is true, we need to make sure that there is an event in the
// thread's event queue before we return. Otherwise, the thread will block
// on its event queue waiting for an event.
PRBool needEvent = mayWait;
while (!NS_HasPendingEvents(thr)) {
// If we have been asked to exit from Run, then we should not wait for
// events to process.
if (mExiting && mayWait)
// events to process. Note that an inner nested event loop causes
// 'mayWait' to become false too, through 'mBlockedWait'.
if (mExiting)
mayWait = PR_FALSE;
mLastNativeEventTime = PR_IntervalNow();
@ -248,6 +253,8 @@ nsBaseAppShell::OnProcessNextEvent(nsIThreadInternal *thr, PRBool mayWait,
break;
}
mBlockedWait = oldBlockedWait;
// Make sure that the thread event queue does not block on its monitor, as
// it normally would do if it did not have any pending events. To avoid
// that, we simply insert a dummy event into its queue during shutdown.

View File

@ -100,14 +100,26 @@ private:
PRBool DoProcessNextNativeEvent(PRBool mayWait);
nsCOMPtr<nsIRunnable> mDummyEvent;
/**
* mBlockedWait points back to a slot that controls the wait loop in
* an outer OnProcessNextEvent invocation. Nested calls always set
* it to PR_FALSE to unblock an outer loop, since all events may
* have been consumed by the inner event loop(s).
*/
PRBool *mBlockedWait;
PRInt32 mFavorPerf;
PRInt32 mNativeEventPending;
PRIntervalTime mStarvationDelay;
PRIntervalTime mSwitchTime;
PRIntervalTime mLastNativeEventTime;
enum EventloopNestingState {
eEventloopNone, // top level thread execution
eEventloopXPCOM, // innermost native event loop is ProcessNextNativeEvent
eEventloopOther // innermost native event loop is a native library/plugin etc
};
EventloopNestingState mEventloopNestingState;
PRPackedBool mRunWasCalled;
PRPackedBool mExiting;
PRPackedBool mProcessingNextNativeEvent;
};
#endif // nsBaseAppShell_h__