net: Move ownership of UploadDataStream from URLRequestHttpJob to URLRequest

chrome/browser/policy/device_management_service_browsertest.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 "base/memory/scoped_ptr.h"
 #include "base/message_loop.h"
 #include "base/stl_util.h"
 #include "chrome/browser/policy/cloud_policy_constants.h"
 #include "chrome/browser/policy/device_management_service.h"
 #include "chrome/test/base/in_process_browser_test.h"
-#include "net/base/upload_data.h"
+#include "net/base/upload_bytes_element_reader.h"
+#include "net/base/upload_data_stream.h"
 #include "net/test/test_server.h"
 #include "net/url_request/url_fetcher.h"
 #include "net/url_request/url_request.h"
 #include "net/url_request/url_request_test_job.h"
 #include "testing/gmock/include/gmock/gmock.h"
 #include "testing/gtest/include/gtest/gtest.h"
 
 using testing::DoAll;
 using testing::Invoke;
 using testing::InvokeWithoutArgs;
@@ skipping 16 matching lines @@
 
   virtual ~CannedResponseInterceptor() {
     net::URLRequest::Deprecated::UnregisterRequestInterceptor(this);
   }
 
   // net::URLRequest::Interceptor overrides.
   virtual net::URLRequestJob* MaybeIntercept(
       net::URLRequest* request,
       net::NetworkDelegate* network_delegate) OVERRIDE {
     em::DeviceManagementRequest dm_request;
-    net::UploadData* upload = request->get_upload_mutable();
+    const net::UploadDataStream* upload = request->get_upload();
     if (request->url().GetOrigin() == service_url_.GetOrigin() &&
         request->url().path() == service_url_.path() &&
         upload != NULL &&
-        upload->elements().size() == 1) {
+        upload->element_readers().size() == 1 &&
+        upload->element_readers()[0]->AsBytesReader()) {
       std::string response_data;
-      ConstructResponse(upload->elements()[0]->bytes(),
-                        upload->elements()[0]->bytes_length(),
+      const net::UploadBytesElementReader* bytes_reader =
+          upload->element_readers()[0]->AsBytesReader();
+      ConstructResponse(bytes_reader->bytes(),
+                        bytes_reader->length(),
                         &response_data);
       return new net::URLRequestTestJob(request,
                                         network_delegate,
                                         net::URLRequestTestJob::test_headers(),
                                         response_data,
                                         true);
     }
 
     return NULL;
   }
@@ skipping 144 matching lines @@
   MessageLoop::current()->Run();
 }
 
 INSTANTIATE_TEST_CASE_P(
     DeviceManagementServiceIntegrationTestInstance,
     DeviceManagementServiceIntegrationTest,
     testing::Values(&DeviceManagementServiceIntegrationTest::InitCannedResponse,
                     &DeviceManagementServiceIntegrationTest::InitTestServer));
 
 }  // namespace policy