| 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 428 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 439 forwarder = new AsyncTaskForwarder(loaderProxy); | 439 forwarder = new AsyncTaskForwarder(loaderProxy); |
| 440 | 440 |
| 441 MainThreadLoaderHolder* mainThreadLoaderHolder = new MainThreadLoaderHolder(
forwarder, workerThreadLifecycleContext); | 441 MainThreadLoaderHolder* mainThreadLoaderHolder = new MainThreadLoaderHolder(
forwarder, workerThreadLifecycleContext); |
| 442 if (mainThreadLoaderHolder->wasContextDestroyedBeforeObserverCreation()) { | 442 if (mainThreadLoaderHolder->wasContextDestroyedBeforeObserverCreation()) { |
| 443 // The thread is already terminating. | 443 // The thread is already terminating. |
| 444 forwarder->abort(); | 444 forwarder->abort(); |
| 445 mainThreadLoaderHolder->m_forwarder = nullptr; | 445 mainThreadLoaderHolder->m_forwarder = nullptr; |
| 446 return; | 446 return; |
| 447 } | 447 } |
| 448 mainThreadLoaderHolder->m_workerLoader = workerLoader; | 448 mainThreadLoaderHolder->m_workerLoader = workerLoader; |
| 449 forwarder->forwardTask(BLINK_FROM_HERE, createCrossThreadTask(&WorkerThreada
bleLoader::didStart, wrapCrossThreadPersistent(workerLoader), wrapCrossThreadPer
sistent(mainThreadLoaderHolder))); |
| 449 mainThreadLoaderHolder->start(*toDocument(executionContext), std::move(reque
st), options, resourceLoaderOptions); | 450 mainThreadLoaderHolder->start(*toDocument(executionContext), std::move(reque
st), options, resourceLoaderOptions); |
| 450 forwarder->forwardTask(BLINK_FROM_HERE, createCrossThreadTask(&WorkerThreada
bleLoader::didStart, wrapCrossThreadPersistent(workerLoader), wrapCrossThreadPer
sistent(mainThreadLoaderHolder))); | |
| 451 } | 451 } |
| 452 | 452 |
| 453 WorkerThreadableLoader::MainThreadLoaderHolder::~MainThreadLoaderHolder() | 453 WorkerThreadableLoader::MainThreadLoaderHolder::~MainThreadLoaderHolder() |
| 454 { | 454 { |
| 455 DCHECK(isMainThread()); | 455 DCHECK(isMainThread()); |
| 456 DCHECK(!m_workerLoader); | 456 DCHECK(!m_workerLoader); |
| 457 } | 457 } |
| 458 | 458 |
| 459 void WorkerThreadableLoader::MainThreadLoaderHolder::overrideTimeout(unsigned lo
ng timeoutMilliseconds) | 459 void WorkerThreadableLoader::MainThreadLoaderHolder::overrideTimeout(unsigned lo
ng timeoutMilliseconds) |
| 460 { | 460 { |
| (...skipping 138 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 599 const ResourceLoaderOptions& originalResourceLoaderOptions) | 599 const ResourceLoaderOptions& originalResourceLoaderOptions) |
| 600 { | 600 { |
| 601 DCHECK(isMainThread()); | 601 DCHECK(isMainThread()); |
| 602 ResourceLoaderOptions resourceLoaderOptions = originalResourceLoaderOptions; | 602 ResourceLoaderOptions resourceLoaderOptions = originalResourceLoaderOptions; |
| 603 resourceLoaderOptions.requestInitiatorContext = WorkerContext; | 603 resourceLoaderOptions.requestInitiatorContext = WorkerContext; |
| 604 m_mainThreadLoader = DocumentThreadableLoader::create(document, this, option
s, resourceLoaderOptions); | 604 m_mainThreadLoader = DocumentThreadableLoader::create(document, this, option
s, resourceLoaderOptions); |
| 605 m_mainThreadLoader->start(ResourceRequest(request.get())); | 605 m_mainThreadLoader->start(ResourceRequest(request.get())); |
| 606 } | 606 } |
| 607 | 607 |
| 608 } // namespace blink | 608 } // namespace blink |
| OLD | NEW |