diff options
author | Ben Murdoch <benm@google.com> | 2011-05-13 16:23:25 +0100 |
---|---|---|
committer | Ben Murdoch <benm@google.com> | 2011-05-16 11:35:02 +0100 |
commit | 65f03d4f644ce73618e5f4f50dd694b26f55ae12 (patch) | |
tree | f478babb801e720de7bfaee23443ffe029f58731 /Source/WebKit2/Platform/RunLoop.h | |
parent | 47de4a2fb7262c7ebdb9cd133ad2c54c187454d0 (diff) | |
download | external_webkit-65f03d4f644ce73618e5f4f50dd694b26f55ae12.zip external_webkit-65f03d4f644ce73618e5f4f50dd694b26f55ae12.tar.gz external_webkit-65f03d4f644ce73618e5f4f50dd694b26f55ae12.tar.bz2 |
Merge WebKit at r75993: Initial merge by git.
Change-Id: I602bbdc3974787a3b0450456a30a7868286921c3
Diffstat (limited to 'Source/WebKit2/Platform/RunLoop.h')
-rw-r--r-- | Source/WebKit2/Platform/RunLoop.h | 154 |
1 files changed, 154 insertions, 0 deletions
diff --git a/Source/WebKit2/Platform/RunLoop.h b/Source/WebKit2/Platform/RunLoop.h new file mode 100644 index 0000000..aa87506 --- /dev/null +++ b/Source/WebKit2/Platform/RunLoop.h @@ -0,0 +1,154 @@ +/* + * Copyright (C) 2010 Apple Inc. All rights reserved. + * Copyright (C) 2010 Nokia Corporation and/or its subsidiary(-ies) + * Portions Copyright (c) 2010 Motorola Mobility, Inc. All rights reserved. + * + * Redistribution and use in source and binary forms, with or without + * modification, are permitted provided that the following conditions + * are met: + * 1. Redistributions of source code must retain the above copyright + * notice, this list of conditions and the following disclaimer. + * 2. Redistributions in binary form must reproduce the above copyright + * notice, this list of conditions and the following disclaimer in the + * documentation and/or other materials provided with the distribution. + * + * THIS SOFTWARE IS PROVIDED BY APPLE INC. AND ITS CONTRIBUTORS ``AS IS'' + * AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, + * THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR + * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE INC. OR ITS CONTRIBUTORS + * BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR + * CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF + * SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS + * INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN + * CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE) + * ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF + * THE POSSIBILITY OF SUCH DAMAGE. + */ + +#ifndef RunLoop_h +#define RunLoop_h + +#include <wtf/HashMap.h> +#include <wtf/PassOwnPtr.h> +#include <wtf/ThreadSpecific.h> +#include <wtf/Threading.h> +#include <wtf/Vector.h> +#if PLATFORM(GTK) +typedef struct _GSource GSource; +typedef struct _GMainLoop GMainLoop; +typedef struct _GMainContext GMainContext; +typedef int gboolean; +#endif + +class WorkItem; + +class RunLoop { +public: + // Must be called from the main thread. + static void initializeMainRunLoop(); + + static RunLoop* current(); + static RunLoop* main(); + + void scheduleWork(PassOwnPtr<WorkItem>); + + static void run(); + void stop(); + + class TimerBase { + friend class RunLoop; + public: + TimerBase(RunLoop*); + virtual ~TimerBase(); + + void startRepeating(double repeatInterval) { start(repeatInterval, true); } + void startOneShot(double interval) { start(interval, false); } + + void stop(); + bool isActive() const; + + virtual void fired() = 0; + + private: + void start(double nextFireInterval, bool repeat); + + RunLoop* m_runLoop; + +#if PLATFORM(WIN) + static void timerFired(RunLoop*, uint64_t ID); + uint64_t m_ID; + bool m_isRepeating; +#elif PLATFORM(MAC) + static void timerFired(CFRunLoopTimerRef, void*); + CFRunLoopTimerRef m_timer; +#elif PLATFORM(QT) + static void timerFired(RunLoop*, int ID); + int m_ID; + bool m_isRepeating; +#elif PLATFORM(GTK) + static gboolean oneShotTimerFired(RunLoop::TimerBase*); + static gboolean repeatingTimerFired(RunLoop::TimerBase*); + void resetTimerSource(); + GSource* m_timerSource; +#endif + }; + + template <typename TimerFiredClass> + class Timer : public TimerBase { + public: + typedef void (TimerFiredClass::*TimerFiredFunction)(); + + Timer(RunLoop* runLoop, TimerFiredClass* o, TimerFiredFunction f) + : TimerBase(runLoop) + , m_object(o) + , m_function(f) + { + } + + private: + virtual void fired() { (m_object->*m_function)(); } + + TimerFiredClass* m_object; + TimerFiredFunction m_function; + }; + +private: + friend class WTF::ThreadSpecific<RunLoop>; + + RunLoop(); + ~RunLoop(); + + void performWork(); + void wakeUp(); + + Mutex m_workItemQueueLock; + Vector<WorkItem*> m_workItemQueue; + +#if PLATFORM(WIN) + static bool registerRunLoopMessageWindowClass(); + static LRESULT CALLBACK RunLoopWndProc(HWND, UINT, WPARAM, LPARAM); + LRESULT wndProc(HWND hWnd, UINT message, WPARAM wParam, LPARAM lParam); + HWND m_runLoopMessageWindow; + + typedef HashMap<uint64_t, TimerBase*> TimerMap; + TimerMap m_activeTimers; +#elif PLATFORM(MAC) + static void performWork(void*); + CFRunLoopRef m_runLoop; + CFRunLoopSourceRef m_runLoopSource; +#elif PLATFORM(QT) + typedef HashMap<int, TimerBase*> TimerMap; + TimerMap m_activeTimers; + class TimerObject; + TimerObject* m_timerObject; +#elif PLATFORM(GTK) +public: + static gboolean queueWork(RunLoop*); + GMainLoop* mainLoop(); +private: + GMainContext* m_runLoopContext; + GMainLoop* m_runLoopMain; +#endif +}; + +#endif // RunLoop_h |