| /external/grpc-grpc/src/core/lib/transport/ |
| D | transport.h | 165 grpc_handler_private_op_data handler_private; member
292 grpc_handler_private_op_data handler_private; member
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 2817 CallData* calld = static_cast<CallData*>(batch->handler_private.extra_arg); in FailPendingBatchInCallCombiner()
2841 batch->handler_private.extra_arg = this; in PendingBatchesFail()
2842 GRPC_CLOSURE_INIT(&batch->handler_private.closure, in PendingBatchesFail()
2845 closures.Add(&batch->handler_private.closure, GRPC_ERROR_REF(error), in PendingBatchesFail()
2864 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in ResumePendingBatchInCallCombiner()
2888 batch->handler_private.extra_arg = elem; in PendingBatchesResume()
2889 GRPC_CLOSURE_INIT(&batch->handler_private.closure, in PendingBatchesResume()
2891 closures.Add(&batch->handler_private.closure, GRPC_ERROR_NONE, in PendingBatchesResume()
3549 static_cast<RetryingCall*>(batch->handler_private.extra_arg); in FailPendingBatchInCallCombiner()
3575 batch->handler_private.extra_arg = this; in PendingBatchesFail()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/transport/ |
| D | transport.h | 217 grpc_handler_private_op_data handler_private; member
374 grpc_handler_private_op_data handler_private; member
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 388 static_cast<SubchannelCall*>(batch->handler_private.extra_arg); in StartBatchInCallCombiner()
394 batch->handler_private.extra_arg = call_; in StartBatch()
395 GRPC_CLOSURE_INIT(&batch->handler_private.closure, StartBatchInCallCombiner, in StartBatch()
397 GRPC_CALL_COMBINER_START(&call_combiner_, &batch->handler_private.closure, in StartBatch()
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 100 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_credentials_metadata()
236 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_host_checked()
304 batch->handler_private.extra_arg = elem; in auth_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 560 static_cast<grpc_channel_element*>(op->handler_private.extra_arg); in start_transport_op_locked()
649 op->handler_private.extra_arg = elem; in cc_start_transport_op()
652 GRPC_CLOSURE_INIT(&op->handler_private.closure, start_transport_op_locked, in cc_start_transport_op()
1223 call_data* calld = static_cast<call_data*>(batch->handler_private.extra_arg); in fail_pending_batch_in_call_combiner()
1250 batch->handler_private.extra_arg = calld; in pending_batches_fail()
1251 GRPC_CLOSURE_INIT(&batch->handler_private.closure, in pending_batches_fail()
1254 closures.Add(&batch->handler_private.closure, GRPC_ERROR_REF(error), in pending_batches_fail()
1273 static_cast<grpc_subchannel_call*>(batch->handler_private.extra_arg); in resume_pending_batch_in_call_combiner()
1303 batch->handler_private.extra_arg = calld->subchannel_call; in pending_batches_resume()
1304 GRPC_CLOSURE_INIT(&batch->handler_private.closure, in pending_batches_resume()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | client_auth_filter.cc | 162 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_credentials_metadata()
333 static_cast<grpc_call_element*>(batch->handler_private.extra_arg); in on_host_checked()
379 batch->handler_private.extra_arg = elem; in client_auth_start_transport_stream_op_batch()
|
| /external/grpc-grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1367 static_cast<grpc_chttp2_stream*>(op->handler_private.extra_arg); in perform_stream_op_locked()
1395 on_complete = GRPC_CLOSURE_INIT(&op->handler_private.closure, do_nothing, in perform_stream_op_locked()
1679 op->handler_private.extra_arg = gs; in perform_stream_op()
1682 GRPC_CLOSURE_INIT(&op->handler_private.closure, perform_stream_op_locked, in perform_stream_op()
1795 static_cast<grpc_chttp2_transport*>(op->handler_private.extra_arg); in perform_transport_op_locked()
1842 op->handler_private.extra_arg = gt; in perform_transport_op()
1844 GRPC_CLOSURE_SCHED(GRPC_CLOSURE_INIT(&op->handler_private.closure, in perform_transport_op()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/chttp2/transport/ |
| D | chttp2_transport.cc | 1338 static_cast<grpc_chttp2_stream*>(op->handler_private.extra_arg); in perform_stream_op_locked()
1610 op->handler_private.extra_arg = gs; in perform_stream_op()
1611 t->combiner->Run(GRPC_CLOSURE_INIT(&op->handler_private.closure, in perform_stream_op()
1757 static_cast<grpc_chttp2_transport*>(op->handler_private.extra_arg); in perform_transport_op_locked()
1804 op->handler_private.extra_arg = gt; in perform_transport_op()
1806 t->combiner->Run(GRPC_CLOSURE_INIT(&op->handler_private.closure, in perform_transport_op()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 637 grpc_call* call = static_cast<grpc_call*>(batch->handler_private.extra_arg); in execute_batch_in_call_combiner()
648 batch->handler_private.extra_arg = call; in execute_batch()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 596 grpc_call* call = static_cast<grpc_call*>(batch->handler_private.extra_arg); in execute_batch_in_call_combiner()
607 batch->handler_private.extra_arg = call; in execute_batch()
|
| /external/grpc-grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 930 on_complete = GRPC_CLOSURE_INIT(&op->handler_private.closure, do_nothing, in perform_stream_op()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/transport/inproc/ |
| D | inproc_transport.cc | 973 on_complete = GRPC_CLOSURE_INIT(&op->handler_private.closure, do_nothing, in perform_stream_op()
|