Home
last modified time | relevance | path

Searched refs:send_ping (Results 1 – 14 of 14) sorted by relevance

/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dlame_client.cc79 if (op->send_ping.on_initiate != nullptr) { in lame_start_transport_op()
80 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_initiate, in lame_start_transport_op()
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()
Dchannel_ping.cc60 op->send_ping.on_ack = &pr->closure; in grpc_channel_ping()
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc104 if (op->send_ping.on_initiate != nullptr) { in lame_start_transport_op()
106 op->send_ping.on_initiate, in lame_start_transport_op()
109 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.h366 } send_ping; member
/external/grpc-grpc/src/core/lib/transport/
Dtransport_op_string.cc189 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in grpc_transport_op_string()
Dtransport.h284 } send_ping; member
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc571 if (op->send_ping.on_initiate != nullptr || op->send_ping.on_ack != nullptr) { in start_transport_op_locked()
575 GRPC_CLOSURE_SCHED(op->send_ping.on_initiate, GRPC_ERROR_REF(error)); in start_transport_op_locked()
576 GRPC_CLOSURE_SCHED(op->send_ping.on_ack, error); in start_transport_op_locked()
589 pick_state.connected_subchannel->Ping(op->send_ping.on_initiate, in start_transport_op_locked()
590 op->send_ping.on_ack); in start_transport_op_locked()
596 GRPC_CLOSURE_SCHED(op->send_ping.on_initiate, GRPC_ERROR_REF(error)); in start_transport_op_locked()
597 GRPC_CLOSURE_SCHED(op->send_ping.on_ack, error); in start_transport_op_locked()
601 op->send_ping.on_initiate = nullptr; in start_transport_op_locked()
602 op->send_ping.on_ack = nullptr; in start_transport_op_locked()
Dsubchannel.cc839 op->send_ping.on_initiate = on_initiate; in Ping()
840 op->send_ping.on_ack = on_ack; in Ping()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dsubchannel.cc118 op->send_ping.on_initiate = on_initiate; in Ping()
119 op->send_ping.on_ack = on_ack; in Ping()
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()
2500 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_initiate, in StartTransportOpLocked()
2502 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_ack, error); in StartTransportOpLocked()
2505 op->send_ping.on_initiate = nullptr; in StartTransportOpLocked()
2506 op->send_ping.on_ack = nullptr; in StartTransportOpLocked()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1815 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()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1776 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()