Home
last modified time | relevance | path

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

1234

/external/libchrome/mojo/core/
Dshared_buffer_unittest.cc66 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
85 std::string message = ReadMessage(h); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
90 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
119 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
135 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
179 EXPECT_EQ("quit", ReadMessage(parent)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
193 EXPECT_EQ("quit", ReadMessage(parent)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
252 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
273 EXPECT_EQ("ok", ReadMessage(h)); in TEST_F()
288 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
Dmessage_pipe_unittest.cc54 MojoResult ReadMessage(MojoHandle message_pipe_handle, in ReadMessage() function in mojo::core::__anon74da8ddd0111::MessagePipeTest
115 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe0_, buffer, &buffer_size)); in TEST_F()
124 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
139 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe0_, buffer, &buffer_size)); in TEST_F()
146 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe0_, buffer, &buffer_size)); in TEST_F()
163 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
175 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
182 ASSERT_EQ(MOJO_RESULT_SHOULD_WAIT, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
206 ASSERT_EQ(MOJO_RESULT_OK, ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
214 ReadMessage(pipe1_, buffer, &buffer_size)); in TEST_F()
[all …]
Dembedder_unittest.cc88 EXPECT_EQ(kHello, ReadMessage(client_mp)); in TEST_F()
117 ASSERT_EQ(std::string(i, 'A' + (i % 26)), ReadMessage(server_mp2)); in TEST_F()
152 EXPECT_EQ(kHello, ReadMessage(h1)); in TEST_F()
155 EXPECT_EQ(kFoo, ReadMessage(h1)); in TEST_F()
162 EXPECT_EQ(kBarBaz, ReadMessage(h0)); in TEST_F()
193 EXPECT_EQ("world!", ReadMessage(server_mp)); in TEST_F()
211 EXPECT_EQ("baz", ReadMessage(mp2)); in TEST_F()
235 EXPECT_EQ("hello", ReadMessage(client_mp)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
259 EXPECT_EQ("FOO", ReadMessage(mp1)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
261 EXPECT_EQ("quit", ReadMessage(client_mp)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
Dinvitation_unittest.cc233 EXPECT_EQ(kMessage, ReadMessage(pipe1)); in TEST_F()
458 EXPECT_EQ(kTestMessage3, ReadMessage(primordial_pipe)); in TEST_F()
478 ASSERT_EQ(kTestMessage1, ReadMessage(primordial_pipe)); in DEFINE_TEST_CLIENT()
497 EXPECT_EQ(kTestMessage3, ReadMessage(pipes[0])); in TEST_F()
498 EXPECT_EQ(kTestMessage4, ReadMessage(pipes[1])); in TEST_F()
523 ASSERT_EQ(kTestMessage1, ReadMessage(pipes[0])); in DEFINE_TEST_CLIENT()
524 ASSERT_EQ(kTestMessage2, ReadMessage(pipes[1])); in DEFINE_TEST_CLIENT()
541 EXPECT_EQ(kTestMessage3, ReadMessage(primordial_pipe)); in TEST_F()
561 ASSERT_EQ(kTestMessage1, ReadMessage(primordial_pipe)); in DEFINE_TEST_CLIENT()
679 EXPECT_EQ(kDisconnectMessage, ReadMessage(pipe)); in DEFINE_TEST_CLIENT()
[all …]
Dcore_unittest.cc60 ASSERT_EQ(MOJO_RESULT_OK, core()->ReadMessage(h, nullptr, &message)); in TEST_F()
62 ASSERT_EQ(MOJO_RESULT_OK, core()->ReadMessage(h, nullptr, &message)); in TEST_F()
130 core()->ReadMessage(MOJO_HANDLE_INVALID, nullptr, nullptr)); in TEST_F()
135 core()->ReadMessage(h, nullptr, nullptr)); in TEST_F()
165 core()->ReadMessage(h[0], nullptr, &message)); in TEST_F()
180 ASSERT_EQ(MOJO_RESULT_OK, core()->ReadMessage(h[0], nullptr, &message)); in TEST_F()
221 ASSERT_EQ(MOJO_RESULT_OK, core()->ReadMessage(h[1], nullptr, &message)); in TEST_F()
265 core()->ReadMessage(h_passing[1], nullptr, &message_handle)); in TEST_F()
Dtrap_unittest.cc205 EXPECT_EQ(kMessage1, ReadMessage(a)); in TEST_F()
206 EXPECT_EQ(kMessage2, ReadMessage(a)); in TEST_F()
207 EXPECT_EQ(kMessage3, ReadMessage(a)); in TEST_F()
858 EXPECT_EQ(kMessage1, ReadMessage(a)); in TEST_F()
859 EXPECT_EQ(kMessage2, ReadMessage(a)); in TEST_F()
860 EXPECT_EQ(kMessage3, ReadMessage(a)); in TEST_F()
861 EXPECT_EQ(kMessage1, ReadMessage(b)); in TEST_F()
862 EXPECT_EQ(kMessage2, ReadMessage(b)); in TEST_F()
863 EXPECT_EQ(kMessage3, ReadMessage(b)); in TEST_F()
913 EXPECT_EQ("hello a", ReadMessage(a)); in TEST_F()
[all …]
Dmultiprocess_message_pipe_unittest.cc97 EXPECT_EQ("ok", ReadMessage(h_)); in Send()
102 EXPECT_EQ("ok", ReadMessage(h_)); in SendHandle()
737 std::string message = ReadMessage(h); in DEFINE_TEST_CLIENT_WITH_PIPE()
763 std::string message = ReadMessage(p); in DEFINE_TEST_CLIENT_WITH_PIPE()
808 EXPECT_EQ(std::string("exit"), ReadMessage(h)); in DEFINE_TEST_CLIENT_WITH_PIPE()
818 WriteMessage(handles[index].value(), ReadMessage(handles[index].value())); in DEFINE_TEST_CLIENT_WITH_PIPE()
903 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
922 EXPECT_EQ("bye", ReadMessage(p0)); in TEST_P()
969 CHECK_EQ(parts[2], ReadMessage(p)); in DEFINE_TEST_CLIENT_WITH_PIPE()
1143 EXPECT_EQ("quit", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
[all …]
Dsignals_unittest.cc65 EXPECT_EQ("ok", ReadMessage(b)); in TEST_F()
114 EXPECT_EQ(kMessage, ReadMessage(d)); in TEST_F()
212 EXPECT_EQ("OK!", ReadMessage(h)); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
Dmessage_unittest.cc233 auto m = MojoTestBase::ReadMessage(h); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
285 MojoTestBase::ReadMessage(pipe.handle1.get().value())); in TEST_F()
311 MojoTestBase::ReadMessage(pipes[0].handle1.get().value())); in TEST_F()
313 MojoTestBase::ReadMessage(pipes[1].handle1.get().value())); in TEST_F()
315 MojoTestBase::ReadMessage(pipes[2].handle1.get().value())); in TEST_F()
317 MojoTestBase::ReadMessage(pipes[3].handle1.get().value())); in TEST_F()
543 EXPECT_EQ(kTestMessage, MojoTestBase::ReadMessage(extracted_handle)); in TEST_F()
919 EXPECT_EQ(kTestMessage, MojoTestBase::ReadMessage(handles[4])); in DEFINE_TEST_CLIENT_TEST_WITH_PIPE()
Dmessage_pipe_dispatcher.h53 MojoResult ReadMessage(
/external/perfetto/src/trace_processor/rpc/
Dproto_ring_buffer_unittest.cc110 auto actual = buf.ReadMessage(); in TEST_F()
119 EXPECT_FALSE(buf.ReadMessage().valid()); in TEST_F()
123 actual = buf.ReadMessage(); in TEST_F()
151 auto msg = buf.ReadMessage(); in TEST_F()
190 auto msg = buf.ReadMessage(); in TEST_F()
208 auto msg = buf.ReadMessage(); in TEST_F()
217 msg = buf.ReadMessage(); in TEST_F()
222 msg = buf.ReadMessage(); in TEST_F()
Dproto_ring_buffer.h122 Message ReadMessage();
/external/libchrome/mojo/core/ports/
Dports_unittest.cc166 bool ReadMessage(const PortRef& port, ScopedMessage* message) { in ReadMessage() function in mojo::core::ports::test::__anoncf17bb2a0111::TestNode
223 if (!ReadMessage(port, &message)) in PortStatusChanged()
599 ASSERT_TRUE(node1.ReadMessage(B, &message)); in TEST_F()
666 ASSERT_TRUE(node1.ReadMessage(B, &message)); in TEST_F()
780 ASSERT_TRUE(node1.ReadMessage(x1, &message)); in TEST_F()
791 ASSERT_TRUE(node0.ReadMessage(x0, &message)); in TEST_F()
801 ASSERT_TRUE(node0.ReadMessage(a3, &message)); in TEST_F()
947 EXPECT_TRUE(node.ReadMessage(B, &message)); in TEST_F()
986 ASSERT_TRUE(node.ReadMessage(Y, &message)); in TEST_F()
993 ASSERT_TRUE(node.ReadMessage(Y, &message)); in TEST_F()
[all …]
/external/libchrome/mojo/public/cpp/system/tests/
Dinvitation_unittest.cc147 static std::string ReadMessage(const ScopedMessagePipeHandle& pipe) { in ReadMessage() function in mojo::__anon8419464e0111::InvitationCppTest
216 CHECK_EQ(kTestMessage1, ReadMessage(pipe)); in DEFINE_TEST_CLIENT()
229 CHECK_EQ(kTestMessage1, ReadMessage(pipe)); in DEFINE_TEST_CLIENT()
245 CHECK_EQ(kTestMessage1, ReadMessage(pipe0)); in DEFINE_TEST_CLIENT()
246 CHECK_EQ(kTestMessage2, ReadMessage(pipe1)); in DEFINE_TEST_CLIENT()
305 EXPECT_EQ(kDisconnectMessage, ReadMessage(pipe)); in DEFINE_TEST_CLIENT()
Dwait_unittest.cc35 std::string ReadMessage(const ScopedMessagePipeHandle& handle) { in ReadMessage() function
115 EXPECT_EQ(kTestMessage1, ReadMessage(p.handle1)); in TEST_F()
214 EXPECT_EQ(kTestMessage1, ReadMessage(p.handle1)); in TEST_F()
Dwait_set_unittest.cc33 std::string ReadMessage(const ScopedMessagePipeHandle& handle) { in ReadMessage() function
240 EXPECT_EQ(kTestMessage1, ReadMessage(p.handle1)); in TEST_F()
296 EXPECT_EQ(kTestMessage, ReadMessage(p.handle1)); in TEST_F()
/external/protobuf/csharp/compatibility_tests/v3.0.0/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/
DCodedInputStreamExtensions.cs45 public static T ReadMessage<T>(this CodedInputStream stream, MessageParser<T> parser)
49 stream.ReadMessage(message);
/external/libchrome/mojo/core/test/
Dmojo_test_base.cc164 std::string MojoTestBase::ReadMessage(MojoHandle mp) { in ReadMessage() function in mojo::core::test::MojoTestBase
169 void MojoTestBase::ReadMessage(MojoHandle mp, char* data, size_t num_bytes) { in ReadMessage() function in mojo::core::test::MojoTestBase
189 EXPECT_TRUE(message == ReadMessage(dest)); in VerifyTransmission()
Dmojo_test_base.h104 static std::string ReadMessage(MojoHandle mp);
108 static void ReadMessage(MojoHandle mp, char* data, size_t num_bytes);
/external/openscreen/osp/go/
Dserver.go23 msg, err := ReadMessage(stream)
Dmessages.go27 func ReadMessage(r io.Reader) (interface{}, error) { func
/external/protobuf/csharp/src/Google.Protobuf.Test/TestProtos/
DUnittestWellKnownTypes.cs797 input.ReadMessage(AnyField); in MergeFrom()
804 input.ReadMessage(ApiField); in MergeFrom()
811 input.ReadMessage(DurationField); in MergeFrom()
818 input.ReadMessage(EmptyField); in MergeFrom()
825 input.ReadMessage(FieldMaskField); in MergeFrom()
832 input.ReadMessage(SourceContextField); in MergeFrom()
839 input.ReadMessage(StructField); in MergeFrom()
846 input.ReadMessage(TimestampField); in MergeFrom()
853 input.ReadMessage(TypeField); in MergeFrom()
923 input.ReadMessage(ValueField); in MergeFrom()
[all …]
/external/grpc-grpc/src/csharp/Grpc.IntegrationTesting/
DMessages.cs898 input.ReadMessage(payload_); in MergeFrom()
913 input.ReadMessage(responseCompressed_); in MergeFrom()
920 input.ReadMessage(responseStatus_); in MergeFrom()
927 input.ReadMessage(expectCompressed_); in MergeFrom()
1123 input.ReadMessage(payload_); in MergeFrom()
1305 input.ReadMessage(payload_); in MergeFrom()
1312 input.ReadMessage(expectCompressed_); in MergeFrom()
1654 input.ReadMessage(compressed_); in MergeFrom()
1882 input.ReadMessage(payload_); in MergeFrom()
1889 input.ReadMessage(responseStatus_); in MergeFrom()
[all …]
/external/grpc-grpc/examples/csharp/RouteGuide/RouteGuide/
DRouteGuide.cs383 input.ReadMessage(lo_); in MergeFrom()
390 input.ReadMessage(hi_); in MergeFrom()
564 input.ReadMessage(location_); in MergeFrom()
732 input.ReadMessage(location_); in MergeFrom()

1234