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 2013 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/upload_list/upload_list.h"
#include <algorithm>
#include <iterator>
#include <utility>
#include "base/bind.h"
#include "base/task/post_task.h"
UploadList::UploadInfo::UploadInfo(const std::string& upload_id,
const base::Time& upload_time,
const std::string& local_id,
const base::Time& capture_time,
State state)
: upload_id(upload_id),
upload_time(upload_time),
local_id(local_id),
capture_time(capture_time),
state(state) {}
UploadList::UploadInfo::UploadInfo(const std::string& local_id,
const base::Time& capture_time,
State state,
const base::string16& file_size)
: local_id(local_id),
capture_time(capture_time),
state(state),
file_size(file_size) {}
UploadList::UploadInfo::UploadInfo(const std::string& upload_id,
const base::Time& upload_time)
: upload_id(upload_id), upload_time(upload_time), state(State::Uploaded) {}
UploadList::UploadInfo::UploadInfo(const UploadInfo& upload_info)
: upload_id(upload_info.upload_id),
upload_time(upload_info.upload_time),
local_id(upload_info.local_id),
capture_time(upload_info.capture_time),
state(upload_info.state),
file_size(upload_info.file_size) {}
UploadList::UploadInfo::~UploadInfo() = default;
UploadList::UploadList() = default;
UploadList::~UploadList() = default;
void UploadList::Load(base::OnceClosure callback) {
DCHECK(sequence_checker_.CalledOnValidSequence());
load_callback_ = std::move(callback);
base::PostTaskWithTraitsAndReplyWithResult(
FROM_HERE, LoadingTaskTraits(),
base::Bind(&UploadList::LoadUploadList, this),
base::Bind(&UploadList::OnLoadComplete, this));
}
void UploadList::Clear(const base::Time& begin,
const base::Time& end,
base::OnceClosure callback) {
DCHECK(sequence_checker_.CalledOnValidSequence());
clear_callback_ = std::move(callback);
base::PostTaskWithTraitsAndReply(
FROM_HERE, LoadingTaskTraits(),
base::BindOnce(&UploadList::ClearUploadList, this, begin, end),
base::BindOnce(&UploadList::OnClearComplete, this));
}
void UploadList::CancelLoadCallback() {
load_callback_.Reset();
}
void UploadList::RequestSingleUploadAsync(const std::string& local_id) {
DCHECK(sequence_checker_.CalledOnValidSequence());
base::PostTaskWithTraits(
FROM_HERE, LoadingTaskTraits(),
base::BindOnce(&UploadList::RequestSingleUpload, this, local_id));
}
void UploadList::GetUploads(size_t max_count,
std::vector<UploadInfo>* uploads) {
DCHECK(sequence_checker_.CalledOnValidSequence());
std::copy(uploads_.begin(),
uploads_.begin() + std::min(uploads_.size(), max_count),
std::back_inserter(*uploads));
}
void UploadList::RequestSingleUpload(const std::string& local_id) {
// Manual uploads for not-yet uploaded crash reports are only available for
// Crashpad systems and for Android.
NOTREACHED();
}
void UploadList::OnLoadComplete(const std::vector<UploadInfo>& uploads) {
uploads_ = uploads;
if (!load_callback_.is_null())
std::move(load_callback_).Run();
}
void UploadList::OnClearComplete() {
if (!clear_callback_.is_null())
std::move(clear_callback_).Run();
}
|
