| 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 182 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 193 workerClientWrapper->didReceiveData(vectorData->data(), vectorData->size()); | 193 workerClientWrapper->didReceiveData(vectorData->data(), vectorData->size()); |
| 194 } | 194 } |
| 195 | 195 |
| 196 void WorkerThreadableLoader::MainThreadBridge::didReceiveData(const char* data,
int dataLength) | 196 void WorkerThreadableLoader::MainThreadBridge::didReceiveData(const char* data,
int dataLength) |
| 197 { | 197 { |
| 198 OwnPtr<Vector<char> > vector = adoptPtr(new Vector<char>(dataLength)); // ne
eds to be an OwnPtr for usage with createCallbackTask. | 198 OwnPtr<Vector<char> > vector = adoptPtr(new Vector<char>(dataLength)); // ne
eds to be an OwnPtr for usage with createCallbackTask. |
| 199 memcpy(vector->data(), data, dataLength); | 199 memcpy(vector->data(), data, dataLength); |
| 200 m_loaderProxy.postTaskForModeToWorkerGlobalScope(createCallbackTask(&workerG
lobalScopeDidReceiveData, m_workerClientWrapper, vector.release()), m_taskMode); | 200 m_loaderProxy.postTaskForModeToWorkerGlobalScope(createCallbackTask(&workerG
lobalScopeDidReceiveData, m_workerClientWrapper, vector.release()), m_taskMode); |
| 201 } | 201 } |
| 202 | 202 |
| 203 static void workerGlobalScopeDidDownloadData(ExecutionContext* context, PassRefP
tr<ThreadableLoaderClientWrapper> workerClientWrapper, int dataLength) |
| 204 { |
| 205 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); |
| 206 workerClientWrapper->didDownloadData(dataLength); |
| 207 } |
| 208 |
| 209 void WorkerThreadableLoader::MainThreadBridge::didDownloadData(int dataLength) |
| 210 { |
| 211 m_loaderProxy.postTaskForModeToWorkerGlobalScope(createCallbackTask(&workerG
lobalScopeDidDownloadData, m_workerClientWrapper, dataLength), m_taskMode); |
| 212 } |
| 213 |
| 203 static void workerGlobalScopeDidReceiveCachedMetadata(ExecutionContext* context,
PassRefPtr<ThreadableLoaderClientWrapper> workerClientWrapper, PassOwnPtr<Vecto
r<char> > vectorData) | 214 static void workerGlobalScopeDidReceiveCachedMetadata(ExecutionContext* context,
PassRefPtr<ThreadableLoaderClientWrapper> workerClientWrapper, PassOwnPtr<Vecto
r<char> > vectorData) |
| 204 { | 215 { |
| 205 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); | 216 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); |
| 206 workerClientWrapper->didReceiveCachedMetadata(vectorData->data(), vectorData
->size()); | 217 workerClientWrapper->didReceiveCachedMetadata(vectorData->data(), vectorData
->size()); |
| 207 } | 218 } |
| 208 | 219 |
| 209 void WorkerThreadableLoader::MainThreadBridge::didReceiveCachedMetadata(const ch
ar* data, int dataLength) | 220 void WorkerThreadableLoader::MainThreadBridge::didReceiveCachedMetadata(const ch
ar* data, int dataLength) |
| 210 { | 221 { |
| 211 OwnPtr<Vector<char> > vector = adoptPtr(new Vector<char>(dataLength)); // ne
eds to be an OwnPtr for usage with createCallbackTask. | 222 OwnPtr<Vector<char> > vector = adoptPtr(new Vector<char>(dataLength)); // ne
eds to be an OwnPtr for usage with createCallbackTask. |
| 212 memcpy(vector->data(), data, dataLength); | 223 memcpy(vector->data(), data, dataLength); |
| (...skipping 38 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 251 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); | 262 ASSERT_UNUSED(context, context->isWorkerGlobalScope()); |
| 252 workerClientWrapper->didFailRedirectCheck(); | 263 workerClientWrapper->didFailRedirectCheck(); |
| 253 } | 264 } |
| 254 | 265 |
| 255 void WorkerThreadableLoader::MainThreadBridge::didFailRedirectCheck() | 266 void WorkerThreadableLoader::MainThreadBridge::didFailRedirectCheck() |
| 256 { | 267 { |
| 257 m_loaderProxy.postTaskForModeToWorkerGlobalScope(createCallbackTask(&workerG
lobalScopeDidFailRedirectCheck, m_workerClientWrapper), m_taskMode); | 268 m_loaderProxy.postTaskForModeToWorkerGlobalScope(createCallbackTask(&workerG
lobalScopeDidFailRedirectCheck, m_workerClientWrapper), m_taskMode); |
| 258 } | 269 } |
| 259 | 270 |
| 260 } // namespace WebCore | 271 } // namespace WebCore |
| OLD | NEW |