| 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 <string> | 5 #include <string> |
| 6 #include <vector> | 6 #include <vector> |
| 7 | 7 |
| 8 #include "base/macros.h" | 8 #include "base/macros.h" |
| 9 #include "base/memory/scoped_ptr.h" | 9 #include "base/memory/scoped_ptr.h" |
| 10 #include "base/memory/shared_memory.h" | 10 #include "base/memory/shared_memory.h" |
| (...skipping 165 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 176 ADD_FAILURE() << "Missing resource request message"; | 176 ADD_FAILURE() << "Missing resource request message"; |
| 177 return -1; | 177 return -1; |
| 178 } | 178 } |
| 179 | 179 |
| 180 ResourceHostMsg_RequestResource::Param params; | 180 ResourceHostMsg_RequestResource::Param params; |
| 181 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() || | 181 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() || |
| 182 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) { | 182 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) { |
| 183 ADD_FAILURE() << "Expected ResourceHostMsg_RequestResource message"; | 183 ADD_FAILURE() << "Expected ResourceHostMsg_RequestResource message"; |
| 184 return -1; | 184 return -1; |
| 185 } | 185 } |
| 186 ResourceHostMsg_Request request = params.c; | 186 ResourceHostMsg_Request request = get<2>(params); |
| 187 EXPECT_EQ(kTestPageUrl, request.url.spec()); | 187 EXPECT_EQ(kTestPageUrl, request.url.spec()); |
| 188 message_queue_.erase(message_queue_.begin()); | 188 message_queue_.erase(message_queue_.begin()); |
| 189 return params.b; | 189 return get<1>(params); |
| 190 } | 190 } |
| 191 | 191 |
| 192 void ConsumeFollowRedirect(int expected_request_id) { | 192 void ConsumeFollowRedirect(int expected_request_id) { |
| 193 ASSERT_FALSE(message_queue_.empty()); | 193 ASSERT_FALSE(message_queue_.empty()); |
| 194 Tuple1<int> args; | 194 Tuple<int> args; |
| 195 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type()); | 195 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type()); |
| 196 ASSERT_TRUE(ResourceHostMsg_FollowRedirect::Read( | 196 ASSERT_TRUE(ResourceHostMsg_FollowRedirect::Read( |
| 197 &message_queue_[0], &args)); | 197 &message_queue_[0], &args)); |
| 198 EXPECT_EQ(expected_request_id, args.a); | 198 EXPECT_EQ(expected_request_id, get<0>(args)); |
| 199 message_queue_.erase(message_queue_.begin()); | 199 message_queue_.erase(message_queue_.begin()); |
| 200 } | 200 } |
| 201 | 201 |
| 202 void ConsumeDataReceived_ACK(int expected_request_id) { | 202 void ConsumeDataReceived_ACK(int expected_request_id) { |
| 203 ASSERT_FALSE(message_queue_.empty()); | 203 ASSERT_FALSE(message_queue_.empty()); |
| 204 Tuple1<int> args; | 204 Tuple<int> args; |
| 205 ASSERT_EQ(ResourceHostMsg_DataReceived_ACK::ID, message_queue_[0].type()); | 205 ASSERT_EQ(ResourceHostMsg_DataReceived_ACK::ID, message_queue_[0].type()); |
| 206 ASSERT_TRUE(ResourceHostMsg_DataReceived_ACK::Read( | 206 ASSERT_TRUE(ResourceHostMsg_DataReceived_ACK::Read( |
| 207 &message_queue_[0], &args)); | 207 &message_queue_[0], &args)); |
| 208 EXPECT_EQ(expected_request_id, args.a); | 208 EXPECT_EQ(expected_request_id, get<0>(args)); |
| 209 message_queue_.erase(message_queue_.begin()); | 209 message_queue_.erase(message_queue_.begin()); |
| 210 } | 210 } |
| 211 | 211 |
| 212 void ConsumeDataDownloaded_ACK(int expected_request_id) { | 212 void ConsumeDataDownloaded_ACK(int expected_request_id) { |
| 213 ASSERT_FALSE(message_queue_.empty()); | 213 ASSERT_FALSE(message_queue_.empty()); |
| 214 Tuple1<int> args; | 214 Tuple<int> args; |
| 215 ASSERT_EQ(ResourceHostMsg_DataDownloaded_ACK::ID, message_queue_[0].type()); | 215 ASSERT_EQ(ResourceHostMsg_DataDownloaded_ACK::ID, message_queue_[0].type()); |
| 216 ASSERT_TRUE(ResourceHostMsg_DataDownloaded_ACK::Read( | 216 ASSERT_TRUE(ResourceHostMsg_DataDownloaded_ACK::Read( |
| 217 &message_queue_[0], &args)); | 217 &message_queue_[0], &args)); |
| 218 EXPECT_EQ(expected_request_id, args.a); | 218 EXPECT_EQ(expected_request_id, get<0>(args)); |
| 219 message_queue_.erase(message_queue_.begin()); | 219 message_queue_.erase(message_queue_.begin()); |
| 220 } | 220 } |
| 221 | 221 |
| 222 void ConsumeReleaseDownloadedFile(int expected_request_id) { | 222 void ConsumeReleaseDownloadedFile(int expected_request_id) { |
| 223 ASSERT_FALSE(message_queue_.empty()); | 223 ASSERT_FALSE(message_queue_.empty()); |
| 224 Tuple1<int> args; | 224 Tuple<int> args; |
| 225 ASSERT_EQ(ResourceHostMsg_ReleaseDownloadedFile::ID, | 225 ASSERT_EQ(ResourceHostMsg_ReleaseDownloadedFile::ID, |
| 226 message_queue_[0].type()); | 226 message_queue_[0].type()); |
| 227 ASSERT_TRUE(ResourceHostMsg_ReleaseDownloadedFile::Read( | 227 ASSERT_TRUE(ResourceHostMsg_ReleaseDownloadedFile::Read( |
| 228 &message_queue_[0], &args)); | 228 &message_queue_[0], &args)); |
| 229 EXPECT_EQ(expected_request_id, args.a); | 229 EXPECT_EQ(expected_request_id, get<0>(args)); |
| 230 message_queue_.erase(message_queue_.begin()); | 230 message_queue_.erase(message_queue_.begin()); |
| 231 } | 231 } |
| 232 | 232 |
| 233 void ConsumeCancelRequest(int expected_request_id) { | 233 void ConsumeCancelRequest(int expected_request_id) { |
| 234 ASSERT_FALSE(message_queue_.empty()); | 234 ASSERT_FALSE(message_queue_.empty()); |
| 235 Tuple1<int> args; | 235 Tuple<int> args; |
| 236 ASSERT_EQ(ResourceHostMsg_CancelRequest::ID, message_queue_[0].type()); | 236 ASSERT_EQ(ResourceHostMsg_CancelRequest::ID, message_queue_[0].type()); |
| 237 ASSERT_TRUE(ResourceHostMsg_CancelRequest::Read( | 237 ASSERT_TRUE(ResourceHostMsg_CancelRequest::Read( |
| 238 &message_queue_[0], &args)); | 238 &message_queue_[0], &args)); |
| 239 EXPECT_EQ(expected_request_id, args.a); | 239 EXPECT_EQ(expected_request_id, get<0>(args)); |
| 240 message_queue_.erase(message_queue_.begin()); | 240 message_queue_.erase(message_queue_.begin()); |
| 241 } | 241 } |
| 242 | 242 |
| 243 void NotifyReceivedRedirect(int request_id) { | 243 void NotifyReceivedRedirect(int request_id) { |
| 244 ResourceResponseHead head; | 244 ResourceResponseHead head; |
| 245 std::string raw_headers(kTestRedirectHeaders); | 245 std::string raw_headers(kTestRedirectHeaders); |
| 246 std::replace(raw_headers.begin(), raw_headers.end(), '\n', '\0'); | 246 std::replace(raw_headers.begin(), raw_headers.end(), '\n', '\0'); |
| 247 head.headers = new net::HttpResponseHeaders(raw_headers); | 247 head.headers = new net::HttpResponseHeaders(raw_headers); |
| 248 net::RedirectInfo redirect_info; | 248 net::RedirectInfo redirect_info; |
| 249 redirect_info.status_code = 302; | 249 redirect_info.status_code = 302; |
| (...skipping 532 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 782 ResourceResponseHead response_head; | 782 ResourceResponseHead response_head; |
| 783 | 783 |
| 784 PerformTest(response_head); | 784 PerformTest(response_head); |
| 785 | 785 |
| 786 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); | 786 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); |
| 787 EXPECT_EQ(base::TimeTicks(), | 787 EXPECT_EQ(base::TimeTicks(), |
| 788 response_info().load_timing.connect_timing.dns_start); | 788 response_info().load_timing.connect_timing.dns_start); |
| 789 } | 789 } |
| 790 | 790 |
| 791 } // namespace content | 791 } // namespace content |
| OLD | NEW |