Home
last modified time | relevance | path

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

12345

/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::__anon0383d23b0111::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()
/external/perfetto/src/protozero/
Dproto_ring_buffer_unittest.cc111 auto actual = buf.ReadMessage(); in TEST_F()
120 EXPECT_FALSE(buf.ReadMessage().valid()); in TEST_F()
124 actual = buf.ReadMessage(); in TEST_F()
152 auto msg = buf.ReadMessage(); in TEST_F()
191 auto msg = buf.ReadMessage(); in TEST_F()
209 auto msg = buf.ReadMessage(); in TEST_F()
218 msg = buf.ReadMessage(); in TEST_F()
223 msg = buf.ReadMessage(); in TEST_F()
256 EXPECT_FALSE(buf.ReadMessage().valid()); in TEST()
258 EXPECT_FALSE(buf.ReadMessage().valid()); in TEST()
[all …]
/external/libchrome/mojo/core/ports/
Dports_unittest.cc166 bool ReadMessage(const PortRef& port, ScopedMessage* message) { in ReadMessage() function in mojo::core::ports::test::__anon955aebc80111::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::__anona713926c0111::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()
/external/cronet/third_party/protobuf/csharp/src/Google.Protobuf.Test/
DCodedInputStreamExtensions.cs45 public static T ReadMessage<T>(this CodedInputStream stream, MessageParser<T> parser)
49 stream.ReadMessage(message);
DLegacyGeneratedCodeTest.cs199 input.ReadMessage(Bb); in MergeFrom()
284 input.ReadMessage(A); in IBufferMessage.InternalMergeFrom()
/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);
DLegacyGeneratedCodeTest.cs199 input.ReadMessage(Bb); in MergeFrom()
284 input.ReadMessage(A); in IBufferMessage.InternalMergeFrom()
/external/cronet/third_party/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/cronet/third_party/protobuf/csharp/src/Google.Protobuf.Test.TestProtos/
DUnittestWellKnownTypes.cs918 input.ReadMessage(AnyField); in MergeFrom()
925 input.ReadMessage(ApiField); in MergeFrom()
932 input.ReadMessage(DurationField); in MergeFrom()
939 input.ReadMessage(EmptyField); in MergeFrom()
946 input.ReadMessage(FieldMaskField); in MergeFrom()
953 input.ReadMessage(SourceContextField); in MergeFrom()
960 input.ReadMessage(StructField); in MergeFrom()
967 input.ReadMessage(TimestampField); in MergeFrom()
974 input.ReadMessage(TypeField); in MergeFrom()
1044 input.ReadMessage(ValueField); in MergeFrom()
[all …]
/external/protobuf/csharp/src/Google.Protobuf.Test.TestProtos/
DUnittestWellKnownTypes.cs918 input.ReadMessage(AnyField); in MergeFrom()
925 input.ReadMessage(ApiField); in MergeFrom()
932 input.ReadMessage(DurationField); in MergeFrom()
939 input.ReadMessage(EmptyField); in MergeFrom()
946 input.ReadMessage(FieldMaskField); in MergeFrom()
953 input.ReadMessage(SourceContextField); in MergeFrom()
960 input.ReadMessage(StructField); in MergeFrom()
967 input.ReadMessage(TimestampField); in MergeFrom()
974 input.ReadMessage(TypeField); in MergeFrom()
1044 input.ReadMessage(ValueField); in MergeFrom()
[all …]
/external/perfetto/src/protozero/test/
Dproto_ring_buffer_benchmark.cc34 protozero::ProtoRingBuffer::Message msg = buffer.ReadMessage(); in BM_ProtoRingBufferReadLargeChunks()
61 protozero::ProtoRingBuffer::Message msg = buffer.ReadMessage(); in BM_ProtoRingBufferRead()
/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/cronet/third_party/protobuf/csharp/src/Google.Protobuf.Benchmarks/
DParseMessagesBenchmark.cs231 input.ReadMessage(msg); in ParseDelimitedMessagesFromByteArray()
241 ctx.ReadMessage(msg); in ParseDelimitedMessagesFromReadOnlySequence()
/external/protobuf/csharp/src/Google.Protobuf.Benchmarks/
DParseMessagesBenchmark.cs231 input.ReadMessage(msg); in ParseDelimitedMessagesFromByteArray()
241 ctx.ReadMessage(msg); in ParseDelimitedMessagesFromReadOnlySequence()
/external/crosvm/devices/src/virtio/snd/common_backend/
Dasync_funcs.rs616 let pcm_xfer: virtio_snd_pcm_xfer = reader.read_obj().map_err(Error::ReadMessage)?; in handle_pcm_queue()
705 .map_err(Error::ReadMessage)? in handle_ctrl_queue()
713 reader.read_obj().map_err(Error::ReadMessage)?; in handle_ctrl_queue()
743 reader.read_obj().map_err(Error::ReadMessage)?; in handle_ctrl_queue()
773 reader.read_obj().map_err(Error::ReadMessage)?; in handle_ctrl_queue()
807 reader.read_obj().map_err(Error::ReadMessage)?; in handle_ctrl_queue()
887 let hdr: virtio_snd_pcm_hdr = reader.read_obj().map_err(Error::ReadMessage)?; in handle_ctrl_queue()

12345