Home
last modified time | relevance | path

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

/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dlame_client.cc83 if (op->send_ping.on_ack != nullptr) { in lame_start_transport_op()
84 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_ack, in lame_start_transport_op()
Dchannel_ping.cc60 op->send_ping.on_ack = &pr->closure; in grpc_channel_ping()
/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/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport_op_string.cc157 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in grpc_transport_op_string()
Dtransport.h365 grpc_closure* on_ack = nullptr; member
/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/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/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc115 grpc_closure* on_ack) { in Ping() argument
119 op->send_ping.on_ack = on_ack; in Ping()
Dsubchannel.h83 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
Dclient_channel.cc2477 connected_subchannel->Ping(op->send_ping.on_initiate, op->send_ping.on_ack); in DoPingLocked()
2497 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in StartTransportOpLocked()
2502 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_ack, error); in StartTransportOpLocked()
2506 op->send_ping.on_ack = nullptr; in StartTransportOpLocked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc149 grpc_closure* on_initiate, grpc_closure* on_ack);
1629 grpc_closure* on_initiate, grpc_closure* on_ack) { in send_ping_locked() argument
1633 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_ack, in send_ping_locked()
1640 grpc_closure_list_append(&pq->lists[GRPC_CHTTP2_PCL_NEXT], on_ack, in send_ping_locked()
1776 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in perform_transport_op_locked()
1777 send_ping_locked(t, op->send_ping.on_initiate, op->send_ping.on_ack); in perform_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()