| /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()
|
| D | transport.cc | 42 gpr_atm val = gpr_atm_no_barrier_load(&refcount->refs.count);
56 gpr_atm val = gpr_atm_no_barrier_load(&refcount->refs.count);
|
| /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()
|
| D | resource_quota.cc | 319 resource_user, gpr_atm_no_barrier_load(&resource_user->shutdown), in rq_alloc()
322 if (gpr_atm_no_barrier_load(&resource_user->shutdown)) { in rq_alloc()
550 GPR_ASSERT(gpr_atm_no_barrier_load(&resource_user->refs) == 0); in ru_destroy()
553 static_cast<int>(gpr_atm_no_barrier_load( in ru_destroy()
678 return (static_cast<double>(gpr_atm_no_barrier_load( in grpc_resource_quota_get_memory_pressure()
707 gpr_atm_no_barrier_load(&resource_quota->last_size)); in grpc_resource_quota_peek_size()
|
| D | ev_epollex_linux.cc | 329 fd->fd, fd, n, gpr_atm_no_barrier_load(&fd->refst),
330 gpr_atm_no_barrier_load(&fd->refst) + n, reason, file, line);
387 fd->fd, fd, n, gpr_atm_no_barrier_load(&fd->refst),
388 gpr_atm_no_barrier_load(&fd->refst) - n, reason, file, line);
603 int r = static_cast<int> gpr_atm_no_barrier_load(&p->refs.count);
618 int r = static_cast<int> gpr_atm_no_barrier_load(&p->refs.count);
921 int worker_count = gpr_atm_no_barrier_load(&pollset->worker_count);
1465 if ((gpr_atm_no_barrier_load(&fds[i]->refst) & 1) == 0) {
|
| D | error.cc | 134 gpr_atm_no_barrier_load(&err->atomics.refs.count), in grpc_error_ref()
135 gpr_atm_no_barrier_load(&err->atomics.refs.count) + 1, file, line); in grpc_error_ref()
184 gpr_atm_no_barrier_load(&err->atomics.refs.count), in grpc_error_unref()
185 gpr_atm_no_barrier_load(&err->atomics.refs.count) - 1, file, line); in grpc_error_unref()
|
| /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()
|
| D | atomic_with_atm.h | 45 expected = gpr_atm_no_barrier_load(&x_) != 0; in compare_exchange_strong()
|
| /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/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/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()
|
| D | trace.h | 70 return gpr_atm_no_barrier_load(&value_) != 0; in enabled()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 47 static __inline gpr_atm gpr_atm_no_barrier_load(const gpr_atm* p) { in gpr_atm_no_barrier_load() function
|
| D | atm_gcc_atomic.h | 51 #define gpr_atm_no_barrier_load(p) (__atomic_load_n((p), __ATOMIC_RELAXED)) macro
|
| /external/grpc-grpc/src/core/lib/security/context/ |
| D | security_context.cc | 140 gpr_atm val = gpr_atm_no_barrier_load(&ctx->refcount.count);
158 gpr_atm val = gpr_atm_no_barrier_load(&ctx->refcount.count);
|