Searched refs:on_consumed (Results 1 – 15 of 15) sorted by relevance
/external/grpc-grpc/src/core/lib/transport/ |
D | transport.h | 253 grpc_closure* on_consumed; member 371 grpc_transport_op* grpc_make_transport_op(grpc_closure* on_consumed); 376 grpc_closure* on_consumed);
|
D | transport.cc | 262 op->op.on_consumed = &op->outer_on_complete;
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
D | lame_client.cc | 88 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/ |
D | lame_client.cc | 115 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/ |
D | channel_stack_builder_test.cc | 55 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in channel_func()
|
/external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
D | transport.h | 332 grpc_closure* on_consumed = nullptr; member
|
D | transport.cc | 234 op->op.on_consumed = &op->outer_on_complete;
|
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_idle/ |
D | client_idle_filter.cc | 377 idle_transport_op_.on_consumed = &idle_transport_op_complete_callback_; in EnterIdle()
|
/external/grpc-grpc/src/core/ext/transport/inproc/ |
D | inproc_transport.cc | 1119 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/ |
D | inproc_transport.cc | 1161 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/ |
D | bm_call_create.cc | 654 GRPC_CLOSURE_SCHED(op->on_consumed, GRPC_ERROR_NONE); in StartTransportOp()
|
/external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
D | chttp2_transport.cc | 1830 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/ |
D | chttp2_transport.cc | 1793 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/ |
D | client_channel.cc | 637 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/ |
D | client_channel.cc | 2543 ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in StartTransportOpLocked()
|