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 |