Home
last modified time | relevance | path

Searched refs:gpr_atm (Results 1 – 25 of 102) sorted by relevance

12345

/external/grpc-grpc/include/grpc/impl/codegen/
Datm_windows.h25 typedef intptr_t gpr_atm; typedef
31 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load()
32 gpr_atm result = *p; in gpr_atm_acq_load()
37 static __inline gpr_atm gpr_atm_no_barrier_load(const gpr_atm* p) { in gpr_atm_no_barrier_load()
42 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store()
47 static __inline void gpr_atm_no_barrier_store(gpr_atm* p, gpr_atm value) { in gpr_atm_no_barrier_store()
52 static __inline int gpr_atm_no_barrier_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_no_barrier_cas()
56 return o == (gpr_atm)InterlockedCompareExchangeAcquire64( in gpr_atm_no_barrier_cas()
59 return o == (gpr_atm)InterlockedCompareExchangeAcquire((volatile LONG*)p, in gpr_atm_no_barrier_cas()
64 static __inline int gpr_atm_acq_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_acq_cas()
[all …]
Datm_gcc_sync.h26 typedef intptr_t gpr_atm; typedef
41 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load()
42 gpr_atm value = *p; in gpr_atm_acq_load()
47 static __inline gpr_atm gpr_atm_no_barrier_load(const gpr_atm* p) { in gpr_atm_no_barrier_load()
48 gpr_atm value = *p; in gpr_atm_no_barrier_load()
53 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store()
58 static __inline void gpr_atm_no_barrier_store(gpr_atm* p, gpr_atm value) { in gpr_atm_no_barrier_store()
75 static __inline gpr_atm gpr_atm_full_xchg(gpr_atm* p, gpr_atm n) { in gpr_atm_full_xchg()
76 gpr_atm cur; in gpr_atm_full_xchg()
Datm_gcc_atomic.h30 typedef intptr_t gpr_atm; typedef
35 extern gpr_atm gpr_counter_atm_cas;
36 extern gpr_atm gpr_counter_atm_add;
64 static __inline int gpr_atm_no_barrier_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_no_barrier_cas()
69 static __inline int gpr_atm_acq_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_acq_cas()
74 static __inline int gpr_atm_rel_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_rel_cas()
79 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas()
Datm.h88 gpr_atm gpr_atm_no_barrier_clamped_add(gpr_atm* value, gpr_atm delta,
89 gpr_atm min, gpr_atm max);
Dsync_generic.h29 gpr_atm state;
37 gpr_atm count;
42 gpr_atm value;
/external/grpc-grpc/test/core/iomgr/
Dbuffer_list_test.cc34 gpr_atm* done = reinterpret_cast<gpr_atm*>(arg); in TestShutdownFlushesListVerifier()
35 gpr_atm_rel_store(done, static_cast<gpr_atm>(1)); in TestShutdownFlushesListVerifier()
47 gpr_atm verifier_called[NUM_ELEM]; in TestShutdownFlushesList()
49 gpr_atm_rel_store(&verifier_called[i], static_cast<gpr_atm>(0)); in TestShutdownFlushesList()
57 static_cast<gpr_atm>(1)); in TestShutdownFlushesList()
69 gpr_atm* done = reinterpret_cast<gpr_atm*>(arg); in TestVerifierCalledOnAckVerifier()
70 gpr_atm_rel_store(done, static_cast<gpr_atm>(1)); in TestVerifierCalledOnAckVerifier()
85 gpr_atm verifier_called; in TestVerifierCalledOnAck()
86 gpr_atm_rel_store(&verifier_called, static_cast<gpr_atm>(0)); in TestVerifierCalledOnAck()
89 GPR_ASSERT(gpr_atm_acq_load(&verifier_called) == static_cast<gpr_atm>(1)); in TestVerifierCalledOnAck()
/external/grpc-grpc/src/core/lib/gpr/
Dlog.cc32 static gpr_atm g_log_func = (gpr_atm)gpr_default_log;
33 static gpr_atm g_min_severity_to_print = GPR_LOG_VERBOSITY_UNSET;
48 return static_cast<gpr_atm>(severity) >= in gpr_should_log()
71 (gpr_atm)min_severity_to_print); in gpr_set_log_verbosity()
78 gpr_atm min_severity_to_print = GPR_LOG_SEVERITY_ERROR; in gpr_log_verbosity_init()
81 min_severity_to_print = static_cast<gpr_atm>(GPR_LOG_SEVERITY_DEBUG); in gpr_log_verbosity_init()
83 min_severity_to_print = static_cast<gpr_atm>(GPR_LOG_SEVERITY_INFO); in gpr_log_verbosity_init()
85 min_severity_to_print = static_cast<gpr_atm>(GPR_LOG_SEVERITY_ERROR); in gpr_log_verbosity_init()
101 gpr_atm_no_barrier_store(&g_log_func, (gpr_atm)(f ? f : gpr_default_log)); in gpr_set_log_function()
Datm.cc25 gpr_atm gpr_atm_no_barrier_clamped_add(gpr_atm* value, gpr_atm delta, in gpr_atm_no_barrier_clamped_add()
26 gpr_atm min, gpr_atm max) { in gpr_atm_no_barrier_clamped_add()
27 gpr_atm current_value; in gpr_atm_no_barrier_clamped_add()
28 gpr_atm new_value; in gpr_atm_no_barrier_clamped_add()
Dmpscq.cc26 gpr_atm_no_barrier_store(&q->head, (gpr_atm)&q->stub); in gpr_mpscq_init()
28 gpr_atm_no_barrier_store(&q->stub.next, (gpr_atm)NULL); in gpr_mpscq_init()
32 GPR_ASSERT(gpr_atm_no_barrier_load(&q->head) == (gpr_atm)&q->stub); in gpr_mpscq_destroy()
37 gpr_atm_no_barrier_store(&n->next, (gpr_atm)NULL); in gpr_mpscq_push()
39 (gpr_mpscq_node*)gpr_atm_full_xchg(&q->head, (gpr_atm)n); in gpr_mpscq_push()
40 gpr_atm_rel_store(&prev->next, (gpr_atm)n); in gpr_mpscq_push()
/external/grpc-grpc/test/core/util/
Dmemory_counters.cc47 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_size_absolute, (gpr_atm)size); in guard_malloc()
48 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_size_relative, (gpr_atm)size); in guard_malloc()
49 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_allocs_absolute, (gpr_atm)1); in guard_malloc()
50 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_allocs_relative, (gpr_atm)1); in guard_malloc()
66 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_size_absolute, (gpr_atm)size); in guard_realloc()
67 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_size_relative, -(gpr_atm)*ptr); in guard_realloc()
68 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_size_relative, (gpr_atm)size); in guard_realloc()
69 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_allocs_absolute, (gpr_atm)1); in guard_realloc()
79 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_size_relative, -(gpr_atm)*ptr); in guard_free()
80 NO_BARRIER_FETCH_ADD(&g_memory_counters.total_allocs_relative, -(gpr_atm)1); in guard_free()
Dmemory_counters.h25 gpr_atm total_size_relative;
26 gpr_atm total_size_absolute;
27 gpr_atm total_allocs_relative;
28 gpr_atm total_allocs_absolute;
/external/grpc-grpc/src/core/ext/filters/client_channel/lb_policy/grpclb/
Dgrpclb_client_stats.cc31 gpr_atm_full_fetch_add(&num_calls_started_, (gpr_atm)1); in AddCallStarted()
36 gpr_atm_full_fetch_add(&num_calls_finished_, (gpr_atm)1); in AddCallFinished()
39 (gpr_atm)1); in AddCallFinished()
42 gpr_atm_full_fetch_add(&num_calls_finished_known_received_, (gpr_atm)1); in AddCallFinished()
48 gpr_atm_full_fetch_add(&num_calls_started_, (gpr_atm)1); in AddCallDroppedLocked()
49 gpr_atm_full_fetch_add(&num_calls_finished_, (gpr_atm)1); in AddCallDroppedLocked()
66 void AtomicGetAndResetCounter(int64_t* value, gpr_atm* counter) { in AtomicGetAndResetCounter()
67 *value = static_cast<int64_t>(gpr_atm_full_xchg(counter, (gpr_atm)0)); in AtomicGetAndResetCounter()
Dgrpclb_client_stats.h63 gpr_atm num_calls_started_ = 0;
64 gpr_atm num_calls_finished_ = 0;
65 gpr_atm num_calls_finished_with_client_failed_to_send_ = 0;
66 gpr_atm num_calls_finished_known_received_ = 0;
/external/grpc-grpc/src/core/lib/iomgr/
Dcall_combiner.cc31 static grpc_error* decode_cancel_state_error(gpr_atm cancel_state) { in decode_cancel_state_error()
33 return (grpc_error*)(cancel_state & ~static_cast<gpr_atm>(1)); in decode_cancel_state_error()
38 static gpr_atm encode_cancel_state_error(grpc_error* error) { in encode_cancel_state_error()
39 return static_cast<gpr_atm>(1) | (gpr_atm)error; in encode_cancel_state_error()
74 gpr_atm_full_fetch_add(&call_combiner->size, (gpr_atm)1)); in grpc_call_combiner_start()
109 gpr_atm_full_fetch_add(&call_combiner->size, (gpr_atm)-1)); in grpc_call_combiner_stop()
148 gpr_atm original_state = gpr_atm_acq_load(&call_combiner->cancel_state); in grpc_call_combiner_set_notify_on_cancel()
163 (gpr_atm)closure)) { 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()
Dlockfree_event.cc75 gpr_atm curr; in DestroyEvent()
96 gpr_atm curr = gpr_atm_acq_load(&state_); in NotifyOn()
110 if (gpr_atm_rel_cas(&state_, kClosureNotReady, (gpr_atm)closure)) { in NotifyOn()
159 gpr_atm new_state = (gpr_atm)shutdown_err | kShutdownBit; in SetShutdown()
162 gpr_atm curr = gpr_atm_no_barrier_load(&state_); in SetShutdown()
210 gpr_atm curr = gpr_atm_no_barrier_load(&state_); in SetReady()
Dcombiner.cc55 gpr_atm initiating_exec_ctx_or_null;
59 gpr_atm state;
99 gpr_atm old_state = gpr_atm_full_fetch_add(&lock->state, -STATE_UNORPHANED); in start_destroy()
162 gpr_atm last = gpr_atm_full_fetch_add(&lock->state, STATE_ELEM_COUNT_LOW_BIT); in combiner_exec()
170 (gpr_atm)grpc_core::ExecCtx::Get()); in combiner_exec()
177 gpr_atm initiator = in combiner_exec()
179 if (initiator != 0 && initiator != (gpr_atm)grpc_core::ExecCtx::Get()) { in combiner_exec()
285 gpr_atm old_state = in grpc_combiner_continue_exec_ctx()
Dresource_quota.cc74 gpr_atm refs;
77 gpr_atm shutdown;
100 gpr_atm num_threads_allocated;
129 gpr_atm memory_usage_estimation;
139 gpr_atm last_size;
183 static void ru_unref_by(grpc_resource_user* resource_user, gpr_atm amount);
297 gpr_atm memory_usage_estimation = MEMORY_USAGE_ESTIMATION_MAX; in rq_update_estimate()
300 GPR_CLAMP((gpr_atm)((1.0 - ((double)resource_quota->free_pool) / in rq_update_estimate()
332 ru_unref_by(resource_user, static_cast<gpr_atm>(aborted_allocations)); in rq_alloc()
700 (gpr_atm)GPR_MIN((size_t)GPR_ATM_MAX, size)); in grpc_resource_quota_resize()
[all …]
/external/grpc-grpc/src/core/ext/filters/client_channel/
Dretry_throttle.cc58 gpr_atm_rel_store(&milli_tokens_, static_cast<gpr_atm>(initial_milli_tokens)); in ServerRetryThrottleData()
64 reinterpret_cast<gpr_atm>(this)); in ServerRetryThrottleData()
95 &throttle_data->milli_tokens_, static_cast<gpr_atm>(-1000), in RecordFailure()
96 static_cast<gpr_atm>(0), in RecordFailure()
97 static_cast<gpr_atm>(throttle_data->max_milli_tokens_))); in RecordFailure()
110 static_cast<gpr_atm>(throttle_data->milli_token_ratio_), in RecordSuccess()
111 static_cast<gpr_atm>(0), in RecordSuccess()
112 static_cast<gpr_atm>(throttle_data->max_milli_tokens_)); in RecordSuccess()
/external/grpc-grpc/src/core/lib/gprpp/
Datomic_with_atm.h36 atomic() { gpr_atm_no_barrier_store(&x_, static_cast<gpr_atm>(false)); } in atomic()
38 gpr_atm_no_barrier_store(&x_, static_cast<gpr_atm>(x)); in atomic()
43 if (!gpr_atm_no_barrier_cas(&x_, static_cast<gpr_atm>(expected), in compare_exchange_strong()
44 static_cast<gpr_atm>(update))) { in compare_exchange_strong()
52 gpr_atm x_;
/external/grpc-grpc/src/core/lib/channel/
Dchannelz.h95 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()
108 gpr_atm calls_started_ = 0;
109 gpr_atm calls_succeeded_ = 0;
110 gpr_atm calls_failed_ = 0;
111 gpr_atm last_call_started_millis_ = 0;
/external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/
DCFStreamEndpointTests.mm44 gpr_atm *p = static_cast<gpr_atm *>(arg);
45 gpr_atm_full_cas(p, -1, reinterpret_cast<gpr_atm>(error));
48 static void init_event_closure(grpc_closure *closure, gpr_atm *atm) {
79 - (BOOL)waitForEvent:(gpr_atm *)event timeout:(int)timeout { argument
110 gpr_atm connected = -1;
153 gpr_atm read;
157 gpr_atm write;
207 gpr_atm read;
210 gpr_atm write;
256 gpr_atm read;
[all …]
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc43 #define MAX_IDLE_STATE_INIT ((gpr_atm)0)
44 #define MAX_IDLE_STATE_SEEN_EXIT_IDLE ((gpr_atm)1)
45 #define MAX_IDLE_STATE_SEEN_ENTER_IDLE ((gpr_atm)2)
46 #define MAX_IDLE_STATE_TIMER_SET ((gpr_atm)3)
95 gpr_atm call_count;
145 gpr_atm idle_state;
147 gpr_atm last_enter_idle_time_millis;
157 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in increase_call_count()
183 (gpr_atm)grpc_core::ExecCtx::Get()->Now()); in decrease_call_count()
185 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in decrease_call_count()
[all …]
/external/grpc-grpc/test/cpp/microbenchmarks/
Dhelpers.h57 extern gpr_atm gpr_mu_locks;
58 extern gpr_atm gpr_counter_atm_cas;
59 extern gpr_atm gpr_counter_atm_add;
60 extern gpr_atm gpr_now_call_count;
/external/grpc-grpc/src/core/lib/transport/
Dmetadata.cc81 gpr_atm refcnt;
84 gpr_atm destroy_user_data;
85 gpr_atm user_data;
97 gpr_atm refcnt;
108 gpr_atm free_estimate;
176 gpr_atm num_freed = 0; in gc_mdtab()
232 static_cast<gpr_atm>(shard->capacity / 4)) { in rehash_mdtab()
421 const gpr_atm prev_refcount = gpr_atm_full_fetch_add(&md->refcnt, -1); in grpc_mdelem_unref()
446 const gpr_atm prev_refcount = gpr_atm_full_fetch_add(&md->refcnt, -1); in grpc_mdelem_unref()
470 if (gpr_atm_acq_load(&im->destroy_user_data) == (gpr_atm)destroy_func) { in grpc_mdelem_get_user_data()
[all …]
/external/grpc-grpc/test/cpp/end2end/
Dstreaming_throughput_test.cc92 gpr_atm* should_exit) { in BidiStream_Sender()
95 while (gpr_atm_acq_load(should_exit) == static_cast<gpr_atm>(0)) { in BidiStream_Sender()
112 gpr_atm should_exit; in BidiStream()
113 gpr_atm_rel_store(&should_exit, static_cast<gpr_atm>(0)); in BidiStream()
126 gpr_atm_rel_store(&should_exit, static_cast<gpr_atm>(1)); in BidiStream()

12345