Home
last modified time | relevance | path

Searched refs:ReadMessage (Results 1 – 25 of 45) sorted by relevance

12

/external/libmojo/mojo/edk/system/
Dmessage_pipe_unittest.cc43 MojoResult ReadMessage(MojoHandle message_pipe_handle, in ReadMessage() function in mojo::edk::__anonea71b00c0111::MessagePipeTest
86 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe0_, buffer, &buffer_size)); in TEST_F()
95 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
110 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe0_, buffer, &buffer_size)); in TEST_F()
117 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe0_, buffer, &buffer_size)); in TEST_F()
134 ReadMessage(pipe1_, nullptr, &buffer_size)); in TEST_F()
143 ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
152 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
164 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
171 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
[all …]
Dshared_buffer_unittest.cc63 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
82 std::string message = ReadMessage(h); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
87 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
116 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
132 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
175 EXPECT_EQ("quit", ReadMessage(parent)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
188 EXPECT_EQ("quit", ReadMessage(parent)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
247 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
268 EXPECT_EQ("ok", ReadMessage(h)); in TEST_F()
282 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
Dcore_unittest.cc62 core()->ReadMessage(h, nullptr, &num_bytes, nullptr, nullptr, in TEST_F()
66 core()->ReadMessage(h, nullptr, nullptr, nullptr, nullptr, in TEST_F()
422 core()->ReadMessage(MOJO_HANDLE_INVALID, nullptr, nullptr, nullptr, in TEST_F()
431 core()->ReadMessage( in TEST_F()
493 core()->ReadMessage(h, nullptr, nullptr, nullptr, &handle_count, in TEST_F()
536 core()->ReadMessage(h[0], buffer, &buffer_size, nullptr, nullptr, in TEST_F()
599 core()->ReadMessage(h[0], nullptr, &buffer_size, nullptr, nullptr, in TEST_F()
607 core()->ReadMessage(h[0], buffer, &buffer_size, nullptr, nullptr, in TEST_F()
655 core()->ReadMessage(h[1], nullptr, nullptr, nullptr, nullptr, in TEST_F()
708 core()->ReadMessage( in TEST_F()
[all …]
Dmultiprocess_message_pipe_unittest.cc49 EXPECT_EQ("ok", ReadMessage(h_)); in Send()
54 EXPECT_EQ("ok", ReadMessage(h_)); in SendHandle()
728 std::string message = ReadMessage(h); in DEFINE_TEST_CLIENT_WITH_PIPE()
753 std::string message = ReadMessage(p); in DEFINE_TEST_CLIENT_WITH_PIPE()
798 EXPECT_EQ(std::string("exit"), ReadMessage(h)); in DEFINE_TEST_CLIENT_WITH_PIPE()
808 WriteMessage(handles[index], ReadMessage(handles[index])); in DEFINE_TEST_CLIENT_WITH_PIPE()
890 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
909 EXPECT_EQ("bye", ReadMessage(p0)); in TEST_F()
957 CHECK_EQ(parts[2], ReadMessage(p)); in DEFINE_TEST_CLIENT_WITH_PIPE()
1131 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
Dmessage_pipe_dispatcher.h58 MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
Dwait_set_dispatcher_unittest.cc97 void ReadMessage(MessagePipeDispatcher* dispatcher, in ReadMessage() function in mojo::edk::__anon5141c4600111::WaitSetDispatcherTest
102 dispatcher->ReadMessage(&message, num_bytes, nullptr, 0, in ReadMessage()
230 ReadMessage(dispatcher0_.get(), read_buffer, &num_bytes); in TEST_F()
Ddispatcher.h83 virtual MojoResult ReadMessage(std::unique_ptr<MessageForTransit>* message,
Ddispatcher.cc40 MojoResult Dispatcher::ReadMessage(std::unique_ptr<MessageForTransit>* message, in ReadMessage() function in mojo::edk::Dispatcher
Dcore.h180 MojoResult ReadMessage(MojoHandle message_pipe_handle,
/external/libmojo/mojo/edk/embedder/
Dembedder_unittest.cc59 EXPECT_EQ(kHello, ReadMessage(client_mp)); in TEST_F()
132 ASSERT_EQ(std::string(i, 'A' + (i % 26)), ReadMessage(server_mp2)); in TEST_F()
167 EXPECT_EQ(kHello, ReadMessage(h1)); in TEST_F()
170 EXPECT_EQ(kFoo, ReadMessage(h1)); in TEST_F()
177 EXPECT_EQ(kBarBaz, ReadMessage(h0)); in TEST_F()
197 EXPECT_EQ(kHello, ReadMessage(child_mp.get().value())); in TEST_F()
260 EXPECT_EQ("world!", ReadMessage(server_mp)); in TEST_F()
278 EXPECT_EQ("baz", ReadMessage(mp2)); in TEST_F()
302 EXPECT_EQ("hello", ReadMessage(client_mp)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
326 EXPECT_EQ("FOO", ReadMessage(mp1)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
/external/protobuf/csharp/src/Google.Protobuf.Test/
DCodedInputStreamExtensions.cs45 public static T ReadMessage<T>(this CodedInputStream stream, MessageParser<T> parser)
49 stream.ReadMessage(message);
/external/protobuf/csharp/src/Google.Protobuf.Test/TestProtos/
DUnittestWellKnownTypes.cs743 input.ReadMessage(anyField_); in MergeFrom()
750 input.ReadMessage(apiField_); in MergeFrom()
757 input.ReadMessage(durationField_); in MergeFrom()
764 input.ReadMessage(emptyField_); in MergeFrom()
771 input.ReadMessage(fieldMaskField_); in MergeFrom()
778 input.ReadMessage(sourceContextField_); in MergeFrom()
785 input.ReadMessage(structField_); in MergeFrom()
792 input.ReadMessage(timestampField_); in MergeFrom()
799 input.ReadMessage(typeField_); in MergeFrom()
869 input.ReadMessage(valueField_); in MergeFrom()
[all …]
DUnittestProto3.cs1359 input.ReadMessage(singleNestedMessage_); in MergeFrom()
1366 input.ReadMessage(singleForeignMessage_); in MergeFrom()
1373 input.ReadMessage(singleImportMessage_); in MergeFrom()
1392 input.ReadMessage(singlePublicImportMessage_); in MergeFrom()
1508 input.ReadMessage(subBuilder); in MergeFrom()
1796 input.ReadMessage(child_); in MergeFrom()
1803 input.ReadMessage(payload_); in MergeFrom()
2206 input.ReadMessage(foreignNested_); in MergeFrom()
2475 input.ReadMessage(a_); in MergeFrom()
2591 input.ReadMessage(bb_); in MergeFrom()
[all …]
/external/libmojo/mojo/edk/test/
Dmojo_test_base.cc179 std::string MojoTestBase::ReadMessage(MojoHandle mp) { in ReadMessage() function in mojo::edk::test::MojoTestBase
184 void MojoTestBase::ReadMessage(MojoHandle mp, in ReadMessage() function in mojo::edk::test::MojoTestBase
213 EXPECT_TRUE(message == ReadMessage(dest)); in VerifyTransmission()
Dmojo_test_base.h106 static std::string ReadMessage(MojoHandle mp);
110 static void ReadMessage(MojoHandle mp, char* data, size_t num_bytes);
/external/libmojo/mojo/public/c/system/
Dthunks.cc69 assert(g_thunks.ReadMessage); in MojoReadMessage()
70 return g_thunks.ReadMessage(message_pipe_handle, bytes, num_bytes, handles, in MojoReadMessage()
Dthunks.h63 MojoResult (*ReadMessage)(MojoHandle message_pipe_handle, member
/external/libmojo/mojo/public/cpp/bindings/lib/
Dmessage.cc94 MojoResult ReadMessage(MessagePipeHandle handle, Message* message) { in ReadMessage() function
Dconnector.cc265 const MojoResult rv = ReadMessage(message_pipe_.get(), &message); in ReadSingleMessage()
/external/protobuf/src/google/protobuf/
Dwire_format_unittest.cc1121 bool ReadMessage(const string &wire_buffer, T *message) { in ReadMessage() function
1168 ReadMessage(wire_buffer, &output); in TEST_F()
1205 ReadMessage(wire_buffer, &output); in TEST_F()
1233 ReadMessage(wire_buffer, &output); in TEST_F()
1251 ReadMessage(wire_buffer, &output); in TEST_F()
/external/libmojo/mojo/public/cpp/bindings/
Dmessage.h196 MojoResult ReadMessage(MessagePipeHandle handle, Message* message);
/external/libmojo/mojo/edk/js/
Dcore.cc155 gin::Dictionary ReadMessage(const gin::Arguments& args, in ReadMessage() function
314 .SetMethod("readMessage", ReadMessage) in GetModule()
/external/protobuf/csharp/src/Google.Protobuf/WellKnownTypes/
DStruct.cs474 input.ReadMessage(subBuilder); in MergeFrom()
483 input.ReadMessage(subBuilder); in MergeFrom()
DType.cs320 input.ReadMessage(sourceContext_); in MergeFrom()
1023 input.ReadMessage(sourceContext_); in MergeFrom()
1334 input.ReadMessage(value_); in MergeFrom()
/external/protobuf/csharp/src/Google.Protobuf.Conformance/
DConformance.cs3000 input.ReadMessage(optionalNestedMessage_); in MergeFrom()
3007 input.ReadMessage(optionalForeignMessage_); in MergeFrom()
3030 input.ReadMessage(recursiveMessage_); in MergeFrom()
3217 input.ReadMessage(subBuilder); in MergeFrom()
3332 input.ReadMessage(optionalDuration_); in MergeFrom()
3339 input.ReadMessage(optionalTimestamp_); in MergeFrom()
3346 input.ReadMessage(optionalFieldMask_); in MergeFrom()
3353 input.ReadMessage(optionalStruct_); in MergeFrom()
3360 input.ReadMessage(optionalAny_); in MergeFrom()
3367 input.ReadMessage(optionalValue_); in MergeFrom()
[all …]

12