| Index: trunk/src/chrome/browser/feedback/feedback_uploader.cc
|
| ===================================================================
|
| --- trunk/src/chrome/browser/feedback/feedback_uploader.cc (revision 247814)
|
| +++ trunk/src/chrome/browser/feedback/feedback_uploader.cc (working copy)
|
| @@ -9,7 +9,6 @@
|
| #include "base/files/file_path.h"
|
| #include "base/task_runner_util.h"
|
| #include "base/threading/sequenced_worker_pool.h"
|
| -#include "chrome/browser/feedback/feedback_report.h"
|
| #include "chrome/common/chrome_switches.h"
|
| #include "content/public/browser/browser_context.h"
|
| #include "content/public/browser/browser_thread.h"
|
| @@ -30,9 +29,28 @@
|
|
|
| } // namespace
|
|
|
| +struct FeedbackReport {
|
| + FeedbackReport(const base::Time& upload_at, scoped_ptr<std::string> data)
|
| + : upload_at(upload_at), data(data.Pass()) {}
|
| +
|
| + FeedbackReport(const FeedbackReport& report) {
|
| + upload_at = report.upload_at;
|
| + data = report.data.Pass();
|
| + }
|
| +
|
| + FeedbackReport& operator=(const FeedbackReport& report) {
|
| + upload_at = report.upload_at;
|
| + data = report.data.Pass();
|
| + return *this;
|
| + }
|
| +
|
| + base::Time upload_at; // Upload this report at or after this time.
|
| + mutable scoped_ptr<std::string> data;
|
| +};
|
| +
|
| bool FeedbackUploader::ReportsUploadTimeComparator::operator()(
|
| - FeedbackReport* a, FeedbackReport* b) const {
|
| - return a->upload_at() > b->upload_at();
|
| + const FeedbackReport& a, const FeedbackReport& b) const {
|
| + return a.upload_at > b.upload_at;
|
| }
|
|
|
| FeedbackUploader::FeedbackUploader(content::BrowserContext* context)
|
| @@ -43,15 +61,15 @@
|
| AsWeakPtr());
|
| }
|
|
|
| -FeedbackUploader::~FeedbackUploader() {}
|
| +FeedbackUploader::~FeedbackUploader() {
|
| +}
|
|
|
| -void FeedbackUploader::QueueReport(const std::string& data) {
|
| - reports_queue_.push(
|
| - new FeedbackReport(context_, base::Time::Now(), data));
|
| +void FeedbackUploader::QueueReport(scoped_ptr<std::string> data) {
|
| + reports_queue_.push(FeedbackReport(base::Time::Now(), data.Pass()));
|
| UpdateUploadTimer();
|
| }
|
|
|
| -void FeedbackUploader::DispatchReport(const std::string& data) {
|
| +void FeedbackUploader::DispatchReport(scoped_ptr<std::string> data) {
|
| GURL post_url;
|
| if (CommandLine::ForCurrentProcess()->HasSwitch(switches::kFeedbackServer))
|
| post_url = GURL(CommandLine::ForCurrentProcess()->GetSwitchValueASCII(
|
| @@ -59,14 +77,17 @@
|
| else
|
| post_url = GURL(kFeedbackPostUrl);
|
|
|
| + // Save the report data pointer since the report.Pass() in the next statement
|
| + // will invalidate the scoper.
|
| + std::string* data_ptr = data.get();
|
| net::URLFetcher* fetcher = net::URLFetcher::Create(
|
| post_url, net::URLFetcher::POST,
|
| new FeedbackUploaderDelegate(
|
| - data,
|
| + data.Pass(),
|
| base::Bind(&FeedbackUploader::UpdateUploadTimer, AsWeakPtr()),
|
| base::Bind(&FeedbackUploader::RetryReport, AsWeakPtr())));
|
|
|
| - fetcher->SetUploadData(std::string(kProtBufMimeType), data);
|
| + fetcher->SetUploadData(std::string(kProtBufMimeType), *data_ptr);
|
| fetcher->SetRequestContext(context_->GetRequestContext());
|
| fetcher->SetLoadFlags(net::LOAD_DO_NOT_SAVE_COOKIES |
|
| net::LOAD_DO_NOT_SEND_COOKIES);
|
| @@ -77,26 +98,25 @@
|
| if (reports_queue_.empty())
|
| return;
|
|
|
| - scoped_refptr<FeedbackReport> report = reports_queue_.top();
|
| + const FeedbackReport& report = reports_queue_.top();
|
| base::Time now = base::Time::Now();
|
| - if (report->upload_at() <= now) {
|
| + if (report.upload_at <= now) {
|
| + scoped_ptr<std::string> data = report.data.Pass();
|
| reports_queue_.pop();
|
| - dispatch_callback_.Run(report->data());
|
| - report->DeleteReportOnDisk();
|
| + dispatch_callback_.Run(data.Pass());
|
| } else {
|
| // Stop the old timer and start an updated one.
|
| if (upload_timer_.IsRunning())
|
| upload_timer_.Stop();
|
| upload_timer_.Start(
|
| - FROM_HERE, report->upload_at() - now, this,
|
| + FROM_HERE, report.upload_at - now, this,
|
| &FeedbackUploader::UpdateUploadTimer);
|
| }
|
| }
|
|
|
| -void FeedbackUploader::RetryReport(const std::string& data) {
|
| - reports_queue_.push(new FeedbackReport(context_,
|
| - base::Time::Now() + retry_delay_,
|
| - data));
|
| +void FeedbackUploader::RetryReport(scoped_ptr<std::string> data) {
|
| + reports_queue_.push(
|
| + FeedbackReport(base::Time::Now() + retry_delay_, data.Pass()));
|
| UpdateUploadTimer();
|
| }
|
|
|
|
|