| /external/grpc-grpc/src/core/lib/gpr/ |
| D | sync.cc | 62 GPR_ASSERT(gpr_atm_acq_load(&ev->state) == 0); in gpr_event_set()
70 return (void*)gpr_atm_acq_load(&ev->state); in gpr_event_get()
74 void* result = (void*)gpr_atm_acq_load(&ev->state); in gpr_event_wait()
79 result = (void*)gpr_atm_acq_load(&ev->state); in gpr_event_wait()
110 return gpr_atm_acq_load(&r->count) == 1; in gpr_ref_is_unique()
123 return gpr_atm_acq_load(&c->value); in gpr_stats_read()
|
| D | mpscq.cc | 51 gpr_mpscq_node* next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()
60 next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()
67 gpr_mpscq_node* head = (gpr_mpscq_node*)gpr_atm_acq_load(&q->head); in gpr_mpscq_pop_and_check_end()
74 next = (gpr_mpscq_node*)gpr_atm_acq_load(&tail->next); in gpr_mpscq_pop_and_check_end()
|
| /external/grpc-grpc/src/core/ext/filters/client_channel/ |
| D | retry_throttle.cc | 53 gpr_atm_acq_load(&old_throttle_data->milli_tokens_)) / in ServerRetryThrottleData()
71 gpr_atm_acq_load(&replacement_)); in ~ServerRetryThrottleData()
82 gpr_atm_acq_load(&(*throttle_data)->replacement_)); in GetReplacementThrottleDataIfNeeded()
|
| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | ev_epollsig_linux.cc | 294 gpr_atm old_cnt = gpr_atm_acq_load(&pi->ref_count); in pi_add_ref_dbg()
306 gpr_atm old_cnt = gpr_atm_acq_load(&pi->ref_count); in pi_unref_dbg()
330 polling_island* next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in pi_unref()
521 polling_island* next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_maybe_get_latest()
524 next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_maybe_get_latest()
543 next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_lock()
550 next = (polling_island*)gpr_atm_acq_load(&pi->merged_to); in polling_island_lock()
609 next_1 = (polling_island*)gpr_atm_acq_load(&pi_1->merged_to); in polling_island_lock_pair()
612 next_1 = (polling_island*)gpr_atm_acq_load(&pi_1->merged_to); in polling_island_lock_pair()
615 next_2 = (polling_island*)gpr_atm_acq_load(&pi_2->merged_to); in polling_island_lock_pair()
[all …]
|
| D | executor.cc | 86 return gpr_atm_acq_load(&num_threads_) > 0; in IsThreaded()
90 gpr_atm curr_num_threads = gpr_atm_acq_load(&num_threads_); in SetThreading()
207 static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
300 cur_thread_count = static_cast<size_t>(gpr_atm_acq_load(&num_threads_)); in Enqueue()
|
| D | call_combiner.cc | 148 gpr_atm original_state = gpr_atm_acq_load(&call_combiner->cancel_state); 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()
|
| D | lockfree_event.cc | 96 gpr_atm curr = gpr_atm_acq_load(&state_); in NotifyOn()
|
| D | iocp_windows.cc | 133 while (gpr_atm_acq_load(&g_custom_events)) { in grpc_iocp_shutdown()
|
| D | ev_epoll1_linux.cc | 651 long num_events = gpr_atm_acq_load(&g_epoll_set.num_events); in process_epoll_events()
652 long cursor = gpr_atm_acq_load(&g_epoll_set.cursor); in process_epoll_events()
1027 if (gpr_atm_acq_load(&g_epoll_set.cursor) == in pollset_work()
1028 gpr_atm_acq_load(&g_epoll_set.num_events)) { in pollset_work()
|
| D | error.cc | 175 gpr_free((void*)gpr_atm_acq_load(&err->atomics.error_string)); in error_destroy()
754 void* p = (void*)gpr_atm_acq_load(&err->atomics.error_string); in grpc_error_string()
775 out = (char*)gpr_atm_acq_load(&err->atomics.error_string); in grpc_error_string()
|
| D | tcp_posix.cc | 197 backup_poller* p = (backup_poller*)gpr_atm_acq_load(&g_backup_poller); in drop_uncovered()
229 while ((p = (backup_poller*)gpr_atm_acq_load(&g_backup_poller)) == in cover_self()
740 static_cast<bool>(gpr_atm_acq_load(&tcp->stop_error_notification))) { in tcp_handle_error()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 41 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
78 cur = gpr_atm_acq_load(p); in gpr_atm_full_xchg()
|
| D | atm_windows.h | 31 static __inline gpr_atm gpr_atm_acq_load(const gpr_atm* p) { in gpr_atm_acq_load() function
39 return gpr_atm_acq_load(p); in gpr_atm_no_barrier_load()
|
| D | atm_gcc_atomic.h | 50 #define gpr_atm_acq_load(p) (__atomic_load_n((p), __ATOMIC_ACQUIRE)) macro
|
| /external/grpc-grpc/test/core/iomgr/ |
| D | buffer_list_test.cc | 56 GPR_ASSERT(gpr_atm_acq_load(&verifier_called[i]) == in TestShutdownFlushesList()
89 GPR_ASSERT(gpr_atm_acq_load(&verifier_called) == static_cast<gpr_atm>(1)); in TestVerifierCalledOnAck()
|
| D | resolve_address_posix_test.cc | 89 bool done = gpr_atm_acq_load(&args->done_atm) != 0; in actually_poll()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | call.cc | 270 parent_call* p = (parent_call*)gpr_atm_acq_load(&call->parent_call_atm); in get_or_create_parent_call()
277 p = (parent_call*)gpr_atm_acq_load(&call->parent_call_atm); in get_or_create_parent_call()
284 return (parent_call*)gpr_atm_acq_load(&call->parent_call_atm); in get_parent_call()
380 if (gpr_atm_acq_load(&args->parent->received_final_op_atm)) { in grpc_call_create()
523 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&c->status_error)); in destroy_call()
565 bool cancel = gpr_atm_acq_load(&c->any_ops_sent_atm) != 0 && in grpc_call_unref()
566 gpr_atm_acq_load(&c->received_final_op_atm) == 0; in grpc_call_unref()
615 char* peer_string = (char*)gpr_atm_acq_load(&call->peer_string); in grpc_call_get_peer()
723 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&call->status_error)) != in set_final_status()
1124 reinterpret_cast<grpc_error*>(gpr_atm_acq_load(&bctl->batch_error))); in reset_batch_errors()
[all …]
|
| D | server.cc | 488 if (error != GRPC_ERROR_NONE || gpr_atm_acq_load(&server->shutdown_flag)) { in publish_new_rpc()
551 if (gpr_atm_acq_load(&server->shutdown_flag)) { in finish_start_new_rpc()
670 if (!gpr_atm_acq_load(&server->shutdown_flag) || server->shutdown_published) { in maybe_finish_shutdown()
1182 if (gpr_atm_acq_load(&s->shutdown_flag) != 0) { in grpc_server_setup_transport()
1250 if (gpr_atm_acq_load(&server->shutdown_flag)) { in grpc_server_shutdown_and_notify()
1303 GPR_ASSERT(gpr_atm_acq_load(&server->shutdown_flag) || !server->listeners); in grpc_server_destroy()
1335 if (gpr_atm_acq_load(&server->shutdown_flag)) { in queue_call_request()
|
| D | completion_queue.cc | 632 gpr_atm count = gpr_atm_acq_load(counter);
720 bool will_definitely_shutdown = gpr_atm_acq_load(&cqd->pending_events) == 1;
1004 if (gpr_atm_acq_load(&cqd->pending_events) == 0) {
1050 gpr_atm_acq_load(&cqd->pending_events) > 0) {
|
| /external/grpc-grpc/src/core/ext/filters/max_age/ |
| D | max_age_filter.cc | 157 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in increase_call_count()
185 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in decrease_call_count()
271 gpr_atm idle_state = gpr_atm_acq_load(&chand->idle_state); in max_idle_timer_cb()
373 if (gpr_atm_acq_load(&chand->idle_state) == MAX_IDLE_STATE_SEEN_EXIT_IDLE) { in channel_connectivity_changed()
|
| /external/grpc-grpc/test/cpp/end2end/ |
| D | streaming_throughput_test.cc | 95 while (gpr_atm_acq_load(should_exit) == static_cast<gpr_atm>(0)) { in BidiStream_Sender()
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 83 while (gpr_atm_acq_load(event) == -1 && [deadline timeIntervalSinceNow] > 0) {
88 return (gpr_atm_acq_load(event) != -1);
|
| /external/grpc-grpc/src/core/lib/transport/ |
| D | metadata.cc | 183 if (gpr_atm_acq_load(&md->refcnt) == 0) { in gc_mdtab()
470 if (gpr_atm_acq_load(&im->destroy_user_data) == (gpr_atm)destroy_func) { in grpc_mdelem_get_user_data()
|
| /external/grpc-grpc/test/core/transport/chttp2/ |
| D | settings_timeout_test.cc | 172 bool done() const { return gpr_atm_acq_load(&done_atm_) != 0; } in done()
|
| /external/grpc-grpc/test/cpp/qps/ |
| D | qps_worker.cc | 293 return (gpr_atm_acq_load(&done_) != static_cast<gpr_atm>(0)); in Done()
|