OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 <mach/mach.h> | 5 #include <mach/mach.h> |
6 #include <mach/mach_vm.h> | 6 #include <mach/mach_vm.h> |
7 #include <servers/bootstrap.h> | 7 #include <servers/bootstrap.h> |
8 | 8 |
9 #include "base/command_line.h" | 9 #include "base/command_line.h" |
10 #include "base/mac/mac_util.h" | |
11 #include "base/mac/mach_logging.h" | 10 #include "base/mac/mach_logging.h" |
12 #include "base/mac/scoped_mach_port.h" | 11 #include "base/mac/scoped_mach_port.h" |
13 #include "base/memory/shared_memory.h" | 12 #include "base/memory/shared_memory.h" |
14 #include "base/process/process_handle.h" | 13 #include "base/process/process_handle.h" |
15 #include "base/rand_util.h" | 14 #include "base/rand_util.h" |
16 #include "base/strings/stringprintf.h" | 15 #include "base/strings/stringprintf.h" |
17 #include "base/sys_info.h" | 16 #include "base/sys_info.h" |
18 #include "base/test/multiprocess_test.h" | 17 #include "base/test/multiprocess_test.h" |
19 #include "base/test/test_timeouts.h" | 18 #include "base/test/test_timeouts.h" |
20 #include "testing/multiprocess_func_list.h" | 19 #include "testing/multiprocess_func_list.h" |
21 | 20 |
22 namespace base { | 21 namespace base { |
23 | 22 |
24 namespace { | 23 namespace { |
25 | 24 |
26 // Gets the current and maximum protection levels of the memory region. | |
27 // Returns whether the operation was successful. | |
28 // |current| and |max| are output variables only populated on success. | |
29 bool GetProtections(void* address, size_t size, int* current, int* max) { | |
30 vm_region_info_t region_info; | |
31 mach_vm_address_t mem_address = reinterpret_cast<mach_vm_address_t>(address); | |
32 mach_vm_size_t mem_size = size; | |
33 vm_region_basic_info_64 basic_info; | |
34 | |
35 region_info = reinterpret_cast<vm_region_recurse_info_t>(&basic_info); | |
36 vm_region_flavor_t flavor = VM_REGION_BASIC_INFO_64; | |
37 memory_object_name_t memory_object; | |
38 mach_port_t ctype; | |
39 | |
40 kern_return_t kr = | |
41 mach_vm_region(mach_task_self(), &mem_address, &mem_size, flavor, | |
42 region_info, &memory_object, &ctype); | |
43 if (kr != KERN_SUCCESS) { | |
44 LOG(ERROR) << "Failed to get region info."; | |
45 return false; | |
46 } | |
47 | |
48 *current = basic_info.protection; | |
49 *max = basic_info.max_protection; | |
50 return true; | |
51 } | |
52 | |
53 // Creates a new SharedMemory with the given |size|, filled with 'a'. | |
54 scoped_ptr<SharedMemory> CreateSharedMemory(int size) { | |
55 SharedMemoryHandle shm(size); | |
56 if (!shm.IsValid()) { | |
57 LOG(ERROR) << "Failed to make SharedMemoryHandle"; | |
58 return nullptr; | |
59 } | |
60 scoped_ptr<SharedMemory> shared_memory(new SharedMemory(shm, false)); | |
61 shared_memory->Map(size); | |
62 memset(shared_memory->memory(), 'a', size); | |
63 return shared_memory; | |
64 } | |
65 | |
66 static const std::string g_service_switch_name = "service_name"; | 25 static const std::string g_service_switch_name = "service_name"; |
67 | 26 |
68 // Structs used to pass a mach port from client to server. | 27 // Structs used to pass a mach port from client to server. |
69 struct MachSendPortMessage { | 28 struct MachSendPortMessage { |
70 mach_msg_header_t header; | 29 mach_msg_header_t header; |
71 mach_msg_body_t body; | 30 mach_msg_body_t body; |
72 mach_msg_port_descriptor_t data; | 31 mach_msg_port_descriptor_t data; |
73 }; | 32 }; |
74 struct MachReceivePortMessage { | 33 struct MachReceivePortMessage { |
75 mach_msg_header_t header; | 34 mach_msg_header_t header; |
(...skipping 142 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
218 // process. | 177 // process. |
219 mac::ScopedMachSendRight client_port_; | 178 mac::ScopedMachSendRight client_port_; |
220 | 179 |
221 base::Process child_process_; | 180 base::Process child_process_; |
222 DISALLOW_COPY_AND_ASSIGN(SharedMemoryMacMultiProcessTest); | 181 DISALLOW_COPY_AND_ASSIGN(SharedMemoryMacMultiProcessTest); |
223 }; | 182 }; |
224 | 183 |
225 // Tests that content written to shared memory in the server process can be read | 184 // Tests that content written to shared memory in the server process can be read |
226 // by the child process. | 185 // by the child process. |
227 TEST_F(SharedMemoryMacMultiProcessTest, MachBasedSharedMemory) { | 186 TEST_F(SharedMemoryMacMultiProcessTest, MachBasedSharedMemory) { |
228 // Mach-based SharedMemory isn't support on OSX 10.6. | |
229 if (mac::IsOSSnowLeopard()) | |
230 return; | |
231 | |
232 SetUpChild("MachBasedSharedMemoryClient"); | 187 SetUpChild("MachBasedSharedMemoryClient"); |
233 | 188 |
234 scoped_ptr<SharedMemory> shared_memory( | 189 SharedMemoryHandle shm(s_memory_size); |
235 CreateSharedMemory(s_memory_size).Pass()); | 190 ASSERT_TRUE(shm.IsValid()); |
| 191 SharedMemory shared_memory(shm, false); |
| 192 shared_memory.Map(s_memory_size); |
| 193 memset(shared_memory.memory(), 'a', s_memory_size); |
236 | 194 |
237 // Send the underlying memory object to the client process. | 195 // Send the underlying memory object to the client process. |
238 SendMachPort(client_port_.get(), shared_memory->handle().GetMemoryObject(), | 196 SendMachPort( |
239 MACH_MSG_TYPE_COPY_SEND); | 197 client_port_.get(), shm.GetMemoryObject(), MACH_MSG_TYPE_COPY_SEND); |
240 int rv = -1; | 198 int rv = -1; |
241 ASSERT_TRUE(child_process_.WaitForExitWithTimeout( | 199 ASSERT_TRUE(child_process_.WaitForExitWithTimeout( |
242 TestTimeouts::action_timeout(), &rv)); | 200 TestTimeouts::action_timeout(), &rv)); |
243 EXPECT_EQ(0, rv); | 201 EXPECT_EQ(0, rv); |
244 } | 202 } |
245 | 203 |
246 MULTIPROCESS_TEST_MAIN(MachBasedSharedMemoryClient) { | 204 MULTIPROCESS_TEST_MAIN(MachBasedSharedMemoryClient) { |
247 mac::ScopedMachReceiveRight client_port(CommonChildProcessSetUp()); | 205 mac::ScopedMachReceiveRight client_port(CommonChildProcessSetUp()); |
248 // The next mach port should be for a memory object. | 206 // The next mach port should be for a memory object. |
249 mach_port_t memory_object = ReceiveMachPort(client_port.get()); | 207 mach_port_t memory_object = ReceiveMachPort(client_port.get()); |
250 SharedMemoryHandle shm(memory_object, | 208 SharedMemoryHandle shm(memory_object, |
251 SharedMemoryMacMultiProcessTest::s_memory_size, | 209 SharedMemoryMacMultiProcessTest::s_memory_size, |
252 GetCurrentProcId()); | 210 GetCurrentProcId()); |
253 SharedMemory shared_memory(shm, false); | 211 SharedMemory shared_memory(shm, false); |
254 shared_memory.Map(SharedMemoryMacMultiProcessTest::s_memory_size); | 212 shared_memory.Map(SharedMemoryMacMultiProcessTest::s_memory_size); |
255 const char* start = static_cast<const char*>(shared_memory.memory()); | 213 const char* start = static_cast<const char*>(shared_memory.memory()); |
256 for (int i = 0; i < SharedMemoryMacMultiProcessTest::s_memory_size; ++i) { | 214 for (int i = 0; i < SharedMemoryMacMultiProcessTest::s_memory_size; ++i) { |
257 DCHECK_EQ(start[i], 'a'); | 215 DCHECK_EQ(start[i], 'a'); |
258 } | 216 } |
259 return 0; | 217 return 0; |
260 } | 218 } |
261 | 219 |
262 // Tests that mapping shared memory with an offset works correctly. | 220 // Tests that mapping shared memory with an offset works correctly. |
263 TEST_F(SharedMemoryMacMultiProcessTest, MachBasedSharedMemoryWithOffset) { | 221 TEST_F(SharedMemoryMacMultiProcessTest, MachBasedSharedMemoryWithOffset) { |
264 // Mach-based SharedMemory isn't support on OSX 10.6. | |
265 if (mac::IsOSSnowLeopard()) | |
266 return; | |
267 | |
268 SetUpChild("MachBasedSharedMemoryWithOffsetClient"); | 222 SetUpChild("MachBasedSharedMemoryWithOffsetClient"); |
269 | 223 |
270 SharedMemoryHandle shm(s_memory_size); | 224 SharedMemoryHandle shm(s_memory_size); |
271 ASSERT_TRUE(shm.IsValid()); | 225 ASSERT_TRUE(shm.IsValid()); |
272 SharedMemory shared_memory(shm, false); | 226 SharedMemory shared_memory(shm, false); |
273 shared_memory.Map(s_memory_size); | 227 shared_memory.Map(s_memory_size); |
274 | 228 |
275 size_t page_size = SysInfo::VMAllocationGranularity(); | 229 size_t page_size = SysInfo::VMAllocationGranularity(); |
276 char* start = static_cast<char*>(shared_memory.memory()); | 230 char* start = static_cast<char*>(shared_memory.memory()); |
277 memset(start, 'a', page_size); | 231 memset(start, 'a', page_size); |
(...skipping 25 matching lines...) Expand all Loading... |
303 } | 257 } |
304 for (size_t i = page_size; i < 2 * page_size; ++i) { | 258 for (size_t i = page_size; i < 2 * page_size; ++i) { |
305 DCHECK_EQ(start[i], 'c'); | 259 DCHECK_EQ(start[i], 'c'); |
306 } | 260 } |
307 return 0; | 261 return 0; |
308 } | 262 } |
309 | 263 |
310 // Tests that duplication and closing has the right effect on Mach reference | 264 // Tests that duplication and closing has the right effect on Mach reference |
311 // counts. | 265 // counts. |
312 TEST_F(SharedMemoryMacMultiProcessTest, MachDuplicateAndClose) { | 266 TEST_F(SharedMemoryMacMultiProcessTest, MachDuplicateAndClose) { |
313 // Mach-based SharedMemory isn't support on OSX 10.6. | |
314 if (mac::IsOSSnowLeopard()) | |
315 return; | |
316 | |
317 mach_msg_type_number_t active_name_count = GetActiveNameCount(); | 267 mach_msg_type_number_t active_name_count = GetActiveNameCount(); |
318 | 268 |
319 // Making a new SharedMemoryHandle increments the name count. | 269 // Making a new SharedMemoryHandle increments the name count. |
320 SharedMemoryHandle shm(s_memory_size); | 270 SharedMemoryHandle shm(s_memory_size); |
321 ASSERT_TRUE(shm.IsValid()); | 271 ASSERT_TRUE(shm.IsValid()); |
322 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); | 272 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); |
323 | 273 |
324 // Duplicating the SharedMemoryHandle increments the ref count, but doesn't | 274 // Duplicating the SharedMemoryHandle increments the ref count, but doesn't |
325 // make a new name. | 275 // make a new name. |
326 shm.Duplicate(); | 276 shm.Duplicate(); |
327 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); | 277 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); |
328 | 278 |
329 // Closing the SharedMemoryHandle decrements the ref count. The first time has | 279 // Closing the SharedMemoryHandle decrements the ref count. The first time has |
330 // no effect. | 280 // no effect. |
331 shm.Close(); | 281 shm.Close(); |
332 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); | 282 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); |
333 | 283 |
334 // Closing the SharedMemoryHandle decrements the ref count. The second time | 284 // Closing the SharedMemoryHandle decrements the ref count. The second time |
335 // destroys the port. | 285 // destroys the port. |
336 shm.Close(); | 286 shm.Close(); |
337 EXPECT_EQ(active_name_count, GetActiveNameCount()); | 287 EXPECT_EQ(active_name_count, GetActiveNameCount()); |
338 } | 288 } |
339 | 289 |
340 // Tests that passing a SharedMemoryHandle to a SharedMemory object also passes | 290 // Tests that passing a SharedMemoryHandle to a SharedMemory object also passes |
341 // ownership, and that destroying the SharedMemory closes the SharedMemoryHandle | 291 // ownership, and that destroying the SharedMemory closes the SharedMemoryHandle |
342 // as well. | 292 // as well. |
343 TEST_F(SharedMemoryMacMultiProcessTest, MachSharedMemoryTakesOwnership) { | 293 TEST_F(SharedMemoryMacMultiProcessTest, MachSharedMemoryTakesOwnership) { |
344 // Mach-based SharedMemory isn't support on OSX 10.6. | |
345 if (mac::IsOSSnowLeopard()) | |
346 return; | |
347 | |
348 mach_msg_type_number_t active_name_count = GetActiveNameCount(); | 294 mach_msg_type_number_t active_name_count = GetActiveNameCount(); |
349 | 295 |
350 // Making a new SharedMemoryHandle increments the name count. | 296 // Making a new SharedMemoryHandle increments the name count. |
351 SharedMemoryHandle shm(s_memory_size); | 297 SharedMemoryHandle shm(s_memory_size); |
352 ASSERT_TRUE(shm.IsValid()); | 298 ASSERT_TRUE(shm.IsValid()); |
353 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); | 299 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); |
354 | 300 |
355 // Name count doesn't change when mapping the memory. | 301 // Name count doesn't change when mapping the memory. |
356 scoped_ptr<SharedMemory> shared_memory(new SharedMemory(shm, false)); | 302 scoped_ptr<SharedMemory> shared_memory(new SharedMemory(shm, false)); |
357 shared_memory->Map(s_memory_size); | 303 shared_memory->Map(s_memory_size); |
358 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); | 304 EXPECT_EQ(active_name_count + 1, GetActiveNameCount()); |
359 | 305 |
360 // Destroying the SharedMemory object frees the resource. | 306 // Destroying the SharedMemory object frees the resource. |
361 shared_memory.reset(); | 307 shared_memory.reset(); |
362 EXPECT_EQ(active_name_count, GetActiveNameCount()); | 308 EXPECT_EQ(active_name_count, GetActiveNameCount()); |
363 } | 309 } |
364 | 310 |
365 // Tests that the read-only flag works. | 311 // Tests that the read-only flag works. |
366 TEST_F(SharedMemoryMacMultiProcessTest, MachReadOnly) { | 312 TEST_F(SharedMemoryMacMultiProcessTest, MachReadOnly) { |
367 // Mach-based SharedMemory isn't support on OSX 10.6. | 313 SharedMemoryHandle shm(s_memory_size); |
368 if (mac::IsOSSnowLeopard()) | 314 ASSERT_TRUE(shm.IsValid()); |
369 return; | 315 SharedMemory shared_memory(shm, false); |
| 316 shared_memory.Map(s_memory_size); |
| 317 memset(shared_memory.memory(), 'a', s_memory_size); |
370 | 318 |
371 scoped_ptr<SharedMemory> shared_memory( | 319 SharedMemoryHandle shm2 = shm.Duplicate(); |
372 CreateSharedMemory(s_memory_size).Pass()); | |
373 | |
374 SharedMemoryHandle shm2 = shared_memory->handle().Duplicate(); | |
375 ASSERT_TRUE(shm2.IsValid()); | 320 ASSERT_TRUE(shm2.IsValid()); |
376 SharedMemory shared_memory2(shm2, true); | 321 SharedMemory shared_memory2(shm, true); |
377 shared_memory2.Map(s_memory_size); | 322 shared_memory2.Map(s_memory_size); |
378 ASSERT_DEATH(memset(shared_memory2.memory(), 'b', s_memory_size), ""); | 323 ASSERT_DEATH(memset(shared_memory2.memory(), 'b', s_memory_size), ""); |
379 } | 324 } |
380 | 325 |
381 // Tests that the method ShareToProcess() works. | |
382 TEST_F(SharedMemoryMacMultiProcessTest, MachShareToProcess) { | |
383 // Mach-based SharedMemory isn't support on OSX 10.6. | |
384 if (mac::IsOSSnowLeopard()) | |
385 return; | |
386 | |
387 mach_msg_type_number_t active_name_count = GetActiveNameCount(); | |
388 | |
389 { | |
390 scoped_ptr<SharedMemory> shared_memory( | |
391 CreateSharedMemory(s_memory_size).Pass()); | |
392 | |
393 SharedMemoryHandle shm2; | |
394 ASSERT_TRUE(shared_memory->ShareToProcess(GetCurrentProcId(), &shm2)); | |
395 ASSERT_TRUE(shm2.IsValid()); | |
396 SharedMemory shared_memory2(shm2, true); | |
397 shared_memory2.Map(s_memory_size); | |
398 | |
399 ASSERT_EQ(0, memcmp(shared_memory->memory(), shared_memory2.memory(), | |
400 s_memory_size)); | |
401 } | |
402 | |
403 EXPECT_EQ(active_name_count, GetActiveNameCount()); | |
404 } | |
405 | |
406 // Tests that the method ShareReadOnlyToProcess() creates a memory object that | |
407 // is read only. | |
408 TEST_F(SharedMemoryMacMultiProcessTest, MachShareToProcessReadonly) { | |
409 // Mach-based SharedMemory isn't support on OSX 10.6. | |
410 if (mac::IsOSSnowLeopard()) | |
411 return; | |
412 | |
413 scoped_ptr<SharedMemory> shared_memory( | |
414 CreateSharedMemory(s_memory_size).Pass()); | |
415 | |
416 // Check the protection levels. | |
417 int current_prot, max_prot; | |
418 ASSERT_TRUE(GetProtections(shared_memory->memory(), | |
419 shared_memory->mapped_size(), ¤t_prot, | |
420 &max_prot)); | |
421 ASSERT_EQ(VM_PROT_READ | VM_PROT_WRITE, current_prot); | |
422 ASSERT_EQ(VM_PROT_READ | VM_PROT_WRITE, max_prot); | |
423 | |
424 // Make a new memory object. | |
425 SharedMemoryHandle shm2; | |
426 ASSERT_TRUE(shared_memory->ShareReadOnlyToProcess(GetCurrentProcId(), &shm2)); | |
427 ASSERT_TRUE(shm2.IsValid()); | |
428 | |
429 // Mapping with |readonly| set to |false| should fail. | |
430 SharedMemory shared_memory2(shm2, false); | |
431 shared_memory2.Map(s_memory_size); | |
432 ASSERT_EQ(nullptr, shared_memory2.memory()); | |
433 | |
434 // Now trying mapping with |readonly| set to |true|. | |
435 SharedMemory shared_memory3(shm2.Duplicate(), true); | |
436 shared_memory3.Map(s_memory_size); | |
437 ASSERT_NE(nullptr, shared_memory3.memory()); | |
438 | |
439 // Check the protection levels. | |
440 ASSERT_TRUE(GetProtections(shared_memory3.memory(), | |
441 shared_memory3.mapped_size(), ¤t_prot, | |
442 &max_prot)); | |
443 ASSERT_EQ(VM_PROT_READ, current_prot); | |
444 ASSERT_EQ(VM_PROT_READ, max_prot); | |
445 | |
446 // The memory should still be readonly, since the underlying memory object | |
447 // is readonly. | |
448 ASSERT_DEATH(memset(shared_memory2.memory(), 'b', s_memory_size), ""); | |
449 } | |
450 | |
451 // Tests that the method ShareReadOnlyToProcess() doesn't leak. | |
452 TEST_F(SharedMemoryMacMultiProcessTest, MachShareToProcessReadonlyLeak) { | |
453 // Mach-based SharedMemory isn't support on OSX 10.6. | |
454 if (mac::IsOSSnowLeopard()) | |
455 return; | |
456 | |
457 mach_msg_type_number_t active_name_count = GetActiveNameCount(); | |
458 | |
459 { | |
460 scoped_ptr<SharedMemory> shared_memory( | |
461 CreateSharedMemory(s_memory_size).Pass()); | |
462 | |
463 SharedMemoryHandle shm2; | |
464 ASSERT_TRUE( | |
465 shared_memory->ShareReadOnlyToProcess(GetCurrentProcId(), &shm2)); | |
466 ASSERT_TRUE(shm2.IsValid()); | |
467 | |
468 // Intentionally map with |readonly| set to |false|. | |
469 SharedMemory shared_memory2(shm2, false); | |
470 shared_memory2.Map(s_memory_size); | |
471 } | |
472 | |
473 EXPECT_EQ(active_name_count, GetActiveNameCount()); | |
474 } | |
475 | |
476 } // namespace base | 326 } // namespace base |
OLD | NEW |