net: Move ownership of UploadDataStream from URLRequestHttpJob to URLRequest

net/test/spawner_communicator.cc

 // Copyright (c) 2012 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 "net/test/spawner_communicator.h"
 
 #include "base/json/json_reader.h"
 #include "base/logging.h"
 #include "base/stringprintf.h"
 #include "base/supports_user_data.h"
 #include "base/test/test_timeouts.h"
 #include "base/time.h"
 #include "base/values.h"
 #include "build/build_config.h"
 #include "googleurl/src/gurl.h"
 #include "net/base/net_util.h"
+#include "net/base/upload_data.h"
 #include "net/http/http_response_headers.h"
 #include "net/url_request/url_request_test_util.h"
 
 namespace net {
 
 namespace {
 
 GURL GenerateSpawnerCommandURL(const std::string& command, uint16 port) {
   // Always performs HTTP request for sending command to the spawner server.
   return GURL(base::StringPrintf("%s:%u/%s", "http://127.0.0.1", port,
@@ skipping 149 matching lines @@
   SpawnerRequestData* data = new SpawnerRequestData(current_request_id,
                                                     result_code,
                                                     data_received);
   DCHECK(data);
   cur_request_->SetUserData(this, data);
 
   if (post_data.empty()) {
     cur_request_->set_method("GET");
   } else {
     cur_request_->set_method("POST");
-    cur_request_->AppendBytesToUpload(post_data.c_str(), post_data.size());
+    scoped_refptr<UploadData> upload_data(new UploadData());
+    upload_data->AppendBytes(post_data.c_str(), post_data.size());
+    cur_request_->set_upload(upload_data);
     net::HttpRequestHeaders headers;
     headers.SetHeader(net::HttpRequestHeaders::kContentType,
                       "application/json");
     cur_request_->SetExtraRequestHeaders(headers);
   }
 
   // Post a task to timeout this request if it takes too long.
   MessageLoop::current()->PostDelayedTask(
       FROM_HERE,
       base::Bind(&SpawnerCommunicator::OnTimeout, weak_factory_.GetWeakPtr(),
@@ skipping 166 matching lines @@
   std::string server_return_data;
   int result_code;
   SendCommandAndWaitForResult("kill", "", &result_code, &server_return_data);
   Shutdown();
   if (OK != result_code || server_return_data != "killed")
     return false;
   return true;
 }
 
 }  // namespace net