| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync.cc | 88 void gpr_ref(gpr_refcount* r) { gpr_atm_no_barrier_fetch_add(&r->count, 1); } in gpr_ref()
92 gpr_atm prior = gpr_atm_no_barrier_fetch_add(&r->count, 1); in gpr_ref_non_zero()
100 gpr_atm_no_barrier_fetch_add(&r->count, n); in gpr_refn()
118 gpr_atm_no_barrier_fetch_add(&c->value, inc); in gpr_stats_inc()
|
| D | arena.cc | 124 size_t begin = gpr_atm_no_barrier_fetch_add(&arena->total_used, size); in gpr_arena_alloc()
|
| /external/grpc-grpc/test/cpp/thread_manager/ |
| D | thread_manager_test.cc | 85 int call_num = gpr_atm_no_barrier_fetch_add(&num_poll_for_work_, 1); in PollForWork()
101 gpr_atm_no_barrier_fetch_add(&num_work_found_, 1); in PollForWork()
106 gpr_atm_no_barrier_fetch_add(&num_do_work_, 1); in DoWork()
|
| /external/grpc-grpc/src/core/lib/debug/ |
| D | stats.h | 42 (gpr_atm_no_barrier_fetch_add(&GRPC_THREAD_STATS_DATA()->counters[(ctr)], 1))
45 (gpr_atm_no_barrier_fetch_add( \
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | metadata.cc | 165 if (0 == gpr_atm_no_barrier_fetch_add(&md->refcnt, 1)) { in ref_md_locked()
166 gpr_atm_no_barrier_fetch_add(&shard->free_estimate, -1); in ref_md_locked()
199 gpr_atm_no_barrier_fetch_add(&shard->free_estimate, -num_freed); in gc_mdtab()
370 gpr_atm_no_barrier_fetch_add(&md->refcnt, 1); in grpc_mdelem_ref()
392 gpr_atm_no_barrier_fetch_add(&md->refcnt, 1); in grpc_mdelem_ref()
427 gpr_atm_no_barrier_fetch_add(&shard->free_estimate, 1); in grpc_mdelem_unref()
|
| /external/grpc-grpc/src/core/lib/channel/ |
| D | channelz.h | 95 gpr_atm_no_barrier_fetch_add(&calls_failed_, (gpr_atm(1))); in RecordCallFailed()
98 gpr_atm_no_barrier_fetch_add(&calls_succeeded_, (gpr_atm(1))); in RecordCallSucceeded()
|
| D | channelz.cc | 65 gpr_atm_no_barrier_fetch_add(&calls_started_, (gpr_atm)1); in RecordCallStarted()
|
| /external/grpc-grpc/src/cpp/common/ |
| D | completion_queue_cc.cc | 47 if (gpr_atm_no_barrier_fetch_add(&avalanches_in_flight_, in CompleteAvalanching()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 66 #define gpr_atm_no_barrier_fetch_add(p, delta) \ macro
|
| D | atm_gcc_atomic.h | 57 #define gpr_atm_no_barrier_fetch_add(p, delta) \ macro
|
| D | atm_windows.h | 94 static __inline gpr_atm gpr_atm_no_barrier_fetch_add(gpr_atm* p, in gpr_atm_no_barrier_fetch_add() function
|
| /external/grpc-grpc/src/core/lib/slice/ |
| D | slice_intern.cc | 76 GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&s->refcnt, 1) > 0); in interned_slice_ref()
229 if (gpr_atm_no_barrier_fetch_add(&s->refcnt, 1) == 0) { in grpc_slice_intern()
|
| /external/grpc-grpc/test/core/util/ |
| D | memory_counters.cc | 40 #define NO_BARRIER_FETCH_ADD(x, sz) gpr_atm_no_barrier_fetch_add(x, sz)
|
| D | passthru_endpoint.cc | 83 gpr_atm_no_barrier_fetch_add(&m->parent->stats->num_writes, (gpr_atm)1); in me_write()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | completion_queue.cc | 430 return gpr_atm_no_barrier_fetch_add(&q->num_queue_items, 1) == 0; in cq_event_queue_push()
452 gpr_atm_no_barrier_fetch_add(&q->num_queue_items, -1); in cq_event_queue_pop()
713 gpr_atm_no_barrier_fetch_add(&cqd->things_queued_ever, 1);
791 gpr_atm_no_barrier_fetch_add(&cqd->things_queued_ever, 1);
853 gpr_atm_no_barrier_fetch_add(&cqd->things_queued_ever, 1);
|
| /external/grpc-grpc/src/core/lib/gprpp/ |
| D | fork.cc | 78 void DecExecCtxCount() { gpr_atm_no_barrier_fetch_add(&count_, -1); } in DecExecCtxCount()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epollsig_linux.cc | 317 gpr_atm_no_barrier_fetch_add(&pi->ref_count, 1); in pi_add_ref()
747 GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&fd->refst, n) > 0);
1212 gpr_atm_no_barrier_fetch_add(&pi->poller_count, 1);
1275 gpr_atm_no_barrier_fetch_add(&pi->poller_count, -1);
|
| D | resource_quota.cc | 802 GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&resource_user->refs, amount) != 0); in ru_ref_by()
840 gpr_atm_no_barrier_fetch_add(&resource_user->num_threads_allocated, in grpc_resource_user_allocate_threads()
854 int old_count = static_cast<int>(gpr_atm_no_barrier_fetch_add( in grpc_resource_user_free_threads()
|
| D | ev_epollex_linux.cc | 337 GPR_ASSERT(gpr_atm_no_barrier_fetch_add(&fd->refst, n) > 0);
434 new_fd->salt = gpr_atm_no_barrier_fetch_add(&g_fd_salt, 1);
1064 gpr_atm_no_barrier_fetch_add(&pollset->worker_count, 1);
1145 gpr_atm_no_barrier_fetch_add(&pollset->worker_count, -1);
|
| D | tcp_posix.cc | 199 gpr_atm_no_barrier_fetch_add(&g_uncovered_notifications_pending, -1); in drop_uncovered()
210 gpr_atm_no_barrier_fetch_add(&g_uncovered_notifications_pending, 2); in cover_self()
|
| D | tcp_server_posix.cc | 232 sp->server->pollsets[static_cast<size_t>(gpr_atm_no_barrier_fetch_add( in on_read()
|
| /external/grpc-grpc/include/grpcpp/impl/codegen/ |
| D | completion_queue.h | 358 gpr_atm_no_barrier_fetch_add(&avalanches_in_flight_, in RegisterAvalanching()
|
| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 256 gpr_atm_no_barrier_fetch_add(&chand->call_count, 1); in close_max_idle_channel()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | thread_stress_test.cc | 288 gpr_atm_no_barrier_fetch_add(errors, static_cast<gpr_atm>(1)); in SendRpc()
|
| /external/grpc-grpc/test/cpp/microbenchmarks/ |
| D | bm_fullstack_trickle.cc | 60 gpr_atm_no_barrier_fetch_add(&g_now_us, 100); in inc_time()
|