| /aosp_15_r20/external/pigweed/pw_transfer/ |
| H A D | transfer_thread_test.cc | 106 auto reader_writer = ctx_.reader_writer(); in TEST_F() local
107 transfer_thread_.SetServerReadStream(reader_writer, [](ConstByteSpan) {}); in TEST_F()
130 auto reader_writer = ctx_.reader_writer(); in TEST_F() local
131 transfer_thread_.SetServerReadStream(reader_writer, [](ConstByteSpan) {}); in TEST_F()
161 auto reader_writer = ctx_.reader_writer(); in TEST_F() local
162 transfer_thread_.SetServerReadStream(reader_writer, [](ConstByteSpan) {}); in TEST_F()
207 auto reader_writer = ctx_.reader_writer(); in TEST_F() local
208 transfer_thread_.SetServerReadStream(reader_writer, [](ConstByteSpan) {}); in TEST_F()
322 auto reader_writer = ctx_.reader_writer(); in TEST_F() local
323 transfer_thread_.SetServerReadStream(reader_writer, [](ConstByteSpan) {}); in TEST_F()
[all …]
|
| /aosp_15_r20/external/grpc-grpc/test/cpp/end2end/ |
| H A D | proto_server_reflection_test.cc | 166 auto reader_writer = stub.ServerReflectionInfo(&context); in TEST_F() local
169 reader_writer->Write(request); in TEST_F()
171 ASSERT_EQ(reader_writer->Read(&response), true); in TEST_F()
178 reader_writer->WriteLast(request, WriteOptions()); in TEST_F()
180 ASSERT_EQ(reader_writer->Read(&response), true); in TEST_F()
192 auto reader_writer = stub.ServerReflectionInfo(&context); in TEST_F() local
195 reader_writer->Write(request); in TEST_F()
197 ASSERT_TRUE(reader_writer->Read(&response)); in TEST_F()
204 reader_writer->WriteLast(request, WriteOptions()); in TEST_F()
206 ASSERT_TRUE(reader_writer->Read(&response)); in TEST_F()
|
| H A D | generic_end2end_test.cc | 204 grpc::GenericServerAsyncReaderWriter reader_writer(&server_context); in DriveCompletionQueue() local
210 &server_context, &reader_writer, srv_cq_.get(), srv_cq_.get(), in DriveCompletionQueue()
228 reader_writer.Finish( in DriveCompletionQueue()
|
| /aosp_15_r20/external/pigweed/pw_rpc/ |
| H A D | benchmark.cc | 60 auto reader_writer = reader_writers.find(rw_id); in BidirectionalEcho() local
61 if (reader_writer == reader_writers.end()) { in BidirectionalEcho()
64 Status status = reader_writer->second.Write(request); in BidirectionalEcho()
66 reader_writer->second.Finish(status) in BidirectionalEcho()
|
| /aosp_15_r20/external/pigweed/pw_transfer/public/pw_transfer/ |
| H A D | transfer.h | 70 void Read(RawServerReaderWriter& reader_writer) { in Read() argument
71 thread_.SetServerReadStream(reader_writer, [this](ConstByteSpan message) { in Read()
76 void Write(RawServerReaderWriter& reader_writer) { in Write() argument
77 thread_.SetServerWriteStream(reader_writer, [this](ConstByteSpan message) { in Write()
|
| H A D | handler.h | 198 ReadWriteHandler(uint32_t resource_id, stream::ReaderWriter& reader_writer) in ReadWriteHandler() argument
199 : Handler(resource_id, &static_cast<stream::Reader&>(reader_writer)) {} in ReadWriteHandler()
207 void set_reader_writer(stream::ReaderWriter& reader_writer) { in set_reader_writer() argument
208 set_reader(reader_writer); in set_reader_writer()
|
| /aosp_15_r20/external/pigweed/pw_rpc/nanopb/public/pw_rpc/nanopb/internal/ |
| H A D | method.h | 264 [](Service& service, NanopbServerCall& reader_writer) {
269 reader_writer));
305 NanopbServerCall& reader_writer);
409 BaseNanopbServerReader<Request> reader_writer(
413 .function_.stream_request(context.service(), reader_writer);
|
| /aosp_15_r20/external/pigweed/pw_rpc/pwpb/public/pw_rpc/pwpb/internal/ |
| H A D | method.h | 194 [](Service& service, internal::PwpbServerCall& reader_writer) { in BidirectionalStreaming()
199 reader_writer)); in BidirectionalStreaming()
235 void (*)(Service&, internal::PwpbServerCall& reader_writer);
363 internal::BasePwpbServerReader<Request> reader_writer( in BidirectionalStreamingInvoker()
367 .function_.stream_request(context.service(), reader_writer); in BidirectionalStreamingInvoker()
|
| /aosp_15_r20/external/pigweed/pw_rpc/nanopb/ |
| H A D | codegen_test.cc | 68 reader_writer = std::move(new_reader_writer); in TestBidirectionalStreamRpc()
73 reader_writer; member in pw::rpc::test::TestService
189 context.service().reader_writer.set_on_next( in TEST()
197 context.service().reader_writer.Write({.chunk = {}, .number = 2})); in TEST()
201 context.service().reader_writer.Finish(Status::NotFound())); in TEST()
|
| H A D | method_test.cc | 186 pw_rpc_test_TestResponse>& reader_writer) { in BidirectionalStream() argument
187 last_reader_writer = std::move(reader_writer); in BidirectionalStream()
|
| /aosp_15_r20/external/pigweed/pw_rpc/pwpb/ |
| H A D | codegen_test.cc | 69 reader_writer = std::move(new_reader_writer); in TestBidirectionalStreamRpc()
76 reader_writer; member in pw::rpc::test::TestService
194 context.service().reader_writer.set_on_next( in TEST()
204 context.service().reader_writer.Write({.chunk = {}, .number = 2})); in TEST()
208 context.service().reader_writer.Finish(Status::NotFound())); in TEST()
|
| H A D | method_test.cc | 189 reader_writer) { in BidirectionalStream()
190 last_reader_writer = std::move(reader_writer); in BidirectionalStream()
|
| /aosp_15_r20/external/grpc-grpc/src/cpp/server/ |
| H A D | async_generic_service.cc | 26 GenericServerContext* ctx, GenericServerAsyncReaderWriter* reader_writer, in RequestCall() argument
29 server_->RequestAsyncGenericCall(ctx, reader_writer, call_cq, notification_cq, in RequestCall()
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/src/cpp/server/ |
| D | async_generic_service.cc | 26 GenericServerContext* ctx, GenericServerAsyncReaderWriter* reader_writer, in RequestCall() argument
29 server_->RequestAsyncGenericCall(ctx, reader_writer, call_cq, notification_cq, in RequestCall()
|
| /aosp_15_r20/external/pigweed/pw_rpc/raw/ |
| H A D | method.cc | 52 RawServerReaderWriter reader_writer(context.ClaimLocked()); in BidirectionalStreamingInvoker() local
55 .function_.stream_request(context.service(), reader_writer); in BidirectionalStreamingInvoker()
|
| H A D | method_test.cc | 134 void BidirectionalStream(RawServerReaderWriter& reader_writer) { in BidirectionalStream() argument
135 last_reader_writer = std::move(reader_writer); in BidirectionalStream()
|
| H A D | codegen_test.cc | 116 void TestBidirectionalStreamRpc(RawServerReaderWriter& reader_writer) { in TestBidirectionalStreamRpc() argument
117 last_reader_writer_ = std::move(reader_writer); in TestBidirectionalStreamRpc()
|
| /aosp_15_r20/external/pigweed/pw_rpc/raw/public/pw_rpc/raw/internal/ |
| H A D | method.h | 88 [](Service& service, RawServerReaderWriter& reader_writer) { in BidirectionalStreaming()
89 return CallMethodImplFunction<kMethod>(service, reader_writer); in BidirectionalStreaming()
|
| /aosp_15_r20/external/pigweed/pw_grpc/ |
| H A D | test_pw_rpc_server.cc | 134 reader_writer) { in BidirectionalStreamingEcho()
136 last_reader_writer_ = std::move(reader_writer); in BidirectionalStreamingEcho()
|
| /aosp_15_r20/external/pigweed/pw_rpc/public/pw_rpc/ |
| H A D | benchmark.h | 32 void BidirectionalEcho(RawServerReaderWriter& reader_writer);
|
| /aosp_15_r20/external/grpc-grpc/include/grpcpp/generic/ |
| H A D | async_generic_service.h | 72 GenericServerAsyncReaderWriter* reader_writer,
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/include/grpcpp/generic/ |
| D | async_generic_service.h | 73 GenericServerAsyncReaderWriter* reader_writer,
|
| /aosp_15_r20/external/rust/android-crates-io/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/generic/ |
| D | async_generic_service.h | 73 GenericServerAsyncReaderWriter* reader_writer,
|
| /aosp_15_r20/external/pigweed/pw_rpc/raw/public/pw_rpc/raw/ |
| H A D | test_method_context.h | 221 RawServerReaderWriter reader_writer() { in reader_writer() function
|
| /aosp_15_r20/external/pigweed/pw_rpc/pwpb/public/pw_rpc/pwpb/ |
| H A D | test_method_context.h | 335 PwpbServerReaderWriter<Request, Response> reader_writer() { in reader_writer() function
|