| /external/grpc-grpc/src/core/lib/iomgr/ |
| D | lockfree_event.cc | 172 if (gpr_atm_full_cas(&state_, curr, new_state)) { in SetShutdown()
191 if (gpr_atm_full_cas(&state_, curr, new_state)) { in SetShutdown()
241 else if (gpr_atm_full_cas(&state_, curr, kClosureNotReady)) { in SetReady()
|
| D | call_combiner.cc | 162 if (gpr_atm_full_cas(&call_combiner->cancel_state, original_state, in grpc_call_combiner_set_notify_on_cancel()
197 if (gpr_atm_full_cas(&call_combiner->cancel_state, original_state, in grpc_call_combiner_cancel()
|
| D | tcp_posix.cc | 175 gpr_atm_full_cas(&g_uncovered_notifications_pending, 1, 0)) { in run_poller()
177 bool cas_ok = gpr_atm_full_cas(&g_backup_poller, (gpr_atm)p, 0); in run_poller()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/iomgr/ |
| D | lockfree_event.cc | 177 if (gpr_atm_full_cas(&state_, curr, new_state)) { in SetShutdown()
196 if (gpr_atm_full_cas(&state_, curr, new_state)) { in SetShutdown()
246 else if (gpr_atm_full_cas(&state_, curr, kClosureNotReady)) { in SetReady()
|
| D | call_combiner.cc | 207 if (gpr_atm_full_cas(&cancel_state_, original_state, in SetNotifyOnCancel()
241 if (gpr_atm_full_cas(&cancel_state_, original_state, in Cancel()
|
| D | tcp_posix.cc | 467 gpr_atm_full_cas(&g_uncovered_notifications_pending, 1, 0)) { in run_poller()
470 gpr_atm_full_cas(&g_backup_poller, reinterpret_cast<gpr_atm>(p), 0); in run_poller()
|
| D | resource_quota.cc | 925 cas_success = gpr_atm_full_cas(&resource_quota->used, used, new_used); in grpc_resource_user_safe_alloc()
|
| /external/grpc-grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 73 #define gpr_atm_full_cas(p, o, n) gpr_atm_acq_cas((p), (o), (n)) macro
|
| D | atm_gcc_atomic.h | 79 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas() function
|
| D | atm_windows.h | 84 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas() function
|
| /external/rust/crates/grpcio-sys/grpc/include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 75 #define gpr_atm_full_cas(p, o, n) gpr_atm_acq_cas((p), (o), (n)) macro
|
| D | atm_gcc_atomic.h | 79 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas() function
|
| D | atm_windows.h | 88 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas() function
|
| /external/rust/crates/grpcio-sys/grpc/spm-core-include/grpc/impl/codegen/ |
| D | atm_gcc_sync.h | 75 #define gpr_atm_full_cas(p, o, n) gpr_atm_acq_cas((p), (o), (n)) macro
|
| D | atm_gcc_atomic.h | 79 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas() function
|
| D | atm_windows.h | 88 static __inline int gpr_atm_full_cas(gpr_atm* p, gpr_atm o, gpr_atm n) { in gpr_atm_full_cas() function
|
| /external/grpc-grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 130 if (gpr_atm_full_cas(&calld->state, static_cast<gpr_atm>(STATE_INIT), in on_md_processing_done()
158 gpr_atm_full_cas(&calld->state, static_cast<gpr_atm>(STATE_INIT), in cancel_call()
|
| /external/rust/crates/grpcio-sys/grpc/src/core/lib/security/transport/ |
| D | server_auth_filter.cc | 176 if (gpr_atm_full_cas(&calld->state, static_cast<gpr_atm>(STATE_INIT), in on_md_processing_done()
204 gpr_atm_full_cas(&calld->state, static_cast<gpr_atm>(STATE_INIT), in cancel_call()
|
| /external/grpc-grpc/src/core/lib/surface/ |
| D | server.cc | 782 if (gpr_atm_full_cas(&calld->state, NOT_STARTED, ZOMBIED)) { in got_initial_metadata()
786 } else if (gpr_atm_full_cas(&calld->state, PENDING, ZOMBIED)) { in got_initial_metadata()
1358 if (!gpr_atm_full_cas(&calld->state, PENDING, ACTIVATED)) { in queue_call_request()
|
| D | completion_queue.cc | 638 } else if (gpr_atm_full_cas(counter, count, count + 1)) {
|
| /external/grpc-grpc/test/core/iomgr/ios/CFStreamTests/ |
| D | CFStreamEndpointTests.mm | 45 gpr_atm_full_cas(p, -1, reinterpret_cast<gpr_atm>(error));
|