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 // This file provides a C++ wrapping around the Mojo C API for message pipes, | 5 // This file provides a C++ wrapping around the Mojo C API for message pipes, |
6 // replacing the prefix of "Mojo" with a "mojo" namespace, and using more | 6 // replacing the prefix of "Mojo" with a "mojo" namespace, and using more |
7 // strongly-typed representations of |MojoHandle|s. | 7 // strongly-typed representations of |MojoHandle|s. |
8 // | 8 // |
9 // Please see "mojo/public/c/system/message_pipe.h" for complete documentation | 9 // Please see "mojo/public/c/system/message_pipe.h" for complete documentation |
10 // of the API. | 10 // of the API. |
11 | 11 |
12 #ifndef MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_PIPE_H_ | 12 #ifndef MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_PIPE_H_ |
13 #define MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_PIPE_H_ | 13 #define MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_PIPE_H_ |
14 | 14 |
15 #include <assert.h> | |
16 #include <stdint.h> | 15 #include <stdint.h> |
17 | 16 |
18 #include "base/compiler_specific.h" | 17 #include "base/compiler_specific.h" |
| 18 #include "base/logging.h" |
19 #include "mojo/public/c/system/message_pipe.h" | 19 #include "mojo/public/c/system/message_pipe.h" |
20 #include "mojo/public/cpp/system/handle.h" | 20 #include "mojo/public/cpp/system/handle.h" |
21 #include "mojo/public/cpp/system/macros.h" | 21 #include "mojo/public/cpp/system/macros.h" |
22 | 22 |
23 namespace mojo { | 23 namespace mojo { |
24 | 24 |
25 // A strongly-typed representation of a |MojoHandle| to one end of a message | 25 // A strongly-typed representation of a |MojoHandle| to one end of a message |
26 // pipe. | 26 // pipe. |
27 class MessagePipeHandle : public Handle { | 27 class MessagePipeHandle : public Handle { |
28 public: | 28 public: |
29 MessagePipeHandle() {} | 29 MessagePipeHandle() {} |
30 explicit MessagePipeHandle(MojoHandle value) : Handle(value) {} | 30 explicit MessagePipeHandle(MojoHandle value) : Handle(value) {} |
31 | 31 |
32 // Copying and assignment allowed. | 32 // Copying and assignment allowed. |
33 }; | 33 }; |
34 | 34 |
35 static_assert(sizeof(MessagePipeHandle) == sizeof(Handle), | 35 static_assert(sizeof(MessagePipeHandle) == sizeof(Handle), |
36 "Bad size for C++ MessagePipeHandle"); | 36 "Bad size for C++ MessagePipeHandle"); |
37 | 37 |
38 typedef ScopedHandleBase<MessagePipeHandle> ScopedMessagePipeHandle; | 38 typedef ScopedHandleBase<MessagePipeHandle> ScopedMessagePipeHandle; |
39 static_assert(sizeof(ScopedMessagePipeHandle) == sizeof(MessagePipeHandle), | 39 static_assert(sizeof(ScopedMessagePipeHandle) == sizeof(MessagePipeHandle), |
40 "Bad size for C++ ScopedMessagePipeHandle"); | 40 "Bad size for C++ ScopedMessagePipeHandle"); |
41 | 41 |
42 // Creates a message pipe. See |MojoCreateMessagePipe()| for complete | 42 // Creates a message pipe. See |MojoCreateMessagePipe()| for complete |
43 // documentation. | 43 // documentation. |
44 inline MojoResult CreateMessagePipe(const MojoCreateMessagePipeOptions* options, | 44 inline MojoResult CreateMessagePipe(const MojoCreateMessagePipeOptions* options, |
45 ScopedMessagePipeHandle* message_pipe0, | 45 ScopedMessagePipeHandle* message_pipe0, |
46 ScopedMessagePipeHandle* message_pipe1) { | 46 ScopedMessagePipeHandle* message_pipe1) { |
47 assert(message_pipe0); | 47 DCHECK(message_pipe0); |
48 assert(message_pipe1); | 48 DCHECK(message_pipe1); |
49 MessagePipeHandle handle0; | 49 MessagePipeHandle handle0; |
50 MessagePipeHandle handle1; | 50 MessagePipeHandle handle1; |
51 MojoResult rv = MojoCreateMessagePipe( | 51 MojoResult rv = MojoCreateMessagePipe( |
52 options, handle0.mutable_value(), handle1.mutable_value()); | 52 options, handle0.mutable_value(), handle1.mutable_value()); |
53 // Reset even on failure (reduces the chances that a "stale"/incorrect handle | 53 // Reset even on failure (reduces the chances that a "stale"/incorrect handle |
54 // will be used). | 54 // will be used). |
55 message_pipe0->reset(handle0); | 55 message_pipe0->reset(handle0); |
56 message_pipe1->reset(handle1); | 56 message_pipe1->reset(handle1); |
57 return rv; | 57 return rv; |
58 } | 58 } |
(...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
96 MessagePipe(); | 96 MessagePipe(); |
97 explicit MessagePipe(const MojoCreateMessagePipeOptions& options); | 97 explicit MessagePipe(const MojoCreateMessagePipeOptions& options); |
98 ~MessagePipe(); | 98 ~MessagePipe(); |
99 | 99 |
100 ScopedMessagePipeHandle handle0; | 100 ScopedMessagePipeHandle handle0; |
101 ScopedMessagePipeHandle handle1; | 101 ScopedMessagePipeHandle handle1; |
102 }; | 102 }; |
103 | 103 |
104 inline MessagePipe::MessagePipe() { | 104 inline MessagePipe::MessagePipe() { |
105 MojoResult result = CreateMessagePipe(nullptr, &handle0, &handle1); | 105 MojoResult result = CreateMessagePipe(nullptr, &handle0, &handle1); |
106 ALLOW_UNUSED_LOCAL(result); | 106 DCHECK_EQ(MOJO_RESULT_OK, result); |
107 assert(result == MOJO_RESULT_OK); | |
108 } | 107 } |
109 | 108 |
110 inline MessagePipe::MessagePipe(const MojoCreateMessagePipeOptions& options) { | 109 inline MessagePipe::MessagePipe(const MojoCreateMessagePipeOptions& options) { |
111 MojoResult result = CreateMessagePipe(&options, &handle0, &handle1); | 110 MojoResult result = CreateMessagePipe(&options, &handle0, &handle1); |
112 ALLOW_UNUSED_LOCAL(result); | 111 DCHECK_EQ(MOJO_RESULT_OK, result); |
113 assert(result == MOJO_RESULT_OK); | |
114 } | 112 } |
115 | 113 |
116 inline MessagePipe::~MessagePipe() { | 114 inline MessagePipe::~MessagePipe() { |
117 } | 115 } |
118 | 116 |
119 } // namespace mojo | 117 } // namespace mojo |
120 | 118 |
121 #endif // MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_PIPE_H_ | 119 #endif // MOJO_PUBLIC_CPP_SYSTEM_MESSAGE_PIPE_H_ |
OLD | NEW |