| OLD | NEW |
| (Empty) |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | |
| 2 // Use of this source code is governed by a BSD-style license that can be | |
| 3 // found in the LICENSE file. | |
| 4 | |
| 5 #include "chrome/browser/net/blob_url_request_job_factory.h" | |
| 6 | |
| 7 #include "base/basictypes.h" | |
| 8 #include "base/compiler_specific.h" | |
| 9 #include "chrome/common/url_constants.h" | |
| 10 #include "content/browser/browser_thread.h" | |
| 11 #include "content/browser/chrome_blob_storage_context.h" | |
| 12 #include "content/browser/renderer_host/resource_dispatcher_host.h" | |
| 13 #include "content/browser/renderer_host/resource_dispatcher_host_request_info.h" | |
| 14 #include "net/url_request/url_request_job_factory.h" | |
| 15 #include "webkit/blob/blob_storage_controller.h" | |
| 16 #include "webkit/blob/blob_url_request_job.h" | |
| 17 | |
| 18 namespace { | |
| 19 | |
| 20 class BlobProtocolHandler | |
| 21 : public net::URLRequestJobFactory::ProtocolHandler { | |
| 22 public: | |
| 23 explicit BlobProtocolHandler( | |
| 24 webkit_blob::BlobStorageController* blob_storage_controller); | |
| 25 virtual ~BlobProtocolHandler(); | |
| 26 | |
| 27 virtual net::URLRequestJob* MaybeCreateJob( | |
| 28 net::URLRequest* request) const OVERRIDE; | |
| 29 | |
| 30 private: | |
| 31 // No scoped_refptr because |blob_storage_controller_| is owned by the | |
| 32 // ProfileIOData, which also owns this ProtocolHandler. | |
| 33 webkit_blob::BlobStorageController* const blob_storage_controller_; | |
| 34 | |
| 35 DISALLOW_COPY_AND_ASSIGN(BlobProtocolHandler); | |
| 36 }; | |
| 37 | |
| 38 BlobProtocolHandler::BlobProtocolHandler( | |
| 39 webkit_blob::BlobStorageController* blob_storage_controller) | |
| 40 : blob_storage_controller_(blob_storage_controller) { | |
| 41 DCHECK(blob_storage_controller); | |
| 42 } | |
| 43 | |
| 44 BlobProtocolHandler::~BlobProtocolHandler() {} | |
| 45 | |
| 46 net::URLRequestJob* BlobProtocolHandler::MaybeCreateJob( | |
| 47 net::URLRequest* request) const { | |
| 48 scoped_refptr<webkit_blob::BlobData> data; | |
| 49 ResourceDispatcherHostRequestInfo* info = | |
| 50 ResourceDispatcherHost::InfoForRequest(request); | |
| 51 if (info) { | |
| 52 // Resource dispatcher host already looked up the blob data. | |
| 53 data = info->requested_blob_data(); | |
| 54 } else { | |
| 55 // This request is not coming through resource dispatcher host. | |
| 56 data = blob_storage_controller_->GetBlobDataFromUrl(request->url()); | |
| 57 } | |
| 58 return new webkit_blob::BlobURLRequestJob( | |
| 59 request, data, | |
| 60 BrowserThread::GetMessageLoopProxyForThread(BrowserThread::FILE)); | |
| 61 } | |
| 62 | |
| 63 } // namespace | |
| 64 | |
| 65 net::URLRequestJobFactory::ProtocolHandler* | |
| 66 CreateBlobProtocolHandler(webkit_blob::BlobStorageController* controller) { | |
| 67 DCHECK(controller); | |
| 68 return new BlobProtocolHandler(controller); | |
| 69 } | |
| OLD | NEW |