Home
last modified time | relevance | path

Searched refs:gpr_atm_no_barrier_store (Results 1 – 25 of 30) sorted by relevance

12

/external/grpc-grpc/src/core/lib/gpr/
Dlog.cc70 gpr_atm_no_barrier_store(&g_min_severity_to_print, in gpr_set_log_verbosity()
91 gpr_atm_no_barrier_store(&g_min_severity_to_print, min_severity_to_print); 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()
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()
37 gpr_atm_no_barrier_store(&n->next, (gpr_atm)NULL); in gpr_mpscq_push()
/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()
Dfork.cc55 gpr_atm_no_barrier_store(&count_, UNBLOCKED(0)); in ExecCtxState()
93 gpr_atm_no_barrier_store(&count_, UNBLOCKED(0)); in AllowExecCtx()
/external/grpc-grpc/test/core/end2end/tests/
Dno_logging.cc262 gpr_atm_no_barrier_store(&g_log_func, (gpr_atm)test_no_error_log); in test_no_error_logging_in_entire_process()
267 gpr_atm_no_barrier_store(&g_log_func, (gpr_atm)gpr_default_log); in test_no_error_logging_in_entire_process()
277 gpr_atm_no_barrier_store(&g_log_func, (gpr_atm)test_no_log); in test_no_logging_in_one_request()
279 gpr_atm_no_barrier_store(&g_log_func, (gpr_atm)gpr_default_log); in test_no_logging_in_one_request()
/external/grpc-grpc/src/core/lib/channel/
Dchannelz.cc58 gpr_atm_no_barrier_store(&last_call_started_millis_, in CallCountingHelper()
66 gpr_atm_no_barrier_store(&last_call_started_millis_, in RecordCallStarted()
/external/grpc-grpc/src/core/lib/surface/
Dcompletion_queue.cc421 gpr_atm_no_barrier_store(&q->num_queue_items, 0); in cq_event_queue_init()
505 gpr_atm_no_barrier_store(&cqd->pending_events, 1); in cq_init_next()
507 gpr_atm_no_barrier_store(&cqd->things_queued_ever, 0); in cq_init_next()
521 gpr_atm_no_barrier_store(&cqd->pending_events, 1); in cq_init_pluck()
524 gpr_atm_no_barrier_store(&cqd->shutdown, 0); in cq_init_pluck()
527 gpr_atm_no_barrier_store(&cqd->things_queued_ever, 0); in cq_init_pluck()
539 gpr_atm_no_barrier_store(&cqd->pending_events, 1); in cq_init_callback()
541 gpr_atm_no_barrier_store(&cqd->things_queued_ever, 0); in cq_init_callback()
1310 gpr_atm_no_barrier_store(&cqd->shutdown, 1);
Dserver.cc339 gpr_atm_no_barrier_store(&calld->state, ZOMBIED); in request_matcher_zombify_all_pending_calls()
489 gpr_atm_no_barrier_store(&calld->state, ZOMBIED); in publish_new_rpc()
506 gpr_atm_no_barrier_store(&calld->state, ACTIVATED); in publish_new_rpc()
529 gpr_atm_no_barrier_store(&calld->state, ACTIVATED); in publish_new_rpc()
535 gpr_atm_no_barrier_store(&calld->state, PENDING); in publish_new_rpc()
552 gpr_atm_no_barrier_store(&calld->state, ZOMBIED); in finish_start_new_rpc()
Dchannel.cc115 gpr_atm_no_barrier_store( in grpc_channel_create_with_builder()
/external/grpc-grpc/src/core/lib/iomgr/
Dcombiner.cc82 gpr_atm_no_barrier_store(&lock->state, STATE_UNORPHANED); in grpc_combiner_create()
169 gpr_atm_no_barrier_store(&lock->initiating_exec_ctx_or_null, in combiner_exec()
180 gpr_atm_no_barrier_store(&lock->initiating_exec_ctx_or_null, 0); in combiner_exec()
Dresource_quota.cc305 gpr_atm_no_barrier_store(&resource_quota->memory_usage_estimation, in rq_update_estimate()
625 gpr_atm_no_barrier_store(&resource_quota->last_size, GPR_ATM_MAX); in grpc_resource_quota_create()
631 gpr_atm_no_barrier_store(&resource_quota->memory_usage_estimation, 0); in grpc_resource_quota_create()
699 gpr_atm_no_barrier_store(&resource_quota->last_size, in grpc_resource_quota_resize()
777 gpr_atm_no_barrier_store(&resource_user->num_threads_allocated, 0); in grpc_resource_user_create()
Dlockfree_event.cc71 gpr_atm_no_barrier_store(&state_, kClosureNotReady); in InitEvent()
Dev_epoll1_linux.cc117 gpr_atm_no_barrier_store(&g_epoll_set.num_events, 0); in epoll_set_init()
118 gpr_atm_no_barrier_store(&g_epoll_set.cursor, 0); in epoll_set_init()
501 gpr_atm_no_barrier_store(&g_active_poller, 0); in pollset_global_init()
933 gpr_atm_no_barrier_store(&g_active_poller, (gpr_atm)worker->next); in end_worker()
943 gpr_atm_no_barrier_store(&g_active_poller, 0); in end_worker()
Dtimer_generic.cc436 gpr_atm_no_barrier_store((gpr_atm*)(&g_shared_mutables.min_timer), in timer_init()
654 gpr_atm_no_barrier_store((gpr_atm*)(&g_shared_mutables.min_timer), in run_some_expired_timers()
Dtcp_posix.cc380 gpr_atm_no_barrier_store(&tcp->stop_error_notification, true); in tcp_destroy()
1065 gpr_atm_no_barrier_store(&tcp->shutdown_count, 0); in grpc_tcp_create()
1107 gpr_atm_no_barrier_store(&tcp->stop_error_notification, true); in grpc_tcp_destroy_and_release_fd()
Derror.cc370 gpr_atm_no_barrier_store(&err->atomics.error_string, 0); in grpc_error_create()
434 gpr_atm_no_barrier_store(&out->atomics.error_string, 0); in copy_error_and_unref()
Dtcp_server_posix.cc99 gpr_atm_no_barrier_store(&s->next_pollset_to_assign, 0); in tcp_server_create()
/external/grpc-grpc/src/core/lib/transport/
Dconnectivity_state.cc50 gpr_atm_no_barrier_store(&tracker->current_state_atm, init_state); in grpc_connectivity_state_init()
185 gpr_atm_no_barrier_store(&tracker->current_state_atm, state); in grpc_connectivity_state_set()
Dmetadata.cc121 gpr_atm_no_barrier_store(&shard->free_estimate, 0); in grpc_mdctx_global_init()
506 gpr_atm_no_barrier_store(&im->user_data, (gpr_atm)user_data); in grpc_mdelem_set_user_data()
/external/grpc-grpc/test/cpp/interop/
Dinterop_server_bootstrap.cc27 gpr_atm_no_barrier_store(&grpc::testing::interop::g_got_sigint, true); in sigint_handler()
/external/grpc-grpc/src/core/lib/debug/
Dtrace.h85 gpr_atm_no_barrier_store(&value_, enabled); in set_enabled()
/external/grpc-grpc/include/grpc/impl/codegen/
Datm_gcc_sync.h58 static __inline void gpr_atm_no_barrier_store(gpr_atm* p, gpr_atm value) { in gpr_atm_no_barrier_store() function
Datm_gcc_atomic.h54 #define gpr_atm_no_barrier_store(p, value) \ macro
Datm_windows.h47 static __inline void gpr_atm_no_barrier_store(gpr_atm* p, gpr_atm value) { in gpr_atm_no_barrier_store() function
/external/grpc-grpc/src/core/ext/filters/max_age/
Dmax_age_filter.cc182 gpr_atm_no_barrier_store(&chand->last_enter_idle_time_millis, in decrease_call_count()
432 gpr_atm_no_barrier_store(&chand->last_enter_idle_time_millis, GPR_ATM_MIN); in init_channel_elem()

12