OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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/core.h" | 5 #include "mojo/edk/system/core.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <limits> | 9 #include <limits> |
10 | 10 |
(...skipping 24 matching lines...) Expand all Loading... |
35 TEST_F(CoreTest, Basic) { | 35 TEST_F(CoreTest, Basic) { |
36 MockHandleInfo info; | 36 MockHandleInfo info; |
37 | 37 |
38 EXPECT_EQ(0u, info.GetCtorCallCount()); | 38 EXPECT_EQ(0u, info.GetCtorCallCount()); |
39 MojoHandle h = CreateMockHandle(&info); | 39 MojoHandle h = CreateMockHandle(&info); |
40 EXPECT_EQ(1u, info.GetCtorCallCount()); | 40 EXPECT_EQ(1u, info.GetCtorCallCount()); |
41 EXPECT_NE(h, MOJO_HANDLE_INVALID); | 41 EXPECT_NE(h, MOJO_HANDLE_INVALID); |
42 | 42 |
43 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 43 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
44 EXPECT_EQ(MOJO_RESULT_OK, | 44 EXPECT_EQ(MOJO_RESULT_OK, |
45 core()->WriteMessage(h, | 45 core()->WriteMessage(h, NullUserPointer(), 0, NullUserPointer(), 0, |
46 NullUserPointer(), | |
47 0, | |
48 NullUserPointer(), | |
49 0, | |
50 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 46 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
51 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 47 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
52 | 48 |
53 EXPECT_EQ(0u, info.GetReadMessageCallCount()); | 49 EXPECT_EQ(0u, info.GetReadMessageCallCount()); |
54 uint32_t num_bytes = 0; | 50 uint32_t num_bytes = 0; |
55 EXPECT_EQ(MOJO_RESULT_OK, | 51 EXPECT_EQ( |
56 core()->ReadMessage(h, | 52 MOJO_RESULT_OK, |
57 NullUserPointer(), | 53 core()->ReadMessage(h, NullUserPointer(), MakeUserPointer(&num_bytes), |
58 MakeUserPointer(&num_bytes), | 54 NullUserPointer(), NullUserPointer(), |
59 NullUserPointer(), | 55 MOJO_READ_MESSAGE_FLAG_NONE)); |
60 NullUserPointer(), | |
61 MOJO_READ_MESSAGE_FLAG_NONE)); | |
62 EXPECT_EQ(1u, info.GetReadMessageCallCount()); | 56 EXPECT_EQ(1u, info.GetReadMessageCallCount()); |
63 EXPECT_EQ(MOJO_RESULT_OK, | 57 EXPECT_EQ(MOJO_RESULT_OK, |
64 core()->ReadMessage(h, | 58 core()->ReadMessage(h, NullUserPointer(), NullUserPointer(), |
65 NullUserPointer(), | 59 NullUserPointer(), NullUserPointer(), |
66 NullUserPointer(), | |
67 NullUserPointer(), | |
68 NullUserPointer(), | |
69 MOJO_READ_MESSAGE_FLAG_NONE)); | 60 MOJO_READ_MESSAGE_FLAG_NONE)); |
70 EXPECT_EQ(2u, info.GetReadMessageCallCount()); | 61 EXPECT_EQ(2u, info.GetReadMessageCallCount()); |
71 | 62 |
72 EXPECT_EQ(0u, info.GetWriteDataCallCount()); | 63 EXPECT_EQ(0u, info.GetWriteDataCallCount()); |
73 EXPECT_EQ( | 64 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, |
74 MOJO_RESULT_UNIMPLEMENTED, | 65 core()->WriteData(h, NullUserPointer(), NullUserPointer(), |
75 core()->WriteData( | 66 MOJO_WRITE_DATA_FLAG_NONE)); |
76 h, NullUserPointer(), NullUserPointer(), MOJO_WRITE_DATA_FLAG_NONE)); | |
77 EXPECT_EQ(1u, info.GetWriteDataCallCount()); | 67 EXPECT_EQ(1u, info.GetWriteDataCallCount()); |
78 | 68 |
79 EXPECT_EQ(0u, info.GetBeginWriteDataCallCount()); | 69 EXPECT_EQ(0u, info.GetBeginWriteDataCallCount()); |
80 EXPECT_EQ( | 70 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, |
81 MOJO_RESULT_UNIMPLEMENTED, | 71 core()->BeginWriteData(h, NullUserPointer(), NullUserPointer(), |
82 core()->BeginWriteData( | 72 MOJO_WRITE_DATA_FLAG_NONE)); |
83 h, NullUserPointer(), NullUserPointer(), MOJO_WRITE_DATA_FLAG_NONE)); | |
84 EXPECT_EQ(1u, info.GetBeginWriteDataCallCount()); | 73 EXPECT_EQ(1u, info.GetBeginWriteDataCallCount()); |
85 | 74 |
86 EXPECT_EQ(0u, info.GetEndWriteDataCallCount()); | 75 EXPECT_EQ(0u, info.GetEndWriteDataCallCount()); |
87 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndWriteData(h, 0)); | 76 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndWriteData(h, 0)); |
88 EXPECT_EQ(1u, info.GetEndWriteDataCallCount()); | 77 EXPECT_EQ(1u, info.GetEndWriteDataCallCount()); |
89 | 78 |
90 EXPECT_EQ(0u, info.GetReadDataCallCount()); | 79 EXPECT_EQ(0u, info.GetReadDataCallCount()); |
91 EXPECT_EQ( | 80 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, |
92 MOJO_RESULT_UNIMPLEMENTED, | 81 core()->ReadData(h, NullUserPointer(), NullUserPointer(), |
93 core()->ReadData( | 82 MOJO_READ_DATA_FLAG_NONE)); |
94 h, NullUserPointer(), NullUserPointer(), MOJO_READ_DATA_FLAG_NONE)); | |
95 EXPECT_EQ(1u, info.GetReadDataCallCount()); | 83 EXPECT_EQ(1u, info.GetReadDataCallCount()); |
96 | 84 |
97 EXPECT_EQ(0u, info.GetBeginReadDataCallCount()); | 85 EXPECT_EQ(0u, info.GetBeginReadDataCallCount()); |
98 EXPECT_EQ( | 86 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, |
99 MOJO_RESULT_UNIMPLEMENTED, | 87 core()->BeginReadData(h, NullUserPointer(), NullUserPointer(), |
100 core()->BeginReadData( | 88 MOJO_READ_DATA_FLAG_NONE)); |
101 h, NullUserPointer(), NullUserPointer(), MOJO_READ_DATA_FLAG_NONE)); | |
102 EXPECT_EQ(1u, info.GetBeginReadDataCallCount()); | 89 EXPECT_EQ(1u, info.GetBeginReadDataCallCount()); |
103 | 90 |
104 EXPECT_EQ(0u, info.GetEndReadDataCallCount()); | 91 EXPECT_EQ(0u, info.GetEndReadDataCallCount()); |
105 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndReadData(h, 0)); | 92 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, core()->EndReadData(h, 0)); |
106 EXPECT_EQ(1u, info.GetEndReadDataCallCount()); | 93 EXPECT_EQ(1u, info.GetEndReadDataCallCount()); |
107 | 94 |
108 EXPECT_EQ(0u, info.GetAddWaiterCallCount()); | 95 EXPECT_EQ(0u, info.GetAddWaiterCallCount()); |
109 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 96 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
110 core()->Wait(h, | 97 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, MOJO_DEADLINE_INDEFINITE, |
111 ~MOJO_HANDLE_SIGNAL_NONE, | |
112 MOJO_DEADLINE_INDEFINITE, | |
113 NullUserPointer())); | 98 NullUserPointer())); |
114 EXPECT_EQ(1u, info.GetAddWaiterCallCount()); | 99 EXPECT_EQ(1u, info.GetAddWaiterCallCount()); |
115 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 100 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
116 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 0, NullUserPointer())); | 101 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 0, NullUserPointer())); |
117 EXPECT_EQ(2u, info.GetAddWaiterCallCount()); | 102 EXPECT_EQ(2u, info.GetAddWaiterCallCount()); |
118 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; | 103 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; |
119 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 104 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
120 core()->Wait(h, | 105 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, MOJO_DEADLINE_INDEFINITE, |
121 ~MOJO_HANDLE_SIGNAL_NONE, | |
122 MOJO_DEADLINE_INDEFINITE, | |
123 MakeUserPointer(&hss))); | 106 MakeUserPointer(&hss))); |
124 EXPECT_EQ(3u, info.GetAddWaiterCallCount()); | 107 EXPECT_EQ(3u, info.GetAddWaiterCallCount()); |
125 EXPECT_EQ(0u, hss.satisfied_signals); | 108 EXPECT_EQ(0u, hss.satisfied_signals); |
126 EXPECT_EQ(0u, hss.satisfiable_signals); | 109 EXPECT_EQ(0u, hss.satisfiable_signals); |
127 EXPECT_EQ( | 110 EXPECT_EQ( |
128 MOJO_RESULT_FAILED_PRECONDITION, | 111 MOJO_RESULT_FAILED_PRECONDITION, |
129 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, NullUserPointer())); | 112 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, NullUserPointer())); |
130 EXPECT_EQ(4u, info.GetAddWaiterCallCount()); | 113 EXPECT_EQ(4u, info.GetAddWaiterCallCount()); |
131 hss = kFullMojoHandleSignalsState; | 114 hss = kFullMojoHandleSignalsState; |
132 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 115 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
133 core()->Wait( | 116 core()->Wait(h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, |
134 h, ~MOJO_HANDLE_SIGNAL_NONE, 10 * 1000, MakeUserPointer(&hss))); | 117 MakeUserPointer(&hss))); |
135 EXPECT_EQ(5u, info.GetAddWaiterCallCount()); | 118 EXPECT_EQ(5u, info.GetAddWaiterCallCount()); |
136 EXPECT_EQ(0u, hss.satisfied_signals); | 119 EXPECT_EQ(0u, hss.satisfied_signals); |
137 EXPECT_EQ(0u, hss.satisfiable_signals); | 120 EXPECT_EQ(0u, hss.satisfiable_signals); |
138 | 121 |
139 MojoHandleSignals handle_signals = ~MOJO_HANDLE_SIGNAL_NONE; | 122 MojoHandleSignals handle_signals = ~MOJO_HANDLE_SIGNAL_NONE; |
140 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 123 EXPECT_EQ( |
141 core()->WaitMany(MakeUserPointer(&h), | 124 MOJO_RESULT_FAILED_PRECONDITION, |
142 MakeUserPointer(&handle_signals), | 125 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, |
143 1, | 126 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
144 MOJO_DEADLINE_INDEFINITE, | 127 NullUserPointer())); |
145 NullUserPointer(), | |
146 NullUserPointer())); | |
147 EXPECT_EQ(6u, info.GetAddWaiterCallCount()); | 128 EXPECT_EQ(6u, info.GetAddWaiterCallCount()); |
148 uint32_t result_index = static_cast<uint32_t>(-1); | 129 uint32_t result_index = static_cast<uint32_t>(-1); |
149 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 130 EXPECT_EQ( |
150 core()->WaitMany(MakeUserPointer(&h), | 131 MOJO_RESULT_FAILED_PRECONDITION, |
151 MakeUserPointer(&handle_signals), | 132 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, |
152 1, | 133 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
153 MOJO_DEADLINE_INDEFINITE, | 134 NullUserPointer())); |
154 MakeUserPointer(&result_index), | |
155 NullUserPointer())); | |
156 EXPECT_EQ(7u, info.GetAddWaiterCallCount()); | 135 EXPECT_EQ(7u, info.GetAddWaiterCallCount()); |
157 EXPECT_EQ(0u, result_index); | 136 EXPECT_EQ(0u, result_index); |
158 hss = kFullMojoHandleSignalsState; | 137 hss = kFullMojoHandleSignalsState; |
159 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 138 EXPECT_EQ( |
160 core()->WaitMany(MakeUserPointer(&h), | 139 MOJO_RESULT_FAILED_PRECONDITION, |
161 MakeUserPointer(&handle_signals), | 140 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, |
162 1, | 141 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
163 MOJO_DEADLINE_INDEFINITE, | 142 MakeUserPointer(&hss))); |
164 NullUserPointer(), | |
165 MakeUserPointer(&hss))); | |
166 EXPECT_EQ(8u, info.GetAddWaiterCallCount()); | 143 EXPECT_EQ(8u, info.GetAddWaiterCallCount()); |
167 EXPECT_EQ(0u, hss.satisfied_signals); | 144 EXPECT_EQ(0u, hss.satisfied_signals); |
168 EXPECT_EQ(0u, hss.satisfiable_signals); | 145 EXPECT_EQ(0u, hss.satisfiable_signals); |
169 result_index = static_cast<uint32_t>(-1); | 146 result_index = static_cast<uint32_t>(-1); |
170 hss = kFullMojoHandleSignalsState; | 147 hss = kFullMojoHandleSignalsState; |
171 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 148 EXPECT_EQ( |
172 core()->WaitMany(MakeUserPointer(&h), | 149 MOJO_RESULT_FAILED_PRECONDITION, |
173 MakeUserPointer(&handle_signals), | 150 core()->WaitMany(MakeUserPointer(&h), MakeUserPointer(&handle_signals), 1, |
174 1, | 151 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
175 MOJO_DEADLINE_INDEFINITE, | 152 MakeUserPointer(&hss))); |
176 MakeUserPointer(&result_index), | |
177 MakeUserPointer(&hss))); | |
178 EXPECT_EQ(9u, info.GetAddWaiterCallCount()); | 153 EXPECT_EQ(9u, info.GetAddWaiterCallCount()); |
179 EXPECT_EQ(0u, result_index); | 154 EXPECT_EQ(0u, result_index); |
180 EXPECT_EQ(0u, hss.satisfied_signals); | 155 EXPECT_EQ(0u, hss.satisfied_signals); |
181 EXPECT_EQ(0u, hss.satisfiable_signals); | 156 EXPECT_EQ(0u, hss.satisfiable_signals); |
182 | 157 |
183 EXPECT_EQ(0u, info.GetDtorCallCount()); | 158 EXPECT_EQ(0u, info.GetDtorCallCount()); |
184 EXPECT_EQ(0u, info.GetCloseCallCount()); | 159 EXPECT_EQ(0u, info.GetCloseCallCount()); |
185 EXPECT_EQ(0u, info.GetCancelAllWaitersCallCount()); | 160 EXPECT_EQ(0u, info.GetCancelAllWaitersCallCount()); |
186 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 161 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
187 EXPECT_EQ(1u, info.GetCancelAllWaitersCallCount()); | 162 EXPECT_EQ(1u, info.GetCancelAllWaitersCallCount()); |
(...skipping 16 matching lines...) Expand all Loading... |
204 MojoHandle h = CreateMockHandle(&info); | 179 MojoHandle h = CreateMockHandle(&info); |
205 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 180 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
206 EXPECT_EQ(1u, info.GetCloseCallCount()); | 181 EXPECT_EQ(1u, info.GetCloseCallCount()); |
207 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h)); | 182 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h)); |
208 EXPECT_EQ(1u, info.GetCloseCallCount()); | 183 EXPECT_EQ(1u, info.GetCloseCallCount()); |
209 } | 184 } |
210 | 185 |
211 // |Wait()|: | 186 // |Wait()|: |
212 { | 187 { |
213 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 188 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
214 core()->Wait(MOJO_HANDLE_INVALID, | 189 core()->Wait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, |
215 ~MOJO_HANDLE_SIGNAL_NONE, | 190 MOJO_DEADLINE_INDEFINITE, NullUserPointer())); |
216 MOJO_DEADLINE_INDEFINITE, | |
217 NullUserPointer())); | |
218 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 191 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
219 core()->Wait(10, | 192 core()->Wait(10, ~MOJO_HANDLE_SIGNAL_NONE, |
220 ~MOJO_HANDLE_SIGNAL_NONE, | 193 MOJO_DEADLINE_INDEFINITE, NullUserPointer())); |
221 MOJO_DEADLINE_INDEFINITE, | |
222 NullUserPointer())); | |
223 | 194 |
224 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; | 195 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; |
225 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 196 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
226 core()->Wait(MOJO_HANDLE_INVALID, | 197 core()->Wait(MOJO_HANDLE_INVALID, ~MOJO_HANDLE_SIGNAL_NONE, |
227 ~MOJO_HANDLE_SIGNAL_NONE, | 198 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&hss))); |
228 MOJO_DEADLINE_INDEFINITE, | |
229 MakeUserPointer(&hss))); | |
230 // On invalid argument, it shouldn't modify the handle signals state. | 199 // On invalid argument, it shouldn't modify the handle signals state. |
231 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 200 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
232 hss.satisfied_signals); | 201 hss.satisfied_signals); |
233 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 202 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
234 hss.satisfiable_signals); | 203 hss.satisfiable_signals); |
235 hss = kFullMojoHandleSignalsState; | 204 hss = kFullMojoHandleSignalsState; |
236 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 205 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
237 core()->Wait(10, | 206 core()->Wait(10, ~MOJO_HANDLE_SIGNAL_NONE, |
238 ~MOJO_HANDLE_SIGNAL_NONE, | 207 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&hss))); |
239 MOJO_DEADLINE_INDEFINITE, | |
240 MakeUserPointer(&hss))); | |
241 // On invalid argument, it shouldn't modify the handle signals state. | 208 // On invalid argument, it shouldn't modify the handle signals state. |
242 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 209 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
243 hss.satisfied_signals); | 210 hss.satisfied_signals); |
244 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 211 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
245 hss.satisfiable_signals); | 212 hss.satisfiable_signals); |
246 } | 213 } |
247 | 214 |
248 // |WaitMany()|: | 215 // |WaitMany()|: |
249 { | 216 { |
250 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; | 217 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; |
251 MojoHandleSignals signals[2] = {~MOJO_HANDLE_SIGNAL_NONE, | 218 MojoHandleSignals signals[2] = {~MOJO_HANDLE_SIGNAL_NONE, |
252 ~MOJO_HANDLE_SIGNAL_NONE}; | 219 ~MOJO_HANDLE_SIGNAL_NONE}; |
| 220 EXPECT_EQ( |
| 221 MOJO_RESULT_INVALID_ARGUMENT, |
| 222 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 0, |
| 223 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
| 224 NullUserPointer())); |
253 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 225 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
254 core()->WaitMany(MakeUserPointer(handles), | 226 core()->WaitMany(NullUserPointer(), MakeUserPointer(signals), 0, |
255 MakeUserPointer(signals), | 227 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
256 0, | |
257 MOJO_DEADLINE_INDEFINITE, | |
258 NullUserPointer(), | |
259 NullUserPointer())); | |
260 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | |
261 core()->WaitMany(NullUserPointer(), | |
262 MakeUserPointer(signals), | |
263 0, | |
264 MOJO_DEADLINE_INDEFINITE, | |
265 NullUserPointer(), | |
266 NullUserPointer())); | 228 NullUserPointer())); |
267 // If |num_handles| is invalid, it should leave |result_index| and | 229 // If |num_handles| is invalid, it should leave |result_index| and |
268 // |signals_states| alone. | 230 // |signals_states| alone. |
269 // (We use -1 internally; make sure that doesn't leak.) | 231 // (We use -1 internally; make sure that doesn't leak.) |
270 uint32_t result_index = 123; | 232 uint32_t result_index = 123; |
271 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; | 233 MojoHandleSignalsState hss = kFullMojoHandleSignalsState; |
272 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 234 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
273 core()->WaitMany(NullUserPointer(), | 235 core()->WaitMany(NullUserPointer(), MakeUserPointer(signals), 0, |
274 MakeUserPointer(signals), | |
275 0, | |
276 MOJO_DEADLINE_INDEFINITE, | 236 MOJO_DEADLINE_INDEFINITE, |
277 MakeUserPointer(&result_index), | 237 MakeUserPointer(&result_index), |
278 MakeUserPointer(&hss))); | 238 MakeUserPointer(&hss))); |
279 EXPECT_EQ(123u, result_index); | 239 EXPECT_EQ(123u, result_index); |
280 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 240 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
281 hss.satisfied_signals); | 241 hss.satisfied_signals); |
282 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 242 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
283 hss.satisfiable_signals); | 243 hss.satisfiable_signals); |
284 | 244 |
285 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 245 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
286 core()->WaitMany(MakeUserPointer(handles), | 246 core()->WaitMany(MakeUserPointer(handles), NullUserPointer(), 0, |
287 NullUserPointer(), | 247 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
288 0, | |
289 MOJO_DEADLINE_INDEFINITE, | |
290 NullUserPointer(), | |
291 NullUserPointer())); | 248 NullUserPointer())); |
292 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 249 EXPECT_EQ( |
293 core()->WaitMany(MakeUserPointer(handles), | 250 MOJO_RESULT_INVALID_ARGUMENT, |
294 MakeUserPointer(signals), | 251 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 1, |
295 1, | 252 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
296 MOJO_DEADLINE_INDEFINITE, | 253 NullUserPointer())); |
297 NullUserPointer(), | |
298 NullUserPointer())); | |
299 // But if a handle is bad, then it should set |result_index| but still leave | 254 // But if a handle is bad, then it should set |result_index| but still leave |
300 // |signals_states| alone. | 255 // |signals_states| alone. |
301 result_index = static_cast<uint32_t>(-1); | 256 result_index = static_cast<uint32_t>(-1); |
302 hss = kFullMojoHandleSignalsState; | 257 hss = kFullMojoHandleSignalsState; |
303 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 258 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
304 core()->WaitMany(MakeUserPointer(handles), | 259 core()->WaitMany( |
305 MakeUserPointer(signals), | 260 MakeUserPointer(handles), MakeUserPointer(signals), 1, |
306 1, | 261 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
307 MOJO_DEADLINE_INDEFINITE, | 262 MakeUserPointer(&hss))); |
308 MakeUserPointer(&result_index), | |
309 MakeUserPointer(&hss))); | |
310 EXPECT_EQ(0u, result_index); | 263 EXPECT_EQ(0u, result_index); |
311 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 264 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
312 hss.satisfied_signals); | 265 hss.satisfied_signals); |
313 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 266 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
314 hss.satisfiable_signals); | 267 hss.satisfiable_signals); |
315 | 268 |
316 MockHandleInfo info[2]; | 269 MockHandleInfo info[2]; |
317 handles[0] = CreateMockHandle(&info[0]); | 270 handles[0] = CreateMockHandle(&info[0]); |
318 | 271 |
319 result_index = static_cast<uint32_t>(-1); | 272 result_index = static_cast<uint32_t>(-1); |
320 hss = kFullMojoHandleSignalsState; | 273 hss = kFullMojoHandleSignalsState; |
321 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 274 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
322 core()->WaitMany(MakeUserPointer(handles), | 275 core()->WaitMany( |
323 MakeUserPointer(signals), | 276 MakeUserPointer(handles), MakeUserPointer(signals), 1, |
324 1, | 277 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
325 MOJO_DEADLINE_INDEFINITE, | 278 MakeUserPointer(&hss))); |
326 MakeUserPointer(&result_index), | |
327 MakeUserPointer(&hss))); | |
328 EXPECT_EQ(0u, result_index); | 279 EXPECT_EQ(0u, result_index); |
329 EXPECT_EQ(0u, hss.satisfied_signals); | 280 EXPECT_EQ(0u, hss.satisfied_signals); |
330 EXPECT_EQ(0u, hss.satisfiable_signals); | 281 EXPECT_EQ(0u, hss.satisfiable_signals); |
331 | 282 |
332 // On invalid argument, it'll leave |signals_states| alone. | 283 // On invalid argument, it'll leave |signals_states| alone. |
333 result_index = static_cast<uint32_t>(-1); | 284 result_index = static_cast<uint32_t>(-1); |
334 hss = kFullMojoHandleSignalsState; | 285 hss = kFullMojoHandleSignalsState; |
335 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 286 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
336 core()->WaitMany(MakeUserPointer(handles), | 287 core()->WaitMany( |
337 MakeUserPointer(signals), | 288 MakeUserPointer(handles), MakeUserPointer(signals), 2, |
338 2, | 289 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
339 MOJO_DEADLINE_INDEFINITE, | 290 MakeUserPointer(&hss))); |
340 MakeUserPointer(&result_index), | |
341 MakeUserPointer(&hss))); | |
342 EXPECT_EQ(1u, result_index); | 291 EXPECT_EQ(1u, result_index); |
343 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, | 292 EXPECT_EQ(kFullMojoHandleSignalsState.satisfied_signals, |
344 hss.satisfied_signals); | 293 hss.satisfied_signals); |
345 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, | 294 EXPECT_EQ(kFullMojoHandleSignalsState.satisfiable_signals, |
346 hss.satisfiable_signals); | 295 hss.satisfiable_signals); |
347 handles[1] = handles[0] + 1; // Invalid handle. | 296 handles[1] = handles[0] + 1; // Invalid handle. |
348 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 297 EXPECT_EQ( |
349 core()->WaitMany(MakeUserPointer(handles), | 298 MOJO_RESULT_INVALID_ARGUMENT, |
350 MakeUserPointer(signals), | 299 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 2, |
351 2, | 300 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
352 MOJO_DEADLINE_INDEFINITE, | 301 NullUserPointer())); |
353 NullUserPointer(), | |
354 NullUserPointer())); | |
355 handles[1] = CreateMockHandle(&info[1]); | 302 handles[1] = CreateMockHandle(&info[1]); |
356 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 303 EXPECT_EQ( |
357 core()->WaitMany(MakeUserPointer(handles), | 304 MOJO_RESULT_FAILED_PRECONDITION, |
358 MakeUserPointer(signals), | 305 core()->WaitMany(MakeUserPointer(handles), MakeUserPointer(signals), 2, |
359 2, | 306 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
360 MOJO_DEADLINE_INDEFINITE, | 307 NullUserPointer())); |
361 NullUserPointer(), | |
362 NullUserPointer())); | |
363 | 308 |
364 // TODO(vtl): Test one where we get "failed precondition" only for the | 309 // TODO(vtl): Test one where we get "failed precondition" only for the |
365 // second handle (and the first one is valid to wait on). | 310 // second handle (and the first one is valid to wait on). |
366 | 311 |
367 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[0])); | 312 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[0])); |
368 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[1])); | 313 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(handles[1])); |
369 } | 314 } |
370 | 315 |
371 // |CreateMessagePipe()|: Nothing to check (apart from things that cause | 316 // |CreateMessagePipe()|: Nothing to check (apart from things that cause |
372 // death). | 317 // death). |
373 | 318 |
374 // |WriteMessage()|: | 319 // |WriteMessage()|: |
375 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 320 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
376 // |num_handles|. | 321 // |num_handles|. |
377 { | 322 { |
378 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 323 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
379 core()->WriteMessage(MOJO_HANDLE_INVALID, | 324 core()->WriteMessage(MOJO_HANDLE_INVALID, NullUserPointer(), 0, |
380 NullUserPointer(), | 325 NullUserPointer(), 0, |
381 0, | |
382 NullUserPointer(), | |
383 0, | |
384 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 326 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
385 | 327 |
386 MockHandleInfo info; | 328 MockHandleInfo info; |
387 MojoHandle h = CreateMockHandle(&info); | 329 MojoHandle h = CreateMockHandle(&info); |
388 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; | 330 MojoHandle handles[2] = {MOJO_HANDLE_INVALID, MOJO_HANDLE_INVALID}; |
389 | 331 |
390 // Huge handle count (implausibly big on some systems -- more than can be | 332 // Huge handle count (implausibly big on some systems -- more than can be |
391 // stored in a 32-bit address space). | 333 // stored in a 32-bit address space). |
392 // Note: This may return either |MOJO_RESULT_INVALID_ARGUMENT| or | 334 // Note: This may return either |MOJO_RESULT_INVALID_ARGUMENT| or |
393 // |MOJO_RESULT_RESOURCE_EXHAUSTED|, depending on whether it's plausible or | 335 // |MOJO_RESULT_RESOURCE_EXHAUSTED|, depending on whether it's plausible or |
394 // not. | 336 // not. |
395 EXPECT_NE(MOJO_RESULT_OK, | 337 EXPECT_NE( |
396 core()->WriteMessage(h, | 338 MOJO_RESULT_OK, |
397 NullUserPointer(), | 339 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
398 0, | 340 std::numeric_limits<uint32_t>::max(), |
399 MakeUserPointer(handles), | 341 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
400 std::numeric_limits<uint32_t>::max(), | |
401 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
402 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 342 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
403 | 343 |
404 // Huge handle count (plausibly big). | 344 // Huge handle count (plausibly big). |
405 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, | 345 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, |
406 core()->WriteMessage( | 346 core()->WriteMessage( |
407 h, | 347 h, NullUserPointer(), 0, MakeUserPointer(handles), |
408 NullUserPointer(), | |
409 0, | |
410 MakeUserPointer(handles), | |
411 std::numeric_limits<uint32_t>::max() / sizeof(handles[0]), | 348 std::numeric_limits<uint32_t>::max() / sizeof(handles[0]), |
412 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 349 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
413 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 350 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
414 | 351 |
415 // Invalid handle in |handles|. | 352 // Invalid handle in |handles|. |
416 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 353 EXPECT_EQ( |
417 core()->WriteMessage(h, | 354 MOJO_RESULT_INVALID_ARGUMENT, |
418 NullUserPointer(), | 355 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
419 0, | 356 1, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
420 MakeUserPointer(handles), | |
421 1, | |
422 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
423 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 357 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
424 | 358 |
425 // Two invalid handles in |handles|. | 359 // Two invalid handles in |handles|. |
426 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 360 EXPECT_EQ( |
427 core()->WriteMessage(h, | 361 MOJO_RESULT_INVALID_ARGUMENT, |
428 NullUserPointer(), | 362 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
429 0, | 363 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
430 MakeUserPointer(handles), | |
431 2, | |
432 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
433 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 364 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
434 | 365 |
435 // Can't send a handle over itself. | 366 // Can't send a handle over itself. |
436 handles[0] = h; | 367 handles[0] = h; |
437 EXPECT_EQ(MOJO_RESULT_BUSY, | 368 EXPECT_EQ( |
438 core()->WriteMessage(h, | 369 MOJO_RESULT_BUSY, |
439 NullUserPointer(), | 370 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
440 0, | 371 1, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
441 MakeUserPointer(handles), | |
442 1, | |
443 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
444 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); | 372 EXPECT_EQ(0u, info.GetWriteMessageCallCount()); |
445 | 373 |
446 MockHandleInfo info2; | 374 MockHandleInfo info2; |
447 MojoHandle h2 = CreateMockHandle(&info2); | 375 MojoHandle h2 = CreateMockHandle(&info2); |
448 | 376 |
449 // This is "okay", but |MockDispatcher| doesn't implement it. | 377 // This is "okay", but |MockDispatcher| doesn't implement it. |
450 handles[0] = h2; | 378 handles[0] = h2; |
451 EXPECT_EQ(MOJO_RESULT_UNIMPLEMENTED, | 379 EXPECT_EQ( |
452 core()->WriteMessage(h, | 380 MOJO_RESULT_UNIMPLEMENTED, |
453 NullUserPointer(), | 381 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
454 0, | 382 1, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
455 MakeUserPointer(handles), | |
456 1, | |
457 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
458 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 383 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
459 | 384 |
460 // One of the |handles| is still invalid. | 385 // One of the |handles| is still invalid. |
461 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 386 EXPECT_EQ( |
462 core()->WriteMessage(h, | 387 MOJO_RESULT_INVALID_ARGUMENT, |
463 NullUserPointer(), | 388 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
464 0, | 389 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
465 MakeUserPointer(handles), | |
466 2, | |
467 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
468 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 390 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
469 | 391 |
470 // One of the |handles| is the same as |handle|. | 392 // One of the |handles| is the same as |handle|. |
471 handles[1] = h; | 393 handles[1] = h; |
472 EXPECT_EQ(MOJO_RESULT_BUSY, | 394 EXPECT_EQ( |
473 core()->WriteMessage(h, | 395 MOJO_RESULT_BUSY, |
474 NullUserPointer(), | 396 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
475 0, | 397 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
476 MakeUserPointer(handles), | |
477 2, | |
478 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
479 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 398 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
480 | 399 |
481 // Can't send a handle twice in the same message. | 400 // Can't send a handle twice in the same message. |
482 handles[1] = h2; | 401 handles[1] = h2; |
483 EXPECT_EQ(MOJO_RESULT_BUSY, | 402 EXPECT_EQ( |
484 core()->WriteMessage(h, | 403 MOJO_RESULT_BUSY, |
485 NullUserPointer(), | 404 core()->WriteMessage(h, NullUserPointer(), 0, MakeUserPointer(handles), |
486 0, | 405 2, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
487 MakeUserPointer(handles), | |
488 2, | |
489 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
490 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); | 406 EXPECT_EQ(1u, info.GetWriteMessageCallCount()); |
491 | 407 |
492 // Note: Since we never successfully sent anything with it, |h2| should | 408 // Note: Since we never successfully sent anything with it, |h2| should |
493 // still be valid. | 409 // still be valid. |
494 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h2)); | 410 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h2)); |
495 | 411 |
496 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 412 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
497 } | 413 } |
498 | 414 |
499 // |ReadMessage()|: | 415 // |ReadMessage()|: |
500 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 416 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
501 // |num_handles|. | 417 // |num_handles|. |
502 { | 418 { |
503 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 419 EXPECT_EQ( |
504 core()->ReadMessage(MOJO_HANDLE_INVALID, | 420 MOJO_RESULT_INVALID_ARGUMENT, |
505 NullUserPointer(), | 421 core()->ReadMessage(MOJO_HANDLE_INVALID, NullUserPointer(), |
506 NullUserPointer(), | 422 NullUserPointer(), NullUserPointer(), |
507 NullUserPointer(), | 423 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); |
508 NullUserPointer(), | |
509 MOJO_READ_MESSAGE_FLAG_NONE)); | |
510 | 424 |
511 MockHandleInfo info; | 425 MockHandleInfo info; |
512 MojoHandle h = CreateMockHandle(&info); | 426 MojoHandle h = CreateMockHandle(&info); |
513 | 427 |
514 // Okay. | 428 // Okay. |
515 uint32_t handle_count = 0; | 429 uint32_t handle_count = 0; |
516 EXPECT_EQ(MOJO_RESULT_OK, | 430 EXPECT_EQ(MOJO_RESULT_OK, |
517 core()->ReadMessage(h, | 431 core()->ReadMessage( |
518 NullUserPointer(), | 432 h, NullUserPointer(), NullUserPointer(), NullUserPointer(), |
519 NullUserPointer(), | 433 MakeUserPointer(&handle_count), MOJO_READ_MESSAGE_FLAG_NONE)); |
520 NullUserPointer(), | |
521 MakeUserPointer(&handle_count), | |
522 MOJO_READ_MESSAGE_FLAG_NONE)); | |
523 // Checked by |Core|, shouldn't go through to the dispatcher. | 434 // Checked by |Core|, shouldn't go through to the dispatcher. |
524 EXPECT_EQ(1u, info.GetReadMessageCallCount()); | 435 EXPECT_EQ(1u, info.GetReadMessageCallCount()); |
525 | 436 |
526 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 437 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
527 } | 438 } |
528 } | 439 } |
529 | 440 |
530 // These test invalid arguments that should cause death if we're being paranoid | 441 // These test invalid arguments that should cause death if we're being paranoid |
531 // about checking arguments (which we would want to do if, e.g., we were in a | 442 // about checking arguments (which we would want to do if, e.g., we were in a |
532 // true "kernel" situation, but we might not want to do otherwise for | 443 // true "kernel" situation, but we might not want to do otherwise for |
533 // performance reasons). Probably blatant errors like passing in null pointers | 444 // performance reasons). Probably blatant errors like passing in null pointers |
534 // (for required pointer arguments) will still cause death, but perhaps not | 445 // (for required pointer arguments) will still cause death, but perhaps not |
535 // predictably. | 446 // predictably. |
536 TEST_F(CoreTest, InvalidArgumentsDeath) { | 447 TEST_F(CoreTest, InvalidArgumentsDeath) { |
537 const char kMemoryCheckFailedRegex[] = "Check failed"; | 448 const char kMemoryCheckFailedRegex[] = "Check failed"; |
538 | 449 |
539 // |WaitMany()|: | 450 // |WaitMany()|: |
540 { | 451 { |
541 MojoHandle handle = MOJO_HANDLE_INVALID; | 452 MojoHandle handle = MOJO_HANDLE_INVALID; |
542 MojoHandleSignals signals = ~MOJO_HANDLE_SIGNAL_NONE; | 453 MojoHandleSignals signals = ~MOJO_HANDLE_SIGNAL_NONE; |
543 EXPECT_DEATH_IF_SUPPORTED(core()->WaitMany(NullUserPointer(), | 454 EXPECT_DEATH_IF_SUPPORTED( |
544 MakeUserPointer(&signals), | 455 core()->WaitMany(NullUserPointer(), MakeUserPointer(&signals), 1, |
545 1, | 456 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
546 MOJO_DEADLINE_INDEFINITE, | 457 NullUserPointer()), |
547 NullUserPointer(), | 458 kMemoryCheckFailedRegex); |
548 NullUserPointer()), | 459 EXPECT_DEATH_IF_SUPPORTED( |
549 kMemoryCheckFailedRegex); | 460 core()->WaitMany(MakeUserPointer(&handle), NullUserPointer(), 1, |
550 EXPECT_DEATH_IF_SUPPORTED(core()->WaitMany(MakeUserPointer(&handle), | 461 MOJO_DEADLINE_INDEFINITE, NullUserPointer(), |
551 NullUserPointer(), | 462 NullUserPointer()), |
552 1, | 463 kMemoryCheckFailedRegex); |
553 MOJO_DEADLINE_INDEFINITE, | |
554 NullUserPointer(), | |
555 NullUserPointer()), | |
556 kMemoryCheckFailedRegex); | |
557 // TODO(vtl): |result_index| and |signals_states| are optional. Test them | 464 // TODO(vtl): |result_index| and |signals_states| are optional. Test them |
558 // with non-null invalid pointers? | 465 // with non-null invalid pointers? |
559 } | 466 } |
560 | 467 |
561 // |CreateMessagePipe()|: | 468 // |CreateMessagePipe()|: |
562 { | 469 { |
563 MojoHandle h; | 470 MojoHandle h; |
564 EXPECT_DEATH_IF_SUPPORTED( | 471 EXPECT_DEATH_IF_SUPPORTED( |
565 core()->CreateMessagePipe( | 472 core()->CreateMessagePipe(NullUserPointer(), NullUserPointer(), |
566 NullUserPointer(), NullUserPointer(), NullUserPointer()), | 473 NullUserPointer()), |
567 kMemoryCheckFailedRegex); | 474 kMemoryCheckFailedRegex); |
568 EXPECT_DEATH_IF_SUPPORTED( | 475 EXPECT_DEATH_IF_SUPPORTED( |
569 core()->CreateMessagePipe( | 476 core()->CreateMessagePipe(NullUserPointer(), MakeUserPointer(&h), |
570 NullUserPointer(), MakeUserPointer(&h), NullUserPointer()), | 477 NullUserPointer()), |
571 kMemoryCheckFailedRegex); | 478 kMemoryCheckFailedRegex); |
572 EXPECT_DEATH_IF_SUPPORTED( | 479 EXPECT_DEATH_IF_SUPPORTED( |
573 core()->CreateMessagePipe( | 480 core()->CreateMessagePipe(NullUserPointer(), NullUserPointer(), |
574 NullUserPointer(), NullUserPointer(), MakeUserPointer(&h)), | 481 MakeUserPointer(&h)), |
575 kMemoryCheckFailedRegex); | 482 kMemoryCheckFailedRegex); |
576 } | 483 } |
577 | 484 |
578 // |WriteMessage()|: | 485 // |WriteMessage()|: |
579 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 486 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
580 // |num_handles|. | 487 // |num_handles|. |
581 { | 488 { |
582 MockHandleInfo info; | 489 MockHandleInfo info; |
583 MojoHandle h = CreateMockHandle(&info); | 490 MojoHandle h = CreateMockHandle(&info); |
584 | 491 |
585 // Null |handles| with nonzero |num_handles|. | 492 // Null |handles| with nonzero |num_handles|. |
586 EXPECT_DEATH_IF_SUPPORTED( | 493 EXPECT_DEATH_IF_SUPPORTED( |
587 core()->WriteMessage(h, | 494 core()->WriteMessage(h, NullUserPointer(), 0, NullUserPointer(), 1, |
588 NullUserPointer(), | |
589 0, | |
590 NullUserPointer(), | |
591 1, | |
592 MOJO_WRITE_MESSAGE_FLAG_NONE), | 495 MOJO_WRITE_MESSAGE_FLAG_NONE), |
593 kMemoryCheckFailedRegex); | 496 kMemoryCheckFailedRegex); |
594 | 497 |
595 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 498 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
596 } | 499 } |
597 | 500 |
598 // |ReadMessage()|: | 501 // |ReadMessage()|: |
599 // Only check arguments checked by |Core|, namely |handle|, |handles|, and | 502 // Only check arguments checked by |Core|, namely |handle|, |handles|, and |
600 // |num_handles|. | 503 // |num_handles|. |
601 { | 504 { |
602 MockHandleInfo info; | 505 MockHandleInfo info; |
603 MojoHandle h = CreateMockHandle(&info); | 506 MojoHandle h = CreateMockHandle(&info); |
604 | 507 |
605 uint32_t handle_count = 1; | 508 uint32_t handle_count = 1; |
606 EXPECT_DEATH_IF_SUPPORTED( | 509 EXPECT_DEATH_IF_SUPPORTED( |
607 core()->ReadMessage(h, | 510 core()->ReadMessage(h, NullUserPointer(), NullUserPointer(), |
608 NullUserPointer(), | 511 NullUserPointer(), MakeUserPointer(&handle_count), |
609 NullUserPointer(), | |
610 NullUserPointer(), | |
611 MakeUserPointer(&handle_count), | |
612 MOJO_READ_MESSAGE_FLAG_NONE), | 512 MOJO_READ_MESSAGE_FLAG_NONE), |
613 kMemoryCheckFailedRegex); | 513 kMemoryCheckFailedRegex); |
614 | 514 |
615 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); | 515 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h)); |
616 } | 516 } |
617 } | 517 } |
618 | 518 |
619 // TODO(vtl): test |Wait()| and |WaitMany()| properly | 519 // TODO(vtl): test |Wait()| and |WaitMany()| properly |
620 // - including |WaitMany()| with the same handle more than once (with | 520 // - including |WaitMany()| with the same handle more than once (with |
621 // same/different signals) | 521 // same/different signals) |
622 | 522 |
623 TEST_F(CoreTest, MessagePipe) { | 523 TEST_F(CoreTest, MessagePipe) { |
624 MojoHandle h[2]; | 524 MojoHandle h[2]; |
625 MojoHandleSignalsState hss[2]; | 525 MojoHandleSignalsState hss[2]; |
626 uint32_t result_index; | 526 uint32_t result_index; |
627 | 527 |
628 EXPECT_EQ( | 528 EXPECT_EQ(MOJO_RESULT_OK, |
629 MOJO_RESULT_OK, | 529 core()->CreateMessagePipe(NullUserPointer(), MakeUserPointer(&h[0]), |
630 core()->CreateMessagePipe( | 530 MakeUserPointer(&h[1]))); |
631 NullUserPointer(), MakeUserPointer(&h[0]), MakeUserPointer(&h[1]))); | |
632 // Should get two distinct, valid handles. | 531 // Should get two distinct, valid handles. |
633 EXPECT_NE(h[0], MOJO_HANDLE_INVALID); | 532 EXPECT_NE(h[0], MOJO_HANDLE_INVALID); |
634 EXPECT_NE(h[1], MOJO_HANDLE_INVALID); | 533 EXPECT_NE(h[1], MOJO_HANDLE_INVALID); |
635 EXPECT_NE(h[0], h[1]); | 534 EXPECT_NE(h[0], h[1]); |
636 | 535 |
637 // Neither should be readable. | 536 // Neither should be readable. |
638 MojoHandleSignals signals[2] = {MOJO_HANDLE_SIGNAL_READABLE, | 537 MojoHandleSignals signals[2] = {MOJO_HANDLE_SIGNAL_READABLE, |
639 MOJO_HANDLE_SIGNAL_READABLE}; | 538 MOJO_HANDLE_SIGNAL_READABLE}; |
640 result_index = static_cast<uint32_t>(-1); | 539 result_index = static_cast<uint32_t>(-1); |
641 hss[0] = kEmptyMojoHandleSignalsState; | 540 hss[0] = kEmptyMojoHandleSignalsState; |
642 hss[1] = kEmptyMojoHandleSignalsState; | 541 hss[1] = kEmptyMojoHandleSignalsState; |
643 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, | 542 EXPECT_EQ( |
644 core()->WaitMany(MakeUserPointer(h), | 543 MOJO_RESULT_DEADLINE_EXCEEDED, |
645 MakeUserPointer(signals), | 544 core()->WaitMany(MakeUserPointer(h), MakeUserPointer(signals), 2, 0, |
646 2, | 545 MakeUserPointer(&result_index), MakeUserPointer(hss))); |
647 0, | |
648 MakeUserPointer(&result_index), | |
649 MakeUserPointer(hss))); | |
650 EXPECT_EQ(static_cast<uint32_t>(-1), result_index); | 546 EXPECT_EQ(static_cast<uint32_t>(-1), result_index); |
651 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 547 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
652 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 548 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
653 hss[0].satisfiable_signals); | 549 hss[0].satisfiable_signals); |
654 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); | 550 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); |
655 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 551 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
656 hss[1].satisfiable_signals); | 552 hss[1].satisfiable_signals); |
657 | 553 |
658 // Try to read anyway. | 554 // Try to read anyway. |
659 char buffer[1] = {'a'}; | 555 char buffer[1] = {'a'}; |
660 uint32_t buffer_size = 1; | 556 uint32_t buffer_size = 1; |
661 EXPECT_EQ(MOJO_RESULT_SHOULD_WAIT, | 557 EXPECT_EQ( |
662 core()->ReadMessage(h[0], | 558 MOJO_RESULT_SHOULD_WAIT, |
663 UserPointer<void>(buffer), | 559 core()->ReadMessage(h[0], UserPointer<void>(buffer), |
664 MakeUserPointer(&buffer_size), | 560 MakeUserPointer(&buffer_size), NullUserPointer(), |
665 NullUserPointer(), | 561 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); |
666 NullUserPointer(), | |
667 MOJO_READ_MESSAGE_FLAG_NONE)); | |
668 // Check that it left its inputs alone. | 562 // Check that it left its inputs alone. |
669 EXPECT_EQ('a', buffer[0]); | 563 EXPECT_EQ('a', buffer[0]); |
670 EXPECT_EQ(1u, buffer_size); | 564 EXPECT_EQ(1u, buffer_size); |
671 | 565 |
672 // Both should be writable. | 566 // Both should be writable. |
673 hss[0] = kEmptyMojoHandleSignalsState; | 567 hss[0] = kEmptyMojoHandleSignalsState; |
674 EXPECT_EQ(MOJO_RESULT_OK, | 568 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(h[0], MOJO_HANDLE_SIGNAL_WRITABLE, |
675 core()->Wait(h[0], | 569 1000000000, MakeUserPointer(&hss[0]))); |
676 MOJO_HANDLE_SIGNAL_WRITABLE, | |
677 1000000000, | |
678 MakeUserPointer(&hss[0]))); | |
679 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 570 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
680 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 571 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
681 hss[0].satisfiable_signals); | 572 hss[0].satisfiable_signals); |
682 hss[0] = kEmptyMojoHandleSignalsState; | 573 hss[0] = kEmptyMojoHandleSignalsState; |
683 EXPECT_EQ(MOJO_RESULT_OK, | 574 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(h[1], MOJO_HANDLE_SIGNAL_WRITABLE, |
684 core()->Wait(h[1], | 575 1000000000, MakeUserPointer(&hss[0]))); |
685 MOJO_HANDLE_SIGNAL_WRITABLE, | |
686 1000000000, | |
687 MakeUserPointer(&hss[0]))); | |
688 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 576 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
689 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 577 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
690 hss[0].satisfiable_signals); | 578 hss[0].satisfiable_signals); |
691 | 579 |
692 // Also check that |h[1]| is writable using |WaitMany()|. | 580 // Also check that |h[1]| is writable using |WaitMany()|. |
693 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; | 581 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; |
694 signals[1] = MOJO_HANDLE_SIGNAL_WRITABLE; | 582 signals[1] = MOJO_HANDLE_SIGNAL_WRITABLE; |
695 result_index = static_cast<uint32_t>(-1); | 583 result_index = static_cast<uint32_t>(-1); |
696 hss[0] = kEmptyMojoHandleSignalsState; | 584 hss[0] = kEmptyMojoHandleSignalsState; |
697 hss[1] = kEmptyMojoHandleSignalsState; | 585 hss[1] = kEmptyMojoHandleSignalsState; |
698 EXPECT_EQ(MOJO_RESULT_OK, | 586 EXPECT_EQ( |
699 core()->WaitMany(MakeUserPointer(h), | 587 MOJO_RESULT_OK, |
700 MakeUserPointer(signals), | 588 core()->WaitMany(MakeUserPointer(h), MakeUserPointer(signals), 2, |
701 2, | 589 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
702 MOJO_DEADLINE_INDEFINITE, | 590 MakeUserPointer(hss))); |
703 MakeUserPointer(&result_index), | |
704 MakeUserPointer(hss))); | |
705 EXPECT_EQ(1u, result_index); | 591 EXPECT_EQ(1u, result_index); |
706 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 592 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
707 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 593 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
708 hss[0].satisfiable_signals); | 594 hss[0].satisfiable_signals); |
709 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); | 595 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); |
710 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 596 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
711 hss[1].satisfiable_signals); | 597 hss[1].satisfiable_signals); |
712 | 598 |
713 // Write to |h[1]|. | 599 // Write to |h[1]|. |
714 buffer[0] = 'b'; | 600 buffer[0] = 'b'; |
715 EXPECT_EQ(MOJO_RESULT_OK, | 601 EXPECT_EQ( |
716 core()->WriteMessage(h[1], | 602 MOJO_RESULT_OK, |
717 UserPointer<const void>(buffer), | 603 core()->WriteMessage(h[1], UserPointer<const void>(buffer), 1, |
718 1, | 604 NullUserPointer(), 0, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
719 NullUserPointer(), | |
720 0, | |
721 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
722 | 605 |
723 // Check that |h[0]| is now readable. | 606 // Check that |h[0]| is now readable. |
724 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; | 607 signals[0] = MOJO_HANDLE_SIGNAL_READABLE; |
725 signals[1] = MOJO_HANDLE_SIGNAL_READABLE; | 608 signals[1] = MOJO_HANDLE_SIGNAL_READABLE; |
726 result_index = static_cast<uint32_t>(-1); | 609 result_index = static_cast<uint32_t>(-1); |
727 hss[0] = kEmptyMojoHandleSignalsState; | 610 hss[0] = kEmptyMojoHandleSignalsState; |
728 hss[1] = kEmptyMojoHandleSignalsState; | 611 hss[1] = kEmptyMojoHandleSignalsState; |
729 EXPECT_EQ(MOJO_RESULT_OK, | 612 EXPECT_EQ( |
730 core()->WaitMany(MakeUserPointer(h), | 613 MOJO_RESULT_OK, |
731 MakeUserPointer(signals), | 614 core()->WaitMany(MakeUserPointer(h), MakeUserPointer(signals), 2, |
732 2, | 615 MOJO_DEADLINE_INDEFINITE, MakeUserPointer(&result_index), |
733 MOJO_DEADLINE_INDEFINITE, | 616 MakeUserPointer(hss))); |
734 MakeUserPointer(&result_index), | |
735 MakeUserPointer(hss))); | |
736 EXPECT_EQ(0u, result_index); | 617 EXPECT_EQ(0u, result_index); |
737 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 618 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
738 hss[0].satisfied_signals); | 619 hss[0].satisfied_signals); |
739 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 620 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
740 hss[0].satisfiable_signals); | 621 hss[0].satisfiable_signals); |
741 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); | 622 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[1].satisfied_signals); |
742 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 623 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
743 hss[1].satisfiable_signals); | 624 hss[1].satisfiable_signals); |
744 | 625 |
745 // Read from |h[0]|. | 626 // Read from |h[0]|. |
746 // First, get only the size. | 627 // First, get only the size. |
747 buffer_size = 0; | 628 buffer_size = 0; |
748 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, | 629 EXPECT_EQ( |
749 core()->ReadMessage(h[0], | 630 MOJO_RESULT_RESOURCE_EXHAUSTED, |
750 NullUserPointer(), | 631 core()->ReadMessage(h[0], NullUserPointer(), |
751 MakeUserPointer(&buffer_size), | 632 MakeUserPointer(&buffer_size), NullUserPointer(), |
752 NullUserPointer(), | 633 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); |
753 NullUserPointer(), | |
754 MOJO_READ_MESSAGE_FLAG_NONE)); | |
755 EXPECT_EQ(1u, buffer_size); | 634 EXPECT_EQ(1u, buffer_size); |
756 // Then actually read it. | 635 // Then actually read it. |
757 buffer[0] = 'c'; | 636 buffer[0] = 'c'; |
758 buffer_size = 1; | 637 buffer_size = 1; |
759 EXPECT_EQ(MOJO_RESULT_OK, | 638 EXPECT_EQ( |
760 core()->ReadMessage(h[0], | 639 MOJO_RESULT_OK, |
761 UserPointer<void>(buffer), | 640 core()->ReadMessage(h[0], UserPointer<void>(buffer), |
762 MakeUserPointer(&buffer_size), | 641 MakeUserPointer(&buffer_size), NullUserPointer(), |
763 NullUserPointer(), | 642 NullUserPointer(), MOJO_READ_MESSAGE_FLAG_NONE)); |
764 NullUserPointer(), | |
765 MOJO_READ_MESSAGE_FLAG_NONE)); | |
766 EXPECT_EQ('b', buffer[0]); | 643 EXPECT_EQ('b', buffer[0]); |
767 EXPECT_EQ(1u, buffer_size); | 644 EXPECT_EQ(1u, buffer_size); |
768 | 645 |
769 // |h[0]| should no longer be readable. | 646 // |h[0]| should no longer be readable. |
770 hss[0] = kEmptyMojoHandleSignalsState; | 647 hss[0] = kEmptyMojoHandleSignalsState; |
771 EXPECT_EQ( | 648 EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, |
772 MOJO_RESULT_DEADLINE_EXCEEDED, | 649 core()->Wait(h[0], MOJO_HANDLE_SIGNAL_READABLE, 0, |
773 core()->Wait( | 650 MakeUserPointer(&hss[0]))); |
774 h[0], MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss[0]))); | |
775 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); | 651 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss[0].satisfied_signals); |
776 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 652 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
777 hss[0].satisfiable_signals); | 653 hss[0].satisfiable_signals); |
778 | 654 |
779 // Write to |h[0]|. | 655 // Write to |h[0]|. |
780 buffer[0] = 'd'; | 656 buffer[0] = 'd'; |
781 EXPECT_EQ(MOJO_RESULT_OK, | 657 EXPECT_EQ( |
782 core()->WriteMessage(h[0], | 658 MOJO_RESULT_OK, |
783 UserPointer<const void>(buffer), | 659 core()->WriteMessage(h[0], UserPointer<const void>(buffer), 1, |
784 1, | 660 NullUserPointer(), 0, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
785 NullUserPointer(), | |
786 0, | |
787 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
788 | 661 |
789 // Close |h[0]|. | 662 // Close |h[0]|. |
790 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[0])); | 663 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[0])); |
791 | 664 |
792 // Check that |h[1]| is no longer writable (and will never be). | 665 // Check that |h[1]| is no longer writable (and will never be). |
793 hss[0] = kEmptyMojoHandleSignalsState; | 666 hss[0] = kEmptyMojoHandleSignalsState; |
794 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 667 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
795 core()->Wait(h[1], | 668 core()->Wait(h[1], MOJO_HANDLE_SIGNAL_WRITABLE, 1000000000, |
796 MOJO_HANDLE_SIGNAL_WRITABLE, | |
797 1000000000, | |
798 MakeUserPointer(&hss[0]))); | 669 MakeUserPointer(&hss[0]))); |
799 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); | 670 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); |
800 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); | 671 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); |
801 | 672 |
802 // Check that |h[1]| is still readable (for the moment). | 673 // Check that |h[1]| is still readable (for the moment). |
803 hss[0] = kEmptyMojoHandleSignalsState; | 674 hss[0] = kEmptyMojoHandleSignalsState; |
804 EXPECT_EQ(MOJO_RESULT_OK, | 675 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(h[1], MOJO_HANDLE_SIGNAL_READABLE, |
805 core()->Wait(h[1], | 676 1000000000, MakeUserPointer(&hss[0]))); |
806 MOJO_HANDLE_SIGNAL_READABLE, | |
807 1000000000, | |
808 MakeUserPointer(&hss[0]))); | |
809 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); | 677 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfied_signals); |
810 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); | 678 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss[0].satisfiable_signals); |
811 | 679 |
812 // Discard a message from |h[1]|. | 680 // Discard a message from |h[1]|. |
813 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, | 681 EXPECT_EQ(MOJO_RESULT_RESOURCE_EXHAUSTED, |
814 core()->ReadMessage(h[1], | 682 core()->ReadMessage(h[1], NullUserPointer(), NullUserPointer(), |
815 NullUserPointer(), | 683 NullUserPointer(), NullUserPointer(), |
816 NullUserPointer(), | |
817 NullUserPointer(), | |
818 NullUserPointer(), | |
819 MOJO_READ_MESSAGE_FLAG_MAY_DISCARD)); | 684 MOJO_READ_MESSAGE_FLAG_MAY_DISCARD)); |
820 | 685 |
821 // |h[1]| is no longer readable (and will never be). | 686 // |h[1]| is no longer readable (and will never be). |
822 hss[0] = kFullMojoHandleSignalsState; | 687 hss[0] = kFullMojoHandleSignalsState; |
823 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 688 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
824 core()->Wait(h[1], | 689 core()->Wait(h[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
825 MOJO_HANDLE_SIGNAL_READABLE, | |
826 1000000000, | |
827 MakeUserPointer(&hss[0]))); | 690 MakeUserPointer(&hss[0]))); |
828 EXPECT_EQ(0u, hss[0].satisfied_signals); | 691 EXPECT_EQ(0u, hss[0].satisfied_signals); |
829 EXPECT_EQ(0u, hss[0].satisfiable_signals); | 692 EXPECT_EQ(0u, hss[0].satisfiable_signals); |
830 | 693 |
831 // Try writing to |h[1]|. | 694 // Try writing to |h[1]|. |
832 buffer[0] = 'e'; | 695 buffer[0] = 'e'; |
833 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 696 EXPECT_EQ( |
834 core()->WriteMessage(h[1], | 697 MOJO_RESULT_FAILED_PRECONDITION, |
835 UserPointer<const void>(buffer), | 698 core()->WriteMessage(h[1], UserPointer<const void>(buffer), 1, |
836 1, | 699 NullUserPointer(), 0, MOJO_WRITE_MESSAGE_FLAG_NONE)); |
837 NullUserPointer(), | |
838 0, | |
839 MOJO_WRITE_MESSAGE_FLAG_NONE)); | |
840 | 700 |
841 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[1])); | 701 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h[1])); |
842 } | 702 } |
843 | 703 |
844 // Tests passing a message pipe handle. | 704 // Tests passing a message pipe handle. |
845 TEST_F(CoreTest, MessagePipeBasicLocalHandlePassing1) { | 705 TEST_F(CoreTest, MessagePipeBasicLocalHandlePassing1) { |
846 const char kHello[] = "hello"; | 706 const char kHello[] = "hello"; |
847 const uint32_t kHelloSize = static_cast<uint32_t>(sizeof(kHello)); | 707 const uint32_t kHelloSize = static_cast<uint32_t>(sizeof(kHello)); |
848 const char kWorld[] = "world!!!"; | 708 const char kWorld[] = "world!!!"; |
849 const uint32_t kWorldSize = static_cast<uint32_t>(sizeof(kWorld)); | 709 const uint32_t kWorldSize = static_cast<uint32_t>(sizeof(kWorld)); |
850 char buffer[100]; | 710 char buffer[100]; |
851 const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer)); | 711 const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer)); |
852 uint32_t num_bytes; | 712 uint32_t num_bytes; |
853 MojoHandle handles[10]; | 713 MojoHandle handles[10]; |
854 uint32_t num_handles; | 714 uint32_t num_handles; |
855 MojoHandleSignalsState hss; | 715 MojoHandleSignalsState hss; |
856 MojoHandle h_received; | 716 MojoHandle h_received; |
857 | 717 |
858 MojoHandle h_passing[2]; | 718 MojoHandle h_passing[2]; |
859 EXPECT_EQ(MOJO_RESULT_OK, | 719 EXPECT_EQ(MOJO_RESULT_OK, |
860 core()->CreateMessagePipe(NullUserPointer(), | 720 core()->CreateMessagePipe(NullUserPointer(), |
861 MakeUserPointer(&h_passing[0]), | 721 MakeUserPointer(&h_passing[0]), |
862 MakeUserPointer(&h_passing[1]))); | 722 MakeUserPointer(&h_passing[1]))); |
863 | 723 |
864 // Make sure that |h_passing[]| work properly. | 724 // Make sure that |h_passing[]| work properly. |
865 EXPECT_EQ(MOJO_RESULT_OK, | 725 EXPECT_EQ(MOJO_RESULT_OK, |
866 core()->WriteMessage(h_passing[0], | 726 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
867 UserPointer<const void>(kHello), | 727 kHelloSize, NullUserPointer(), 0, |
868 kHelloSize, | |
869 NullUserPointer(), | |
870 0, | |
871 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 728 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
872 hss = kEmptyMojoHandleSignalsState; | 729 hss = kEmptyMojoHandleSignalsState; |
873 EXPECT_EQ(MOJO_RESULT_OK, | 730 EXPECT_EQ(MOJO_RESULT_OK, |
874 core()->Wait(h_passing[1], | 731 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
875 MOJO_HANDLE_SIGNAL_READABLE, | |
876 1000000000, | |
877 MakeUserPointer(&hss))); | 732 MakeUserPointer(&hss))); |
878 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 733 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
879 hss.satisfied_signals); | 734 hss.satisfied_signals); |
880 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 735 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
881 hss.satisfiable_signals); | 736 hss.satisfiable_signals); |
882 num_bytes = kBufferSize; | 737 num_bytes = kBufferSize; |
883 num_handles = arraysize(handles); | 738 num_handles = arraysize(handles); |
884 EXPECT_EQ(MOJO_RESULT_OK, | 739 EXPECT_EQ(MOJO_RESULT_OK, |
885 core()->ReadMessage(h_passing[1], | 740 core()->ReadMessage( |
886 UserPointer<void>(buffer), | 741 h_passing[1], UserPointer<void>(buffer), |
887 MakeUserPointer(&num_bytes), | 742 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
888 MakeUserPointer(handles), | 743 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
889 MakeUserPointer(&num_handles), | |
890 MOJO_READ_MESSAGE_FLAG_NONE)); | |
891 EXPECT_EQ(kHelloSize, num_bytes); | 744 EXPECT_EQ(kHelloSize, num_bytes); |
892 EXPECT_STREQ(kHello, buffer); | 745 EXPECT_STREQ(kHello, buffer); |
893 EXPECT_EQ(0u, num_handles); | 746 EXPECT_EQ(0u, num_handles); |
894 | 747 |
895 // Make sure that you can't pass either of the message pipe's handles over | 748 // Make sure that you can't pass either of the message pipe's handles over |
896 // itself. | 749 // itself. |
897 EXPECT_EQ(MOJO_RESULT_BUSY, | 750 EXPECT_EQ(MOJO_RESULT_BUSY, |
898 core()->WriteMessage(h_passing[0], | 751 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
899 UserPointer<const void>(kHello), | 752 kHelloSize, MakeUserPointer(&h_passing[0]), 1, |
900 kHelloSize, | |
901 MakeUserPointer(&h_passing[0]), | |
902 1, | |
903 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 753 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
904 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 754 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
905 core()->WriteMessage(h_passing[0], | 755 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
906 UserPointer<const void>(kHello), | 756 kHelloSize, MakeUserPointer(&h_passing[1]), 1, |
907 kHelloSize, | |
908 MakeUserPointer(&h_passing[1]), | |
909 1, | |
910 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 757 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
911 | 758 |
912 MojoHandle h_passed[2]; | 759 MojoHandle h_passed[2]; |
913 EXPECT_EQ(MOJO_RESULT_OK, | 760 EXPECT_EQ(MOJO_RESULT_OK, |
914 core()->CreateMessagePipe(NullUserPointer(), | 761 core()->CreateMessagePipe(NullUserPointer(), |
915 MakeUserPointer(&h_passed[0]), | 762 MakeUserPointer(&h_passed[0]), |
916 MakeUserPointer(&h_passed[1]))); | 763 MakeUserPointer(&h_passed[1]))); |
917 | 764 |
918 // Make sure that |h_passed[]| work properly. | 765 // Make sure that |h_passed[]| work properly. |
919 EXPECT_EQ(MOJO_RESULT_OK, | 766 EXPECT_EQ(MOJO_RESULT_OK, |
920 core()->WriteMessage(h_passed[0], | 767 core()->WriteMessage(h_passed[0], UserPointer<const void>(kHello), |
921 UserPointer<const void>(kHello), | 768 kHelloSize, NullUserPointer(), 0, |
922 kHelloSize, | |
923 NullUserPointer(), | |
924 0, | |
925 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 769 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
926 hss = kEmptyMojoHandleSignalsState; | 770 hss = kEmptyMojoHandleSignalsState; |
927 EXPECT_EQ(MOJO_RESULT_OK, | 771 EXPECT_EQ(MOJO_RESULT_OK, |
928 core()->Wait(h_passed[1], | 772 core()->Wait(h_passed[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
929 MOJO_HANDLE_SIGNAL_READABLE, | |
930 1000000000, | |
931 MakeUserPointer(&hss))); | 773 MakeUserPointer(&hss))); |
932 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 774 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
933 hss.satisfied_signals); | 775 hss.satisfied_signals); |
934 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 776 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
935 hss.satisfiable_signals); | 777 hss.satisfiable_signals); |
936 num_bytes = kBufferSize; | 778 num_bytes = kBufferSize; |
937 num_handles = arraysize(handles); | 779 num_handles = arraysize(handles); |
938 EXPECT_EQ(MOJO_RESULT_OK, | 780 EXPECT_EQ(MOJO_RESULT_OK, |
939 core()->ReadMessage(h_passed[1], | 781 core()->ReadMessage( |
940 UserPointer<void>(buffer), | 782 h_passed[1], UserPointer<void>(buffer), |
941 MakeUserPointer(&num_bytes), | 783 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
942 MakeUserPointer(handles), | 784 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
943 MakeUserPointer(&num_handles), | |
944 MOJO_READ_MESSAGE_FLAG_NONE)); | |
945 EXPECT_EQ(kHelloSize, num_bytes); | 785 EXPECT_EQ(kHelloSize, num_bytes); |
946 EXPECT_STREQ(kHello, buffer); | 786 EXPECT_STREQ(kHello, buffer); |
947 EXPECT_EQ(0u, num_handles); | 787 EXPECT_EQ(0u, num_handles); |
948 | 788 |
949 // Send |h_passed[1]| from |h_passing[0]| to |h_passing[1]|. | 789 // Send |h_passed[1]| from |h_passing[0]| to |h_passing[1]|. |
950 EXPECT_EQ(MOJO_RESULT_OK, | 790 EXPECT_EQ(MOJO_RESULT_OK, |
951 core()->WriteMessage(h_passing[0], | 791 core()->WriteMessage(h_passing[0], UserPointer<const void>(kWorld), |
952 UserPointer<const void>(kWorld), | 792 kWorldSize, MakeUserPointer(&h_passed[1]), 1, |
953 kWorldSize, | |
954 MakeUserPointer(&h_passed[1]), | |
955 1, | |
956 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 793 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
957 hss = kEmptyMojoHandleSignalsState; | 794 hss = kEmptyMojoHandleSignalsState; |
958 EXPECT_EQ(MOJO_RESULT_OK, | 795 EXPECT_EQ(MOJO_RESULT_OK, |
959 core()->Wait(h_passing[1], | 796 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
960 MOJO_HANDLE_SIGNAL_READABLE, | |
961 1000000000, | |
962 MakeUserPointer(&hss))); | 797 MakeUserPointer(&hss))); |
963 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 798 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
964 hss.satisfied_signals); | 799 hss.satisfied_signals); |
965 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 800 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
966 hss.satisfiable_signals); | 801 hss.satisfiable_signals); |
967 num_bytes = kBufferSize; | 802 num_bytes = kBufferSize; |
968 num_handles = arraysize(handles); | 803 num_handles = arraysize(handles); |
969 EXPECT_EQ(MOJO_RESULT_OK, | 804 EXPECT_EQ(MOJO_RESULT_OK, |
970 core()->ReadMessage(h_passing[1], | 805 core()->ReadMessage( |
971 UserPointer<void>(buffer), | 806 h_passing[1], UserPointer<void>(buffer), |
972 MakeUserPointer(&num_bytes), | 807 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
973 MakeUserPointer(handles), | 808 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
974 MakeUserPointer(&num_handles), | |
975 MOJO_READ_MESSAGE_FLAG_NONE)); | |
976 EXPECT_EQ(kWorldSize, num_bytes); | 809 EXPECT_EQ(kWorldSize, num_bytes); |
977 EXPECT_STREQ(kWorld, buffer); | 810 EXPECT_STREQ(kWorld, buffer); |
978 EXPECT_EQ(1u, num_handles); | 811 EXPECT_EQ(1u, num_handles); |
979 h_received = handles[0]; | 812 h_received = handles[0]; |
980 EXPECT_NE(h_received, MOJO_HANDLE_INVALID); | 813 EXPECT_NE(h_received, MOJO_HANDLE_INVALID); |
981 EXPECT_NE(h_received, h_passing[0]); | 814 EXPECT_NE(h_received, h_passing[0]); |
982 EXPECT_NE(h_received, h_passing[1]); | 815 EXPECT_NE(h_received, h_passing[1]); |
983 EXPECT_NE(h_received, h_passed[0]); | 816 EXPECT_NE(h_received, h_passed[0]); |
984 | 817 |
985 // Note: We rely on the Mojo system not re-using handle values very often. | 818 // Note: We rely on the Mojo system not re-using handle values very often. |
986 EXPECT_NE(h_received, h_passed[1]); | 819 EXPECT_NE(h_received, h_passed[1]); |
987 | 820 |
988 // |h_passed[1]| should no longer be valid; check that trying to close it | 821 // |h_passed[1]| should no longer be valid; check that trying to close it |
989 // fails. See above note. | 822 // fails. See above note. |
990 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h_passed[1])); | 823 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(h_passed[1])); |
991 | 824 |
992 // Write to |h_passed[0]|. Should receive on |h_received|. | 825 // Write to |h_passed[0]|. Should receive on |h_received|. |
993 EXPECT_EQ(MOJO_RESULT_OK, | 826 EXPECT_EQ(MOJO_RESULT_OK, |
994 core()->WriteMessage(h_passed[0], | 827 core()->WriteMessage(h_passed[0], UserPointer<const void>(kHello), |
995 UserPointer<const void>(kHello), | 828 kHelloSize, NullUserPointer(), 0, |
996 kHelloSize, | |
997 NullUserPointer(), | |
998 0, | |
999 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 829 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1000 hss = kEmptyMojoHandleSignalsState; | 830 hss = kEmptyMojoHandleSignalsState; |
1001 EXPECT_EQ(MOJO_RESULT_OK, | 831 EXPECT_EQ(MOJO_RESULT_OK, |
1002 core()->Wait(h_received, | 832 core()->Wait(h_received, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1003 MOJO_HANDLE_SIGNAL_READABLE, | |
1004 1000000000, | |
1005 MakeUserPointer(&hss))); | 833 MakeUserPointer(&hss))); |
1006 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 834 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1007 hss.satisfied_signals); | 835 hss.satisfied_signals); |
1008 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 836 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1009 hss.satisfiable_signals); | 837 hss.satisfiable_signals); |
1010 num_bytes = kBufferSize; | 838 num_bytes = kBufferSize; |
1011 num_handles = arraysize(handles); | 839 num_handles = arraysize(handles); |
1012 EXPECT_EQ(MOJO_RESULT_OK, | 840 EXPECT_EQ(MOJO_RESULT_OK, |
1013 core()->ReadMessage(h_received, | 841 core()->ReadMessage( |
1014 UserPointer<void>(buffer), | 842 h_received, UserPointer<void>(buffer), |
1015 MakeUserPointer(&num_bytes), | 843 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
1016 MakeUserPointer(handles), | 844 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
1017 MakeUserPointer(&num_handles), | |
1018 MOJO_READ_MESSAGE_FLAG_NONE)); | |
1019 EXPECT_EQ(kHelloSize, num_bytes); | 845 EXPECT_EQ(kHelloSize, num_bytes); |
1020 EXPECT_STREQ(kHello, buffer); | 846 EXPECT_STREQ(kHello, buffer); |
1021 EXPECT_EQ(0u, num_handles); | 847 EXPECT_EQ(0u, num_handles); |
1022 | 848 |
1023 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); | 849 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); |
1024 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); | 850 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); |
1025 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passed[0])); | 851 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passed[0])); |
1026 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_received)); | 852 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_received)); |
1027 } | 853 } |
1028 | 854 |
1029 TEST_F(CoreTest, DataPipe) { | 855 TEST_F(CoreTest, DataPipe) { |
1030 MojoHandle ph, ch; // p is for producer and c is for consumer. | 856 MojoHandle ph, ch; // p is for producer and c is for consumer. |
1031 MojoHandleSignalsState hss; | 857 MojoHandleSignalsState hss; |
1032 | 858 |
1033 EXPECT_EQ(MOJO_RESULT_OK, | 859 EXPECT_EQ(MOJO_RESULT_OK, |
1034 core()->CreateDataPipe( | 860 core()->CreateDataPipe(NullUserPointer(), MakeUserPointer(&ph), |
1035 NullUserPointer(), MakeUserPointer(&ph), MakeUserPointer(&ch))); | 861 MakeUserPointer(&ch))); |
1036 // Should get two distinct, valid handles. | 862 // Should get two distinct, valid handles. |
1037 EXPECT_NE(ph, MOJO_HANDLE_INVALID); | 863 EXPECT_NE(ph, MOJO_HANDLE_INVALID); |
1038 EXPECT_NE(ch, MOJO_HANDLE_INVALID); | 864 EXPECT_NE(ch, MOJO_HANDLE_INVALID); |
1039 EXPECT_NE(ph, ch); | 865 EXPECT_NE(ph, ch); |
1040 | 866 |
1041 // Producer should be never-readable, but already writable. | 867 // Producer should be never-readable, but already writable. |
1042 hss = kEmptyMojoHandleSignalsState; | 868 hss = kEmptyMojoHandleSignalsState; |
1043 EXPECT_EQ( | 869 EXPECT_EQ( |
1044 MOJO_RESULT_FAILED_PRECONDITION, | 870 MOJO_RESULT_FAILED_PRECONDITION, |
1045 core()->Wait(ph, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); | 871 core()->Wait(ph, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); |
1046 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 872 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
1047 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 873 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
1048 hss = kEmptyMojoHandleSignalsState; | 874 hss = kEmptyMojoHandleSignalsState; |
1049 EXPECT_EQ( | 875 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(ph, MOJO_HANDLE_SIGNAL_WRITABLE, 0, |
1050 MOJO_RESULT_OK, | 876 MakeUserPointer(&hss))); |
1051 core()->Wait(ph, MOJO_HANDLE_SIGNAL_WRITABLE, 0, MakeUserPointer(&hss))); | |
1052 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); | 877 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfied_signals); |
1053 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); | 878 EXPECT_EQ(MOJO_HANDLE_SIGNAL_WRITABLE, hss.satisfiable_signals); |
1054 | 879 |
1055 // Consumer should be never-writable, and not yet readable. | 880 // Consumer should be never-writable, and not yet readable. |
1056 hss = kFullMojoHandleSignalsState; | 881 hss = kFullMojoHandleSignalsState; |
1057 EXPECT_EQ( | 882 EXPECT_EQ( |
1058 MOJO_RESULT_FAILED_PRECONDITION, | 883 MOJO_RESULT_FAILED_PRECONDITION, |
1059 core()->Wait(ch, MOJO_HANDLE_SIGNAL_WRITABLE, 0, MakeUserPointer(&hss))); | 884 core()->Wait(ch, MOJO_HANDLE_SIGNAL_WRITABLE, 0, MakeUserPointer(&hss))); |
1060 EXPECT_EQ(0u, hss.satisfied_signals); | 885 EXPECT_EQ(0u, hss.satisfied_signals); |
1061 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 886 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
1062 hss = kFullMojoHandleSignalsState; | 887 hss = kFullMojoHandleSignalsState; |
1063 EXPECT_EQ( | 888 EXPECT_EQ( |
1064 MOJO_RESULT_DEADLINE_EXCEEDED, | 889 MOJO_RESULT_DEADLINE_EXCEEDED, |
1065 core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); | 890 core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); |
1066 EXPECT_EQ(0u, hss.satisfied_signals); | 891 EXPECT_EQ(0u, hss.satisfied_signals); |
1067 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 892 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
1068 | 893 |
1069 // Write. | 894 // Write. |
1070 char elements[2] = {'A', 'B'}; | 895 char elements[2] = {'A', 'B'}; |
1071 uint32_t num_bytes = 2u; | 896 uint32_t num_bytes = 2u; |
1072 EXPECT_EQ(MOJO_RESULT_OK, | 897 EXPECT_EQ(MOJO_RESULT_OK, |
1073 core()->WriteData(ph, | 898 core()->WriteData(ph, UserPointer<const void>(elements), |
1074 UserPointer<const void>(elements), | |
1075 MakeUserPointer(&num_bytes), | 899 MakeUserPointer(&num_bytes), |
1076 MOJO_WRITE_DATA_FLAG_NONE)); | 900 MOJO_WRITE_DATA_FLAG_NONE)); |
1077 EXPECT_EQ(2u, num_bytes); | 901 EXPECT_EQ(2u, num_bytes); |
1078 | 902 |
1079 // Consumer should now be readable. | 903 // Consumer should now be readable. |
1080 hss = kEmptyMojoHandleSignalsState; | 904 hss = kEmptyMojoHandleSignalsState; |
1081 EXPECT_EQ( | 905 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, |
1082 MOJO_RESULT_OK, | 906 MakeUserPointer(&hss))); |
1083 core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, 0, MakeUserPointer(&hss))); | |
1084 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 907 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
1085 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 908 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
1086 | 909 |
1087 // Peek one character. | 910 // Peek one character. |
1088 elements[0] = -1; | 911 elements[0] = -1; |
1089 elements[1] = -1; | 912 elements[1] = -1; |
1090 num_bytes = 1u; | 913 num_bytes = 1u; |
1091 EXPECT_EQ(MOJO_RESULT_OK, | 914 EXPECT_EQ(MOJO_RESULT_OK, |
1092 core()->ReadData( | 915 core()->ReadData( |
1093 ch, | 916 ch, UserPointer<void>(elements), MakeUserPointer(&num_bytes), |
1094 UserPointer<void>(elements), | |
1095 MakeUserPointer(&num_bytes), | |
1096 MOJO_READ_DATA_FLAG_NONE | MOJO_READ_DATA_FLAG_PEEK)); | 917 MOJO_READ_DATA_FLAG_NONE | MOJO_READ_DATA_FLAG_PEEK)); |
1097 EXPECT_EQ('A', elements[0]); | 918 EXPECT_EQ('A', elements[0]); |
1098 EXPECT_EQ(-1, elements[1]); | 919 EXPECT_EQ(-1, elements[1]); |
1099 | 920 |
1100 // Read one character. | 921 // Read one character. |
1101 elements[0] = -1; | 922 elements[0] = -1; |
1102 elements[1] = -1; | 923 elements[1] = -1; |
1103 num_bytes = 1u; | 924 num_bytes = 1u; |
1104 EXPECT_EQ(MOJO_RESULT_OK, | 925 EXPECT_EQ(MOJO_RESULT_OK, core()->ReadData(ch, UserPointer<void>(elements), |
1105 core()->ReadData(ch, | 926 MakeUserPointer(&num_bytes), |
1106 UserPointer<void>(elements), | 927 MOJO_READ_DATA_FLAG_NONE)); |
1107 MakeUserPointer(&num_bytes), | |
1108 MOJO_READ_DATA_FLAG_NONE)); | |
1109 EXPECT_EQ('A', elements[0]); | 928 EXPECT_EQ('A', elements[0]); |
1110 EXPECT_EQ(-1, elements[1]); | 929 EXPECT_EQ(-1, elements[1]); |
1111 | 930 |
1112 // Two-phase write. | 931 // Two-phase write. |
1113 void* write_ptr = nullptr; | 932 void* write_ptr = nullptr; |
1114 num_bytes = 0u; | 933 num_bytes = 0u; |
1115 ASSERT_EQ(MOJO_RESULT_OK, | 934 ASSERT_EQ(MOJO_RESULT_OK, |
1116 core()->BeginWriteData(ph, | 935 core()->BeginWriteData(ph, MakeUserPointer(&write_ptr), |
1117 MakeUserPointer(&write_ptr), | |
1118 MakeUserPointer(&num_bytes), | 936 MakeUserPointer(&num_bytes), |
1119 MOJO_WRITE_DATA_FLAG_NONE)); | 937 MOJO_WRITE_DATA_FLAG_NONE)); |
1120 // We count on the default options providing a decent buffer size. | 938 // We count on the default options providing a decent buffer size. |
1121 ASSERT_GE(num_bytes, 3u); | 939 ASSERT_GE(num_bytes, 3u); |
1122 | 940 |
1123 // Trying to do a normal write during a two-phase write should fail. | 941 // Trying to do a normal write during a two-phase write should fail. |
1124 elements[0] = 'X'; | 942 elements[0] = 'X'; |
1125 num_bytes = 1u; | 943 num_bytes = 1u; |
1126 EXPECT_EQ(MOJO_RESULT_BUSY, | 944 EXPECT_EQ(MOJO_RESULT_BUSY, |
1127 core()->WriteData(ph, | 945 core()->WriteData(ph, UserPointer<const void>(elements), |
1128 UserPointer<const void>(elements), | |
1129 MakeUserPointer(&num_bytes), | 946 MakeUserPointer(&num_bytes), |
1130 MOJO_WRITE_DATA_FLAG_NONE)); | 947 MOJO_WRITE_DATA_FLAG_NONE)); |
1131 | 948 |
1132 // Actually write the data, and complete it now. | 949 // Actually write the data, and complete it now. |
1133 static_cast<char*>(write_ptr)[0] = 'C'; | 950 static_cast<char*>(write_ptr)[0] = 'C'; |
1134 static_cast<char*>(write_ptr)[1] = 'D'; | 951 static_cast<char*>(write_ptr)[1] = 'D'; |
1135 static_cast<char*>(write_ptr)[2] = 'E'; | 952 static_cast<char*>(write_ptr)[2] = 'E'; |
1136 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 3u)); | 953 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 3u)); |
1137 | 954 |
1138 // Query how much data we have. | 955 // Query how much data we have. |
1139 num_bytes = 0; | 956 num_bytes = 0; |
1140 EXPECT_EQ(MOJO_RESULT_OK, | 957 EXPECT_EQ(MOJO_RESULT_OK, |
1141 core()->ReadData(ch, | 958 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), |
1142 NullUserPointer(), | |
1143 MakeUserPointer(&num_bytes), | |
1144 MOJO_READ_DATA_FLAG_QUERY)); | 959 MOJO_READ_DATA_FLAG_QUERY)); |
1145 EXPECT_EQ(4u, num_bytes); | 960 EXPECT_EQ(4u, num_bytes); |
1146 | 961 |
1147 // Try to query with peek. Should fail. | 962 // Try to query with peek. Should fail. |
1148 num_bytes = 0; | 963 num_bytes = 0; |
1149 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 964 EXPECT_EQ( |
1150 core()->ReadData( | 965 MOJO_RESULT_INVALID_ARGUMENT, |
1151 ch, | 966 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), |
1152 NullUserPointer(), | 967 MOJO_READ_DATA_FLAG_QUERY | MOJO_READ_DATA_FLAG_PEEK)); |
1153 MakeUserPointer(&num_bytes), | |
1154 MOJO_READ_DATA_FLAG_QUERY | MOJO_READ_DATA_FLAG_PEEK)); | |
1155 EXPECT_EQ(0u, num_bytes); | 968 EXPECT_EQ(0u, num_bytes); |
1156 | 969 |
1157 // Try to discard ten characters, in all-or-none mode. Should fail. | 970 // Try to discard ten characters, in all-or-none mode. Should fail. |
1158 num_bytes = 10; | 971 num_bytes = 10; |
1159 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, | 972 EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, |
1160 core()->ReadData( | 973 core()->ReadData( |
1161 ch, | 974 ch, NullUserPointer(), MakeUserPointer(&num_bytes), |
1162 NullUserPointer(), | |
1163 MakeUserPointer(&num_bytes), | |
1164 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 975 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
1165 | 976 |
1166 // Try to discard two characters, in peek mode. Should fail. | 977 // Try to discard two characters, in peek mode. Should fail. |
1167 num_bytes = 2; | 978 num_bytes = 2; |
1168 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 979 EXPECT_EQ( |
1169 core()->ReadData( | 980 MOJO_RESULT_INVALID_ARGUMENT, |
1170 ch, | 981 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), |
1171 NullUserPointer(), | 982 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_PEEK)); |
1172 MakeUserPointer(&num_bytes), | |
1173 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_PEEK)); | |
1174 | 983 |
1175 // Discard two characters. | 984 // Discard two characters. |
1176 num_bytes = 2; | 985 num_bytes = 2; |
1177 EXPECT_EQ(MOJO_RESULT_OK, | 986 EXPECT_EQ(MOJO_RESULT_OK, |
1178 core()->ReadData( | 987 core()->ReadData( |
1179 ch, | 988 ch, NullUserPointer(), MakeUserPointer(&num_bytes), |
1180 NullUserPointer(), | |
1181 MakeUserPointer(&num_bytes), | |
1182 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 989 MOJO_READ_DATA_FLAG_DISCARD | MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
1183 | 990 |
1184 // Try a two-phase read of the remaining two bytes with peek. Should fail. | 991 // Try a two-phase read of the remaining two bytes with peek. Should fail. |
1185 const void* read_ptr = nullptr; | 992 const void* read_ptr = nullptr; |
1186 num_bytes = 2; | 993 num_bytes = 2; |
1187 ASSERT_EQ(MOJO_RESULT_INVALID_ARGUMENT, | 994 ASSERT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
1188 core()->BeginReadData(ch, | 995 core()->BeginReadData(ch, MakeUserPointer(&read_ptr), |
1189 MakeUserPointer(&read_ptr), | |
1190 MakeUserPointer(&num_bytes), | 996 MakeUserPointer(&num_bytes), |
1191 MOJO_READ_DATA_FLAG_PEEK)); | 997 MOJO_READ_DATA_FLAG_PEEK)); |
1192 | 998 |
1193 // Read the remaining two characters, in two-phase mode (all-or-none). | 999 // Read the remaining two characters, in two-phase mode (all-or-none). |
1194 num_bytes = 2; | 1000 num_bytes = 2; |
1195 ASSERT_EQ(MOJO_RESULT_OK, | 1001 ASSERT_EQ(MOJO_RESULT_OK, |
1196 core()->BeginReadData(ch, | 1002 core()->BeginReadData(ch, MakeUserPointer(&read_ptr), |
1197 MakeUserPointer(&read_ptr), | |
1198 MakeUserPointer(&num_bytes), | 1003 MakeUserPointer(&num_bytes), |
1199 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 1004 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
1200 // Note: Count on still being able to do the contiguous read here. | 1005 // Note: Count on still being able to do the contiguous read here. |
1201 ASSERT_EQ(2u, num_bytes); | 1006 ASSERT_EQ(2u, num_bytes); |
1202 | 1007 |
1203 // Discarding right now should fail. | 1008 // Discarding right now should fail. |
1204 num_bytes = 1; | 1009 num_bytes = 1; |
1205 EXPECT_EQ(MOJO_RESULT_BUSY, | 1010 EXPECT_EQ(MOJO_RESULT_BUSY, |
1206 core()->ReadData(ch, | 1011 core()->ReadData(ch, NullUserPointer(), MakeUserPointer(&num_bytes), |
1207 NullUserPointer(), | |
1208 MakeUserPointer(&num_bytes), | |
1209 MOJO_READ_DATA_FLAG_DISCARD)); | 1012 MOJO_READ_DATA_FLAG_DISCARD)); |
1210 | 1013 |
1211 // Actually check our data and end the two-phase read. | 1014 // Actually check our data and end the two-phase read. |
1212 EXPECT_EQ('D', static_cast<const char*>(read_ptr)[0]); | 1015 EXPECT_EQ('D', static_cast<const char*>(read_ptr)[0]); |
1213 EXPECT_EQ('E', static_cast<const char*>(read_ptr)[1]); | 1016 EXPECT_EQ('E', static_cast<const char*>(read_ptr)[1]); |
1214 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 2u)); | 1017 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 2u)); |
1215 | 1018 |
1216 // Consumer should now be no longer readable. | 1019 // Consumer should now be no longer readable. |
1217 hss = kFullMojoHandleSignalsState; | 1020 hss = kFullMojoHandleSignalsState; |
1218 EXPECT_EQ( | 1021 EXPECT_EQ( |
(...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
1251 MojoHandleSignalsState hss; | 1054 MojoHandleSignalsState hss; |
1252 | 1055 |
1253 MojoHandle h_passing[2]; | 1056 MojoHandle h_passing[2]; |
1254 EXPECT_EQ(MOJO_RESULT_OK, | 1057 EXPECT_EQ(MOJO_RESULT_OK, |
1255 core()->CreateMessagePipe(NullUserPointer(), | 1058 core()->CreateMessagePipe(NullUserPointer(), |
1256 MakeUserPointer(&h_passing[0]), | 1059 MakeUserPointer(&h_passing[0]), |
1257 MakeUserPointer(&h_passing[1]))); | 1060 MakeUserPointer(&h_passing[1]))); |
1258 | 1061 |
1259 MojoHandle ph, ch; | 1062 MojoHandle ph, ch; |
1260 EXPECT_EQ(MOJO_RESULT_OK, | 1063 EXPECT_EQ(MOJO_RESULT_OK, |
1261 core()->CreateDataPipe( | 1064 core()->CreateDataPipe(NullUserPointer(), MakeUserPointer(&ph), |
1262 NullUserPointer(), MakeUserPointer(&ph), MakeUserPointer(&ch))); | 1065 MakeUserPointer(&ch))); |
1263 | 1066 |
1264 // Send |ch| from |h_passing[0]| to |h_passing[1]|. | 1067 // Send |ch| from |h_passing[0]| to |h_passing[1]|. |
1265 EXPECT_EQ(MOJO_RESULT_OK, | 1068 EXPECT_EQ(MOJO_RESULT_OK, |
1266 core()->WriteMessage(h_passing[0], | 1069 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
1267 UserPointer<const void>(kHello), | 1070 kHelloSize, MakeUserPointer(&ch), 1, |
1268 kHelloSize, | |
1269 MakeUserPointer(&ch), | |
1270 1, | |
1271 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1071 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1272 hss = kEmptyMojoHandleSignalsState; | 1072 hss = kEmptyMojoHandleSignalsState; |
1273 EXPECT_EQ(MOJO_RESULT_OK, | 1073 EXPECT_EQ(MOJO_RESULT_OK, |
1274 core()->Wait(h_passing[1], | 1074 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1275 MOJO_HANDLE_SIGNAL_READABLE, | |
1276 1000000000, | |
1277 MakeUserPointer(&hss))); | 1075 MakeUserPointer(&hss))); |
1278 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1076 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1279 hss.satisfied_signals); | 1077 hss.satisfied_signals); |
1280 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1078 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1281 hss.satisfiable_signals); | 1079 hss.satisfiable_signals); |
1282 num_bytes = kBufferSize; | 1080 num_bytes = kBufferSize; |
1283 num_handles = arraysize(handles); | 1081 num_handles = arraysize(handles); |
1284 EXPECT_EQ(MOJO_RESULT_OK, | 1082 EXPECT_EQ(MOJO_RESULT_OK, |
1285 core()->ReadMessage(h_passing[1], | 1083 core()->ReadMessage( |
1286 UserPointer<void>(buffer), | 1084 h_passing[1], UserPointer<void>(buffer), |
1287 MakeUserPointer(&num_bytes), | 1085 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
1288 MakeUserPointer(handles), | 1086 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
1289 MakeUserPointer(&num_handles), | |
1290 MOJO_READ_MESSAGE_FLAG_NONE)); | |
1291 EXPECT_EQ(kHelloSize, num_bytes); | 1087 EXPECT_EQ(kHelloSize, num_bytes); |
1292 EXPECT_STREQ(kHello, buffer); | 1088 EXPECT_STREQ(kHello, buffer); |
1293 EXPECT_EQ(1u, num_handles); | 1089 EXPECT_EQ(1u, num_handles); |
1294 MojoHandle ch_received = handles[0]; | 1090 MojoHandle ch_received = handles[0]; |
1295 EXPECT_NE(ch_received, MOJO_HANDLE_INVALID); | 1091 EXPECT_NE(ch_received, MOJO_HANDLE_INVALID); |
1296 EXPECT_NE(ch_received, h_passing[0]); | 1092 EXPECT_NE(ch_received, h_passing[0]); |
1297 EXPECT_NE(ch_received, h_passing[1]); | 1093 EXPECT_NE(ch_received, h_passing[1]); |
1298 EXPECT_NE(ch_received, ph); | 1094 EXPECT_NE(ch_received, ph); |
1299 | 1095 |
1300 // Note: We rely on the Mojo system not re-using handle values very often. | 1096 // Note: We rely on the Mojo system not re-using handle values very often. |
1301 EXPECT_NE(ch_received, ch); | 1097 EXPECT_NE(ch_received, ch); |
1302 | 1098 |
1303 // |ch| should no longer be valid; check that trying to close it fails. See | 1099 // |ch| should no longer be valid; check that trying to close it fails. See |
1304 // above note. | 1100 // above note. |
1305 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ch)); | 1101 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ch)); |
1306 | 1102 |
1307 // Write to |ph|. Should receive on |ch_received|. | 1103 // Write to |ph|. Should receive on |ch_received|. |
1308 num_bytes = kWorldSize; | 1104 num_bytes = kWorldSize; |
1309 EXPECT_EQ(MOJO_RESULT_OK, | 1105 EXPECT_EQ(MOJO_RESULT_OK, |
1310 core()->WriteData(ph, | 1106 core()->WriteData(ph, UserPointer<const void>(kWorld), |
1311 UserPointer<const void>(kWorld), | |
1312 MakeUserPointer(&num_bytes), | 1107 MakeUserPointer(&num_bytes), |
1313 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); | 1108 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); |
1314 hss = kEmptyMojoHandleSignalsState; | 1109 hss = kEmptyMojoHandleSignalsState; |
1315 EXPECT_EQ(MOJO_RESULT_OK, | 1110 EXPECT_EQ(MOJO_RESULT_OK, |
1316 core()->Wait(ch_received, | 1111 core()->Wait(ch_received, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1317 MOJO_HANDLE_SIGNAL_READABLE, | |
1318 1000000000, | |
1319 MakeUserPointer(&hss))); | 1112 MakeUserPointer(&hss))); |
1320 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1113 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
1321 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1114 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
1322 num_bytes = kBufferSize; | 1115 num_bytes = kBufferSize; |
1323 EXPECT_EQ(MOJO_RESULT_OK, | 1116 EXPECT_EQ(MOJO_RESULT_OK, |
1324 core()->ReadData(ch_received, | 1117 core()->ReadData(ch_received, UserPointer<void>(buffer), |
1325 UserPointer<void>(buffer), | |
1326 MakeUserPointer(&num_bytes), | 1118 MakeUserPointer(&num_bytes), |
1327 MOJO_READ_MESSAGE_FLAG_NONE)); | 1119 MOJO_READ_MESSAGE_FLAG_NONE)); |
1328 EXPECT_EQ(kWorldSize, num_bytes); | 1120 EXPECT_EQ(kWorldSize, num_bytes); |
1329 EXPECT_STREQ(kWorld, buffer); | 1121 EXPECT_STREQ(kWorld, buffer); |
1330 | 1122 |
1331 // Now pass |ph| in the same direction. | 1123 // Now pass |ph| in the same direction. |
1332 EXPECT_EQ(MOJO_RESULT_OK, | 1124 EXPECT_EQ(MOJO_RESULT_OK, |
1333 core()->WriteMessage(h_passing[0], | 1125 core()->WriteMessage(h_passing[0], UserPointer<const void>(kWorld), |
1334 UserPointer<const void>(kWorld), | 1126 kWorldSize, MakeUserPointer(&ph), 1, |
1335 kWorldSize, | |
1336 MakeUserPointer(&ph), | |
1337 1, | |
1338 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1127 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1339 hss = kEmptyMojoHandleSignalsState; | 1128 hss = kEmptyMojoHandleSignalsState; |
1340 EXPECT_EQ(MOJO_RESULT_OK, | 1129 EXPECT_EQ(MOJO_RESULT_OK, |
1341 core()->Wait(h_passing[1], | 1130 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1342 MOJO_HANDLE_SIGNAL_READABLE, | |
1343 1000000000, | |
1344 MakeUserPointer(&hss))); | 1131 MakeUserPointer(&hss))); |
1345 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1132 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1346 hss.satisfied_signals); | 1133 hss.satisfied_signals); |
1347 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1134 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1348 hss.satisfiable_signals); | 1135 hss.satisfiable_signals); |
1349 num_bytes = kBufferSize; | 1136 num_bytes = kBufferSize; |
1350 num_handles = arraysize(handles); | 1137 num_handles = arraysize(handles); |
1351 EXPECT_EQ(MOJO_RESULT_OK, | 1138 EXPECT_EQ(MOJO_RESULT_OK, |
1352 core()->ReadMessage(h_passing[1], | 1139 core()->ReadMessage( |
1353 UserPointer<void>(buffer), | 1140 h_passing[1], UserPointer<void>(buffer), |
1354 MakeUserPointer(&num_bytes), | 1141 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
1355 MakeUserPointer(handles), | 1142 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
1356 MakeUserPointer(&num_handles), | |
1357 MOJO_READ_MESSAGE_FLAG_NONE)); | |
1358 EXPECT_EQ(kWorldSize, num_bytes); | 1143 EXPECT_EQ(kWorldSize, num_bytes); |
1359 EXPECT_STREQ(kWorld, buffer); | 1144 EXPECT_STREQ(kWorld, buffer); |
1360 EXPECT_EQ(1u, num_handles); | 1145 EXPECT_EQ(1u, num_handles); |
1361 MojoHandle ph_received = handles[0]; | 1146 MojoHandle ph_received = handles[0]; |
1362 EXPECT_NE(ph_received, MOJO_HANDLE_INVALID); | 1147 EXPECT_NE(ph_received, MOJO_HANDLE_INVALID); |
1363 EXPECT_NE(ph_received, h_passing[0]); | 1148 EXPECT_NE(ph_received, h_passing[0]); |
1364 EXPECT_NE(ph_received, h_passing[1]); | 1149 EXPECT_NE(ph_received, h_passing[1]); |
1365 EXPECT_NE(ph_received, ch_received); | 1150 EXPECT_NE(ph_received, ch_received); |
1366 | 1151 |
1367 // Again, rely on the Mojo system not re-using handle values very often. | 1152 // Again, rely on the Mojo system not re-using handle values very often. |
1368 EXPECT_NE(ph_received, ph); | 1153 EXPECT_NE(ph_received, ph); |
1369 | 1154 |
1370 // |ph| should no longer be valid; check that trying to close it fails. See | 1155 // |ph| should no longer be valid; check that trying to close it fails. See |
1371 // above note. | 1156 // above note. |
1372 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ph)); | 1157 EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, core()->Close(ph)); |
1373 | 1158 |
1374 // Write to |ph_received|. Should receive on |ch_received|. | 1159 // Write to |ph_received|. Should receive on |ch_received|. |
1375 num_bytes = kHelloSize; | 1160 num_bytes = kHelloSize; |
1376 EXPECT_EQ(MOJO_RESULT_OK, | 1161 EXPECT_EQ(MOJO_RESULT_OK, |
1377 core()->WriteData(ph_received, | 1162 core()->WriteData(ph_received, UserPointer<const void>(kHello), |
1378 UserPointer<const void>(kHello), | |
1379 MakeUserPointer(&num_bytes), | 1163 MakeUserPointer(&num_bytes), |
1380 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); | 1164 MOJO_WRITE_DATA_FLAG_ALL_OR_NONE)); |
1381 hss = kEmptyMojoHandleSignalsState; | 1165 hss = kEmptyMojoHandleSignalsState; |
1382 EXPECT_EQ(MOJO_RESULT_OK, | 1166 EXPECT_EQ(MOJO_RESULT_OK, |
1383 core()->Wait(ch_received, | 1167 core()->Wait(ch_received, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1384 MOJO_HANDLE_SIGNAL_READABLE, | |
1385 1000000000, | |
1386 MakeUserPointer(&hss))); | 1168 MakeUserPointer(&hss))); |
1387 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1169 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
1388 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1170 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
1389 num_bytes = kBufferSize; | 1171 num_bytes = kBufferSize; |
1390 EXPECT_EQ(MOJO_RESULT_OK, | 1172 EXPECT_EQ(MOJO_RESULT_OK, |
1391 core()->ReadData(ch_received, | 1173 core()->ReadData(ch_received, UserPointer<void>(buffer), |
1392 UserPointer<void>(buffer), | |
1393 MakeUserPointer(&num_bytes), | 1174 MakeUserPointer(&num_bytes), |
1394 MOJO_READ_MESSAGE_FLAG_NONE)); | 1175 MOJO_READ_MESSAGE_FLAG_NONE)); |
1395 EXPECT_EQ(kHelloSize, num_bytes); | 1176 EXPECT_EQ(kHelloSize, num_bytes); |
1396 EXPECT_STREQ(kHello, buffer); | 1177 EXPECT_STREQ(kHello, buffer); |
1397 | 1178 |
1398 ph = ph_received; | 1179 ph = ph_received; |
1399 ph_received = MOJO_HANDLE_INVALID; | 1180 ph_received = MOJO_HANDLE_INVALID; |
1400 ch = ch_received; | 1181 ch = ch_received; |
1401 ch_received = MOJO_HANDLE_INVALID; | 1182 ch_received = MOJO_HANDLE_INVALID; |
1402 | 1183 |
1403 // Make sure that |ph| can't be sent if it's in a two-phase write. | 1184 // Make sure that |ph| can't be sent if it's in a two-phase write. |
1404 void* write_ptr = nullptr; | 1185 void* write_ptr = nullptr; |
1405 num_bytes = 0; | 1186 num_bytes = 0; |
1406 ASSERT_EQ(MOJO_RESULT_OK, | 1187 ASSERT_EQ(MOJO_RESULT_OK, |
1407 core()->BeginWriteData(ph, | 1188 core()->BeginWriteData(ph, MakeUserPointer(&write_ptr), |
1408 MakeUserPointer(&write_ptr), | |
1409 MakeUserPointer(&num_bytes), | 1189 MakeUserPointer(&num_bytes), |
1410 MOJO_WRITE_DATA_FLAG_NONE)); | 1190 MOJO_WRITE_DATA_FLAG_NONE)); |
1411 ASSERT_GE(num_bytes, 1u); | 1191 ASSERT_GE(num_bytes, 1u); |
1412 EXPECT_EQ(MOJO_RESULT_BUSY, | 1192 EXPECT_EQ(MOJO_RESULT_BUSY, |
1413 core()->WriteMessage(h_passing[0], | 1193 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
1414 UserPointer<const void>(kHello), | 1194 kHelloSize, MakeUserPointer(&ph), 1, |
1415 kHelloSize, | |
1416 MakeUserPointer(&ph), | |
1417 1, | |
1418 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1195 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1419 | 1196 |
1420 // But |ch| can, even if |ph| is in a two-phase write. | 1197 // But |ch| can, even if |ph| is in a two-phase write. |
1421 EXPECT_EQ(MOJO_RESULT_OK, | 1198 EXPECT_EQ(MOJO_RESULT_OK, |
1422 core()->WriteMessage(h_passing[0], | 1199 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
1423 UserPointer<const void>(kHello), | 1200 kHelloSize, MakeUserPointer(&ch), 1, |
1424 kHelloSize, | |
1425 MakeUserPointer(&ch), | |
1426 1, | |
1427 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1201 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1428 ch = MOJO_HANDLE_INVALID; | 1202 ch = MOJO_HANDLE_INVALID; |
1429 EXPECT_EQ(MOJO_RESULT_OK, | 1203 EXPECT_EQ(MOJO_RESULT_OK, |
1430 core()->Wait(h_passing[1], | 1204 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1431 MOJO_HANDLE_SIGNAL_READABLE, | |
1432 1000000000, | |
1433 NullUserPointer())); | 1205 NullUserPointer())); |
1434 num_bytes = kBufferSize; | 1206 num_bytes = kBufferSize; |
1435 num_handles = arraysize(handles); | 1207 num_handles = arraysize(handles); |
1436 EXPECT_EQ(MOJO_RESULT_OK, | 1208 EXPECT_EQ(MOJO_RESULT_OK, |
1437 core()->ReadMessage(h_passing[1], | 1209 core()->ReadMessage( |
1438 UserPointer<void>(buffer), | 1210 h_passing[1], UserPointer<void>(buffer), |
1439 MakeUserPointer(&num_bytes), | 1211 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
1440 MakeUserPointer(handles), | 1212 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
1441 MakeUserPointer(&num_handles), | |
1442 MOJO_READ_MESSAGE_FLAG_NONE)); | |
1443 EXPECT_EQ(kHelloSize, num_bytes); | 1213 EXPECT_EQ(kHelloSize, num_bytes); |
1444 EXPECT_STREQ(kHello, buffer); | 1214 EXPECT_STREQ(kHello, buffer); |
1445 EXPECT_EQ(1u, num_handles); | 1215 EXPECT_EQ(1u, num_handles); |
1446 ch = handles[0]; | 1216 ch = handles[0]; |
1447 EXPECT_NE(ch, MOJO_HANDLE_INVALID); | 1217 EXPECT_NE(ch, MOJO_HANDLE_INVALID); |
1448 | 1218 |
1449 // Complete the two-phase write. | 1219 // Complete the two-phase write. |
1450 static_cast<char*>(write_ptr)[0] = 'x'; | 1220 static_cast<char*>(write_ptr)[0] = 'x'; |
1451 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 1)); | 1221 EXPECT_EQ(MOJO_RESULT_OK, core()->EndWriteData(ph, 1)); |
1452 | 1222 |
1453 // Wait for |ch| to be readable. | 1223 // Wait for |ch| to be readable. |
1454 hss = kEmptyMojoHandleSignalsState; | 1224 hss = kEmptyMojoHandleSignalsState; |
1455 EXPECT_EQ( | 1225 EXPECT_EQ(MOJO_RESULT_OK, core()->Wait(ch, MOJO_HANDLE_SIGNAL_READABLE, |
1456 MOJO_RESULT_OK, | 1226 1000000000, MakeUserPointer(&hss))); |
1457 core()->Wait( | |
1458 ch, MOJO_HANDLE_SIGNAL_READABLE, 1000000000, MakeUserPointer(&hss))); | |
1459 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); | 1227 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfied_signals); |
1460 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); | 1228 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE, hss.satisfiable_signals); |
1461 | 1229 |
1462 // Make sure that |ch| can't be sent if it's in a two-phase read. | 1230 // Make sure that |ch| can't be sent if it's in a two-phase read. |
1463 const void* read_ptr = nullptr; | 1231 const void* read_ptr = nullptr; |
1464 num_bytes = 1; | 1232 num_bytes = 1; |
1465 ASSERT_EQ(MOJO_RESULT_OK, | 1233 ASSERT_EQ(MOJO_RESULT_OK, |
1466 core()->BeginReadData(ch, | 1234 core()->BeginReadData(ch, MakeUserPointer(&read_ptr), |
1467 MakeUserPointer(&read_ptr), | |
1468 MakeUserPointer(&num_bytes), | 1235 MakeUserPointer(&num_bytes), |
1469 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); | 1236 MOJO_READ_DATA_FLAG_ALL_OR_NONE)); |
1470 EXPECT_EQ(MOJO_RESULT_BUSY, | 1237 EXPECT_EQ(MOJO_RESULT_BUSY, |
1471 core()->WriteMessage(h_passing[0], | 1238 core()->WriteMessage(h_passing[0], UserPointer<const void>(kHello), |
1472 UserPointer<const void>(kHello), | 1239 kHelloSize, MakeUserPointer(&ch), 1, |
1473 kHelloSize, | |
1474 MakeUserPointer(&ch), | |
1475 1, | |
1476 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1240 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1477 | 1241 |
1478 // But |ph| can, even if |ch| is in a two-phase read. | 1242 // But |ph| can, even if |ch| is in a two-phase read. |
1479 EXPECT_EQ(MOJO_RESULT_OK, | 1243 EXPECT_EQ(MOJO_RESULT_OK, |
1480 core()->WriteMessage(h_passing[0], | 1244 core()->WriteMessage(h_passing[0], UserPointer<const void>(kWorld), |
1481 UserPointer<const void>(kWorld), | 1245 kWorldSize, MakeUserPointer(&ph), 1, |
1482 kWorldSize, | |
1483 MakeUserPointer(&ph), | |
1484 1, | |
1485 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 1246 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
1486 ph = MOJO_HANDLE_INVALID; | 1247 ph = MOJO_HANDLE_INVALID; |
1487 hss = kEmptyMojoHandleSignalsState; | 1248 hss = kEmptyMojoHandleSignalsState; |
1488 EXPECT_EQ(MOJO_RESULT_OK, | 1249 EXPECT_EQ(MOJO_RESULT_OK, |
1489 core()->Wait(h_passing[1], | 1250 core()->Wait(h_passing[1], MOJO_HANDLE_SIGNAL_READABLE, 1000000000, |
1490 MOJO_HANDLE_SIGNAL_READABLE, | |
1491 1000000000, | |
1492 MakeUserPointer(&hss))); | 1251 MakeUserPointer(&hss))); |
1493 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1252 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1494 hss.satisfied_signals); | 1253 hss.satisfied_signals); |
1495 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, | 1254 EXPECT_EQ(MOJO_HANDLE_SIGNAL_READABLE | MOJO_HANDLE_SIGNAL_WRITABLE, |
1496 hss.satisfiable_signals); | 1255 hss.satisfiable_signals); |
1497 num_bytes = kBufferSize; | 1256 num_bytes = kBufferSize; |
1498 num_handles = arraysize(handles); | 1257 num_handles = arraysize(handles); |
1499 EXPECT_EQ(MOJO_RESULT_OK, | 1258 EXPECT_EQ(MOJO_RESULT_OK, |
1500 core()->ReadMessage(h_passing[1], | 1259 core()->ReadMessage( |
1501 UserPointer<void>(buffer), | 1260 h_passing[1], UserPointer<void>(buffer), |
1502 MakeUserPointer(&num_bytes), | 1261 MakeUserPointer(&num_bytes), MakeUserPointer(handles), |
1503 MakeUserPointer(handles), | 1262 MakeUserPointer(&num_handles), MOJO_READ_MESSAGE_FLAG_NONE)); |
1504 MakeUserPointer(&num_handles), | |
1505 MOJO_READ_MESSAGE_FLAG_NONE)); | |
1506 EXPECT_EQ(kWorldSize, num_bytes); | 1263 EXPECT_EQ(kWorldSize, num_bytes); |
1507 EXPECT_STREQ(kWorld, buffer); | 1264 EXPECT_STREQ(kWorld, buffer); |
1508 EXPECT_EQ(1u, num_handles); | 1265 EXPECT_EQ(1u, num_handles); |
1509 ph = handles[0]; | 1266 ph = handles[0]; |
1510 EXPECT_NE(ph, MOJO_HANDLE_INVALID); | 1267 EXPECT_NE(ph, MOJO_HANDLE_INVALID); |
1511 | 1268 |
1512 // Complete the two-phase read. | 1269 // Complete the two-phase read. |
1513 EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); | 1270 EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); |
1514 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 1)); | 1271 EXPECT_EQ(MOJO_RESULT_OK, core()->EndReadData(ch, 1)); |
1515 | 1272 |
1516 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); | 1273 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[0])); |
1517 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); | 1274 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(h_passing[1])); |
1518 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ph)); | 1275 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ph)); |
1519 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ch)); | 1276 EXPECT_EQ(MOJO_RESULT_OK, core()->Close(ch)); |
1520 } | 1277 } |
1521 | 1278 |
1522 // TODO(vtl): Test |DuplicateBufferHandle()| and |MapBuffer()|. | 1279 // TODO(vtl): Test |DuplicateBufferHandle()| and |MapBuffer()|. |
1523 | 1280 |
1524 } // namespace | 1281 } // namespace |
1525 } // namespace system | 1282 } // namespace system |
1526 } // namespace mojo | 1283 } // namespace mojo |
OLD | NEW |