/external/libchrome/mojo/core/ |
D | shared_buffer_unittest.cc | 66 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 …]
|
D | message_pipe_unittest.cc | 54 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 …]
|
D | embedder_unittest.cc | 88 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 …]
|
D | invitation_unittest.cc | 233 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 …]
|
D | core_unittest.cc | 60 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()
|
D | trap_unittest.cc | 205 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 …]
|
D | multiprocess_message_pipe_unittest.cc | 97 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 …]
|
D | signals_unittest.cc | 65 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()
|
D | message_unittest.cc | 233 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()
|
D | message_pipe_dispatcher.h | 53 MojoResult ReadMessage(
|
/external/perfetto/src/trace_processor/rpc/ |
D | proto_ring_buffer_unittest.cc | 110 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()
|
D | proto_ring_buffer.h | 122 Message ReadMessage();
|
/external/libchrome/mojo/core/ports/ |
D | ports_unittest.cc | 166 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/ |
D | invitation_unittest.cc | 147 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()
|
D | wait_unittest.cc | 35 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()
|
D | wait_set_unittest.cc | 33 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/ |
D | CodedInputStreamExtensions.cs | 45 public static T ReadMessage<T>(this CodedInputStream stream, MessageParser<T> parser) 49 stream.ReadMessage(message);
|
/external/protobuf/csharp/src/Google.Protobuf.Test/ |
D | CodedInputStreamExtensions.cs | 45 public static T ReadMessage<T>(this CodedInputStream stream, MessageParser<T> parser) 49 stream.ReadMessage(message);
|
/external/libchrome/mojo/core/test/ |
D | mojo_test_base.cc | 164 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()
|
D | mojo_test_base.h | 104 static std::string ReadMessage(MojoHandle mp); 108 static void ReadMessage(MojoHandle mp, char* data, size_t num_bytes);
|
/external/openscreen/osp/go/ |
D | server.go | 23 msg, err := ReadMessage(stream)
|
D | messages.go | 27 func ReadMessage(r io.Reader) (interface{}, error) { func
|
/external/protobuf/csharp/src/Google.Protobuf.Test/TestProtos/ |
D | UnittestWellKnownTypes.cs | 797 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/ |
D | Messages.cs | 898 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/ |
D | RouteGuide.cs | 383 input.ReadMessage(lo_); in MergeFrom() 390 input.ReadMessage(hi_); in MergeFrom() 564 input.ReadMessage(location_); in MergeFrom() 732 input.ReadMessage(location_); in MergeFrom()
|