| OLD | NEW |
| 1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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 "components/image_fetcher/image_data_fetcher.h" | 5 #include "components/image_fetcher/image_data_fetcher.h" |
| 6 | 6 |
| 7 #include "net/base/load_flags.h" | 7 #include "net/base/load_flags.h" |
| 8 #include "net/url_request/url_fetcher.h" | 8 #include "net/url_request/url_fetcher.h" |
| 9 #include "net/url_request/url_fetcher_delegate.h" | |
| 10 #include "net/url_request/url_request.h" | 9 #include "net/url_request/url_request.h" |
| 11 #include "net/url_request/url_request_context_getter.h" | 10 #include "net/url_request/url_request_context_getter.h" |
| 12 #include "net/url_request/url_request_status.h" | 11 #include "net/url_request/url_request_status.h" |
| 13 #include "url/gurl.h" | 12 #include "url/gurl.h" |
| 14 | 13 |
| 15 namespace image_fetcher { | 14 namespace image_fetcher { |
| 16 | 15 |
| 17 // An active image URL fetcher request. The class contains any related request | 16 // An active image URL fetcher request. The struct contains the related requests |
| 18 // state and logic for handling a single image url request. | 17 // state. |
| 19 class ImageDataFetcher::ImageDataFetcherRequest | 18 struct ImageDataFetcher::ImageDataFetcherRequest { |
| 20 : public net::URLFetcherDelegate { | 19 ImageDataFetcherRequest(const ImageDataFetcherCallback& callback, |
| 21 public: | 20 std::unique_ptr<net::URLFetcher> url_fetcher) |
| 22 ImageDataFetcherRequest(const GURL& url, | 21 : callback(callback), |
| 23 const ImageDataFetcherCallback& callback, | 22 url_fetcher(std::move(url_fetcher)) {} |
| 24 ImageDataFetcher* image_url_fetcher); | |
| 25 ~ImageDataFetcherRequest() override {} | |
| 26 | 23 |
| 27 // Sends the URL requests. | 24 ~ImageDataFetcherRequest() {} |
| 28 void Start(net::URLRequestContextGetter* request_context); | |
| 29 | |
| 30 private: | |
| 31 // Method inherited from URLFetcherDelegate | |
| 32 void OnURLFetchComplete(const net::URLFetcher* source) override; | |
| 33 | |
| 34 // The URL of the image to fetch. | |
| 35 const GURL url_; | |
| 36 | 25 |
| 37 // The callback to run after the image data was fetched. The callback will | 26 // The callback to run after the image data was fetched. The callback will |
| 38 // be run even if the image data could not be fetched successfully. | 27 // be run even if the image data could not be fetched successfully. |
| 39 ImageDataFetcherCallback callback_; | 28 ImageDataFetcherCallback callback; |
| 40 | 29 |
| 41 // The ImageDataFetcher that owns the ImageDataFetcherRequest. | 30 std::unique_ptr<net::URLFetcher> url_fetcher; |
| 42 ImageDataFetcher* image_url_fetcher_; | |
| 43 | |
| 44 std::unique_ptr<net::URLFetcher> url_fetcher_; | |
| 45 | |
| 46 DISALLOW_COPY_AND_ASSIGN(ImageDataFetcherRequest); | |
| 47 }; | 31 }; |
| 48 | 32 |
| 49 ImageDataFetcher::ImageDataFetcherRequest::ImageDataFetcherRequest( | |
| 50 const GURL& url, | |
| 51 const ImageDataFetcherCallback& callback, | |
| 52 ImageDataFetcher* image_url_fetcher) | |
| 53 : url_(url), | |
| 54 callback_(callback), | |
| 55 image_url_fetcher_(image_url_fetcher) { | |
| 56 } | |
| 57 | |
| 58 void ImageDataFetcher::ImageDataFetcherRequest::Start( | |
| 59 net::URLRequestContextGetter* request_context) { | |
| 60 DCHECK(!url_fetcher_); | |
| 61 | |
| 62 url_fetcher_ = net::URLFetcher::Create(url_, net::URLFetcher::GET, this); | |
| 63 url_fetcher_->SetRequestContext(request_context); | |
| 64 url_fetcher_->Start(); | |
| 65 } | |
| 66 | |
| 67 void ImageDataFetcher::ImageDataFetcherRequest::OnURLFetchComplete( | |
| 68 const net::URLFetcher* source) { | |
| 69 // An empty string is passed to the callback in case on an unsuccessfull URL | |
| 70 // request. | |
| 71 std::string image_data; | |
| 72 if (source->GetStatus().status() == net::URLRequestStatus::SUCCESS) { | |
| 73 source->GetResponseAsString(&image_data); | |
| 74 } | |
| 75 callback_.Run(image_data); | |
| 76 | |
| 77 // Remove the completed ImageDataFetcherRequest from the internal request | |
| 78 // queue. This must be last in the method. | |
| 79 image_url_fetcher_->RemoveImageDataFetcherRequest(url_); | |
| 80 } | |
| 81 | |
| 82 ImageDataFetcher::ImageDataFetcher( | 33 ImageDataFetcher::ImageDataFetcher( |
| 83 net::URLRequestContextGetter* url_request_context_getter) | 34 net::URLRequestContextGetter* url_request_context_getter) |
| 84 : url_request_context_getter_(url_request_context_getter) {} | 35 : url_request_context_getter_(url_request_context_getter) {} |
| 85 | 36 |
| 86 ImageDataFetcher::~ImageDataFetcher() {} | 37 ImageDataFetcher::~ImageDataFetcher() {} |
| 87 | 38 |
| 88 void ImageDataFetcher::FetchImageData( | 39 void ImageDataFetcher::FetchImageData( |
| 89 const GURL& url, const ImageDataFetcherCallback& callback) { | 40 const GURL& url, const ImageDataFetcherCallback& callback) { |
| 41 std::unique_ptr<net::URLFetcher> url_fetcher = |
| 42 net::URLFetcher::Create(url, net::URLFetcher::GET, this); |
| 43 |
| 90 std::unique_ptr<ImageDataFetcherRequest> request( | 44 std::unique_ptr<ImageDataFetcherRequest> request( |
| 91 new ImageDataFetcherRequest(url, callback, this)); | 45 new ImageDataFetcherRequest(callback, std::move(url_fetcher))); |
| 92 request->Start(url_request_context_getter_.get()); | 46 request->url_fetcher->SetRequestContext(url_request_context_getter_.get()); |
| 93 pending_requests_[url] = std::move(request); | 47 request->url_fetcher->Start(); |
| 48 |
| 49 pending_requests_[request->url_fetcher.get()] = std::move(request); |
| 94 } | 50 } |
| 95 | 51 |
| 96 void ImageDataFetcher::RemoveImageDataFetcherRequest(const GURL& image_url) { | 52 void ImageDataFetcher::OnURLFetchComplete(const net::URLFetcher* source) { |
| 97 size_t count = pending_requests_.erase(image_url); | 53 auto request_iter = pending_requests_.find(source); |
| 98 DCHECK(count); | 54 DCHECK(request_iter != pending_requests_.end()); |
| 55 |
| 56 std::string image_data; |
| 57 if (source->GetStatus().status() == net::URLRequestStatus::SUCCESS) { |
| 58 source->GetResponseAsString(&image_data); |
| 59 } |
| 60 request_iter->second->callback.Run(image_data); |
| 61 |
| 62 // Remove the finished request. |
| 63 pending_requests_.erase(request_iter); |
| 99 } | 64 } |
| 100 | 65 |
| 101 } // namespace image_fetcher | 66 } // namespace image_fetcher |
| OLD | NEW |