]>
Commit | Line | Data |
---|---|---|
b37bf2e1 | 1 | /* |
9dae56ea | 2 | * Copyright (C) 2007, 2008 Apple Inc. All rights reserved. |
b37bf2e1 A |
3 | * |
4 | * Redistribution and use in source and binary forms, with or without | |
5 | * modification, are permitted provided that the following conditions | |
6 | * are met: | |
7 | * | |
8 | * 1. Redistributions of source code must retain the above copyright | |
9dae56ea | 9 | * notice, this list of conditions and the following disclaimer. |
b37bf2e1 A |
10 | * 2. Redistributions in binary form must reproduce the above copyright |
11 | * notice, this list of conditions and the following disclaimer in the | |
9dae56ea | 12 | * documentation and/or other materials provided with the distribution. |
b37bf2e1 A |
13 | * 3. Neither the name of Apple Computer, Inc. ("Apple") nor the names of |
14 | * its contributors may be used to endorse or promote products derived | |
9dae56ea | 15 | * from this software without specific prior written permission. |
b37bf2e1 A |
16 | * |
17 | * THIS SOFTWARE IS PROVIDED BY APPLE AND ITS CONTRIBUTORS "AS IS" AND ANY | |
18 | * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE IMPLIED | |
19 | * WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE ARE | |
20 | * DISCLAIMED. IN NO EVENT SHALL APPLE OR ITS CONTRIBUTORS BE LIABLE FOR ANY | |
21 | * DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES | |
22 | * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; | |
23 | * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND | |
24 | * ON ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
25 | * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE OF | |
26 | * THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
27 | */ | |
9dae56ea A |
28 | |
29 | #import "config.h" | |
30 | #import "MainThread.h" | |
b37bf2e1 | 31 | |
4e4e5a6f | 32 | #import <CoreFoundation/CoreFoundation.h> |
9dae56ea | 33 | #import <Foundation/NSThread.h> |
4e4e5a6f | 34 | #import <stdio.h> |
ba379fdc | 35 | #import <wtf/Assertions.h> |
4e4e5a6f | 36 | #import <wtf/Threading.h> |
b37bf2e1 | 37 | |
9dae56ea A |
38 | @interface WTFMainThreadCaller : NSObject { |
39 | } | |
40 | - (void)call; | |
41 | @end | |
b37bf2e1 | 42 | |
9dae56ea | 43 | @implementation WTFMainThreadCaller |
b37bf2e1 | 44 | |
9dae56ea A |
45 | - (void)call |
46 | { | |
47 | WTF::dispatchFunctionsFromMainThread(); | |
48 | } | |
b37bf2e1 | 49 | |
9dae56ea | 50 | @end // implementation WTFMainThreadCaller |
b37bf2e1 | 51 | |
9dae56ea | 52 | namespace WTF { |
b37bf2e1 | 53 | |
4e4e5a6f A |
54 | static WTFMainThreadCaller* staticMainThreadCaller; |
55 | static bool isTimerPosted; // This is only accessed on the 'main' thread. | |
56 | static bool mainThreadEstablishedAsPthreadMain; | |
57 | static pthread_t mainThreadPthread; | |
58 | static NSThread* mainThreadNSThread; | |
ba379fdc A |
59 | |
60 | void initializeMainThreadPlatform() | |
61 | { | |
62 | ASSERT(!staticMainThreadCaller); | |
63 | staticMainThreadCaller = [[WTFMainThreadCaller alloc] init]; | |
f9bf01c6 | 64 | |
4e4e5a6f A |
65 | mainThreadEstablishedAsPthreadMain = false; |
66 | mainThreadPthread = pthread_self(); | |
67 | mainThreadNSThread = [[NSThread currentThread] retain]; | |
ba379fdc A |
68 | } |
69 | ||
4e4e5a6f A |
70 | void initializeMainThreadToProcessMainThreadPlatform() |
71 | { | |
72 | if (!pthread_main_np()) | |
73 | NSLog(@"WebKit Threading Violation - initial use of WebKit from a secondary thread."); | |
74 | ||
75 | ASSERT(!staticMainThreadCaller); | |
76 | staticMainThreadCaller = [[WTFMainThreadCaller alloc] init]; | |
77 | ||
78 | mainThreadEstablishedAsPthreadMain = true; | |
79 | mainThreadPthread = 0; | |
80 | mainThreadNSThread = nil; | |
81 | } | |
82 | ||
83 | static void timerFired(CFRunLoopTimerRef timer, void*) | |
84 | { | |
85 | CFRelease(timer); | |
86 | isTimerPosted = false; | |
87 | WTF::dispatchFunctionsFromMainThread(); | |
88 | } | |
89 | ||
90 | static void postTimer() | |
91 | { | |
92 | ASSERT(isMainThread()); | |
93 | ||
94 | if (isTimerPosted) | |
95 | return; | |
96 | ||
97 | isTimerPosted = true; | |
98 | CFRunLoopAddTimer(CFRunLoopGetCurrent(), CFRunLoopTimerCreate(0, 0, 0, 0, 0, timerFired, 0), kCFRunLoopCommonModes); | |
99 | } | |
100 | ||
9dae56ea A |
101 | void scheduleDispatchFunctionsOnMainThread() |
102 | { | |
ba379fdc | 103 | ASSERT(staticMainThreadCaller); |
4e4e5a6f A |
104 | |
105 | if (isMainThread()) { | |
106 | postTimer(); | |
107 | return; | |
108 | } | |
109 | ||
110 | if (mainThreadEstablishedAsPthreadMain) { | |
111 | ASSERT(!mainThreadNSThread); | |
112 | [staticMainThreadCaller performSelectorOnMainThread:@selector(call) withObject:nil waitUntilDone:NO]; | |
113 | return; | |
114 | } | |
115 | ||
4e4e5a6f A |
116 | ASSERT(mainThreadNSThread); |
117 | [staticMainThreadCaller performSelector:@selector(call) onThread:mainThreadNSThread withObject:nil waitUntilDone:NO]; | |
9dae56ea | 118 | } |
b37bf2e1 | 119 | |
4e4e5a6f A |
120 | bool isMainThread() |
121 | { | |
122 | if (mainThreadEstablishedAsPthreadMain) { | |
123 | ASSERT(!mainThreadPthread); | |
124 | return pthread_main_np(); | |
125 | } | |
126 | ||
4e4e5a6f A |
127 | ASSERT(mainThreadPthread); |
128 | return pthread_equal(pthread_self(), mainThreadPthread); | |
4e4e5a6f A |
129 | } |
130 | ||
131 | // This function is the same as isMainThread() above except that it does not do | |
132 | // a ASSERT(mainThreadPthread). This should only be used by code that can get | |
133 | // invoked when the WebThread hasn't been started. See <rdar://8502487>. | |
134 | bool isWebThread() | |
135 | { | |
136 | ASSERT(!mainThreadEstablishedAsPthreadMain); | |
137 | return pthread_equal(pthread_self(), mainThreadPthread); | |
138 | } | |
139 | ||
9dae56ea | 140 | } // namespace WTF |