Home
last modified time | relevance | path

Searched refs:read_done (Results 1 – 4 of 4) sorted by relevance

/external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/
DCFStreamEndpointTests.mm154 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/
Dendpoint_tests.cc111 int read_done; member
128 state->read_done = 1 + (error == GRPC_ERROR_NONE); in read_and_write_test_read_handler()
200 state.read_done = 0; in read_and_write_test()
232 while (!state.read_done || !state.write_done) { in read_and_write_test()
/external/grpc-grpc/test/cpp/qps/
Dserver_async.cc338 next_state_ = &ServerRpcContextStreamingImpl::read_done; in request_done()
343 bool read_done(bool ok) { in read_done() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingImpl
361 next_state_ = &ServerRpcContextStreamingImpl::read_done; in write_done()
417 next_state_ = &ServerRpcContextStreamingFromClientImpl::read_done; in request_done()
422 bool read_done(bool ok) { in read_done() function in grpc::testing::AsyncQpsServerTest::ServerRpcContextStreamingFromClientImpl
/external/grpc-grpc/test/core/bad_client/
Dbad_client.cc74 gpr_event* read_done = static_cast<gpr_event*>(arg); in set_read_done() local
75 gpr_event_set(read_done, (void*)1); in set_read_done()