| /external/grpc-grpc/src/core/lib/transport/ |
| D | metadata.cc | 159 gpr_atm_no_barrier_load(&md->refcnt), in ref_md_locked()
160 gpr_atm_no_barrier_load(&md->refcnt) + 1, key_str, value_str); in ref_md_locked()
181 void* user_data = (void*)gpr_atm_no_barrier_load(&md->user_data); in gc_mdtab()
187 ((destroy_user_data_func)gpr_atm_no_barrier_load( in gc_mdtab()
231 if (gpr_atm_no_barrier_load(&shard->free_estimate) > in rehash_mdtab()
258 (void*)allocated, gpr_atm_no_barrier_load(&allocated->refcnt), in grpc_mdelem_create()
311 gpr_atm_no_barrier_load(&md->refcnt), key_str, value_str); in grpc_mdelem_create()
359 (void*)md, gpr_atm_no_barrier_load(&md->refcnt), in grpc_mdelem_ref()
360 gpr_atm_no_barrier_load(&md->refcnt) + 1, key_str, value_str); in grpc_mdelem_ref()
369 GPR_ASSERT(gpr_atm_no_barrier_load(&md->refcnt) >= 1); in grpc_mdelem_ref()
[all …]
|
| D | connectivity_state.cc | 79 gpr_atm_no_barrier_load(&tracker->current_state_atm)); in grpc_connectivity_state_check()
90 gpr_atm_no_barrier_load(&tracker->current_state_atm)); in grpc_connectivity_state_get()
110 gpr_atm_no_barrier_load(&tracker->current_state_atm)); in grpc_connectivity_state_notify_on_state_change()
160 gpr_atm_no_barrier_load(&tracker->current_state_atm)); in grpc_connectivity_state_set()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/gpr/ |
| D | log.cc | 59 gpr_atm_no_barrier_load(&g_min_severity_to_print) in gpr_should_log()
66 gpr_atm_no_barrier_load(&g_min_severity_to_print_stacktrace) in gpr_should_log_stacktrace()
83 reinterpret_cast<gpr_log_func>(gpr_atm_no_barrier_load(&g_log_func))(&lfargs); in gpr_log_message()
107 if ((gpr_atm_no_barrier_load(&g_min_severity_to_print)) == in gpr_log_verbosity_init()
119 if ((gpr_atm_no_barrier_load(&g_min_severity_to_print_stacktrace)) == in gpr_log_verbosity_init()
|
| D | atm.cc | 30 current_value = gpr_atm_no_barrier_load(value); in gpr_atm_no_barrier_clamped_add()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | helpers.h | 75 const size_t mu_locks_at_start_ = gpr_atm_no_barrier_load(&gpr_mu_locks);
77 gpr_atm_no_barrier_load(&gpr_counter_atm_cas);
79 gpr_atm_no_barrier_load(&gpr_counter_atm_add);
81 gpr_atm_no_barrier_load(&gpr_now_call_count);
|
| D | helpers.cc | 61 << ((double)(gpr_atm_no_barrier_load(&gpr_mu_locks) - in AddToLabel()
65 << ((double)(gpr_atm_no_barrier_load(&gpr_counter_atm_cas) - in AddToLabel()
69 << ((double)(gpr_atm_no_barrier_load(&gpr_counter_atm_add) - in AddToLabel()
73 << ((double)(gpr_atm_no_barrier_load(&gpr_now_call_count) - in AddToLabel()
|
| /external/grpc-grpc/src/core/lib/gpr/ |
| D | log.cc | 49 gpr_atm_no_barrier_load(&g_min_severity_to_print) in gpr_should_log()
66 ((gpr_log_func)gpr_atm_no_barrier_load(&g_log_func))(&lfargs); in gpr_log_message()
89 if ((gpr_atm_no_barrier_load(&g_min_severity_to_print)) == in gpr_log_verbosity_init()
|
| D | atm.cc | 30 current_value = gpr_atm_no_barrier_load(value); in gpr_atm_no_barrier_clamped_add()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | lockfree_event.cc | 77 curr = gpr_atm_no_barrier_load(&state_); in DestroyEvent()
162 gpr_atm curr = gpr_atm_no_barrier_load(&state_); in SetShutdown()
210 gpr_atm curr = gpr_atm_no_barrier_load(&state_); in SetReady()
|
| D | combiner.cc | 93 GPR_ASSERT(gpr_atm_no_barrier_load(&lock->state) == 0); in really_destroy()
112 gpr_atm_no_barrier_load(&lock->refs.count), \
113 gpr_atm_no_barrier_load(&lock->refs.count) + (delta), reason); \
178 gpr_atm_no_barrier_load(&lock->initiating_exec_ctx_or_null); in combiner_exec()
220 gpr_atm_no_barrier_load(&lock->initiating_exec_ctx_or_null) == 0; in grpc_combiner_continue_exec_ctx()
|
| D | cfstream_handle.cc | 165 gpr_atm val = gpr_atm_no_barrier_load(&refcount_.count); in Ref()
175 gpr_atm val = gpr_atm_no_barrier_load(&refcount_.count); in Unref()
|
| D | lockfree_event.h | 47 return (gpr_atm_no_barrier_load(&state_) & kShutdownBit) != 0; in IsShutdown()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | lockfree_event.cc | 78 curr = gpr_atm_no_barrier_load(&state_); in DestroyEvent()
166 gpr_atm curr = gpr_atm_no_barrier_load(&state_); in SetShutdown()
215 gpr_atm curr = gpr_atm_no_barrier_load(&state_); in SetReady()
|
| D | combiner.cc | 67 GPR_ASSERT(gpr_atm_no_barrier_load(&lock->state) == 0); in really_destroy()
85 gpr_atm_no_barrier_load(&lock->refs.count), \
86 gpr_atm_no_barrier_load(&lock->refs.count) + (delta), reason); \
148 gpr_atm_no_barrier_load(&lock->initiating_exec_ctx_or_null); in combiner_exec()
191 gpr_atm_no_barrier_load(&lock->initiating_exec_ctx_or_null) == 0; in grpc_combiner_continue_exec_ctx()
|
| D | resource_quota.cc | 327 resource_user, gpr_atm_no_barrier_load(&resource_user->shutdown), in rq_alloc()
330 if (gpr_atm_no_barrier_load(&resource_user->shutdown)) { in rq_alloc()
573 GPR_ASSERT(gpr_atm_no_barrier_load(&resource_user->refs) == 0); in ru_destroy()
576 static_cast<int>(gpr_atm_no_barrier_load( in ru_destroy()
704 return (static_cast<double>(gpr_atm_no_barrier_load( in grpc_resource_quota_get_memory_pressure()
733 gpr_atm_no_barrier_load(&resource_quota->last_size)); in grpc_resource_quota_peek_size()
913 if (gpr_atm_no_barrier_load(&resource_user->shutdown)) return false; in grpc_resource_user_safe_alloc()
918 gpr_atm used = gpr_atm_no_barrier_load(&resource_quota->used); in grpc_resource_user_safe_alloc()
1002 gpr_atm_no_barrier_load(&slice_allocator->resource_user->shutdown))) { in grpc_resource_user_alloc_slices()
|
| D | lockfree_event.h | 47 return (gpr_atm_no_barrier_load(&state_) & kShutdownBit) != 0; in IsShutdown()
|
| D | cfstream_handle.cc | 183 gpr_atm val = gpr_atm_no_barrier_load(&refcount_.count); in Ref()
193 gpr_atm val = gpr_atm_no_barrier_load(&refcount_.count); in Unref()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/gprpp/ |
| D | fork.cc | 69 gpr_atm count = gpr_atm_no_barrier_load(&count_); in IncExecCtxCount()
75 if (gpr_atm_no_barrier_load(&count_) <= BLOCKED(1)) { in IncExecCtxCount()
84 count = gpr_atm_no_barrier_load(&count_); in IncExecCtxCount()
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 59 gpr_atm count = gpr_atm_no_barrier_load(&count_); in IncExecCtxCount()
65 if (gpr_atm_no_barrier_load(&count_) <= BLOCKED(1)) { in IncExecCtxCount()
74 count = gpr_atm_no_barrier_load(&count_); in IncExecCtxCount()
|
| D | ref_counted.h | 101 gpr_atm old_refs = gpr_atm_no_barrier_load(&refs_.count); in Ref()
122 gpr_atm old_refs = gpr_atm_no_barrier_load(&refs_.count); in Unref()
|
| D | orphanable.h | 159 gpr_atm old_refs = gpr_atm_no_barrier_load(&refs_.count); in Ref()
180 gpr_atm old_refs = gpr_atm_no_barrier_load(&refs_.count); in Unref()
|
| /external/grpc-grpc/test/cpp/thread_manager/ |
| D | thread_manager_test.cc | 111 return static_cast<int>(gpr_atm_no_barrier_load(&num_work_found_)); in GetNumWorkFound()
115 return static_cast<int>(gpr_atm_no_barrier_load(&num_do_work_)); in GetNumDoWork()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 461 return static_cast<long>(gpr_atm_no_barrier_load(&q->num_queue_items)); in cq_event_queue_num_items()
563 gpr_atm val = gpr_atm_no_barrier_load(&cq->owning_refs.count);
583 gpr_atm val = gpr_atm_no_barrier_load(&cq->owning_refs.count);
894 gpr_atm_no_barrier_load(&cqd->things_queued_ever);
899 gpr_atm_no_barrier_load(&cqd->things_queued_ever);
965 gpr_atm_no_barrier_load(&cqd->things_queued_ever),
1074 GPR_ASSERT(gpr_atm_no_barrier_load(&cqd->pending_events) == 0);
1148 gpr_atm_no_barrier_load(&cqd->things_queued_ever);
1153 gpr_atm_no_barrier_load(&cqd->things_queued_ever);
1209 gpr_atm_no_barrier_load(&cqd->things_queued_ever),
[all …]
|
| /external/grpc-grpc/src/core/lib/debug/ |
| D | stats.cc | 47 output->counters[i] += gpr_atm_no_barrier_load( in grpc_stats_collect()
51 output->histograms[i] += gpr_atm_no_barrier_load( in grpc_stats_collect()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/debug/ |
| D | stats.cc | 52 output->counters[i] += gpr_atm_no_barrier_load( in grpc_stats_collect()
56 output->histograms[i] += gpr_atm_no_barrier_load( in grpc_stats_collect()
|