1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
|
// Copyright 2017 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.
#include "components/download/public/common/download_job.h"
#include "base/bind.h"
#include "base/bind_helpers.h"
#include "components/download/public/common/download_item.h"
#include "components/download/public/common/download_task_runner.h"
namespace download {
DownloadJob::DownloadJob(
DownloadItem* download_item,
std::unique_ptr<DownloadRequestHandleInterface> request_handle)
: download_item_(download_item),
request_handle_(std::move(request_handle)),
is_paused_(false),
weak_ptr_factory_(this) {}
DownloadJob::~DownloadJob() = default;
void DownloadJob::Cancel(bool user_cancel) {
if (request_handle_)
request_handle_->CancelRequest(user_cancel);
}
void DownloadJob::Pause() {
is_paused_ = true;
DownloadFile* download_file = download_item_->GetDownloadFile();
if (download_file) {
GetDownloadTaskRunner()->PostTask(
FROM_HERE,
base::BindOnce(&DownloadFile::Pause,
// Safe because we control download file lifetime.
base::Unretained(download_file)));
}
if (request_handle_)
request_handle_->PauseRequest();
}
void DownloadJob::Resume(bool resume_request) {
is_paused_ = false;
if (!resume_request)
return;
DownloadFile* download_file = download_item_->GetDownloadFile();
if (download_file) {
GetDownloadTaskRunner()->PostTask(
FROM_HERE,
base::BindOnce(&DownloadFile::Resume,
// Safe because we control download file lifetime.
base::Unretained(download_file)));
}
if (request_handle_)
request_handle_->ResumeRequest();
}
void DownloadJob::Start(DownloadFile* download_file_,
DownloadFile::InitializeCallback callback,
const DownloadItem::ReceivedSlices& received_slices) {
GetDownloadTaskRunner()->PostTask(
FROM_HERE,
base::BindOnce(
&DownloadFile::Initialize,
// Safe because we control download file lifetime.
base::Unretained(download_file_),
base::BindRepeating(&DownloadJob::OnDownloadFileInitialized,
weak_ptr_factory_.GetWeakPtr(), callback),
base::BindRepeating(&DownloadJob::CancelRequestWithOffset,
weak_ptr_factory_.GetWeakPtr()),
received_slices, IsParallelizable()));
}
void DownloadJob::OnDownloadFileInitialized(
DownloadFile::InitializeCallback callback,
DownloadInterruptReason result,
int64_t bytes_wasted) {
std::move(callback).Run(result, bytes_wasted);
}
bool DownloadJob::AddInputStream(std::unique_ptr<InputStream> stream,
int64_t offset,
int64_t length) {
DownloadFile* download_file = download_item_->GetDownloadFile();
if (!download_file) {
CancelRequestWithOffset(offset);
return false;
}
// download_file_ is owned by download_item_ on the UI thread and is always
// deleted on the download task runner after download_file_ is nulled out.
// So it's safe to use base::Unretained here.
GetDownloadTaskRunner()->PostTask(
FROM_HERE, base::BindOnce(&DownloadFile::AddInputStream,
base::Unretained(download_file),
std::move(stream), offset, length));
return true;
}
void DownloadJob::CancelRequestWithOffset(int64_t offset) {}
bool DownloadJob::IsParallelizable() const {
return false;
}
bool DownloadJob::IsSavePackageDownload() const {
return false;
}
} // namespace download
|
