Searched refs:on_ack (Results 1 – 8 of 8) sorted by relevance
/external/grpc-grpc/src/core/lib/surface/ |
D | lame_client.cc | 109 if (op->send_ping.on_ack != nullptr) { in lame_start_transport_op() 111 op->send_ping.on_ack, in lame_start_transport_op()
|
D | channel_ping.cc | 61 op->send_ping.on_ack = &pr->closure; in grpc_channel_ping()
|
/external/grpc-grpc/src/core/lib/transport/ |
D | transport.h | 283 grpc_closure* on_ack; member
|
D | transport_op_string.cc | 189 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in grpc_transport_op_string()
|
/external/grpc-grpc/src/core/ext/filters/client_channel/ |
D | subchannel.h | 96 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
|
D | subchannel.cc | 836 grpc_closure* on_ack) { in Ping() argument 840 op->send_ping.on_ack = on_ack; in Ping()
|
D | client_channel.cc | 571 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in start_transport_op_locked() 576 GRPC_CLOSURE_SCHED(op->send_ping.on_ack, error); in start_transport_op_locked() 590 op->send_ping.on_ack); in start_transport_op_locked() 597 GRPC_CLOSURE_SCHED(op->send_ping.on_ack, error); in start_transport_op_locked() 602 op->send_ping.on_ack = nullptr; in start_transport_op_locked()
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | chttp2_transport.cc | 1700 grpc_closure* on_initiate, grpc_closure* on_ack) { in send_ping_locked() argument 1703 GRPC_CLOSURE_SCHED(on_ack, GRPC_ERROR_REF(t->closed_with_error)); in send_ping_locked() 1709 grpc_closure_list_append(&pq->lists[GRPC_CHTTP2_PCL_NEXT], on_ack, in send_ping_locked() 1815 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in perform_transport_op_locked() 1816 send_ping_locked(t, op->send_ping.on_initiate, op->send_ping.on_ack); in perform_transport_op_locked()
|