OLD | NEW |
1 // Copyright 2016 The Chromium Authors. All rights reserved. | 1 // Copyright 2016 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/system/channel.h" | 5 #include "mojo/edk/system/channel.h" |
6 | 6 |
7 #include <stddef.h> | 7 #include <stddef.h> |
8 #include <string.h> | 8 #include <string.h> |
9 | 9 |
10 #include <algorithm> | 10 #include <algorithm> |
11 #include <limits> | 11 #include <limits> |
12 #include <utility> | 12 #include <utility> |
13 | 13 |
14 #include "base/macros.h" | 14 #include "base/macros.h" |
15 #include "base/memory/aligned_memory.h" | 15 #include "base/memory/aligned_memory.h" |
16 #include "base/process/process_handle.h" | 16 #include "base/process/process_handle.h" |
17 #include "mojo/edk/embedder/embedder_internal.h" | |
18 #include "mojo/edk/embedder/platform_handle.h" | 17 #include "mojo/edk/embedder/platform_handle.h" |
19 | 18 |
20 #if defined(OS_MACOSX) && !defined(OS_IOS) | 19 #if defined(OS_MACOSX) && !defined(OS_IOS) |
21 #include "base/mac/mach_logging.h" | 20 #include "base/mac/mach_logging.h" |
22 #elif defined(OS_WIN) | 21 #elif defined(OS_WIN) |
23 #include "base/win/win_util.h" | 22 #include "base/win/win_util.h" |
24 #endif | 23 #endif |
25 | 24 |
26 namespace mojo { | 25 namespace mojo { |
27 namespace edk { | 26 namespace edk { |
(...skipping 11 matching lines...) Expand all Loading... |
39 "LegacyHeader must be 8 bytes on ChromeOS and Android"); | 38 "LegacyHeader must be 8 bytes on ChromeOS and Android"); |
40 | 39 |
41 static_assert(offsetof(Channel::Message::LegacyHeader, num_bytes) == | 40 static_assert(offsetof(Channel::Message::LegacyHeader, num_bytes) == |
42 offsetof(Channel::Message::Header, num_bytes), | 41 offsetof(Channel::Message::Header, num_bytes), |
43 "num_bytes should be at the same offset in both Header structs."); | 42 "num_bytes should be at the same offset in both Header structs."); |
44 static_assert(offsetof(Channel::Message::LegacyHeader, message_type) == | 43 static_assert(offsetof(Channel::Message::LegacyHeader, message_type) == |
45 offsetof(Channel::Message::Header, message_type), | 44 offsetof(Channel::Message::Header, message_type), |
46 "message_type should be at the same offset in both Header " | 45 "message_type should be at the same offset in both Header " |
47 "structs."); | 46 "structs."); |
48 | 47 |
49 bool g_use_legacy_protocol = false; | |
50 | |
51 } // namespace | 48 } // namespace |
52 | 49 |
53 const size_t kReadBufferSize = 4096; | 50 const size_t kReadBufferSize = 4096; |
54 const size_t kMaxUnusedReadBufferCapacity = 4096; | 51 const size_t kMaxUnusedReadBufferCapacity = 4096; |
55 const size_t kMaxChannelMessageSize = 256 * 1024 * 1024; | 52 const size_t kMaxChannelMessageSize = 256 * 1024 * 1024; |
56 const size_t kMaxAttachedHandles = 128; | 53 const size_t kMaxAttachedHandles = 128; |
57 | 54 |
58 Channel::Message::Message(size_t payload_size, size_t max_handles) | 55 Channel::Message::Message(size_t payload_size, size_t max_handles) |
59 : Message(payload_size, | 56 #if defined(MOJO_EDK_LEGACY_PROTOCOL) |
60 max_handles, | 57 : Message(payload_size, max_handles, MessageType::NORMAL_LEGACY) { |
61 g_use_legacy_protocol ? MessageType::NORMAL_LEGACY | 58 } |
62 : MessageType::NORMAL) {} | 59 #else |
| 60 : Message(payload_size, max_handles, MessageType::NORMAL) { |
| 61 } |
| 62 #endif |
63 | 63 |
64 Channel::Message::Message(size_t payload_size, | 64 Channel::Message::Message(size_t payload_size, |
65 size_t max_handles, | 65 size_t max_handles, |
66 MessageType message_type) | 66 MessageType message_type) |
67 : max_handles_(max_handles) { | 67 : max_handles_(max_handles) { |
68 DCHECK_LE(max_handles_, kMaxAttachedHandles); | 68 DCHECK_LE(max_handles_, kMaxAttachedHandles); |
69 | 69 |
70 const bool is_legacy_message = (message_type == MessageType::NORMAL_LEGACY); | 70 const bool is_legacy_message = (message_type == MessageType::NORMAL_LEGACY); |
71 size_t extra_header_size = 0; | 71 size_t extra_header_size = 0; |
72 #if defined(OS_WIN) | 72 #if defined(OS_WIN) |
(...skipping 315 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
388 ++it; | 388 ++it; |
389 } | 389 } |
390 } | 390 } |
391 } | 391 } |
392 return std::move(handle_vector_); | 392 return std::move(handle_vector_); |
393 #else | 393 #else |
394 return std::move(handle_vector_); | 394 return std::move(handle_vector_); |
395 #endif | 395 #endif |
396 } | 396 } |
397 | 397 |
398 // static | |
399 void Channel::Message::SetUseLegacyTransportProtocol(bool use_legacy_protocol) { | |
400 // Make sure this is called before mojo::edk::Init() is called. | |
401 DCHECK(!internal::g_core); | |
402 g_use_legacy_protocol = use_legacy_protocol; | |
403 } | |
404 | |
405 #if defined(OS_WIN) | 398 #if defined(OS_WIN) |
406 // static | 399 // static |
407 bool Channel::Message::RewriteHandles(base::ProcessHandle from_process, | 400 bool Channel::Message::RewriteHandles(base::ProcessHandle from_process, |
408 base::ProcessHandle to_process, | 401 base::ProcessHandle to_process, |
409 PlatformHandleVector* handles) { | 402 PlatformHandleVector* handles) { |
410 bool success = true; | 403 bool success = true; |
411 for (size_t i = 0; i < handles->size(); ++i) { | 404 for (size_t i = 0; i < handles->size(); ++i) { |
412 if (!(*handles)[i].is_valid()) { | 405 if (!(*handles)[i].is_valid()) { |
413 DLOG(ERROR) << "Refusing to duplicate invalid handle."; | 406 DLOG(ERROR) << "Refusing to duplicate invalid handle."; |
414 continue; | 407 continue; |
(...skipping 266 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
681 | 674 |
682 bool Channel::OnControlMessage(Message::MessageType message_type, | 675 bool Channel::OnControlMessage(Message::MessageType message_type, |
683 const void* payload, | 676 const void* payload, |
684 size_t payload_size, | 677 size_t payload_size, |
685 ScopedPlatformHandleVectorPtr handles) { | 678 ScopedPlatformHandleVectorPtr handles) { |
686 return false; | 679 return false; |
687 } | 680 } |
688 | 681 |
689 } // namespace edk | 682 } // namespace edk |
690 } // namespace mojo | 683 } // namespace mojo |
OLD | NEW |