NOT FOR REVIEW - Slow Reports Reference Implementation

chrome/browser/tracing/crash_service_uploader.cc

 // Copyright 2014 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 "chrome/browser/tracing/crash_service_uploader.h"
 
 #include "base/command_line.h"
 #include "base/files/file_path.h"
 #include "base/files/file_util.h"
 #include "base/format_macros.h"
@@ skipping 75 matching lines @@
     const UploadProgressCallback& progress_callback,
     const UploadDoneCallback& done_callback) {
   DCHECK_CURRENTLY_ON(content::BrowserThread::UI);
   content::BrowserThread::PostTask(
       content::BrowserThread::FILE, FROM_HERE,
       base::Bind(&TraceCrashServiceUploader::DoUploadOnFileThread,
                  base::Unretained(this), file_contents, progress_callback,
                  done_callback));
 }
 
+void TraceCrashServiceUploader::SetUploadURL(const std::string& url) {
+  upload_url_ = url;
+}
+
 void TraceCrashServiceUploader::DoUploadOnFileThread(
     const std::string& file_contents,
     const UploadProgressCallback& progress_callback,
     const UploadDoneCallback& done_callback) {
   DCHECK_CURRENTLY_ON(content::BrowserThread::FILE);
   DCHECK(!url_fetcher_.get());
 
   progress_callback_ = progress_callback;
   done_callback_ = done_callback;
 
   const base::CommandLine& command_line =
       *base::CommandLine::ForCurrentProcess();
   std::string upload_url = kUploadURL;
+  if (!upload_url_.empty())
+    upload_url = upload_url_;
+
   if (command_line.HasSwitch(switches::kTraceUploadURL)) {
     upload_url = command_line.GetSwitchValueASCII(switches::kTraceUploadURL);
   }
   if (!GURL(upload_url).is_valid())
     upload_url.clear();
 
   if (upload_url.empty()) {
     OnUploadError("Upload URL empty or invalid");
     return;
   }
@@ skipping 24 matching lines @@
     version = product_components[1];
   } else {
     version = "unknown";
   }
 
   if (url_fetcher_.get()) {
     OnUploadError("Already uploading.");
     return;
   }
 
-  scoped_ptr<char[]> compressed_contents(new char[kMaxUploadBytes]);
-  int compressed_bytes;
-  if (!Compress(file_contents, kMaxUploadBytes, compressed_contents.get(),
-                &compressed_bytes)) {
-    OnUploadError("Compressing file failed.");
-    return;
-  }
-
   std::string post_data;
-  SetupMultipart(product, version, "trace.json.gz",
-                 std::string(compressed_contents.get(), compressed_bytes),
-                 &post_data);
+  SetupMultipart(product, version, "trace.json.gz", file_contents, &post_data);
+  //  scoped_ptr<char[]> compressed_contents(new char[kMaxUploadBytes]);
+  //  int compressed_bytes;
+  //  if (!Compress(file_contents, kMaxUploadBytes, compressed_contents.get(),
+  //                &compressed_bytes)) {
+  //    OnUploadError("Compressing file failed.");
+  //    return;
+  //  }
+  //
+  //  std::string post_data;
+  //  SetupMultipart(product, version, "trace.json.gz",
+  //                 std::string(compressed_contents.get(), compressed_bytes),
+  //                 &post_data);
 
   content::BrowserThread::PostTask(
       content::BrowserThread::UI, FROM_HERE,
       base::Bind(&TraceCrashServiceUploader::CreateAndStartURLFetcher,
                  base::Unretained(this), upload_url, post_data));
 }
 
 void TraceCrashServiceUploader::OnUploadError(std::string error_message) {
   LOG(ERROR) << error_message;
   content::BrowserThread::PostTask(
@@ skipping 80 matching lines @@
   std::string content_type = kUploadContentType;
   content_type.append("; boundary=");
   content_type.append(kMultipartBoundary);
 
   url_fetcher_.reset(
       net::URLFetcher::Create(GURL(upload_url), net::URLFetcher::POST, this));
   url_fetcher_->SetRequestContext(request_context_);
   url_fetcher_->SetUploadData(content_type, post_data);
   url_fetcher_->Start();
 }