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