| /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/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();
|
| D | proto_reflection_descriptor_database.cc | 43 stream_->WritesDone(); in ~ProtoReflectionDescriptorDatabase()
|
| D | grpc_tool.cc | 650 call.WritesDone(); in CallMethod()
747 call.WritesDone(); in CallMethod()
|
| /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()
|
| D | driver.cc | 452 if (!client->stream->WritesDone()) { in RunScenario()
498 if (!server->stream->WritesDone()) { in RunScenario()
|
| /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 | filter_end2end_test.cc | 186 call->WritesDone(tag(3)); in SendRpc()
305 cli_stream->WritesDone(tag(7)); in TEST_F()
|
| D | exception_test.cc | 106 stream->WritesDone(); 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()
|
| D | raw_end2end_test.cc | 250 cli_stream->WritesDone(tag(7)); in TEST_F()
339 cli_stream->WritesDone(tag(7)); in TEST_F()
|
| D | end2end_test.cc | 400 stream->WritesDone(); in TestRequestStreamServerCancel()
559 stream->WritesDone(); in TestBidiStreamServerCancel()
741 stream->WritesDone(); in TEST_P()
773 stream->WritesDone(); in TEST_P()
789 stream->WritesDone(); in TEST_P()
887 stream->WritesDone(); in TEST_P()
1109 stream->WritesDone(); in TEST_P()
|
| D | server_load_reporting_end2end_test.cc | 178 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()
|
| D | fullstack_streaming_pump.h | 84 request_rw->WritesDone(tag(1)); in BM_PumpStreamClientToServer()
|
| /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/grpc-grpc/src/proto/grpc/testing/ |
| D | benchmark_service.proto | 34 // The server returns the client payload as-is once the client does WritesDone
|
| /external/grpc-grpc-java/benchmarks/src/main/proto/grpc/testing/ |
| D | services.proto | 37 // The server returns the client payload as-is once the client does WritesDone
|