| /external/libmojo/mojo/edk/system/ |
| shared_buffer_unittest.cc | 63 EXPECT_EQ("quit", ReadMessage(h));
82 std::string message = ReadMessage(h);
87 EXPECT_EQ("quit", ReadMessage(h));
116 EXPECT_EQ("quit", ReadMessage(h));
132 EXPECT_EQ("quit", ReadMessage(h));
175 EXPECT_EQ("quit", ReadMessage(parent));
188 EXPECT_EQ("quit", ReadMessage(parent));
247 EXPECT_EQ("quit", ReadMessage(h));
268 EXPECT_EQ("ok", ReadMessage(h));
282 EXPECT_EQ("quit", ReadMessage(h))
[all...] |
| message_pipe_unittest.cc | 43 MojoResult ReadMessage(MojoHandle message_pipe_handle,
86 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe0_, buffer, &buffer_size));
95 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe1_, buffer, &buffer_size));
110 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe0_, buffer, &buffer_size));
117 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe0_, buffer, &buffer_size));
134 ReadMessage(pipe1_, nullptr, &buffer_size));
143 ReadMessage(pipe1_, buffer, &buffer_size));
152 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size));
164 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size));
171 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe1_, buffer, &buffer_size))
[all...] |
| core_unittest.cc | 62 core()->ReadMessage(h, nullptr, &num_bytes, nullptr, nullptr,
66 core()->ReadMessage(h, nullptr, nullptr, nullptr, nullptr,
416 // |ReadMessage()|:
422 core()->ReadMessage(MOJO_HANDLE_INVALID, nullptr, nullptr, nullptr,
431 core()->ReadMessage(
484 // |ReadMessage()|:
493 core()->ReadMessage(h, nullptr, nullptr, nullptr, &handle_count,
536 core()->ReadMessage(h[0], buffer, &buffer_size, nullptr, nullptr,
599 core()->ReadMessage(h[0], nullptr, &buffer_size, nullptr, nullptr,
607 core()->ReadMessage(h[0], buffer, &buffer_size, nullptr, nullptr
[all...] |
| message_pipe_dispatcher.h | 57 MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
|
| multiprocess_message_pipe_unittest.cc | 52 EXPECT_EQ("ok", ReadMessage(h_));
57 EXPECT_EQ("ok", ReadMessage(h_));
740 std::string message = ReadMessage(h);
765 std::string message = ReadMessage(p);
811 EXPECT_EQ(std::string("exit"), ReadMessage(h));
821 WriteMessage(handles[index], ReadMessage(handles[index]));
[all...] |
| dispatcher.cc | 40 MojoResult Dispatcher::ReadMessage(std::unique_ptr<MessageForTransit>* message,
|
| dispatcher.h | 83 virtual MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
|
| wait_set_dispatcher_unittest.cc | 97 void ReadMessage(MessagePipeDispatcher* dispatcher,
102 dispatcher->ReadMessage(&message, num_bytes, nullptr, 0,
230 ReadMessage(dispatcher0_.get(), read_buffer, &num_bytes);
|
| core.h | 191 MojoResult ReadMessage(MojoHandle message_pipe_handle,
|
| core_test_base.cc | 58 MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
|
| /external/libmojo/mojo/edk/embedder/ |
| embedder_unittest.cc | 67 EXPECT_EQ(kHello, ReadMessage(client_mp));
140 ASSERT_EQ(std::string(i, 'A' + (i % 26)), ReadMessage(server_mp2));
175 EXPECT_EQ(kHello, ReadMessage(h1));
178 EXPECT_EQ(kFoo, ReadMessage(h1));
185 EXPECT_EQ(kBarBaz, ReadMessage(h0));
204 EXPECT_EQ(kHello, ReadMessage(child_mp.get().value()));
266 EXPECT_EQ("world!", ReadMessage(server_mp));
284 EXPECT_EQ("baz", ReadMessage(mp2));
308 EXPECT_EQ("hello", ReadMessage(client_mp));
332 EXPECT_EQ("FOO", ReadMessage(mp1))
[all...] |
| entrypoints.cc | 129 return g_core->ReadMessage(
|
| /external/libmojo/mojo/edk/system/ports/ |
| ports_unittest.cc | 174 bool ReadMessage(const PortRef& port, ScopedMessage* message) {
242 if (!ReadMessage(port, &message))
630 ASSERT_TRUE(node1.ReadMessage(B, &message));
697 ASSERT_TRUE(node1.ReadMessage(B, &message));
815 ASSERT_TRUE(node1.ReadMessage(x1, &message));
826 ASSERT_TRUE(node0.ReadMessage(x0, &message));
836 ASSERT_TRUE(node0.ReadMessage(a3, &message));
982 EXPECT_TRUE(node.ReadMessage(B, &message));
1021 ASSERT_TRUE(node.ReadMessage(Y, &message));
1028 ASSERT_TRUE(node.ReadMessage(Y, &message))
[all...] |
| /external/libmojo/mojo/edk/test/ |
| mojo_test_base.h | 110 static std::string ReadMessage(MojoHandle mp);
114 static void ReadMessage(MojoHandle mp, char* data, size_t num_bytes);
|
| mojo_test_base.cc | 186 std::string MojoTestBase::ReadMessage(MojoHandle mp) {
191 void MojoTestBase::ReadMessage(MojoHandle mp,
220 EXPECT_TRUE(message == ReadMessage(dest));
|
| /system/core/init/ |
| subcontext.cpp | 64 Result<std::string> ReadMessage(int socket) {
178 auto init_message = ReadMessage(init_fd_);
281 auto subcontext_message = ReadMessage(socket_);
|
| /prebuilts/go/darwin-x86/src/net/mail/ |
| example_test.go | 54 m, err := mail.ReadMessage(r)
|
| /prebuilts/go/linux-x86/src/net/mail/ |
| example_test.go | 54 m, err := mail.ReadMessage(r)
|
| /external/libmojo/mojo/public/c/system/ |
| thunks.h | 63 MojoResult (*ReadMessage)(MojoHandle message_pipe_handle,
|
| thunks.cc | 69 assert(g_thunks.ReadMessage);
70 return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles,
|
| /external/libmojo/mojo/public/cpp/bindings/ |
| message.h | 295 MojoResult ReadMessage(MessagePipeHandle handle, Message* message);
|
| /external/libmojo/mojo/edk/js/ |
| core.cc | 155 gin::Dictionary ReadMessage(const gin::Arguments& args,
314 .SetMethod("readMessage", ReadMessage)
|
| /external/libmojo/mojo/public/cpp/bindings/lib/ |
| connector.cc | 253 const MojoResult rv = ReadMessage(message_pipe_.get(), &message);
|
| /external/protobuf/src/google/protobuf/ |
| wire_format_unittest.cc | [all...] |
| /external/protobuf/csharp/src/Google.Protobuf.Test/TestProtos/ |
| UnittestWellKnownTypes.cs | [all...] |
