Home
last modified time | relevance | path

Searched refs:on_initiate (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()
/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()
/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.h363 grpc_closure* on_initiate = nullptr; member
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dsubchannel.h96 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
Dsubchannel.cc835 void ConnectedSubchannel::Ping(grpc_closure* on_initiate, in Ping() argument
839 op->send_ping.on_initiate = on_initiate; in Ping()
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()
589 pick_state.connected_subchannel->Ping(op->send_ping.on_initiate, in start_transport_op_locked()
596 GRPC_CLOSURE_SCHED(op->send_ping.on_initiate, GRPC_ERROR_REF(error)); in start_transport_op_locked()
601 op->send_ping.on_initiate = nullptr; in start_transport_op_locked()
/external/grpc-grpc/src/core/lib/transport/
Dtransport.h281 grpc_closure* on_initiate; 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.cc114 void ConnectedSubchannel::Ping(grpc_closure* on_initiate, in Ping() argument
118 op->send_ping.on_initiate = on_initiate; 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()
2500 ExecCtx::Run(DEBUG_LOCATION, op->send_ping.on_initiate, in StartTransportOpLocked()
2505 op->send_ping.on_initiate = nullptr; in StartTransportOpLocked()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc137 grpc_closure* on_initiate,
1700 grpc_closure* on_initiate, grpc_closure* on_ack) { in send_ping_locked() argument
1702 GRPC_CLOSURE_SCHED(on_initiate, GRPC_ERROR_REF(t->closed_with_error)); in send_ping_locked()
1707 grpc_closure_list_append(&pq->lists[GRPC_CHTTP2_PCL_INITIATE], on_initiate, 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()
/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
1631 grpc_core::ExecCtx::Run(DEBUG_LOCATION, on_initiate, in send_ping_locked()
1638 grpc_closure_list_append(&pq->lists[GRPC_CHTTP2_PCL_INITIATE], on_initiate, 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()