| 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 <utility> | 12 #include <utility> |
| 13 #include <vector> | 13 #include <vector> |
| 14 | 14 |
| 15 #include "base/macros.h" | 15 #include "base/macros.h" |
| 16 #include "base/memory/ptr_util.h" | 16 #include "base/memory/ptr_util.h" |
| 17 #include "base/memory/shared_memory.h" | 17 #include "base/memory/shared_memory.h" |
| 18 #include "base/message_loop/message_loop.h" | 18 #include "base/message_loop/message_loop.h" |
| 19 #include "base/process/process_handle.h" | 19 #include "base/process/process_handle.h" |
| 20 #include "base/run_loop.h" | 20 #include "base/run_loop.h" |
| 21 #include "base/stl_util.h" | 21 #include "base/stl_util.h" |
| 22 #include "content/child/request_extra_data.h" | 22 #include "content/child/request_extra_data.h" |
| 23 #include "content/child/request_info.h" | 23 #include "content/child/request_info.h" |
| 24 #include "content/common/appcache_interfaces.h" | 24 #include "content/common/appcache_interfaces.h" |
| 25 #include "content/common/resource_messages.h" | 25 #include "content/common/resource_messages.h" |
| 26 #include "content/common/resource_request.h" |
| 27 #include "content/common/resource_request_completion_status.h" |
| 26 #include "content/common/service_worker/service_worker_types.h" | 28 #include "content/common/service_worker/service_worker_types.h" |
| 27 #include "content/public/child/fixed_received_data.h" | 29 #include "content/public/child/fixed_received_data.h" |
| 28 #include "content/public/child/request_peer.h" | 30 #include "content/public/child/request_peer.h" |
| 29 #include "content/public/child/resource_dispatcher_delegate.h" | 31 #include "content/public/child/resource_dispatcher_delegate.h" |
| 30 #include "content/public/common/resource_response.h" | 32 #include "content/public/common/resource_response.h" |
| 31 #include "net/base/net_errors.h" | 33 #include "net/base/net_errors.h" |
| 32 #include "net/http/http_response_headers.h" | 34 #include "net/http/http_response_headers.h" |
| 33 #include "testing/gtest/include/gtest/gtest.h" | 35 #include "testing/gtest/include/gtest/gtest.h" |
| 34 | 36 |
| 35 namespace content { | 37 namespace content { |
| (...skipping 129 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 165 ADD_FAILURE() << "Missing resource request message"; | 167 ADD_FAILURE() << "Missing resource request message"; |
| 166 return -1; | 168 return -1; |
| 167 } | 169 } |
| 168 | 170 |
| 169 ResourceHostMsg_RequestResource::Param params; | 171 ResourceHostMsg_RequestResource::Param params; |
| 170 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() || | 172 if (ResourceHostMsg_RequestResource::ID != message_queue_[0].type() || |
| 171 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) { | 173 !ResourceHostMsg_RequestResource::Read(&message_queue_[0], ¶ms)) { |
| 172 ADD_FAILURE() << "Expected ResourceHostMsg_RequestResource message"; | 174 ADD_FAILURE() << "Expected ResourceHostMsg_RequestResource message"; |
| 173 return -1; | 175 return -1; |
| 174 } | 176 } |
| 175 ResourceHostMsg_Request request = base::get<2>(params); | 177 ResourceRequest request = base::get<2>(params); |
| 176 EXPECT_EQ(kTestPageUrl, request.url.spec()); | 178 EXPECT_EQ(kTestPageUrl, request.url.spec()); |
| 177 message_queue_.erase(message_queue_.begin()); | 179 message_queue_.erase(message_queue_.begin()); |
| 178 return base::get<1>(params); | 180 return base::get<1>(params); |
| 179 } | 181 } |
| 180 | 182 |
| 181 void ConsumeFollowRedirect(int expected_request_id) { | 183 void ConsumeFollowRedirect(int expected_request_id) { |
| 182 ASSERT_FALSE(message_queue_.empty()); | 184 ASSERT_FALSE(message_queue_.empty()); |
| 183 base::Tuple<int> args; | 185 base::Tuple<int> args; |
| 184 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type()); | 186 ASSERT_EQ(ResourceHostMsg_FollowRedirect::ID, message_queue_[0].type()); |
| 185 ASSERT_TRUE(ResourceHostMsg_FollowRedirect::Read( | 187 ASSERT_TRUE(ResourceHostMsg_FollowRedirect::Read( |
| (...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 276 ResourceMsg_DataReceived(request_id, 0, data.length(), data.length()))); | 278 ResourceMsg_DataReceived(request_id, 0, data.length(), data.length()))); |
| 277 } | 279 } |
| 278 | 280 |
| 279 void NotifyDataDownloaded(int request_id, int decoded_length, | 281 void NotifyDataDownloaded(int request_id, int decoded_length, |
| 280 int encoded_length) { | 282 int encoded_length) { |
| 281 EXPECT_TRUE(dispatcher_->OnMessageReceived(ResourceMsg_DataDownloaded( | 283 EXPECT_TRUE(dispatcher_->OnMessageReceived(ResourceMsg_DataDownloaded( |
| 282 request_id, decoded_length, encoded_length))); | 284 request_id, decoded_length, encoded_length))); |
| 283 } | 285 } |
| 284 | 286 |
| 285 void NotifyRequestComplete(int request_id, size_t total_size) { | 287 void NotifyRequestComplete(int request_id, size_t total_size) { |
| 286 ResourceMsg_RequestCompleteData request_complete_data; | 288 ResourceRequestCompletionStatus request_complete_data; |
| 287 request_complete_data.error_code = net::OK; | 289 request_complete_data.error_code = net::OK; |
| 288 request_complete_data.was_ignored_by_handler = false; | 290 request_complete_data.was_ignored_by_handler = false; |
| 289 request_complete_data.exists_in_cache = false; | 291 request_complete_data.exists_in_cache = false; |
| 290 request_complete_data.encoded_data_length = total_size; | 292 request_complete_data.encoded_data_length = total_size; |
| 291 EXPECT_TRUE(dispatcher_->OnMessageReceived( | 293 EXPECT_TRUE(dispatcher_->OnMessageReceived( |
| 292 ResourceMsg_RequestComplete(request_id, request_complete_data))); | 294 ResourceMsg_RequestComplete(request_id, request_complete_data))); |
| 293 } | 295 } |
| 294 | 296 |
| 295 RequestInfo* CreateRequestInfo(bool download_to_file) { | 297 RequestInfo* CreateRequestInfo(bool download_to_file) { |
| 296 RequestInfo* request_info = new RequestInfo(); | 298 RequestInfo* request_info = new RequestInfo(); |
| (...skipping 596 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 893 ResourceResponseHead response_head; | 895 ResourceResponseHead response_head; |
| 894 | 896 |
| 895 PerformTest(response_head); | 897 PerformTest(response_head); |
| 896 | 898 |
| 897 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); | 899 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); |
| 898 EXPECT_EQ(base::TimeTicks(), | 900 EXPECT_EQ(base::TimeTicks(), |
| 899 response_info().load_timing.connect_timing.dns_start); | 901 response_info().load_timing.connect_timing.dns_start); |
| 900 } | 902 } |
| 901 | 903 |
| 902 } // namespace content | 904 } // namespace content |
| OLD | NEW |