Searched refs:on_consumed (Results 1 – 8 of 8) sorted by relevance
| /third_party/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()
|
| /third_party/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;
|
| /third_party/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()
|
| /third_party/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()
|
| /third_party/grpc/test/cpp/microbenchmarks/ |
| D | bm_call_create.cc | 641 grpc_core::ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in StartTransportOp()
|
| /third_party/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()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 2539 ExecCtx::Run(DEBUG_LOCATION, op->on_consumed, GRPC_ERROR_NONE); in StartTransportOpLocked()
|