123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120 |
- // 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/check.h"
- #include "base/notreached.h"
- #include "base/task/task_traits.h"
- #include "base/task/thread_pool.h"
- namespace {
- // USER_VISIBLE because loading uploads blocks chrome://crashes,
- // chrome://webrtc-logs and the feedback UI. See https://crbug.com/972526.
- constexpr base::TaskTraits kLoadingTaskTraits = {
- base::MayBlock(), base::TaskPriority::USER_BLOCKING,
- base::TaskShutdownBehavior::CONTINUE_ON_SHUTDOWN};
- } // namespace
- 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 std::u16string& 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),
- source(upload_info.source),
- 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::ThreadPool::PostTaskAndReplyWithResult(
- FROM_HERE, kLoadingTaskTraits,
- base::BindOnce(&UploadList::LoadUploadList, this),
- base::BindOnce(&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::ThreadPool::PostTaskAndReply(
- FROM_HERE, kLoadingTaskTraits,
- 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::ThreadPool::PostTask(
- FROM_HERE, kLoadingTaskTraits,
- 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();
- }
|