| OLD | NEW |
| 1 /* | 1 /* |
| 2 * Copyright (C) 2009 Google Inc. All rights reserved. | 2 * Copyright (C) 2009 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 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 49 namespace blink { | 49 namespace blink { |
| 50 | 50 |
| 51 class ResourceError; | 51 class ResourceError; |
| 52 class ResourceRequest; | 52 class ResourceRequest; |
| 53 class ResourceResponse; | 53 class ResourceResponse; |
| 54 class WorkerGlobalScope; | 54 class WorkerGlobalScope; |
| 55 class WorkerLoaderProxy; | 55 class WorkerLoaderProxy; |
| 56 struct CrossThreadResourceRequestData; | 56 struct CrossThreadResourceRequestData; |
| 57 struct CrossThreadResourceTimingInfoData; | 57 struct CrossThreadResourceTimingInfoData; |
| 58 | 58 |
| 59 // A WorkerThreadableLoader is a ThreadableLoader implementation intended to | 59 // TODO(yhirano): Draw a diagram to illustrate the class relationship. |
| 60 // be used in a WebWorker thread. Because Blink's ResourceFetcher and | 60 // TODO(yhirano): Rename inner classes so that readers can see in which thread |
| 61 // ResourceLoader work only in the main thread, a WorkerThreadableLoader holds | 61 // they are living easily. |
| 62 // a ThreadableLoader in the main thread and delegates tasks asynchronously | |
| 63 // to the loader. | |
| 64 // | |
| 65 // CTP: CrossThreadPersistent | |
| 66 // CTWP: CrossThreadWeakPersistent | |
| 67 // | |
| 68 // ---------------------------------------------------------------- | |
| 69 // +------------------------+ | |
| 70 // raw ptr | ThreadableLoaderClient | | |
| 71 // +--------> | worker thread | | |
| 72 // | +------------------------+ | |
| 73 // | | |
| 74 // +----+------------------+ CTP +------------------------+ | |
| 75 // + WorkerThreadableLoader|<--------+ MainThreadLoaderHolder | | |
| 76 // | worker thread +-------->| main thread | | |
| 77 // +-----------------------+ CTWP +----------------------+-+ | |
| 78 // | | |
| 79 // +------------------+ | Member | |
| 80 // | ThreadableLoader | <---+ | |
| 81 // | main thread | | |
| 82 // +------------------+ | |
| 83 // | |
| 84 class WorkerThreadableLoader final : public ThreadableLoader { | 62 class WorkerThreadableLoader final : public ThreadableLoader { |
| 85 public: | 63 public: |
| 86 static void loadResourceSynchronously(WorkerGlobalScope&, const ResourceRequ
est&, ThreadableLoaderClient&, const ThreadableLoaderOptions&, const ResourceLoa
derOptions&); | 64 static void loadResourceSynchronously(WorkerGlobalScope&, const ResourceRequ
est&, ThreadableLoaderClient&, const ThreadableLoaderOptions&, const ResourceLoa
derOptions&); |
| 87 static WorkerThreadableLoader* create(WorkerGlobalScope& workerGlobalScope,
ThreadableLoaderClient* client, const ThreadableLoaderOptions& options, const Re
sourceLoaderOptions& resourceLoaderOptions) | 65 static WorkerThreadableLoader* create(WorkerGlobalScope& workerGlobalScope,
ThreadableLoaderClient* client, const ThreadableLoaderOptions& options, const Re
sourceLoaderOptions& resourceLoaderOptions) |
| 88 { | 66 { |
| 89 return new WorkerThreadableLoader(workerGlobalScope, client, options, re
sourceLoaderOptions, LoadAsynchronously); | 67 return new WorkerThreadableLoader(workerGlobalScope, client, options, re
sourceLoaderOptions, LoadAsynchronously); |
| 90 } | 68 } |
| 91 | 69 |
| 92 ~WorkerThreadableLoader() override; | 70 ~WorkerThreadableLoader() override; |
| 93 | 71 |
| (...skipping 22 matching lines...) Expand all Loading... |
| 116 }; | 94 }; |
| 117 class AsyncTaskForwarder; | 95 class AsyncTaskForwarder; |
| 118 struct TaskWithLocation; | 96 struct TaskWithLocation; |
| 119 class WaitableEventWithTasks; | 97 class WaitableEventWithTasks; |
| 120 class SyncTaskForwarder; | 98 class SyncTaskForwarder; |
| 121 | 99 |
| 122 // An instance of this class lives in the main thread. It is a | 100 // An instance of this class lives in the main thread. It is a |
| 123 // ThreadableLoaderClient for a DocumentThreadableLoader and forward | 101 // ThreadableLoaderClient for a DocumentThreadableLoader and forward |
| 124 // notifications to the associated WorkerThreadableLoader living in the | 102 // notifications to the associated WorkerThreadableLoader living in the |
| 125 // worker thread. | 103 // worker thread. |
| 126 class MainThreadLoaderHolder final : public GarbageCollectedFinalized<MainTh
readLoaderHolder>, public ThreadableLoaderClient, public WorkerThreadLifecycleOb
server { | 104 class Peer final : public GarbageCollectedFinalized<Peer>, public Threadable
LoaderClient, public WorkerThreadLifecycleObserver { |
| 127 USING_GARBAGE_COLLECTED_MIXIN(MainThreadLoaderHolder); | 105 USING_GARBAGE_COLLECTED_MIXIN(Peer); |
| 128 public: | 106 public: |
| 129 static void createAndStart( | 107 static void createAndStart( |
| 130 WorkerThreadableLoader*, | 108 WorkerThreadableLoader*, |
| 131 PassRefPtr<WorkerLoaderProxy>, | 109 PassRefPtr<WorkerLoaderProxy>, |
| 132 WorkerThreadLifecycleContext*, | 110 WorkerThreadLifecycleContext*, |
| 133 std::unique_ptr<CrossThreadResourceRequestData>, | 111 std::unique_ptr<CrossThreadResourceRequestData>, |
| 134 const ThreadableLoaderOptions&, | 112 const ThreadableLoaderOptions&, |
| 135 const ResourceLoaderOptions&, | 113 const ResourceLoaderOptions&, |
| 136 PassRefPtr<WaitableEventWithTasks>, | 114 PassRefPtr<WaitableEventWithTasks>, |
| 137 ExecutionContext*); | 115 ExecutionContext*); |
| 138 ~MainThreadLoaderHolder() override; | 116 ~Peer() override; |
| 139 | 117 |
| 140 void overrideTimeout(unsigned long timeoutMillisecond); | 118 void overrideTimeout(unsigned long timeoutMillisecond); |
| 141 void cancel(); | 119 void cancel(); |
| 142 | 120 |
| 143 void didSendData(unsigned long long bytesSent, unsigned long long totalB
ytesToBeSent) override; | 121 void didSendData(unsigned long long bytesSent, unsigned long long totalB
ytesToBeSent) override; |
| 144 void didReceiveResponse(unsigned long identifier, const ResourceResponse
&, std::unique_ptr<WebDataConsumerHandle>) override; | 122 void didReceiveResponse(unsigned long identifier, const ResourceResponse
&, std::unique_ptr<WebDataConsumerHandle>) override; |
| 145 void didReceiveData(const char*, unsigned dataLength) override; | 123 void didReceiveData(const char*, unsigned dataLength) override; |
| 146 void didDownloadData(int dataLength) override; | 124 void didDownloadData(int dataLength) override; |
| 147 void didReceiveCachedMetadata(const char*, int dataLength) override; | 125 void didReceiveCachedMetadata(const char*, int dataLength) override; |
| 148 void didFinishLoading(unsigned long identifier, double finishTime) overr
ide; | 126 void didFinishLoading(unsigned long identifier, double finishTime) overr
ide; |
| 149 void didFail(const ResourceError&) override; | 127 void didFail(const ResourceError&) override; |
| 150 void didFailAccessControlCheck(const ResourceError&) override; | 128 void didFailAccessControlCheck(const ResourceError&) override; |
| 151 void didFailRedirectCheck() override; | 129 void didFailRedirectCheck() override; |
| 152 void didReceiveResourceTiming(const ResourceTimingInfo&) override; | 130 void didReceiveResourceTiming(const ResourceTimingInfo&) override; |
| 153 | 131 |
| 154 void contextDestroyed() override; | 132 void contextDestroyed() override; |
| 155 | 133 |
| 156 DECLARE_TRACE(); | 134 DECLARE_TRACE(); |
| 157 | 135 |
| 158 private: | 136 private: |
| 159 MainThreadLoaderHolder(TaskForwarder*, WorkerThreadLifecycleContext*); | 137 Peer(TaskForwarder*, WorkerThreadLifecycleContext*); |
| 160 void start(Document&, std::unique_ptr<CrossThreadResourceRequestData>, c
onst ThreadableLoaderOptions&, const ResourceLoaderOptions&); | 138 void start(Document&, std::unique_ptr<CrossThreadResourceRequestData>, c
onst ThreadableLoaderOptions&, const ResourceLoaderOptions&); |
| 161 | 139 |
| 162 Member<TaskForwarder> m_forwarder; | 140 Member<TaskForwarder> m_forwarder; |
| 163 Member<ThreadableLoader> m_mainThreadLoader; | 141 Member<ThreadableLoader> m_mainThreadLoader; |
| 164 | 142 |
| 165 // |*m_workerLoader| lives in the worker thread. | 143 // |*m_workerLoader| lives in the worker thread. |
| 166 CrossThreadWeakPersistent<WorkerThreadableLoader> m_workerLoader; | 144 CrossThreadWeakPersistent<WorkerThreadableLoader> m_workerLoader; |
| 167 }; | 145 }; |
| 168 | 146 |
| 169 WorkerThreadableLoader(WorkerGlobalScope&, ThreadableLoaderClient*, const Th
readableLoaderOptions&, const ResourceLoaderOptions&, BlockingBehavior); | 147 WorkerThreadableLoader(WorkerGlobalScope&, ThreadableLoaderClient*, const Th
readableLoaderOptions&, const ResourceLoaderOptions&, BlockingBehavior); |
| 170 void didStart(MainThreadLoaderHolder*); | 148 void didStart(Peer*); |
| 171 | 149 |
| 172 void didSendData(unsigned long long bytesSent, unsigned long long totalBytes
ToBeSent); | 150 void didSendData(unsigned long long bytesSent, unsigned long long totalBytes
ToBeSent); |
| 173 void didReceiveResponse(unsigned long identifier, std::unique_ptr<CrossThrea
dResourceResponseData>, std::unique_ptr<WebDataConsumerHandle>); | 151 void didReceiveResponse(unsigned long identifier, std::unique_ptr<CrossThrea
dResourceResponseData>, std::unique_ptr<WebDataConsumerHandle>); |
| 174 void didReceiveData(std::unique_ptr<Vector<char>> data); | 152 void didReceiveData(std::unique_ptr<Vector<char>> data); |
| 175 void didReceiveCachedMetadata(std::unique_ptr<Vector<char>> data); | 153 void didReceiveCachedMetadata(std::unique_ptr<Vector<char>> data); |
| 176 void didFinishLoading(unsigned long identifier, double finishTime); | 154 void didFinishLoading(unsigned long identifier, double finishTime); |
| 177 void didFail(const ResourceError&); | 155 void didFail(const ResourceError&); |
| 178 void didFailAccessControlCheck(const ResourceError&); | 156 void didFailAccessControlCheck(const ResourceError&); |
| 179 void didFailRedirectCheck(); | 157 void didFailRedirectCheck(); |
| 180 void didDownloadData(int dataLength); | 158 void didDownloadData(int dataLength); |
| 181 void didReceiveResourceTiming(std::unique_ptr<CrossThreadResourceTimingInfoD
ata>); | 159 void didReceiveResourceTiming(std::unique_ptr<CrossThreadResourceTimingInfoD
ata>); |
| 182 | 160 |
| 183 Member<WorkerGlobalScope> m_workerGlobalScope; | 161 Member<WorkerGlobalScope> m_workerGlobalScope; |
| 184 RefPtr<WorkerLoaderProxy> m_workerLoaderProxy; | 162 RefPtr<WorkerLoaderProxy> m_workerLoaderProxy; |
| 185 ThreadableLoaderClient* m_client; | 163 ThreadableLoaderClient* m_client; |
| 186 | 164 |
| 187 ThreadableLoaderOptions m_threadableLoaderOptions; | 165 ThreadableLoaderOptions m_threadableLoaderOptions; |
| 188 ResourceLoaderOptions m_resourceLoaderOptions; | 166 ResourceLoaderOptions m_resourceLoaderOptions; |
| 189 BlockingBehavior m_blockingBehavior; | 167 BlockingBehavior m_blockingBehavior; |
| 190 | 168 |
| 191 // |*m_mainThreadLoaderHolder| lives in the main thread. | 169 // |*m_peer| lives in the main thread. |
| 192 CrossThreadPersistent<MainThreadLoaderHolder> m_mainThreadLoaderHolder; | 170 CrossThreadPersistent<Peer> m_peer; |
| 193 }; | 171 }; |
| 194 | 172 |
| 195 } // namespace blink | 173 } // namespace blink |
| 196 | 174 |
| 197 #endif // WorkerThreadableLoader_h | 175 #endif // WorkerThreadableLoader_h |
| OLD | NEW |