| /external/grpc-grpc/include/grpcpp/test/ |
| D | mock_stream.h | 61 MOCK_METHOD0_T(WritesDone, bool());
81 MOCK_METHOD0_T(WritesDone, bool());
122 MOCK_METHOD1_T(WritesDone, void(void*));
142 MOCK_METHOD1_T(WritesDone, void(void*));
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/test/ |
| D | mock_stream.h | 61 MOCK_METHOD0_T(WritesDone, bool());
82 MOCK_METHOD0_T(WritesDone, bool());
123 MOCK_METHOD1_T(WritesDone, void(void*));
143 MOCK_METHOD1_T(WritesDone, void(void*));
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/test/ |
| D | mock_stream.h | 61 MOCK_METHOD0_T(WritesDone, bool());
82 MOCK_METHOD0_T(WritesDone, bool());
123 MOCK_METHOD1_T(WritesDone, void(void*));
143 MOCK_METHOD1_T(WritesDone, void(void*));
|
| /external/grpc-grpc/test/cpp/util/ |
| D | cli_call.cc | 45 call.WritesDone(); in Call()
114 void CliCall::WritesDone() { in WritesDone() function in grpc::testing::CliCall
118 call_->WritesDone(tag(4)); in WritesDone()
138 call_->WritesDone(tag(4)); in WritesDoneAndWait()
|
| D | cli_call.h | 62 void WritesDone();
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | client_sync.cc | 227 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingPingPongClient()
262 stream_[thread_idx]->WritesDone(); in ThreadFuncImpl()
284 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingFromClientClient()
315 stream_[thread_idx]->WritesDone(); in ThreadFuncImpl()
383 [this](size_t thread_idx) { stream_[thread_idx]->WritesDone(); }); in ~SynchronousStreamingBothWaysClient()
|
| /external/grpc-grpc/doc/cpp/ |
| D | perf_notes.md | 5 Generally, each write operation (Write(), WritesDone()) implies a syscall.
22 - the call is finished for writing (WritesDone() called on the client,
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | mock_test.cc | 97 cstream->WritesDone(); in DoRequestStream()
151 stream->WritesDone(); in DoBidiStream()
284 EXPECT_CALL(*w, WritesDone()); in TEST_F()
335 EXPECT_CALL(*rw, WritesDone()); in TEST_F()
|
| D | server_early_return_test.cc | 167 stream->WritesDone(); in DoBidiStream()
198 stream->WritesDone(); in DoRequestStream()
|
| D | exception_test.cc | 106 stream->WritesDone(); in TEST_F()
|
| D | filter_end2end_test.cc | 186 call->WritesDone(tag(3)); in SendRpc()
305 cli_stream->WritesDone(tag(7)); in TEST_F()
|
| D | generic_end2end_test.cc | 136 call->WritesDone(tag(3)); in SendRpc()
308 cli_stream->WritesDone(tag(7)); in TEST_F()
|
| D | streaming_throughput_test.cc | 182 stream->WritesDone(); in TEST_F()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | fullstack_streaming_ping_pong.h | 116 request_rw->WritesDone(tag(0)); in BM_StreamingPingPong()
205 request_rw->WritesDone(tag(0)); in BM_StreamingPingPongMsgs()
366 request_rw->WritesDone(tag(6)); in BM_StreamingPingPongWithCoalescingApi()
|
| /external/grpc-grpc/test/cpp/interop/ |
| D | interop_client.cc | 410 GPR_ASSERT(stream->WritesDone()); in DoRequestStreaming()
514 GPR_ASSERT(stream->WritesDone()); in DoClientCompressedStreaming()
646 stream->WritesDone(); in DoHalfDuplex()
706 stream->WritesDone(); in DoPingPong()
808 stream->WritesDone(); in DoEmptyStream()
852 stream->WritesDone(); in DoStatusWithMessage()
990 stream->WritesDone(); in DoCustomMetadata()
|
| /external/grpc-grpc/examples/cpp/route_guide/ |
| D | route_guide_client.cc | 141 writer->WritesDone(); in RecordRoute()
172 stream->WritesDone(); in RouteChat()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | sync_stream.h | 274 virtual bool WritesDone() = 0;
342 bool WritesDone() override { in WritesDone() function
425 virtual bool WritesDone() = 0;
513 bool WritesDone() override { in WritesDone() function
|
| D | async_stream.h | 312 virtual void WritesDone(void* tag) = 0;
404 void WritesDone(void* tag) override { in WritesDone() function
482 virtual void WritesDone(void* tag) = 0;
581 void WritesDone(void* tag) override { in WritesDone() function
|
| /external/rust/crates/grpcio-sys/grpc/include/grpcpp/impl/codegen/ |
| D | client_callback.h | 152 virtual void WritesDone() = 0;
188 virtual void WritesDone() = 0;
275 void StartWritesDone() { stream_->WritesDone(); } in StartWritesDone()
399 void StartWritesDone() { writer_->WritesDone(); } in StartWritesDone()
548 void WritesDone() override { in WritesDone() function
945 void WritesDone() override { in WritesDone() function
|
| D | sync_stream.h | 275 virtual bool WritesDone() = 0;
343 bool WritesDone() override { in WritesDone() function
426 virtual bool WritesDone() = 0;
516 bool WritesDone() override { in WritesDone() function
|
| D | async_stream.h | 309 virtual void WritesDone(void* tag) = 0;
401 void WritesDone(void* tag) override { in WritesDone() function
479 virtual void WritesDone(void* tag) = 0;
578 void WritesDone(void* tag) override { in WritesDone() function
|
| /external/rust/crates/grpcio-sys/grpc/spm-cpp-include/grpcpp/impl/codegen/ |
| D | client_callback.h | 152 virtual void WritesDone() = 0;
188 virtual void WritesDone() = 0;
275 void StartWritesDone() { stream_->WritesDone(); } in StartWritesDone()
399 void StartWritesDone() { writer_->WritesDone(); } in StartWritesDone()
548 void WritesDone() override { in WritesDone() function
945 void WritesDone() override { in WritesDone() function
|
| D | sync_stream.h | 275 virtual bool WritesDone() = 0;
343 bool WritesDone() override { in WritesDone() function
426 virtual bool WritesDone() = 0;
516 bool WritesDone() override { in WritesDone() function
|
| D | async_stream.h | 309 virtual void WritesDone(void* tag) = 0;
401 void WritesDone(void* tag) override { in WritesDone() function
479 virtual void WritesDone(void* tag) = 0;
578 void WritesDone(void* tag) override { in WritesDone() function
|
| /external/grpc-grpc/src/proto/grpc/testing/ |
| D | benchmark_service.proto | 34 // The server returns the client payload as-is once the client does WritesDone
|