| 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/browser/download/download_worker.h" | 5 #include "content/browser/download/download_worker.h" |
| 6 | 6 |
| 7 #include "content/browser/download/download_create_info.h" | 7 #include "content/browser/download/download_create_info.h" |
| 8 #include "content/public/browser/download_interrupt_reasons.h" | 8 #include "content/public/browser/download_interrupt_reasons.h" |
| 9 #include "content/public/browser/web_contents.h" | 9 #include "content/public/browser/web_contents.h" |
| 10 #include "net/traffic_annotation/network_traffic_annotation.h" |
| 10 | 11 |
| 11 namespace content { | 12 namespace content { |
| 12 namespace { | 13 namespace { |
| 13 | 14 |
| 14 const int kVerboseLevel = 1; | 15 const int kVerboseLevel = 1; |
| 15 | 16 |
| 16 class CompletedByteStreamReader : public ByteStreamReader { | 17 class CompletedByteStreamReader : public ByteStreamReader { |
| 17 public: | 18 public: |
| 18 CompletedByteStreamReader(int status) : status_(status) {}; | 19 CompletedByteStreamReader(int status) : status_(status) {}; |
| 19 ~CompletedByteStreamReader() override = default; | 20 ~CompletedByteStreamReader() override = default; |
| (...skipping 11 matching lines...) Expand all Loading... |
| 31 }; | 32 }; |
| 32 | 33 |
| 33 std::unique_ptr<UrlDownloader, BrowserThread::DeleteOnIOThread> | 34 std::unique_ptr<UrlDownloader, BrowserThread::DeleteOnIOThread> |
| 34 CreateUrlDownloader(std::unique_ptr<DownloadUrlParameters> params, | 35 CreateUrlDownloader(std::unique_ptr<DownloadUrlParameters> params, |
| 35 base::WeakPtr<UrlDownloader::Delegate> delegate) { | 36 base::WeakPtr<UrlDownloader::Delegate> delegate) { |
| 36 DCHECK_CURRENTLY_ON(BrowserThread::IO); | 37 DCHECK_CURRENTLY_ON(BrowserThread::IO); |
| 37 | 38 |
| 38 // Build the URLRequest, BlobDataHandle is hold in original request for image | 39 // Build the URLRequest, BlobDataHandle is hold in original request for image |
| 39 // download. | 40 // download. |
| 40 std::unique_ptr<net::URLRequest> url_request = | 41 std::unique_ptr<net::URLRequest> url_request = |
| 41 DownloadRequestCore::CreateRequestOnIOThread(DownloadItem::kInvalidId, | 42 DownloadRequestCore::CreateRequestOnIOThread( |
| 42 params.get()); | 43 DownloadItem::kInvalidId, params.get(), NO_TRAFFIC_ANNOTATION_YET); |
| 43 | 44 |
| 44 return std::unique_ptr<UrlDownloader, BrowserThread::DeleteOnIOThread>( | 45 return std::unique_ptr<UrlDownloader, BrowserThread::DeleteOnIOThread>( |
| 45 UrlDownloader::BeginDownload(delegate, std::move(url_request), | 46 UrlDownloader::BeginDownload(delegate, std::move(url_request), |
| 46 params->referrer(), true) | 47 params->referrer(), true) |
| 47 .release()); | 48 .release()); |
| 48 } | 49 } |
| 49 | 50 |
| 50 } // namespace | 51 } // namespace |
| 51 | 52 |
| 52 DownloadWorker::DownloadWorker(DownloadWorker::Delegate* delegate, | 53 DownloadWorker::DownloadWorker(DownloadWorker::Delegate* delegate, |
| (...skipping 77 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 130 url_downloader_.reset(); | 131 url_downloader_.reset(); |
| 131 } | 132 } |
| 132 | 133 |
| 133 void DownloadWorker::AddUrlDownloader( | 134 void DownloadWorker::AddUrlDownloader( |
| 134 std::unique_ptr<UrlDownloader, BrowserThread::DeleteOnIOThread> | 135 std::unique_ptr<UrlDownloader, BrowserThread::DeleteOnIOThread> |
| 135 downloader) { | 136 downloader) { |
| 136 url_downloader_ = std::move(downloader); | 137 url_downloader_ = std::move(downloader); |
| 137 } | 138 } |
| 138 | 139 |
| 139 } // namespace content | 140 } // namespace content |
| OLD | NEW |