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> |
(...skipping 149 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
160 EXPECT_EQ(true, dispatcher_->OnMessageReceived( | 160 EXPECT_EQ(true, dispatcher_->OnMessageReceived( |
161 ResourceMsg_ReceivedResponse(request_id, head))); | 161 ResourceMsg_ReceivedResponse(request_id, head))); |
162 } | 162 } |
163 | 163 |
164 void NotifySetDataBuffer(int request_id, size_t buffer_size) { | 164 void NotifySetDataBuffer(int request_id, size_t buffer_size) { |
165 base::SharedMemory* shared_memory = new base::SharedMemory(); | 165 base::SharedMemory* shared_memory = new base::SharedMemory(); |
166 ASSERT_FALSE(shared_memory_map_[request_id]); | 166 ASSERT_FALSE(shared_memory_map_[request_id]); |
167 shared_memory_map_[request_id] = base::WrapUnique(shared_memory); | 167 shared_memory_map_[request_id] = base::WrapUnique(shared_memory); |
168 EXPECT_TRUE(shared_memory->CreateAndMapAnonymous(buffer_size)); | 168 EXPECT_TRUE(shared_memory->CreateAndMapAnonymous(buffer_size)); |
169 | 169 |
170 base::SharedMemoryHandle duplicate_handle; | 170 base::SharedMemoryHandle duplicate_handle = |
171 EXPECT_TRUE(shared_memory->ShareToProcess(base::GetCurrentProcessHandle(), | 171 shared_memory->handle().Duplicate(); |
172 &duplicate_handle)); | 172 EXPECT_TRUE(duplicate_handle.IsValid()); |
173 EXPECT_TRUE(dispatcher_->OnMessageReceived(ResourceMsg_SetDataBuffer( | 173 EXPECT_TRUE(dispatcher_->OnMessageReceived(ResourceMsg_SetDataBuffer( |
174 request_id, duplicate_handle, shared_memory->requested_size(), 0))); | 174 request_id, duplicate_handle, shared_memory->requested_size(), 0))); |
175 } | 175 } |
176 | 176 |
177 void NotifyDataReceived(int request_id, const std::string& data) { | 177 void NotifyDataReceived(int request_id, const std::string& data) { |
178 ASSERT_LE(data.length(), shared_memory_map_[request_id]->requested_size()); | 178 ASSERT_LE(data.length(), shared_memory_map_[request_id]->requested_size()); |
179 memcpy(shared_memory_map_[request_id]->memory(), data.c_str(), | 179 memcpy(shared_memory_map_[request_id]->memory(), data.c_str(), |
180 data.length()); | 180 data.length()); |
181 | 181 |
182 EXPECT_TRUE(dispatcher_->OnMessageReceived(ResourceMsg_DataReceived( | 182 EXPECT_TRUE(dispatcher_->OnMessageReceived(ResourceMsg_DataReceived( |
(...skipping 730 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
913 ResourceResponseHead response_head; | 913 ResourceResponseHead response_head; |
914 | 914 |
915 PerformTest(response_head); | 915 PerformTest(response_head); |
916 | 916 |
917 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); | 917 EXPECT_EQ(base::TimeTicks(), response_info().load_timing.request_start); |
918 EXPECT_EQ(base::TimeTicks(), | 918 EXPECT_EQ(base::TimeTicks(), |
919 response_info().load_timing.connect_timing.dns_start); | 919 response_info().load_timing.connect_timing.dns_start); |
920 } | 920 } |
921 | 921 |
922 } // namespace content | 922 } // namespace content |
OLD | NEW |