| /external/pigweed/pw_rpc/public/pw_rpc/ |
| D | synchronous_call.h | 105 internal::SynchronousCallState<Response> call_state; in SynchronousCall() local
110 call_state.OnCompletedCallback(), in SynchronousCall()
111 call_state.OnRpcErrorCallback()); in SynchronousCall()
113 call_state.notify.acquire(); in SynchronousCall()
115 return std::move(call_state.result); in SynchronousCall()
139 internal::SynchronousCallState<Response> call_state; in SynchronousCall() local
142 call_state.OnCompletedCallback(), in SynchronousCall()
143 call_state.OnRpcErrorCallback()); in SynchronousCall()
145 call_state.notify.acquire(); in SynchronousCall()
147 return std::move(call_state.result); in SynchronousCall()
[all …]
|
| /external/grpc-grpc/src/python/grpcio/grpc/_cython/_cygrpc/ |
| D | channel.pyx.pxi | 102 _ChannelState channel_state, _CallState call_state, object operations, argument
107 if call_state.due:
108 c_call_error, tag = _operate(call_state.c_call, operations, user_tag)
110 call_state.due.add(tag)
111 channel_state.integrated_call_states[tag] = call_state
120 _ChannelState channel_state, _CallState call_state, object operations, argument
125 if call_state.due:
126 c_call_error, tag = _operate(call_state.c_call, operations, user_tag)
128 call_state.due.add(tag)
137 _ChannelState channel_state, _CallState call_state, grpc_status_code code, argument
[all …]
|
| /external/grpc-grpc/test/core/end2end/fuzzers/ |
| D | api_fuzzer.cc | 515 typedef struct call_state { struct
542 struct call_state* next; argument
543 struct call_state* prev; argument
544 } call_state; typedef
546 static call_state* g_active_call;
548 static call_state* new_call(call_state* sibling, call_state_type type) { in new_call()
549 call_state* c = static_cast<call_state*>(gpr_malloc(sizeof(*c))); in new_call()
562 static call_state* maybe_delete_call_state(call_state* call) { in maybe_delete_call_state()
563 call_state* next = call->next; in maybe_delete_call_state()
595 static void add_to_free(call_state* call, void* p) { in add_to_free()
[all …]
|
| /external/grpc-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()
|
| /external/autotest/client/cros/cellular/ |
| D | base_station_8960.py | 68 call_state = self.c.Query('CALL:STATus?')
70 return call_state == 'IDLE' and data_state in ['IDLE', 'OFF']
|
| /external/tensorflow/tensorflow/c/eager/ |
| D | tape.h | 940 AccumulatorCallState& call_state = call_state_.top(); in ForwardpropFromTape() local
941 call_state.backward_tape = tape.get(); in ForwardpropFromTape()
943 gtl::MakeCleanup([&call_state] { call_state.backward_tape = nullptr; }); in ForwardpropFromTape()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | lb_policy.h | 202 CallState* call_state; member
|
| D | client_channel.cc | 2982 pick_args.call_state = &lb_call_state; in PickSubchannelLocked()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/lb_policy/xds/ |
| D | xds_cluster_impl.cc | 335 CallState* call_state) { in Pick() argument
347 original_recv_trailing_metadata_ready(error, metadata, call_state); in Pick()
|
| D | xds_cluster_manager.cc | 210 args.call_state->ExperimentalGetCallAttribute(kXdsClusterAttribute); in Pick()
|
| /external/vulkan-validation-layers/layers/ |
| D | core_validation.cpp | 13656 auto &call_state = physical_device_state->vkGetPhysicalDeviceSurfacePresentModesKHRState; in PostCallRecordGetPhysicalDeviceSurfacePresentModesKHR() local
13659 if (call_state < QUERY_COUNT) call_state = QUERY_COUNT; in PostCallRecordGetPhysicalDeviceSurfacePresentModesKHR()
13664 if (call_state < QUERY_DETAILS) call_state = QUERY_DETAILS; in PostCallRecordGetPhysicalDeviceSurfacePresentModesKHR()
13676 const auto &call_state = physical_device_state->vkGetPhysicalDeviceSurfaceFormatsKHRState; in PreCallValidateGetPhysicalDeviceSurfaceFormatsKHR() local
13678 switch (call_state) { in PreCallValidateGetPhysicalDeviceSurfaceFormatsKHR()
13709 auto &call_state = physical_device_state->vkGetPhysicalDeviceSurfaceFormatsKHRState; in PostCallRecordGetPhysicalDeviceSurfaceFormatsKHR() local
13712 if (call_state < QUERY_COUNT) call_state = QUERY_COUNT; in PostCallRecordGetPhysicalDeviceSurfaceFormatsKHR()
13717 if (call_state < QUERY_DETAILS) call_state = QUERY_DETAILS; in PostCallRecordGetPhysicalDeviceSurfaceFormatsKHR()
|
| /external/rust/crates/grpcio-sys/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()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 124 } call_state; typedef
|