OLD | NEW |
1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 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 <iterator> | 5 #include <iterator> |
6 | 6 |
7 #include "chrome/browser/predictors/resource_prefetcher.h" | 7 #include "chrome/browser/predictors/resource_prefetcher.h" |
8 | 8 |
9 #include "base/stl_util.h" | 9 #include "base/stl_util.h" |
10 #include "content/public/browser/browser_thread.h" | 10 #include "content/public/browser/browser_thread.h" |
(...skipping 147 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
158 | 158 |
159 TryToLaunchPrefetchRequests(); | 159 TryToLaunchPrefetchRequests(); |
160 } | 160 } |
161 | 161 |
162 void ResourcePrefetcher::ReadFullResponse(net::URLRequest* request) { | 162 void ResourcePrefetcher::ReadFullResponse(net::URLRequest* request) { |
163 bool status = true; | 163 bool status = true; |
164 while (status) { | 164 while (status) { |
165 int bytes_read = 0; | 165 int bytes_read = 0; |
166 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer( | 166 scoped_refptr<net::IOBuffer> buffer(new net::IOBuffer( |
167 kResourceBufferSizeBytes)); | 167 kResourceBufferSizeBytes)); |
168 status = request->Read(buffer, kResourceBufferSizeBytes, &bytes_read); | 168 status = request->Read(buffer.get(), kResourceBufferSizeBytes, &bytes_read); |
169 | 169 |
170 if (status) { | 170 if (status) { |
171 if (request->status().error()) { | 171 if (request->status().error()) { |
172 FinishRequest(request, Request::PREFETCH_STATUS_FAILED); | 172 FinishRequest(request, Request::PREFETCH_STATUS_FAILED); |
173 return; | 173 return; |
174 } else if (bytes_read == 0) { | 174 } else if (bytes_read == 0) { |
175 if (request->was_cached()) | 175 if (request->was_cached()) |
176 FinishRequest(request, Request::PREFETCH_STATUS_FROM_CACHE); | 176 FinishRequest(request, Request::PREFETCH_STATUS_FROM_CACHE); |
177 else | 177 else |
178 FinishRequest(request, Request::PREFETCH_STATUS_FROM_NETWORK); | 178 FinishRequest(request, Request::PREFETCH_STATUS_FROM_NETWORK); |
(...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
218 int bytes_read) { | 218 int bytes_read) { |
219 if (request->status().error()) { | 219 if (request->status().error()) { |
220 FinishRequest(request, Request::PREFETCH_STATUS_FAILED); | 220 FinishRequest(request, Request::PREFETCH_STATUS_FAILED); |
221 return; | 221 return; |
222 } | 222 } |
223 | 223 |
224 ReadFullResponse(request); | 224 ReadFullResponse(request); |
225 } | 225 } |
226 | 226 |
227 } // namespace predictors | 227 } // namespace predictors |
OLD | NEW |