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
|
// Copyright 2017 The Chromium Authors
// 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/functional/bind.h"
#include "base/functional/callback_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,
CancelRequestCallback cancel_request_callback)
: download_item_(download_item),
cancel_request_callback_(std::move(cancel_request_callback)),
is_paused_(false) {}
DownloadJob::~DownloadJob() = default;
void DownloadJob::Cancel(bool user_cancel) {
if (cancel_request_callback_)
std::move(cancel_request_callback_).Run(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)));
}
}
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)));
}
}
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));
}
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) {
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));
return true;
}
void DownloadJob::CancelRequestWithOffset(int64_t offset) {}
bool DownloadJob::IsParallelizable() const {
return false;
}
bool DownloadJob::IsSavePackageDownload() const {
return false;
}
} // namespace download
|
