Searched refs:on_initiate (Results 1 – 7 of 7) sorted by relevance
| /external/grpc-grpc/src/core/lib/surface/ |
| D | lame_client.cc | 104 if (op->send_ping.on_initiate != nullptr) { in lame_start_transport_op()
106 op->send_ping.on_initiate, in lame_start_transport_op()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 281 grpc_closure* on_initiate; member
|
| D | transport_op_string.cc | 189 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/ |
| D | subchannel.h | 96 void Ping(grpc_closure* on_initiate, grpc_closure* on_ack);
|
| D | subchannel.cc | 835 void ConnectedSubchannel::Ping(grpc_closure* on_initiate, in Ping() argument
839 op->send_ping.on_initiate = on_initiate; in Ping()
|
| D | client_channel.cc | 571 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/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 137 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()
|