Searched refs:on_ack (Results 1 – 8 of 8) sorted by relevance
| /third_party/grpc/src/core/lib/surface/ |
| D | lame_client.cc | 83 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()
|
| D | channel_ping.cc | 60 op->send_ping.on_ack = &pr->closure; in grpc_channel_ping()
|
| /third_party/grpc/src/core/lib/transport/ |
| D | transport_op_string.cc | 157 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in grpc_transport_op_string()
|
| D | transport.h | 365 grpc_closure* on_ack = nullptr; member
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | subchannel.cc | 115 grpc_closure* on_ack) { in Ping() argument
119 op->send_ping.on_ack = on_ack; in Ping()
|
| D | subchannel.h | 83 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
|
| D | client_channel.cc | 2473 connected_subchannel->Ping(op->send_ping.on_initiate, op->send_ping.on_ack); in DoPingLocked()
2493 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in StartTransportOpLocked()
2498 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_ack, error); in StartTransportOpLocked()
2502 op->send_ping.on_ack = nullptr; in StartTransportOpLocked()
|
| /third_party/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 149 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()
|