| Index: content/browser/loader/upload_progress_tracker.cc
|
| diff --git a/content/browser/loader/upload_progress_tracker.cc b/content/browser/loader/upload_progress_tracker.cc
|
| index 790bea4642d4727edac42db5e98f396d7c7b7905..39b5c487b984ddfcd36959d859b464f401bced88 100644
|
| --- a/content/browser/loader/upload_progress_tracker.cc
|
| +++ b/content/browser/loader/upload_progress_tracker.cc
|
| @@ -5,8 +5,8 @@
|
| #include "content/browser/loader/upload_progress_tracker.h"
|
|
|
| #include "base/logging.h"
|
| +#include "base/single_thread_task_runner.h"
|
| #include "net/base/upload_progress.h"
|
| -#include "net/url_request/url_request.h"
|
|
|
| namespace content {
|
| namespace {
|
| @@ -15,14 +15,17 @@ constexpr base::TimeDelta kUploadProgressInterval =
|
| base::TimeDelta::FromMilliseconds(100);
|
| } // namespace
|
|
|
| +UploadProgressTracker::Client::Client() = default;
|
| +UploadProgressTracker::Client::~Client() = default;
|
| +
|
| UploadProgressTracker::UploadProgressTracker(
|
| const tracked_objects::Location& location,
|
| - UploadProgressReportCallback report_progress,
|
| - net::URLRequest* request)
|
| - : request_(request), report_progress_(std::move(report_progress)) {
|
| - DCHECK(request_);
|
| - DCHECK(report_progress_);
|
| + Client* client,
|
| + scoped_refptr<base::SingleThreadTaskRunner> task_runner)
|
| + : client_(client) {
|
| + DCHECK(client_);
|
|
|
| + progress_timer_.SetTaskRunner(std::move(task_runner));
|
| progress_timer_.Start(location, kUploadProgressInterval, this,
|
| &UploadProgressTracker::ReportUploadProgressIfNeeded);
|
| }
|
| @@ -39,11 +42,15 @@ void UploadProgressTracker::OnUploadCompleted() {
|
| progress_timer_.Stop();
|
| }
|
|
|
| +base::TimeTicks UploadProgressTracker::GetCurrentTime() {
|
| + return base::TimeTicks::Now();
|
| +}
|
| +
|
| void UploadProgressTracker::ReportUploadProgressIfNeeded() {
|
| if (waiting_for_upload_progress_ack_)
|
| return;
|
|
|
| - net::UploadProgress progress = request_->GetUploadProgress();
|
| + net::UploadProgress progress = client_->GetUploadProgress();
|
| if (!progress.size())
|
| return; // Nothing to upload.
|
|
|
| @@ -54,7 +61,8 @@ void UploadProgressTracker::ReportUploadProgressIfNeeded() {
|
| const base::TimeDelta kOneSecond = base::TimeDelta::FromMilliseconds(1000);
|
|
|
| uint64_t amt_since_last = progress.position() - last_upload_position_;
|
| - base::TimeDelta time_since_last = base::TimeTicks::Now() - last_upload_ticks_;
|
| + base::TimeTicks now = GetCurrentTime();
|
| + base::TimeDelta time_since_last = now - last_upload_ticks_;
|
|
|
| bool is_finished = (progress.size() == progress.position());
|
| bool enough_new_progress =
|
| @@ -62,9 +70,9 @@ void UploadProgressTracker::ReportUploadProgressIfNeeded() {
|
| bool too_much_time_passed = time_since_last > kOneSecond;
|
|
|
| if (is_finished || enough_new_progress || too_much_time_passed) {
|
| - report_progress_.Run(progress.position(), progress.size());
|
| + client_->ReportUploadProgress(progress.position(), progress.size());
|
| waiting_for_upload_progress_ack_ = true;
|
| - last_upload_ticks_ = base::TimeTicks::Now();
|
| + last_upload_ticks_ = now;
|
| last_upload_position_ = progress.position();
|
| }
|
| }
|
|
|