Home
last modified time | relevance | path

Searched refs:on_ack (Results 1 – 8 of 8) sorted by relevance

/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc109 if (op->send_ping.on_ack != nullptr) { in lame_start_transport_op()
111 op->send_ping.on_ack, in lame_start_transport_op()
Dchannel_ping.cc61 op->send_ping.on_ack = &pr->closure; in grpc_channel_ping()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h283 grpc_closure* on_ack; member
Dtransport_op_string.cc189 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/
Dsubchannel.h96 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
Dsubchannel.cc836 grpc_closure* on_ack) { in Ping() argument
840 op->send_ping.on_ack = on_ack; in Ping()
Dclient_channel.cc571 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/
Dchttp2_transport.cc1700 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()