| /external/grpc-grpc/test/core/iomgr/ |
| D | buffer_list_test.cc | 35 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()
|
| D | resolve_address_posix_test.cc | 107 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()
|
| D | resolve_address_test.cc | 57 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()
|
| D | tcp_posix_test.cc | 391 gpr_atm_rel_store(done_timestamps, static_cast<gpr_atm>(1)); in timestamps_verifier()
446 gpr_atm_rel_store(&done_timestamps, static_cast<gpr_atm>(0)); in write_test()
|
| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync.cc | 63 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()
|
| D | spinlock.h | 41 #define gpr_spinlock_unlock(lock) (gpr_atm_rel_store(&(lock)->atm, 0))
|
| D | mpscq.cc | 40 gpr_atm_rel_store(&prev->next, (gpr_atm)n); in gpr_mpscq_push()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | executor.cc | 54 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()
|
| D | ev_epollsig_linux.cc | 350 gpr_atm_rel_store(&g_epoll_sync, (gpr_atm)0); in polling_island_add_fds_locked()
483 gpr_atm_rel_store(&pi->ref_count, 0); in polling_island_create()
484 gpr_atm_rel_store(&pi->poller_count, 0); in polling_island_create()
485 gpr_atm_rel_store(&pi->merged_to, (gpr_atm) nullptr); in polling_island_create()
679 gpr_atm_rel_store(&p->merged_to, (gpr_atm)q); in polling_island_merge()
837 gpr_atm_rel_store(&new_fd->refst, (gpr_atm)1);
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | streaming_throughput_test.cc | 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()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | retry_throttle.cc | 58 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/grpc-grpc/include/grpc/impl/codegen/ |
| D | atm_windows.h | 42 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()
|
| D | atm_gcc_sync.h | 53 static __inline void gpr_atm_rel_store(gpr_atm* p, gpr_atm value) { in gpr_atm_rel_store() function
|
| D | atm_gcc_atomic.h | 52 #define gpr_atm_rel_store(p, value) \ macro
|
| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 167 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/ |
| D | qps_worker.cc | 274 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()
|
| D | client.h | 218 gpr_atm_rel_store(&thread_pool_done_, static_cast<gpr_atm>(true)); in AwaitThreadsCompletion()
243 gpr_atm_rel_store(&thread_pool_done_, static_cast<gpr_atm>(false)); in StartThreads()
|
| /external/grpc-grpc/test/core/surface/ |
| D | concurrent_connectivity_test.cc | 150 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/ |
| D | dns_resolver_cooldown_test.cc | 124 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/test/cpp/naming/ |
| D | resolver_component_test.cc | 175 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()
|
| D | cancel_ares_query_test.cc | 124 gpr_atm_rel_store(&args->done_atm, 0); in ArgsInit()
166 gpr_atm_rel_store(&args->done_atm, 1); in CheckResolverResultAssertFailureLocked()
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | metadata.cc | 252 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/core/end2end/ |
| D | bad_server_response_test.cc | 98 gpr_atm_rel_store(&state.done_atm, 1); in done_write()
259 gpr_atm_rel_store(&state.done_atm, 0); in poll_server_until_read_done()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 710 gpr_atm_rel_store(&call->status_error, reinterpret_cast<gpr_atm>(error)); in set_final_status()
1125 gpr_atm_rel_store(&bctl->batch_error, in reset_batch_errors()
1148 gpr_atm_rel_store(&call->received_final_op_atm, 1); in post_batch_completion()
1299 gpr_atm_rel_store(&bctl->batch_error, in receiving_stream_ready()
1408 gpr_atm_rel_store(&bctl->batch_error, in receiving_initial_metadata_ready()
1461 gpr_atm_rel_store(&bctl->batch_error, in finish_batch()
1693 gpr_atm_rel_store(&call->status_error, in call_start_batch()
1843 gpr_atm_rel_store(&call->any_ops_sent_atm, 1); in call_start_batch()
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 182 gpr_atm_rel_store(&state->done_atm_, 1); in OnEventDone()
|