Home
last modified time | relevance | path

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

123

/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::__anone631497f0111::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(
Dquota_unittest.cc183 EXPECT_EQ(kTestMessage, ReadMessage(b)); in TEST_F()
242 EXPECT_EQ(kTestMessage, ReadMessage(b)); in TEST_F()
/external/libchrome/mojo/core/ports/
Dports_unittest.cc166 bool ReadMessage(const PortRef& port, ScopedMessage* message) { in ReadMessage() function in mojo::core::ports::test::__anon08d48a8c0111::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::__anon611efa300111::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/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 …]
/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/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 …]
DControl.cs592 input.ReadMessage(subBuilder); in MergeFrom()
601 input.ReadMessage(subBuilder); in MergeFrom()
1550 input.ReadMessage(securityParams_); in MergeFrom()
1573 input.ReadMessage(loadParams_); in MergeFrom()
1580 input.ReadMessage(payloadConfig_); in MergeFrom()
1587 input.ReadMessage(histogramParams_); in MergeFrom()
1751 input.ReadMessage(stats_); in MergeFrom()
2080 input.ReadMessage(subBuilder); in MergeFrom()
2089 input.ReadMessage(subBuilder); in MergeFrom()
2483 input.ReadMessage(securityParams_); in MergeFrom()
[all …]
DPayloads.cs683 input.ReadMessage(subBuilder); in MergeFrom()
692 input.ReadMessage(subBuilder); in MergeFrom()
701 input.ReadMessage(subBuilder); in MergeFrom()
/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()
/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/grpc-grpc/src/csharp/Grpc.Reflection/
DReflection.cs402 input.ReadMessage(subBuilder); in MergeFrom()
903 input.ReadMessage(originalRequest_); in MergeFrom()
911 input.ReadMessage(subBuilder); in MergeFrom()
920 input.ReadMessage(subBuilder); in MergeFrom()
929 input.ReadMessage(subBuilder); in MergeFrom()
938 input.ReadMessage(subBuilder); in MergeFrom()

123