| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync.cc | 62 GPR_ASSERT(gpr_atm_acq_load(&ev->state) == 0); in gpr_event_set()
70 return (void*)gpr_atm_acq_load(&ev->state); in gpr_event_get()
74 void* result = (void*)gpr_atm_acq_load(&ev->state); in gpr_event_wait()
79 result = (void*)gpr_atm_acq_load(&ev->state); in gpr_event_wait()
110 return gpr_atm_acq_load(&r->count) == 1; in gpr_ref_is_unique()
123 return gpr_atm_acq_load(&c->value); in gpr_stats_read()
|
| D | mpscq.cc | 51 gpr_mpscq_node* next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()
60 next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()
67 gpr_mpscq_node* head = (gpr_mpscq_node*)gpr_atm_acq_load(&q->head); in gpr_mpscq_pop_and_check_end()
74 next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/gpr/ |
| D | sync.cc | 62 GPR_ASSERT(gpr_atm_acq_load(&ev->state) == 0); in gpr_event_set()
70 return reinterpret_cast<void*>(gpr_atm_acq_load(&ev->state)); in gpr_event_get()
74 void* result = reinterpret_cast<void*>(gpr_atm_acq_load(&ev->state)); in gpr_event_wait()
79 result = reinterpret_cast<void*>(gpr_atm_acq_load(&ev->state)); in gpr_event_wait()
110 return gpr_atm_acq_load(&r->count) == 1; in gpr_ref_is_unique()
123 return gpr_atm_acq_load(&c->value); in gpr_stats_read()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | retry_throttle.cc | 53 gpr_atm_acq_load(&old_throttle_data->milli_tokens_)) / in ServerRetryThrottleData()
71 gpr_atm_acq_load(&replacement_)); in ~ServerRetryThrottleData()
82 gpr_atm_acq_load(&(*throttle_data)->replacement_)); in GetReplacementThrottleDataIfNeeded()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/ |
| D | retry_throttle.cc | 55 gpr_atm_acq_load(&old_throttle_data->milli_tokens_)) / in ServerRetryThrottleData()
73 gpr_atm_acq_load(&replacement_)); in ~ServerRetryThrottleData()
84 gpr_atm_acq_load(&(*throttle_data)->replacement_)); in GetReplacementThrottleDataIfNeeded()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 41 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
78 cur = gpr_atm_acq_load(p); in gpr_atm_full_xchg()
|
| D | atm_windows.h | 31 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
39 return gpr_atm_acq_load(p); in gpr_atm_no_barrier_load()
|
| D | atm_gcc_atomic.h | 50 #define gpr_atm_acq_load(p) (__atomic_load_n((p), __ATOMIC_ACQUIRE)) macro
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 43 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
80 cur = gpr_atm_acq_load(p); in gpr_atm_full_xchg()
|
| D | atm_windows.h | 35 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
43 return gpr_atm_acq_load(p); in gpr_atm_no_barrier_load()
|
| D | atm_gcc_atomic.h | 50 #define gpr_atm_acq_load(p) (__atomic_load_n((p), __ATOMIC_ACQUIRE)) macro
|
| /external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 43 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
80 cur = gpr_atm_acq_load(p); in gpr_atm_full_xchg()
|
| D | atm_windows.h | 35 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
43 return gpr_atm_acq_load(p); in gpr_atm_no_barrier_load()
|
| D | atm_gcc_atomic.h | 50 #define gpr_atm_acq_load(p) (__atomic_load_n((p), __ATOMIC_ACQUIRE)) macro
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epollsig_linux.cc | 294 gpr_atm old_cnt = gpr_atm_acq_load(&pi->ref_count); in pi_add_ref_dbg()
306 gpr_atm old_cnt = gpr_atm_acq_load(&pi->ref_count); in pi_unref_dbg()
330 polling_island* next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in pi_unref()
521 polling_island* next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_maybe_get_latest()
524 next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_maybe_get_latest()
543 next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_lock()
550 next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_lock()
609 next_1 = (polling_island*)gpr_atm_acq_load(&pi_1->merged_to); in polling_island_lock_pair()
612 next_1 = (polling_island*)gpr_atm_acq_load(&pi_1->merged_to); in polling_island_lock_pair()
615 next_2 = (polling_island*)gpr_atm_acq_load(&pi_2->merged_to); in polling_island_lock_pair()
[all …]
|
| D | executor.cc | 86 return gpr_atm_acq_load(&num_threads_) > 0; in IsThreaded()
90 gpr_atm curr_num_threads = gpr_atm_acq_load(&num_threads_); in SetThreading()
207 static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
300 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
|
| D | call_combiner.cc | 148 gpr_atm original_state = gpr_atm_acq_load(&call_combiner->cancel_state); in grpc_call_combiner_set_notify_on_cancel()
191 gpr_atm original_state = gpr_atm_acq_load(&call_combiner->cancel_state); in grpc_call_combiner_cancel()
|
| D | lockfree_event.cc | 96 gpr_atm curr = gpr_atm_acq_load(&state_); in NotifyOn()
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | buffer_list_test.cc | 56 GPR_ASSERT(gpr_atm_acq_load(&verifier_called[i]) == in TestShutdownFlushesList()
89 GPR_ASSERT(gpr_atm_acq_load(&verifier_called) == static_cast<gpr_atm>(1)); in TestVerifierCalledOnAck()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 156 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in increase_call_count()
184 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in decrease_call_count()
250 if (gpr_atm_acq_load(&chand_->idle_state) == in OnConnectivityStateChange()
312 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in max_idle_timer_cb()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | executor.cc | 137 return gpr_atm_acq_load(&num_threads_) > 0; in IsThreaded()
141 gpr_atm curr_num_threads = gpr_atm_acq_load(&num_threads_); in SetThreading()
266 static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
364 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
|
| D | call_combiner.cc | 193 gpr_atm original_state = gpr_atm_acq_load(&cancel_state_); in SetNotifyOnCancel()
235 gpr_atm original_state = gpr_atm_acq_load(&cancel_state_); in Cancel()
|
| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 157 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in increase_call_count()
185 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in decrease_call_count()
271 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in max_idle_timer_cb()
373 if (gpr_atm_acq_load(&chand->idle_state) == MAX_IDLE_STATE_SEEN_EXIT_IDLE) { in channel_connectivity_changed()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 270 parent_call* p = (parent_call*)gpr_atm_acq_load(&call->parent_call_atm); in get_or_create_parent_call()
277 p = (parent_call*)gpr_atm_acq_load(&call->parent_call_atm); in get_or_create_parent_call()
284 return (parent_call*)gpr_atm_acq_load(&call->parent_call_atm); in get_parent_call()
380 if (gpr_atm_acq_load(&args->parent->received_final_op_atm)) { in grpc_call_create()
523 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&c->status_error)); in destroy_call()
565 bool cancel = gpr_atm_acq_load(&c->any_ops_sent_atm) != 0 && in grpc_call_unref()
566 gpr_atm_acq_load(&c->received_final_op_atm) == 0; in grpc_call_unref()
615 char* peer_string = (char*)gpr_atm_acq_load(&call->peer_string); in grpc_call_get_peer()
723 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&call->status_error)) != in set_final_status()
1124 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in reset_batch_errors()
[all …]
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/surface/ |
| D | call.cc | 314 reinterpret_cast<parent_call*>(gpr_atm_acq_load(&call->parent_call_atm)); in get_or_create_parent_call()
322 gpr_atm_acq_load(&call->parent_call_atm)); in get_or_create_parent_call()
330 gpr_atm_acq_load(&call->parent_call_atm)); in get_parent_call()
422 if (gpr_atm_acq_load(&args->parent->received_final_op_atm)) { in grpc_call_create()
563 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&c->status_error)); in destroy_call()
605 bool cancel = gpr_atm_acq_load(&c->any_ops_sent_atm) != 0 && in grpc_call_unref()
606 gpr_atm_acq_load(&c->received_final_op_atm) == 0; in grpc_call_unref()
657 reinterpret_cast<char*>(gpr_atm_acq_load(&call->peer_string)); in grpc_call_get_peer()
774 gpr_atm_acq_load(&call->status_error)) != GRPC_ERROR_NONE) { in set_final_status()
1175 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in reset_batch_errors()
[all …]
|