| OLD | NEW |
| 1 // Copyright 2017 The Chromium Authors. All rights reserved. | 1 // Copyright 2017 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/network/cache_url_loader.h" | 5 #include "content/network/cache_url_loader.h" |
| 6 | 6 |
| 7 #include "base/bind.h" | 7 #include "base/bind.h" |
| 8 #include "base/macros.h" | 8 #include "base/macros.h" |
| 9 #include "base/strings/string_util.h" | 9 #include "base/strings/string_util.h" |
| 10 #include "base/threading/thread_task_runner_handle.h" | 10 #include "base/threading/thread_task_runner_handle.h" |
| (...skipping 34 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 45 | 45 |
| 46 if (rv != net::ERR_IO_PENDING) | 46 if (rv != net::ERR_IO_PENDING) |
| 47 DataAvailable(rv); | 47 DataAvailable(rv); |
| 48 } | 48 } |
| 49 | 49 |
| 50 ~CacheURLLoader() {} | 50 ~CacheURLLoader() {} |
| 51 | 51 |
| 52 private: | 52 private: |
| 53 void DataAvailable(int result) { | 53 void DataAvailable(int result) { |
| 54 DCHECK_EQ(net::OK, result); | 54 DCHECK_EQ(net::OK, result); |
| 55 MojoCreateDataPipeOptions options; | 55 mojo::DataPipe data_pipe(data_.size()); |
| 56 options.struct_size = sizeof(MojoCreateDataPipeOptions); | |
| 57 options.flags = MOJO_CREATE_DATA_PIPE_OPTIONS_FLAG_NONE; | |
| 58 options.element_num_bytes = 1; | |
| 59 options.capacity_num_bytes = data_.size(); | |
| 60 mojo::DataPipe data_pipe(options); | |
| 61 | |
| 62 DCHECK(data_pipe.producer_handle.is_valid()); | |
| 63 DCHECK(data_pipe.consumer_handle.is_valid()); | |
| 64 | 56 |
| 65 CHECK( | 57 CHECK( |
| 66 mojo::common::BlockingCopyFromString(data_, data_pipe.producer_handle)); | 58 mojo::common::BlockingCopyFromString(data_, data_pipe.producer_handle)); |
| 67 | 59 |
| 68 client_->OnStartLoadingResponseBody(std::move(data_pipe.consumer_handle)); | 60 client_->OnStartLoadingResponseBody(std::move(data_pipe.consumer_handle)); |
| 69 | 61 client_->OnComplete(ResourceRequestCompletionStatus(data_.size())); |
| 70 ResourceRequestCompletionStatus request_complete_data; | |
| 71 request_complete_data.error_code = net::OK; | |
| 72 request_complete_data.exists_in_cache = false; | |
| 73 request_complete_data.completion_time = base::TimeTicks::Now(); | |
| 74 request_complete_data.encoded_data_length = data_.size(); | |
| 75 request_complete_data.encoded_body_length = data_.size(); | |
| 76 client_->OnComplete(request_complete_data); | |
| 77 | 62 |
| 78 // So we don't delete |this| in the constructor. | 63 // So we don't delete |this| in the constructor. |
| 79 base::ThreadTaskRunnerHandle::Get()->DeleteSoon(FROM_HERE, this); | 64 base::ThreadTaskRunnerHandle::Get()->DeleteSoon(FROM_HERE, this); |
| 80 } | 65 } |
| 81 | 66 |
| 82 std::string data_; | 67 std::string data_; |
| 83 mojom::URLLoaderClientPtr client_; | 68 mojom::URLLoaderClientPtr client_; |
| 84 net::ViewCacheHelper cache_helper_; | 69 net::ViewCacheHelper cache_helper_; |
| 85 | 70 |
| 86 DISALLOW_COPY_AND_ASSIGN(CacheURLLoader); | 71 DISALLOW_COPY_AND_ASSIGN(CacheURLLoader); |
| 87 }; | 72 }; |
| 88 } | 73 } |
| 89 | 74 |
| 90 void StartCacheURLLoader(const ResourceRequest& request, | 75 void StartCacheURLLoader(const ResourceRequest& request, |
| 91 net::URLRequestContext* request_context, | 76 net::URLRequestContext* request_context, |
| 92 mojom::URLLoaderClientPtr client) { | 77 mojom::URLLoaderClientPtr client) { |
| 93 new CacheURLLoader(request, request_context, std::move(client)); | 78 new CacheURLLoader(request, request_context, std::move(client)); |
| 94 } | 79 } |
| 95 | 80 |
| 96 } // namespace content | 81 } // namespace content |
| OLD | NEW |