Home
last modified time | relevance | path

Searched refs:on_consumed (Results 1 – 15 of 15) sorted by relevance

/external/grpc-grpc/src/core/lib/transport/
Dtransport.h253 grpc_closure* on_consumed; member
371 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_consumed);
376 grpc_closure* on_consumed);
Dtransport.cc262 op->op.on_consumed = &op->outer_on_complete;
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/
Dlame_client.cc88 if (op->on_consumed != nullptr) { in lame_start_transport_op()
89 ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in lame_start_transport_op()
/external/grpc-grpc/src/core/lib/surface/
Dlame_client.cc115 if (op->on_consumed != nullptr) { in lame_start_transport_op()
116 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in lame_start_transport_op()
/external/grpc-grpc/test/core/channel/
Dchannel_stack_builder_test.cc55 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in channel_func()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/
Dtransport.h332 grpc_closure* on_consumed = nullptr; member
Dtransport.cc234 op->op.on_consumed = &op->outer_on_complete;
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_idle/
Dclient_idle_filter.cc377 idle_transport_op_.on_consumed = &idle_transport_op_complete_callback_; in EnterIdle()
/external/grpc-grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc1119 if (op->on_consumed) { in perform_transport_op()
1120 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in perform_transport_op()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/
Dinproc_transport.cc1161 if (op->on_consumed) { in perform_transport_op()
1162 grpc_core::ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in perform_transport_op()
/external/grpc-grpc/test/cpp/microbenchmarks/
Dbm_call_create.cc654 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in StartTransportOp()
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1830 GRPC_CLOSURE_RUN(op->on_consumed, GRPC_ERROR_NONE); in perform_transport_op_locked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/
Dchttp2_transport.cc1793 grpc_core::ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in perform_transport_op_locked()
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc637 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in start_transport_op_locked()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dclient_channel.cc2543 ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in StartTransportOpLocked()