| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| CFStreamEndpointTests.mm | 154 grpc_closure read_done;
189 init_event_closure(&read_done, &read);
190 grpc_endpoint_read(ep_, &read_one_slice, &read_done);
208 grpc_closure read_done;
220 init_event_closure(&read_done, &read);
221 grpc_endpoint_read(ep_, &read_slices, &read_done);
257 grpc_closure read_done;
268 init_event_closure(&read_done, &read);
270 grpc_endpoint_read(ep_, &read_slices, &read_done);
304 grpc_closure read_done;
[all...] |
| /external/grpc-grpc/test/core/iomgr/ |
| endpoint_tests.cc | 111 int read_done; member in struct:read_and_write_test_state
128 state->read_done = 1 + (error == GRPC_ERROR_NONE);
200 state.read_done = 0;
232 while (!state.read_done || !state.write_done) {
|
| /external/grpc-grpc/test/cpp/qps/ |
| server_async.cc | 338 next_state_ = &ServerRpcContextStreamingImpl::read_done;
343 bool read_done(bool ok) { function in class:grpc::testing::final::final
361 next_state_ = &ServerRpcContextStreamingImpl::read_done;
417 next_state_ = &ServerRpcContextStreamingFromClientImpl::read_done;
422 bool read_done(bool ok) { function in class:grpc::testing::final::final
|
| /external/grpc-grpc/test/core/bad_client/ |
| bad_client.cc | 72 /* Sets the read_done event */
74 gpr_event* read_done = static_cast<gpr_event*>(arg); local
75 gpr_event_set(read_done, (void*)1);
|
