Home
last modified time | relevance | path

Searched refs:Ordering (Results 1 – 25 of 65) sorted by relevance

123

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_signal/src/
H A Dspin_rwlock.rs33 use std::sync::atomic::{AtomicPtr, AtomicUsize, Ordering};
65 let version = self.version.load(Ordering::SeqCst) % VERSIONS; in read()
68 if curr_count.fetch_add(1, Ordering::SeqCst) > HOLDER_COUNT_MAX { in read()
82 let data = self.data[version].load(Ordering::SeqCst); in read()
84 curr_count.fetch_sub(1, Ordering::SeqCst); in read()
102 let version = self.version.load(Ordering::SeqCst); in write()
113 while count.load(Ordering::SeqCst) != 0 { in wait_version_release()
126 self.version_holder_count.fetch_sub(1, Ordering::SeqCst); in drop()
151 self.lock.data[new_version].store(val_ptr, Ordering::SeqCst); in store()
152 self.lock.version.store(new_version, Ordering::SeqCst); in store()
[all …]
H A Dcommon.rs134 use std::sync::atomic::{AtomicUsize, Ordering};
183 value_cpy.fetch_add(1, Ordering::Relaxed); in ut_signal_register()
190 value2_cpy.fetch_add(10, Ordering::Relaxed); in ut_signal_register()
194 assert_eq!(value.load(Ordering::Relaxed), 0); in ut_signal_register()
197 assert_eq!(value.load(Ordering::Relaxed), 1); in ut_signal_register()
198 assert_eq!(value2.load(Ordering::Relaxed), 10); in ut_signal_register()
201 assert_eq!(value.load(Ordering::Relaxed), 1); in ut_signal_register()
202 assert_eq!(value2.load(Ordering::Relaxed), 20); in ut_signal_register()
211 value2_cpy2.fetch_add(20, Ordering::Relaxed); in ut_signal_register()
217 assert_eq!(value2.load(Ordering::Relaxed), 40); in ut_signal_register()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_signal/tests/
H A Dsignal.rs17 use std::sync::atomic::{AtomicUsize, Ordering};
57 value_cpy.fetch_add(1, Ordering::Relaxed); in sdv_signal_register_succeed()
64 value2_cpy.fetch_add(10, Ordering::Relaxed); in sdv_signal_register_succeed()
68 assert_eq!(value.load(Ordering::Relaxed), 0); in sdv_signal_register_succeed()
71 assert_eq!(value.load(Ordering::Relaxed), 1); in sdv_signal_register_succeed()
72 assert_eq!(value2.load(Ordering::Relaxed), 10); in sdv_signal_register_succeed()
75 assert_eq!(value.load(Ordering::Relaxed), 1); in sdv_signal_register_succeed()
76 assert_eq!(value2.load(Ordering::Relaxed), 20); in sdv_signal_register_succeed()
85 value2_cpy2.fetch_add(20, Ordering::Relaxed); in sdv_signal_register_succeed()
91 assert_eq!(value2.load(Ordering::Relaxed), 40); in sdv_signal_register_succeed()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dsleeper.rs14 use std::sync::atomic::{AtomicUsize, Ordering};
117 let ret = self.0.fetch_sub(1, Ordering::SeqCst); in dec_searching_num()
122 self.0.fetch_add(1, Ordering::SeqCst); in inc_searching_num()
128 self.0.fetch_add(inc, Ordering::SeqCst); in inc_active_num()
134 let ret = self.0.fetch_sub(dec, Ordering::SeqCst); in dec_active_num()
140 let union_num = self.0.load(Ordering::SeqCst); in load_state()
/ohos5.0/base/request/request/services/src/task/
H A Doperator.rs16 use std::sync::atomic::{AtomicBool, Ordering};
59 if self.abort_flag.load(Ordering::Acquire) { in poll_progress_common()
64 if current >= self.task.last_notify.load(Ordering::SeqCst) + FRONT_NOTIFY_INTERVAL { in poll_progress_common()
66 self.task.last_notify.store(current, Ordering::SeqCst); in poll_progress_common()
74 self.task.background_notify_time.load(Ordering::SeqCst); in poll_progress_common()
89 let speed_limit = self.task.rate_limiting.load(Ordering::SeqCst); in poll_progress_common()
106 - (current - self.task.last_notify.load(Ordering::SeqCst)); in poll_progress_common()
H A Drequest_task.rs15 use std::sync::atomic::{AtomicBool, AtomicI64, AtomicU32, AtomicU64, Ordering};
98 let old = self.rate_limiting.swap(limit, Ordering::SeqCst); in speed_limit()
105 if self.tries.load(Ordering::SeqCst) < RETRY_TIMES { in network_retry()
106 self.tries.fetch_add(1, Ordering::SeqCst); in network_retry()
276 tries: self.tries.load(Ordering::SeqCst), in update_progress_in_database()
423 self.file_total_size.store(v, Ordering::SeqCst); in get_file_info()
594 tries: self.tries.load(Ordering::SeqCst), in info()
608 let mut file_total_size = self.file_total_size.load(Ordering::SeqCst); in background_notify()
622 .store(get_current_timestamp(), Ordering::SeqCst); in background_notify()
H A Dupload.rs17 use std::sync::atomic::{AtomicBool, Ordering};
247 if self.upload_resume.load(Ordering::SeqCst) { in prepare_single_upload()
248 self.upload_resume.store(false, Ordering::SeqCst); in prepare_single_upload()
279 task.tries.store(0, Ordering::SeqCst); in upload()
392 if task.timeout_tries.load(Ordering::SeqCst) < 2 { in upload_one_file()
393 task.timeout_tries.fetch_add(1, Ordering::SeqCst); in upload_one_file()
399 task.timeout_tries.store(0, Ordering::SeqCst); in upload_one_file()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dwake_list.rs17 use std::sync::atomic::{AtomicUsize, Ordering};
85 if self.flag.load(Ordering::SeqCst) & NOTIFIABLE != 0 { in notify()
97 while self.flag.fetch_or(LOCKED, Ordering::Acquire) & LOCKED != 0 { in lock()
148 self.waker_set.flag.store(flag, Ordering::SeqCst); in drop()
186 assert_eq!(wakelist.flag.load(Ordering::SeqCst), 0); in ut_wakelist_new_01()
H A Dmutex.rs187 use std::sync::atomic::{AtomicBool, Ordering};
258 lock_flag_clone.store(false, Ordering::SeqCst); in ut_mutex_try_lock_02()
259 while flag_clone.load(Ordering::SeqCst) { in ut_mutex_try_lock_02()
263 while lock_flag.load(Ordering::SeqCst) { in ut_mutex_try_lock_02()
268 flag.store(false, Ordering::SeqCst); in ut_mutex_try_lock_02()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dyield.rs14 use std::sync::atomic::Ordering::{Acquire, Release};
15 use std::sync::atomic::{AtomicUsize, Ordering};
75 val_cpy.fetch_add(1, Ordering::Relaxed); in sdv_yield_now_single_worker()
78 let cur = val_cpy.load(Ordering::Relaxed); in sdv_yield_now_single_worker()
/ohos5.0/base/request/request/services/src/manage/
H A Daccount.rs14 use std::sync::atomic::{AtomicBool, AtomicI32, Ordering};
43 .compare_exchange(false, true, Ordering::SeqCst, Ordering::SeqCst) in update_accounts()
66 let old_foreground = FOREGROUND_ACCOUNT.load(Ordering::SeqCst); in update()
73 FOREGROUND_ACCOUNT.store(foreground_account, Ordering::SeqCst); in update()
90 UPDATE_FLAG.store(false, Ordering::SeqCst); in drop()
281 assert_eq!(0, FOREGROUND_ACCOUNT.load(Ordering::SeqCst)); in ut_account_check_oh()
293 assert_ne!(FOREGROUND_ACCOUNT.load(Ordering::SeqCst), 0); in ut_account_check_oh()
H A Dnetwork_manager.rs16 use std::sync::atomic::Ordering;
59 let foreground_account = FOREGROUND_ACCOUNT.load(Ordering::SeqCst) as u64; in query_active_accounts()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dsleep.rs280 use std::sync::atomic::{AtomicUsize, Ordering};
300 val_cpy.fetch_add(1, Ordering::Relaxed); in ut_new_timer_sleep()
303 assert_eq!(val.load(Ordering::Relaxed), 1); in ut_new_timer_sleep()
309 val_cpy2.fetch_add(1, Ordering::Relaxed); in ut_new_timer_sleep()
313 val_cpy3.fetch_add(1, Ordering::Relaxed); in ut_new_timer_sleep()
317 val_cpy4.fetch_add(1, Ordering::Relaxed); in ut_new_timer_sleep()
322 assert_eq!(val.load(Ordering::Relaxed), 4); in ut_new_timer_sleep()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/huffman/
H A Dmod.rs38 use core::cmp::Ordering;
78 Ordering::Greater => { in huffman_encode()
82 Ordering::Equal => { in huffman_encode()
99 Ordering::Less => { in huffman_encode()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs65 use std::sync::atomic::{AtomicBool, Ordering};
112 .compare_exchange(false, true, Ordering::Acquire, Ordering::Relaxed) in dispatch()
120 self.inner.shutdown.load(Ordering::Relaxed) in is_shutdown()
137 self.inner.shutdown.store(true, Ordering::Release); in shutdown()
143 self.inner.occupied.store(false, Ordering::Release) in drop()
154 use std::sync::atomic::{AtomicBool, AtomicU32, Ordering};
381 self.io_shutdown.load(Ordering::Relaxed) in is_shutdown()
433 self.id.fetch_add(2, Ordering::Relaxed) in generate_id()
450 self.io_shutdown.store(true, Ordering::Release); in shutdown()
/ohos5.0/base/request/request/services/src/utils/
H A Dtask_id_generator.rs15 use std::sync::atomic::{AtomicU32, Ordering};
32 ID.fetch_add(1, Ordering::Relaxed) in generate()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
H A Ddecoder.rs14 use core::cmp::Ordering;
451 Ordering::Greater | Ordering::Equal => { in decode()
457 Ordering::Less => { in decode()
495 Ordering::Greater | Ordering::Equal => { in decode()
506 Ordering::Less => { in decode()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/
H A Dstreams.rs16 use std::cmp::{min, Ordering};
223 Ordering::Less => { in apply_send_initial_window_size()
233 Ordering::Greater => { in apply_send_initial_window_size()
239 Ordering::Equal => {} in apply_send_initial_window_size()
248 Ordering::Less => { in apply_recv_initial_window_size()
255 Ordering::Greater => { in apply_recv_initial_window_size()
260 Ordering::Equal => {} in apply_recv_initial_window_size()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dselector.rs22 use std::sync::atomic::{AtomicBool, Ordering};
124 !self.polling.swap(true, Ordering::AcqRel), in select_inner()
134 self.polling.store(false, Ordering::Relaxed); in select_inner()
225 if this.polling.load(Ordering::Acquire) { in register()
245 if self.polling.load(Ordering::Acquire) { in reregister()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/format/
H A Ddecoder.rs25 use std::cmp::Ordering;
587 Ordering::Greater | Ordering::Equal => { in decode()
592 Ordering::Less => { in decode()
703 Ordering::Greater | Ordering::Equal => { in decode()
714 Ordering::Less => { in decode()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/
H A Dinteger.rs17 use std::cmp::Ordering;
59 Ordering::Less => Ok(index as usize), in first_byte()
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dlib.rs45 use std::sync::atomic::{ AtomicUsize, Ordering };
72 id: ID_RADIX.fetch_add(1, Ordering::Relaxed), in new()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/
H A Dinteger.rs25 use core::cmp::Ordering;
58 Ordering::Less => Ok(index as usize), in first_byte()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Ddriver.rs111 .load(std::sync::atomic::Ordering::Acquire) in get_registered_count()
119 .load(std::sync::atomic::Ordering::Acquire) in get_ready_count()
280 .fetch_add(events.len() as u64, std::sync::atomic::Ordering::AcqRel); in drive()
394 .fetch_add(1, std::sync::atomic::Ordering::AcqRel); in register_source()
/ohos5.0/base/request/request/services/src/
H A Dability.rs16 use std::sync::atomic::{AtomicBool, Ordering};
146 if self.remote_busy.load(Ordering::Acquire) { in on_idle()

123