OLD | NEW |
---|---|
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 "mojo/edk/embedder/platform_shared_buffer.h" | 5 #include "mojo/edk/embedder/platform_shared_buffer.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 | 8 |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
11 #include "base/logging.h" | 11 #include "base/logging.h" |
12 #include "base/memory/ptr_util.h" | 12 #include "base/memory/ptr_util.h" |
13 #include "base/memory/shared_memory.h" | 13 #include "base/memory/shared_memory.h" |
14 #include "base/process/process_handle.h" | 14 #include "base/process/process_handle.h" |
15 #include "base/sys_info.h" | 15 #include "base/sys_info.h" |
16 #include "mojo/edk/embedder/platform_handle_utils.h" | 16 #include "mojo/edk/embedder/platform_handle_utils.h" |
17 | 17 |
18 namespace mojo { | 18 namespace mojo { |
19 namespace edk { | 19 namespace edk { |
20 | 20 |
21 namespace { | |
22 | |
23 // Takes ownership of |memory_handle|. | |
24 ScopedPlatformHandle SharedMemoryToPlatformHandle( | |
25 base::SharedMemoryHandle memory_handle) { | |
26 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) | |
27 return ScopedPlatformHandle(PlatformHandle(memory_handle.fd)); | |
28 #elif defined(OS_WIN) | |
29 return ScopedPlatformHandle(PlatformHandle(memory_handle.GetHandle())); | |
30 #else | |
31 return ScopedPlatformHandle(PlatformHandle(memory_handle.GetMemoryObject())); | |
32 #endif | |
33 } | |
34 | |
35 } // namespace | |
36 | |
37 // static | 21 // static |
38 PlatformSharedBuffer* PlatformSharedBuffer::Create(size_t num_bytes) { | 22 PlatformSharedBuffer* PlatformSharedBuffer::Create(size_t num_bytes) { |
39 DCHECK_GT(num_bytes, 0u); | 23 DCHECK_GT(num_bytes, 0u); |
40 | 24 |
41 PlatformSharedBuffer* rv = new PlatformSharedBuffer(num_bytes, false); | 25 PlatformSharedBuffer* rv = new PlatformSharedBuffer(num_bytes, false); |
42 if (!rv->Init()) { | 26 if (!rv->Init()) { |
43 // We can't just delete it directly, due to the "in destructor" (debug) | 27 // We can't just delete it directly, due to the "in destructor" (debug) |
44 // check. | 28 // check. |
45 scoped_refptr<PlatformSharedBuffer> deleter(rv); | 29 scoped_refptr<PlatformSharedBuffer> deleter(rv); |
46 return nullptr; | 30 return nullptr; |
(...skipping 47 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
94 bool read_only, | 78 bool read_only, |
95 base::SharedMemoryHandle handle) { | 79 base::SharedMemoryHandle handle) { |
96 DCHECK_GT(num_bytes, 0u); | 80 DCHECK_GT(num_bytes, 0u); |
97 | 81 |
98 PlatformSharedBuffer* rv = new PlatformSharedBuffer(num_bytes, read_only); | 82 PlatformSharedBuffer* rv = new PlatformSharedBuffer(num_bytes, read_only); |
99 rv->InitFromSharedMemoryHandle(handle); | 83 rv->InitFromSharedMemoryHandle(handle); |
100 | 84 |
101 return rv; | 85 return rv; |
102 } | 86 } |
103 | 87 |
88 // static | |
89 base::SharedMemoryHandle | |
90 PlatformSharedBuffer::GetSharedMemoryHandleFromPlatformHandle( | |
91 MojoPlatformHandle platform_handle, | |
92 size_t size, | |
93 bool read_only) { | |
94 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) | |
95 return base::SharedMemoryHandle(static_cast<int>(platform_handle), | |
96 false); | |
97 #elif defined(OS_WIN) | |
98 return base::SharedMemoryHandle(static_cast<HANDLE>(platform_handle), | |
99 base::GetCurrentProcessHandle()); | |
100 #else | |
101 return base::SharedMemoryHandle(static_cast<mach_port_t>(platform_handle), | |
102 static_cast<mach_vm_size_t>(num_bytes), | |
103 base::GetCurrentProcId()); | |
104 #endif | |
105 } | |
106 | |
107 // static | |
108 PlatformHandle PlatformSharedBuffer::GetPlatformHandleFromSharedMemoryHandle( | |
109 base::SharedMemoryHandle memory_handle) { | |
110 #if defined(OS_POSIX) && !(defined(OS_MACOSX) && !defined(OS_IOS)) | |
111 return PlatformHandle(memory_handle.fd); | |
112 #elif defined(OS_WIN) | |
113 return PlatformHandle(memory_handle.GetHandle()); | |
114 #else | |
115 return PlatformHandle(memory_handle.GetMemoryObject()); | |
116 #endif | |
117 } | |
118 | |
104 size_t PlatformSharedBuffer::GetNumBytes() const { | 119 size_t PlatformSharedBuffer::GetNumBytes() const { |
105 return num_bytes_; | 120 return num_bytes_; |
106 } | 121 } |
107 | 122 |
108 bool PlatformSharedBuffer::IsReadOnly() const { | 123 bool PlatformSharedBuffer::IsReadOnly() const { |
109 return read_only_; | 124 return read_only_; |
110 } | 125 } |
111 | 126 |
112 std::unique_ptr<PlatformSharedBufferMapping> PlatformSharedBuffer::Map( | 127 std::unique_ptr<PlatformSharedBufferMapping> PlatformSharedBuffer::Map( |
113 size_t offset, | 128 size_t offset, |
(...skipping 40 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
154 ScopedPlatformHandle PlatformSharedBuffer::DuplicatePlatformHandle() { | 169 ScopedPlatformHandle PlatformSharedBuffer::DuplicatePlatformHandle() { |
155 DCHECK(shared_memory_); | 170 DCHECK(shared_memory_); |
156 base::SharedMemoryHandle handle; | 171 base::SharedMemoryHandle handle; |
157 { | 172 { |
158 base::AutoLock locker(lock_); | 173 base::AutoLock locker(lock_); |
159 handle = base::SharedMemory::DuplicateHandle(shared_memory_->handle()); | 174 handle = base::SharedMemory::DuplicateHandle(shared_memory_->handle()); |
160 } | 175 } |
161 if (handle == base::SharedMemory::NULLHandle()) | 176 if (handle == base::SharedMemory::NULLHandle()) |
162 return ScopedPlatformHandle(); | 177 return ScopedPlatformHandle(); |
163 | 178 |
164 return SharedMemoryToPlatformHandle(handle); | 179 return ScopedPlatformHandle(GetPlatformHandleFromSharedMemoryHandle(handle)); |
165 } | 180 } |
166 | 181 |
167 ScopedPlatformHandle PlatformSharedBuffer::PassPlatformHandle() { | 182 ScopedPlatformHandle PlatformSharedBuffer::PassPlatformHandle() { |
168 DCHECK(HasOneRef()); | 183 DCHECK(HasOneRef()); |
169 | 184 |
170 // The only way to pass a handle from base::SharedMemory is to duplicate it | 185 // The only way to pass a handle from base::SharedMemory is to duplicate it |
171 // and close the original. | 186 // and close the original. |
172 ScopedPlatformHandle handle = DuplicatePlatformHandle(); | 187 ScopedPlatformHandle handle = DuplicatePlatformHandle(); |
173 | 188 |
174 base::AutoLock locker(lock_); | 189 base::AutoLock locker(lock_); |
(...skipping 48 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
223 options.share_read_only = true; | 238 options.share_read_only = true; |
224 | 239 |
225 shared_memory_.reset(new base::SharedMemory); | 240 shared_memory_.reset(new base::SharedMemory); |
226 return shared_memory_->Create(options); | 241 return shared_memory_->Create(options); |
227 } | 242 } |
228 | 243 |
229 bool PlatformSharedBuffer::InitFromPlatformHandle( | 244 bool PlatformSharedBuffer::InitFromPlatformHandle( |
230 ScopedPlatformHandle platform_handle) { | 245 ScopedPlatformHandle platform_handle) { |
231 DCHECK(!shared_memory_); | 246 DCHECK(!shared_memory_); |
232 | 247 |
233 #if defined(OS_WIN) | 248 #if defined(OS_WIN) |
Anand Mistry (off Chromium)
2016/05/20 06:25:40
Please change this to use the new function.
Ken Rockot(use gerrit already)
2016/05/20 22:19:43
No longer relevant since I removed the new functio
| |
234 base::SharedMemoryHandle handle(platform_handle.release().handle, | 249 base::SharedMemoryHandle handle(platform_handle.release().handle, |
235 base::GetCurrentProcId()); | 250 base::GetCurrentProcId()); |
236 #elif defined(OS_MACOSX) && !defined(OS_IOS) | 251 #elif defined(OS_MACOSX) && !defined(OS_IOS) |
237 base::SharedMemoryHandle handle; | 252 base::SharedMemoryHandle handle; |
238 handle = base::SharedMemoryHandle(platform_handle.release().port, num_bytes_, | 253 handle = base::SharedMemoryHandle(platform_handle.release().port, num_bytes_, |
239 base::GetCurrentProcId()); | 254 base::GetCurrentProcId()); |
240 #else | 255 #else |
241 base::SharedMemoryHandle handle(platform_handle.release().handle, false); | 256 base::SharedMemoryHandle handle(platform_handle.release().handle, false); |
242 #endif | 257 #endif |
243 | 258 |
(...skipping 54 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
298 base_ = static_cast<char*>(shared_memory_.memory()) + offset_rounding; | 313 base_ = static_cast<char*>(shared_memory_.memory()) + offset_rounding; |
299 return true; | 314 return true; |
300 } | 315 } |
301 | 316 |
302 void PlatformSharedBufferMapping::Unmap() { | 317 void PlatformSharedBufferMapping::Unmap() { |
303 shared_memory_.Unmap(); | 318 shared_memory_.Unmap(); |
304 } | 319 } |
305 | 320 |
306 } // namespace edk | 321 } // namespace edk |
307 } // namespace mojo | 322 } // namespace mojo |
OLD | NEW |