blob: b7f5dfc5075e7dbcbdfb2c5ea1df8879efa982d7 (
plain)
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
|
// 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 "content/browser/download/download_job.h"
#include "base/bind_helpers.h"
#include "content/browser/download/download_file.h"
#include "content/browser/download/download_item_impl.h"
#include "content/public/browser/browser_thread.h"
namespace content {
DownloadJob::DownloadJob(DownloadItemImpl* download_item)
: download_item_(download_item), is_paused_(false) {}
DownloadJob::~DownloadJob() = default;
void DownloadJob::Pause() {
is_paused_ = true;
}
void DownloadJob::Resume(bool resume_request) {
is_paused_ = false;
}
void DownloadJob::StartDownload() const {
download_item_->StartDownload();
}
bool DownloadJob::AddByteStream(std::unique_ptr<ByteStreamReader> stream_reader,
int64_t offset,
int64_t length) {
DCHECK_CURRENTLY_ON(BrowserThread::UI);
DownloadFile* download_file = download_item_->download_file_.get();
if (!download_file)
return false;
// download_file_ is owned by download_item_ on the UI thread and is always
// deleted on the FILE thread after download_file_ is nulled out.
// So it's safe to use base::Unretained here.
BrowserThread::PostTask(
BrowserThread::FILE, FROM_HERE,
base::Bind(&DownloadFile::AddByteStream, base::Unretained(download_file),
base::Passed(&stream_reader), offset, length));
return true;
}
void DownloadJob::CancelRequestWithOffset(int64_t offset) {
NOTREACHED();
}
bool DownloadJob::IsParallelizable() const {
return false;
}
} // namespace content
|
