Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(415)

Side by Side Diff: third_party/WebKit/Source/core/loader/WorkerThreadableLoader.cpp

Issue 1728803002: Rename WorkerThread to WorkerScript Base URL: https://chromium.googlesource.com/chromium/src.git@workerscript-controller
Patch Set: Created 4 years, 10 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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
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
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
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
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698