Searched refs:call_state (Results 1 – 9 of 9) sorted by relevance
| /third_party/grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | channel.pyx.pxi | 98 _ChannelState channel_state, _CallState call_state, object operations, argument
103 if call_state.due:
104 c_call_error, tag = _operate(call_state.c_call, operations, user_tag)
106 call_state.due.add(tag)
107 channel_state.integrated_call_states[tag] = call_state
116 _ChannelState channel_state, _CallState call_state, object operations, argument
121 if call_state.due:
122 c_call_error, tag = _operate(call_state.c_call, operations, user_tag)
124 call_state.due.add(tag)
133 _ChannelState channel_state, _CallState call_state, grpc_status_code code, argument
[all …]
|
| D | _hooks.pyx.pxi | 31 def set_census_context_on_call(_CallState call_state, CensusContext census_ctx): argument
|
| /third_party/grpc/test/core/util/ |
| D | test_lb_policies.cc | 232 new (args.call_state->Alloc(sizeof(TrailingMetadataHandler))) in Pick()
282 CallState* call_state) { in TrailingMetadataHandler() argument
283 RecordRecvTrailingMetadata(error, metadata, call_state); in TrailingMetadataHandler()
290 CallState* call_state) { in RecordRecvTrailingMetadata() argument
292 args_seen.backend_metric_data = call_state->GetBackendMetricData(); in RecordRecvTrailingMetadata()
|
| /third_party/grpc/test/core/fling/ |
| D | server.cc | 77 } call_state; typedef
174 call_state* s; in main()
253 s = static_cast<call_state*>(ev.tag); in main()
|
| /third_party/grpc/src/core/ext/filters/client_channel/ |
| D | lb_policy.h | 202 CallState* call_state; member
|
| D | client_channel.cc | 5370 pick_args.call_state = &lb_call_state; in PickSubchannelLocked()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | xds_cluster_impl.cc | 348 CallState* call_state) { in Pick() argument
360 original_recv_trailing_metadata_ready(error, metadata, call_state); in Pick()
|
| D | xds_cluster_manager.cc | 210 args.call_state->ExperimentalGetCallAttribute(kXdsClusterAttribute); in Pick()
|
| /third_party/grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/ |
| D | grpclb.cc | 652 args.call_state->Alloc(subchannel_wrapper->lb_token().size() + 1)); in Pick()
|