OLD | NEW |
1 /* | 1 /* |
2 * Copyright (C) 2009, 2010 Google Inc. All rights reserved. | 2 * Copyright (C) 2009, 2010 Google Inc. All rights reserved. |
3 * | 3 * |
4 * Redistribution and use in source and binary forms, with or without | 4 * Redistribution and use in source and binary forms, with or without |
5 * modification, are permitted provided that the following conditions are | 5 * modification, are permitted provided that the following conditions are |
6 * met: | 6 * met: |
7 * | 7 * |
8 * * Redistributions of source code must retain the above copyright | 8 * * Redistributions of source code must retain the above copyright |
9 * notice, this list of conditions and the following disclaimer. | 9 * notice, this list of conditions and the following disclaimer. |
10 * * Redistributions in binary form must reproduce the above | 10 * * Redistributions in binary form must reproduce the above |
(...skipping 18 matching lines...) Expand all Loading... |
29 */ | 29 */ |
30 | 30 |
31 #include "core/loader/WorkerThreadableLoader.h" | 31 #include "core/loader/WorkerThreadableLoader.h" |
32 | 32 |
33 #include "core/dom/CrossThreadTask.h" | 33 #include "core/dom/CrossThreadTask.h" |
34 #include "core/dom/Document.h" | 34 #include "core/dom/Document.h" |
35 #include "core/loader/DocumentThreadableLoader.h" | 35 #include "core/loader/DocumentThreadableLoader.h" |
36 #include "core/timing/WorkerGlobalScopePerformance.h" | 36 #include "core/timing/WorkerGlobalScopePerformance.h" |
37 #include "core/workers/WorkerGlobalScope.h" | 37 #include "core/workers/WorkerGlobalScope.h" |
38 #include "core/workers/WorkerLoaderProxy.h" | 38 #include "core/workers/WorkerLoaderProxy.h" |
39 #include "core/workers/WorkerThread.h" | 39 #include "core/workers/WorkerScript.h" |
40 #include "platform/ThreadSafeFunctional.h" | 40 #include "platform/ThreadSafeFunctional.h" |
41 #include "platform/WaitableEvent.h" | 41 #include "platform/WaitableEvent.h" |
42 #include "platform/heap/SafePoint.h" | 42 #include "platform/heap/SafePoint.h" |
43 #include "platform/network/ResourceError.h" | 43 #include "platform/network/ResourceError.h" |
44 #include "platform/network/ResourceRequest.h" | 44 #include "platform/network/ResourceRequest.h" |
45 #include "platform/network/ResourceResponse.h" | 45 #include "platform/network/ResourceResponse.h" |
46 #include "platform/network/ResourceTimingInfo.h" | 46 #include "platform/network/ResourceTimingInfo.h" |
47 #include "platform/weborigin/SecurityPolicy.h" | 47 #include "platform/weborigin/SecurityPolicy.h" |
48 #include "public/platform/Platform.h" | 48 #include "public/platform/Platform.h" |
49 #include "wtf/MainThread.h" | 49 #include "wtf/MainThread.h" |
(...skipping 211 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
261 void WorkerThreadableLoader::MainThreadBridgeBase::didReceiveResourceTiming(cons
t ResourceTimingInfo& info) | 261 void WorkerThreadableLoader::MainThreadBridgeBase::didReceiveResourceTiming(cons
t ResourceTimingInfo& info) |
262 { | 262 { |
263 forwardTaskToWorker(createCrossThreadTask(&ThreadableLoaderClientWrapper::di
dReceiveResourceTiming, m_workerClientWrapper, info)); | 263 forwardTaskToWorker(createCrossThreadTask(&ThreadableLoaderClientWrapper::di
dReceiveResourceTiming, m_workerClientWrapper, info)); |
264 } | 264 } |
265 | 265 |
266 WorkerThreadableLoader::MainThreadAsyncBridge::MainThreadAsyncBridge( | 266 WorkerThreadableLoader::MainThreadAsyncBridge::MainThreadAsyncBridge( |
267 WorkerGlobalScope& workerGlobalScope, | 267 WorkerGlobalScope& workerGlobalScope, |
268 PassRefPtr<ThreadableLoaderClientWrapper> workerClientWrapper, | 268 PassRefPtr<ThreadableLoaderClientWrapper> workerClientWrapper, |
269 const ThreadableLoaderOptions& options, | 269 const ThreadableLoaderOptions& options, |
270 const ResourceLoaderOptions& resourceLoaderOptions) | 270 const ResourceLoaderOptions& resourceLoaderOptions) |
271 : MainThreadBridgeBase(workerClientWrapper, workerGlobalScope.thread()->work
erLoaderProxy()) | 271 : MainThreadBridgeBase(workerClientWrapper, workerGlobalScope.workerScript()
->workerLoaderProxy()) |
272 { | 272 { |
273 createLoaderInMainThread(options, resourceLoaderOptions); | 273 createLoaderInMainThread(options, resourceLoaderOptions); |
274 } | 274 } |
275 | 275 |
276 void WorkerThreadableLoader::MainThreadAsyncBridge::start(const ResourceRequest&
request, const WorkerGlobalScope& workerGlobalScope) | 276 void WorkerThreadableLoader::MainThreadAsyncBridge::start(const ResourceRequest&
request, const WorkerGlobalScope& workerGlobalScope) |
277 { | 277 { |
278 startInMainThread(request, workerGlobalScope); | 278 startInMainThread(request, workerGlobalScope); |
279 } | 279 } |
280 | 280 |
281 WorkerThreadableLoader::MainThreadAsyncBridge::~MainThreadAsyncBridge() | 281 WorkerThreadableLoader::MainThreadAsyncBridge::~MainThreadAsyncBridge() |
282 { | 282 { |
283 } | 283 } |
284 | 284 |
285 void WorkerThreadableLoader::MainThreadAsyncBridge::forwardTaskToWorker(PassOwnP
tr<ExecutionContextTask> task) | 285 void WorkerThreadableLoader::MainThreadAsyncBridge::forwardTaskToWorker(PassOwnP
tr<ExecutionContextTask> task) |
286 { | 286 { |
287 loaderProxy()->postTaskToWorkerGlobalScope(task); | 287 loaderProxy()->postTaskToWorkerGlobalScope(task); |
288 } | 288 } |
289 | 289 |
290 void WorkerThreadableLoader::MainThreadAsyncBridge::forwardTaskToWorkerOnLoaderD
one(PassOwnPtr<ExecutionContextTask> task) | 290 void WorkerThreadableLoader::MainThreadAsyncBridge::forwardTaskToWorkerOnLoaderD
one(PassOwnPtr<ExecutionContextTask> task) |
291 { | 291 { |
292 loaderProxy()->postTaskToWorkerGlobalScope(task); | 292 loaderProxy()->postTaskToWorkerGlobalScope(task); |
293 } | 293 } |
294 | 294 |
295 WorkerThreadableLoader::MainThreadSyncBridge::MainThreadSyncBridge( | 295 WorkerThreadableLoader::MainThreadSyncBridge::MainThreadSyncBridge( |
296 WorkerGlobalScope& workerGlobalScope, | 296 WorkerGlobalScope& workerGlobalScope, |
297 PassRefPtr<ThreadableLoaderClientWrapper> workerClientWrapper, | 297 PassRefPtr<ThreadableLoaderClientWrapper> workerClientWrapper, |
298 const ThreadableLoaderOptions& options, | 298 const ThreadableLoaderOptions& options, |
299 const ResourceLoaderOptions& resourceLoaderOptions) | 299 const ResourceLoaderOptions& resourceLoaderOptions) |
300 : MainThreadBridgeBase(workerClientWrapper, workerGlobalScope.thread()->work
erLoaderProxy()) | 300 : MainThreadBridgeBase(workerClientWrapper, workerGlobalScope.workerScript()
->workerLoaderProxy()) |
301 , m_done(false) | 301 , m_done(false) |
302 { | 302 { |
303 createLoaderInMainThread(options, resourceLoaderOptions); | 303 createLoaderInMainThread(options, resourceLoaderOptions); |
304 } | 304 } |
305 | 305 |
306 void WorkerThreadableLoader::MainThreadSyncBridge::start(const ResourceRequest&
request, const WorkerGlobalScope& workerGlobalScope) | 306 void WorkerThreadableLoader::MainThreadSyncBridge::start(const ResourceRequest&
request, const WorkerGlobalScope& workerGlobalScope) |
307 { | 307 { |
308 WaitableEvent* shutdownEvent = workerGlobalScope.thread()->shutdownEvent(); | 308 WaitableEvent* shutdownEvent = workerGlobalScope.workerScript()->shutdownEve
nt(); |
309 m_loaderDoneEvent = adoptPtr(new WaitableEvent()); | 309 m_loaderDoneEvent = adoptPtr(new WaitableEvent()); |
310 | 310 |
311 startInMainThread(request, workerGlobalScope); | 311 startInMainThread(request, workerGlobalScope); |
312 | 312 |
313 size_t signaledIndex; | 313 size_t signaledIndex; |
314 { | 314 { |
315 Vector<WaitableEvent*> events; | 315 Vector<WaitableEvent*> events; |
316 // Order is important; indicies are used later. | 316 // Order is important; indicies are used later. |
317 events.append(shutdownEvent); | 317 events.append(shutdownEvent); |
318 events.append(m_loaderDoneEvent.get()); | 318 events.append(m_loaderDoneEvent.get()); |
(...skipping 44 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
363 | 363 |
364 MutexLocker lock(m_lock); | 364 MutexLocker lock(m_lock); |
365 RELEASE_ASSERT(!m_done); | 365 RELEASE_ASSERT(!m_done); |
366 | 366 |
367 m_clientTasks.append(task); | 367 m_clientTasks.append(task); |
368 m_done = true; | 368 m_done = true; |
369 m_loaderDoneEvent->signal(); | 369 m_loaderDoneEvent->signal(); |
370 } | 370 } |
371 | 371 |
372 } // namespace blink | 372 } // namespace blink |
OLD | NEW |