Home
last modified time | relevance | path

Searched refs:gpr_atm_rel_store (Results 1 – 25 of 57) sorted by relevance

123

/external/grpc-grpc/test/core/iomgr/
Dbuffer_list_test.cc35 gpr_atm_rel_store(done, static_cast<gpr_atm>(1)); in TestShutdownFlushesListVerifier()
49 gpr_atm_rel_store(&verifier_called[i], static_cast<gpr_atm>(0)); in TestShutdownFlushesList()
70 gpr_atm_rel_store(done, static_cast<gpr_atm>(1)); in TestVerifierCalledOnAckVerifier()
86 gpr_atm_rel_store(&verifier_called, static_cast<gpr_atm>(0)); in TestVerifierCalledOnAck()
Dresolve_address_posix_test.cc107 gpr_atm_rel_store(&args->done_atm, 0); in poll_pollset_until_request_done()
117 gpr_atm_rel_store(&args->done_atm, 1); in must_succeed()
123 gpr_atm_rel_store(&args->done_atm, 1); in must_fail()
Dresolve_address_test.cc57 gpr_atm_rel_store(&args->done_atm, 0); in args_init()
108 gpr_atm_rel_store(&args->done_atm, 1); in must_succeed()
117 gpr_atm_rel_store(&args->done_atm, 1); in must_fail()
/external/grpc-grpc/src/core/lib/gpr/
Dsync.cc63 gpr_atm_rel_store(&ev->state, (gpr_atm)value); in gpr_event_set()
86 void gpr_ref_init(gpr_refcount* r, int n) { gpr_atm_rel_store(&r->count, n); } in gpr_ref_init()
114 gpr_atm_rel_store(&c->value, n); in gpr_stats_init()
Dspinlock.h41 #define gpr_spinlock_unlock(lock) (gpr_atm_rel_store(&(lock)->atm, 0))
/external/rust/crates/grpcio-sys/grpc/src/core/lib/gpr/
Dsync.cc63 gpr_atm_rel_store(&ev->state, (gpr_atm)value); in gpr_event_set()
86 void gpr_ref_init(gpr_refcount* r, int n) { gpr_atm_rel_store(&r->count, n); } in gpr_ref_init()
114 gpr_atm_rel_store(&c->value, n); in gpr_stats_init()
Dspinlock.h41 #define gpr_spinlock_unlock(lock) (gpr_atm_rel_store(&(lock)->atm, 0))
/external/grpc-grpc/src/core/lib/iomgr/
Dexecutor.cc54 gpr_atm_rel_store(&num_threads_, 0); in GrpcExecutor()
100 gpr_atm_rel_store(&num_threads_, 1); in SetThreading()
142 gpr_atm_rel_store(&num_threads_, 0); in SetThreading()
304 gpr_atm_rel_store(&num_threads_, cur_thread_count + 1); in Enqueue()
/external/grpc-grpc/test/cpp/end2end/
Dstreaming_throughput_test.cc113 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()
/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()
63 gpr_atm_rel_store(&old_throttle_data->replacement_, in ServerRetryThrottleData()
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/client_channel/
Dretry_throttle.cc60 gpr_atm_rel_store(&milli_tokens_, static_cast<gpr_atm>(initial_milli_tokens)); in ServerRetryThrottleData()
65 gpr_atm_rel_store(&old_throttle_data->replacement_, in ServerRetryThrottleData()
/external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/
Datm_windows.h46 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
53 gpr_atm_rel_store(p, value); in gpr_atm_no_barrier_store()
Datm_gcc_sync.h55 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
/external/grpc-grpc/include/grpc/impl/codegen/
Datm_windows.h42 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
49 gpr_atm_rel_store(p, value); in gpr_atm_no_barrier_store()
Datm_gcc_sync.h53 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
/external/rust/crates/grpcio-sys/grpc/include/grpc/impl/codegen/
Datm_windows.h46 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
53 gpr_atm_rel_store(p, value); in gpr_atm_no_barrier_store()
Datm_gcc_sync.h55 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
/external/rust/crates/grpcio-sys/grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc166 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_SEEN_EXIT_IDLE); in increase_call_count()
193 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_TIMER_SET); in decrease_call_count()
318 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_INIT); in max_idle_timer_cb()
502 gpr_atm_rel_store(&chand->call_count, 1); in max_age_init_channel_elem()
/external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/
Dexecutor.cc94 gpr_atm_rel_store(&num_threads_, 0); in Executor()
151 gpr_atm_rel_store(&num_threads_, 1); in SetThreading()
192 gpr_atm_rel_store(&num_threads_, 0); in SetThreading()
368 gpr_atm_rel_store(&num_threads_, cur_thread_count + 1); in Enqueue()
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc167 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_SEEN_EXIT_IDLE); in increase_call_count()
194 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_TIMER_SET); in decrease_call_count()
277 gpr_atm_rel_store(&chand->idle_state, MAX_IDLE_STATE_INIT); in max_idle_timer_cb()
491 gpr_atm_rel_store(&chand->call_count, 1); in init_channel_elem()
/external/grpc-grpc/test/cpp/qps/
Dqps_worker.cc274 gpr_atm_rel_store(&done_, static_cast<gpr_atm>(0)); in QpsWorker()
296 gpr_atm_rel_store(&done_, static_cast<gpr_atm>(1)); in MarkDone()
/external/grpc-grpc/test/core/surface/
Dconcurrent_connectivity_test.cc150 gpr_atm_rel_store(&args->stop, 1); in bad_server_thread()
237 gpr_atm_rel_store(&args.stop, 1); in run_concurrent_connectivity_test()
/external/grpc-grpc/test/core/client_channel/resolvers/
Ddns_resolver_cooldown_test.cc124 gpr_atm_rel_store(&args->done_atm, 0); in iomgr_args_init()
187 gpr_atm_rel_store(&g_iomgr_args.done_atm, 1); in on_second_resolution()
/external/grpc-grpc/src/core/lib/transport/
Dmetadata.cc252 gpr_atm_rel_store(&allocated->refcnt, 1); in grpc_mdelem_create()
298 gpr_atm_rel_store(&md->refcnt, 1); in grpc_mdelem_create()
507 gpr_atm_rel_store(&im->destroy_user_data, (gpr_atm)destroy_func); in grpc_mdelem_set_user_data()
/external/grpc-grpc/test/cpp/naming/
Dresolver_component_test.cc175 gpr_atm_rel_store(&args->done_atm, 0); in ArgsInit()
416 gpr_atm_rel_store(&args->done_atm, 1); in CheckResolverResultLocked()
425 gpr_atm_rel_store(&args->done_atm, 1); in CheckResolvedWithoutErrorLocked()

123