| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_worker.cc | 106 ServerReaderWriter<ClientStatus, ClientArgs>* stream) override { in RunClient()
120 ServerReaderWriter<ServerStatus, ServerArgs>* stream) override { in RunServer()
181 ServerReaderWriter<ClientStatus, ClientArgs>* stream) { in RunClientBody()
221 ServerReaderWriter<ServerStatus, ServerArgs>* stream) { in RunServerBody()
|
| D | server_sync.cc | 49 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override { in StreamingCall()
84 ServerReaderWriter<SimpleResponse, SimpleRequest>* stream) override { in StreamingBothWays()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | streaming_throughput_test.cc | 91 ServerReaderWriter<EchoResponse, EchoRequest>* stream, in BidiStream_Sender()
110 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
|
| D | client_crash_test_server.cc | 49 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
|
| D | test_service_impl.h | 66 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override;
|
| D | server_crash_test.cc | 54 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
|
| D | server_early_return_test.cc | 77 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
|
| D | test_service_impl.cc | 278 ServerReaderWriter<EchoResponse, EchoRequest>* stream) { in BidiStream()
|
| D | mock_test.cc | 198 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | method_handler_impl.h | 237 ServerReaderWriter<ResponseType, RequestType>, false> {
241 ServerReaderWriter<ResponseType, RequestType>*)> in BidiStreamingHandler()
245 ServerReaderWriter<ResponseType, RequestType>, false>(std::bind( in BidiStreamingHandler()
|
| D | sync_stream.h | 772 class ServerReaderWriter final : public ServerReaderWriterInterface<W, R> {
798 friend class internal::TemplatedBidiStreamingHandler<ServerReaderWriter<W, R>,
800 ServerReaderWriter(internal::Call* call, ServerContext* ctx) in ServerReaderWriter() function
|
| /external/grpc-grpc/examples/cpp/route_guide/ |
| D | route_guide_server.cc | 38 using grpc::ServerReaderWriter;
149 ServerReaderWriter<RouteNote, RouteNote>* stream) override { in RouteChat()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_server.cc | 53 using grpc::ServerReaderWriter;
255 ServerReaderWriter<StreamingOutputCallResponse, in FullDuplexCall()
291 ServerReaderWriter<StreamingOutputCallResponse, in HalfDuplexCall()
|
| D | reconnect_interop_server.cc | 51 using grpc::ServerReaderWriter;
|
| /external/grpc-grpc/test/core/tsi/alts/fake_handshaker/ |
| D | fake_handshaker_server.cc | 63 ServerReaderWriter<HandshakerResp, HandshakerReq>* stream) override { in DoHandshake()
220 ServerReaderWriter<HandshakerResp, HandshakerReq>* stream, in WriteErrorResponse()
|
| /external/tensorflow/tensorflow/core/debug/ |
| D | debug_grpc_testlib.h | 41 ::grpc::ServerReaderWriter< ::tensorflow::EventReply,
|
| D | debug_grpc_testlib.cc | 34 ::grpc::ServerReaderWriter<::tensorflow::EventReply, ::tensorflow::Event>* in SendEvents()
|
| /external/grpc-grpc/src/cpp/ext/ |
| D | proto_server_reflection.h | 42 ServerReaderWriter<reflection::v1alpha::ServerReflectionResponse,
|
| D | proto_server_reflection.cc | 49 ServerReaderWriter<ServerReflectionResponse, ServerReflectionRequest>* in ServerReflectionInfo()
|
| /external/flatbuffers/tests/ |
| D | monster_test.grpc.fb.h | 150 …:Status GetMinMaxHitPoints(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< flatbuffers…
224 …::grpc::Status GetMinMaxHitPoints(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< flat… in GetMinMaxHitPoints()
296 …::grpc::Status GetMinMaxHitPoints(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< flat… in GetMinMaxHitPoints()
|
| D | monster_test.grpc.fb.cc | 133 …ervice::GetMinMaxHitPoints(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< flatbuffers… in GetMinMaxHitPoints()
|
| /external/grpc-grpc/test/cpp/client/ |
| D | client_channel_stress_test.cc | 68 using Stream = ServerReaderWriter<LoadBalanceResponse, LoadBalanceRequest>;
|
| /external/grpc-grpc/test/cpp/codegen/ |
| D | compiler_test_golden | 226 …virtual ::grpc::Status MethodA4(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc…
301 …::grpc::Status MethodA4(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testin…
373 …::grpc::Status MethodA4(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testin…
450 …::grpc::Status MethodA4(::grpc::ServerContext* context, ::grpc::ServerReaderWriter< ::grpc::testin…
|
| /external/grpc-grpc/examples/cpp/ |
| D | cpptutorial.md | 267 ServerReaderWriter<RouteNote, RouteNote>* stream) override {
284 This time we get a `ServerReaderWriter` that can be used to read *and* write
|
| /external/grpc-grpc/test/cpp/util/ |
| D | grpc_tool_test.cc | 191 ServerReaderWriter<EchoResponse, EchoRequest>* stream) override { in BidiStream()
|