| 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 |