| OLD | NEW |
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include "content/child/resource_dispatcher.h" | 5 #include "content/child/resource_dispatcher.h" |
| 6 | 6 |
| 7 #include <stddef.h> | 7 #include <stddef.h> |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| 11 #include <string> | 11 #include <string> |
| 12 #include <tuple> |
| 12 #include <utility> | 13 #include <utility> |
| 13 #include <vector> | 14 #include <vector> |
| 14 | 15 |
| 15 #include "base/macros.h" | 16 #include "base/macros.h" |
| 16 #include "base/memory/ptr_util.h" | 17 #include "base/memory/ptr_util.h" |
| 17 #include "base/memory/shared_memory.h" | 18 #include "base/memory/shared_memory.h" |
| 18 #include "base/message_loop/message_loop.h" | 19 #include "base/message_loop/message_loop.h" |
| 19 #include "base/process/process_handle.h" | 20 #include "base/process/process_handle.h" |
| 20 #include "base/run_loop.h" | 21 #include "base/run_loop.h" |
| 21 #include "base/stl_util.h" | 22 #include "base/stl_util.h" |
| (...skipping 145 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 167 ADD_FAILURE() << "Missing resource request message"; | 168 ADD_FAILURE() << "Missing resource request message"; |
| 168 return -1; | 169 return -1; |
| 169 } | 170 } |
| 170 | 171 |
| 171 ResourceHostMsg_RequestResource::Param params; | 172 ResourceHostMsg_RequestResource::Param params; |
| 172 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() || | 173 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() || |
| 173 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) { | 174 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) { |
| 174 ADD_FAILURE() << "Expected ResourceHostMsg_RequestResource message"; | 175 ADD_FAILURE() << "Expected ResourceHostMsg_RequestResource message"; |
| 175 return -1; | 176 return -1; |
| 176 } | 177 } |
| 177 ResourceRequest request = base::get<2>(params); | 178 ResourceRequest request = std::get<2>(params); |
| 178 EXPECT_EQ(kTestPageUrl, request.url.spec()); | 179 EXPECT_EQ(kTestPageUrl, request.url.spec()); |
| 179 message_queue_.erase(message_queue_.begin()); | 180 message_queue_.erase(message_queue_.begin()); |
| 180 return base::get<1>(params); | 181 return std::get<1>(params); |
| 181 } | 182 } |
| 182 | 183 |
| 183 void ConsumeFollowRedirect(int expected_request_id) { | 184 void ConsumeFollowRedirect(int expected_request_id) { |
| 184 ASSERT_FALSE(message_queue_.empty()); | 185 ASSERT_FALSE(message_queue_.empty()); |
| 185 base::Tuple<int> args; | 186 std::tuple<int> args; |
| 186 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type()); | 187 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type()); |
| 187 ASSERT_TRUE(ResourceHostMsg_FollowRedirect::Read( | 188 ASSERT_TRUE(ResourceHostMsg_FollowRedirect::Read( |
| 188 &message_queue_[0], &args)); | 189 &message_queue_[0], &args)); |
| 189 EXPECT_EQ(expected_request_id, base::get<0>(args)); | 190 EXPECT_EQ(expected_request_id, std::get<0>(args)); |
| 190 message_queue_.erase(message_queue_.begin()); | 191 message_queue_.erase(message_queue_.begin()); |
| 191 } | 192 } |
| 192 | 193 |
| 193 void ConsumeDataReceived_ACK(int expected_request_id) { | 194 void ConsumeDataReceived_ACK(int expected_request_id) { |
| 194 ASSERT_FALSE(message_queue_.empty()); | 195 ASSERT_FALSE(message_queue_.empty()); |
| 195 base::Tuple<int> args; | 196 std::tuple<int> args; |
| 196 ASSERT_EQ(ResourceHostMsg_DataReceived_ACK::ID, message_queue_[0].type()); | 197 ASSERT_EQ(ResourceHostMsg_DataReceived_ACK::ID, message_queue_[0].type()); |
| 197 ASSERT_TRUE(ResourceHostMsg_DataReceived_ACK::Read( | 198 ASSERT_TRUE(ResourceHostMsg_DataReceived_ACK::Read( |
| 198 &message_queue_[0], &args)); | 199 &message_queue_[0], &args)); |
| 199 EXPECT_EQ(expected_request_id, base::get<0>(args)); | 200 EXPECT_EQ(expected_request_id, std::get<0>(args)); |
| 200 message_queue_.erase(message_queue_.begin()); | 201 message_queue_.erase(message_queue_.begin()); |
| 201 } | 202 } |
| 202 | 203 |
| 203 void ConsumeDataDownloaded_ACK(int expected_request_id) { | 204 void ConsumeDataDownloaded_ACK(int expected_request_id) { |
| 204 ASSERT_FALSE(message_queue_.empty()); | 205 ASSERT_FALSE(message_queue_.empty()); |
| 205 base::Tuple<int> args; | 206 std::tuple<int> args; |
| 206 ASSERT_EQ(ResourceHostMsg_DataDownloaded_ACK::ID, message_queue_[0].type()); | 207 ASSERT_EQ(ResourceHostMsg_DataDownloaded_ACK::ID, message_queue_[0].type()); |
| 207 ASSERT_TRUE(ResourceHostMsg_DataDownloaded_ACK::Read( | 208 ASSERT_TRUE(ResourceHostMsg_DataDownloaded_ACK::Read( |
| 208 &message_queue_[0], &args)); | 209 &message_queue_[0], &args)); |
| 209 EXPECT_EQ(expected_request_id, base::get<0>(args)); | 210 EXPECT_EQ(expected_request_id, std::get<0>(args)); |
| 210 message_queue_.erase(message_queue_.begin()); | 211 message_queue_.erase(message_queue_.begin()); |
| 211 } | 212 } |
| 212 | 213 |
| 213 void ConsumeReleaseDownloadedFile(int expected_request_id) { | 214 void ConsumeReleaseDownloadedFile(int expected_request_id) { |
| 214 ASSERT_FALSE(message_queue_.empty()); | 215 ASSERT_FALSE(message_queue_.empty()); |
| 215 base::Tuple<int> args; | 216 std::tuple<int> args; |
| 216 ASSERT_EQ(ResourceHostMsg_ReleaseDownloadedFile::ID, | 217 ASSERT_EQ(ResourceHostMsg_ReleaseDownloadedFile::ID, |
| 217 message_queue_[0].type()); | 218 message_queue_[0].type()); |
| 218 ASSERT_TRUE(ResourceHostMsg_ReleaseDownloadedFile::Read( | 219 ASSERT_TRUE(ResourceHostMsg_ReleaseDownloadedFile::Read( |
| 219 &message_queue_[0], &args)); | 220 &message_queue_[0], &args)); |
| 220 EXPECT_EQ(expected_request_id, base::get<0>(args)); | 221 EXPECT_EQ(expected_request_id, std::get<0>(args)); |
| 221 message_queue_.erase(message_queue_.begin()); | 222 message_queue_.erase(message_queue_.begin()); |
| 222 } | 223 } |
| 223 | 224 |
| 224 void ConsumeCancelRequest(int expected_request_id) { | 225 void ConsumeCancelRequest(int expected_request_id) { |
| 225 ASSERT_FALSE(message_queue_.empty()); | 226 ASSERT_FALSE(message_queue_.empty()); |
| 226 base::Tuple<int> args; | 227 std::tuple<int> args; |
| 227 ASSERT_EQ(ResourceHostMsg_CancelRequest::ID, message_queue_[0].type()); | 228 ASSERT_EQ(ResourceHostMsg_CancelRequest::ID, message_queue_[0].type()); |
| 228 ASSERT_TRUE(ResourceHostMsg_CancelRequest::Read( | 229 ASSERT_TRUE(ResourceHostMsg_CancelRequest::Read( |
| 229 &message_queue_[0], &args)); | 230 &message_queue_[0], &args)); |
| 230 EXPECT_EQ(expected_request_id, base::get<0>(args)); | 231 EXPECT_EQ(expected_request_id, std::get<0>(args)); |
| 231 message_queue_.erase(message_queue_.begin()); | 232 message_queue_.erase(message_queue_.begin()); |
| 232 } | 233 } |
| 233 | 234 |
| 234 void NotifyReceivedRedirect(int request_id) { | 235 void NotifyReceivedRedirect(int request_id) { |
| 235 ResourceResponseHead head; | 236 ResourceResponseHead head; |
| 236 std::string raw_headers(kTestRedirectHeaders); | 237 std::string raw_headers(kTestRedirectHeaders); |
| 237 std::replace(raw_headers.begin(), raw_headers.end(), '\n', '\0'); | 238 std::replace(raw_headers.begin(), raw_headers.end(), '\n', '\0'); |
| 238 head.headers = new net::HttpResponseHeaders(raw_headers); | 239 head.headers = new net::HttpResponseHeaders(raw_headers); |
| 239 net::RedirectInfo redirect_info; | 240 net::RedirectInfo redirect_info; |
| 240 redirect_info.status_code = 302; | 241 redirect_info.status_code = 302; |
| (...skipping 654 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 895 ResourceResponseHead response_head; | 896 ResourceResponseHead response_head; |
| 896 | 897 |
| 897 PerformTest(response_head); | 898 PerformTest(response_head); |
| 898 | 899 |
| 899 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); | 900 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); |
| 900 EXPECT_EQ(base::TimeTicks(), | 901 EXPECT_EQ(base::TimeTicks(), |
| 901 response_info().load_timing.connect_timing.dns_start); | 902 response_info().load_timing.connect_timing.dns_start); |
| 902 } | 903 } |
| 903 | 904 |
| 904 } // namespace content | 905 } // namespace content |
| OLD | NEW |