| /third_party/grpc/src/core/ext/filters/http/message_compress/ |
| D | message_compress_filter.cc | 106 : call_combiner_(args.call_combiner) { in CallData()
149 grpc_core::CallCombiner* call_combiner_; member in __anon610b22500111::CallData
356 calld->call_combiner_); in FailSendMessageBatchInCallCombiner()
444 call_combiner_, in CompressStartTransportStreamOpBatch()
455 batch, GRPC_ERROR_REF(cancel_error_), call_combiner_); in CompressStartTransportStreamOpBatch()
465 call_combiner_); in CompressStartTransportStreamOpBatch()
476 call_combiner_, &start_send_message_batch_in_call_combiner_, in CompressStartTransportStreamOpBatch()
489 call_combiner_, "send_message batch pending send_initial_metadata"); in CompressStartTransportStreamOpBatch()
|
| D | message_decompress_filter.cc | 61 : call_combiner_(args.call_combiner), in CallData()
107 CallCombiner* call_combiner_; member in grpc_core::__anonbad6d6990111::CallData
171 GRPC_CALL_COMBINER_START(call_combiner_, &on_recv_message_ready_, in MaybeResumeOnRecvMessageReady()
182 GRPC_CALL_COMBINER_STOP(calld->call_combiner_, in OnRecvMessageReady()
299 GRPC_CALL_COMBINER_START(call_combiner_, &on_recv_trailing_metadata_ready_, in MaybeResumeOnRecvTrailingMetadataReady()
311 calld->call_combiner_, in OnRecvTrailingMetadataReady()
|
| /third_party/grpc/src/core/ext/filters/client_channel/health/ |
| D | health_check_client.cc | 275 call_combiner_.SetNotifyOnCancel(nullptr); in ~CallState()
281 call_combiner_.Cancel(GRPC_ERROR_CANCELLED); in Orphan()
294 &call_combiner_, in StartCall()
397 GRPC_CALL_COMBINER_START(&call_combiner_, &batch->handler_private.closure, in StartBatch()
412 GRPC_CALL_COMBINER_STOP(&self->call_combiner_, "health_cancel"); in OnCancelComplete()
433 &call_combiner_, in Cancel()
443 GRPC_CALL_COMBINER_STOP(&self->call_combiner_, "on_complete"); in OnComplete()
453 GRPC_CALL_COMBINER_STOP(&self->call_combiner_, "recv_initial_metadata_ready"); in RecvInitialMetadataReady()
535 GRPC_CALL_COMBINER_STOP(&self->call_combiner_, "recv_message_ready"); in RecvMessageReady()
551 GRPC_CALL_COMBINER_STOP(&self->call_combiner_, in RecvTrailingMetadataReady()
|
| D | health_check_client.h | 96 grpc_core::CallCombiner call_combiner_; variable
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | client_channel.cc | 504 CallCombiner* call_combiner_; member in grpc_core::__anonee6b702a0111::CallData
838 CallCombiner* call_combiner_; member in grpc_core::__anonee6b702a0111::RetryingCall
1009 CallCombiner* call_combiner_; member in grpc_core::__anonee6b702a0111::LoadBalancedCall
1170 calld->arena_, calld->call_combiner_}; in SetPollent()
1207 call_combiner_(args.call_combiner), in DynamicTerminationFilterCallData()
1217 CallCombiner* call_combiner_; member in grpc_core::__anonee6b702a0111::DynamicTerminationFilterCallData
2649 call_combiner_(args.call_combiner), in CallData()
2707 batch, GRPC_ERROR_REF(calld->cancel_error_), calld->call_combiner_); in StartTransportStreamOpBatch()
2732 batch, GRPC_ERROR_REF(calld->cancel_error_), calld->call_combiner_); in StartTransportStreamOpBatch()
2771 GRPC_CALL_COMBINER_STOP(calld->call_combiner_, in StartTransportStreamOpBatch()
[all …]
|
| /third_party/grpc/src/core/lib/surface/ |
| D | server.h | 316 CallCombiner* call_combiner_; variable
|
| D | server.cc | 1190 call_combiner_(args.call_combiner) { in CallData()
1416 GRPC_CALL_COMBINER_START(calld->call_combiner_, in RecvInitialMetadataReady()
1433 GRPC_CALL_COMBINER_STOP(calld->call_combiner_, in RecvTrailingMetadataReady()
|