Home
last modified time | relevance | path

Searched refs:load (Results 1 - 25 of 35) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_signal/tests/
H A Dsignal.rs68 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()
91 assert_eq!(value2.load(Ordering::Relaxed), 40); in sdv_signal_register_succeed()
164 assert_eq!(global.value.load(Ordering::Relaxed), 0); in sdv_signal_register_with_old()
175 assert_eq!(global.value.load(Ordering::Relaxed), 2); in sdv_signal_register_with_old()
183 assert_eq!(global.value.load(Ordering::Relaxed), 3); in sdv_signal_register_with_old()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dqueue.rs137 let next_block = block.next.load(Acquire); in send_inner()
151 let mut tail = self.tail.index.load(Acquire);
152 let mut block_ptr = self.tail.block.load(Acquire);
160 tail = self.tail.index.load(Acquire);
161 block_ptr = self.tail.block.load(Acquire);
178 tail = self.tail.index.load(Acquire);
179 block_ptr = self.tail.block.load(Acquire);
199 head.block = NonNull::new(block.next.load(Acquire)).unwrap();
201 unsafe { (*self.tail.block.load(Acquire)).insert(block_ptr) };
210 let tail_index = self.tail.index.load(Acquir
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs56 let (steal_pos, _) = unwrap(self.inner.front.load(Acquire)); in is_half_full()
153 let rear = self.rear.load(Acquire); in len()
154 let (_, head) = unwrap(self.front.load(Acquire)); in len()
160 self.metrics.count.load(Acquire) in count()
166 self.metrics.task_from_global_count.load(Acquire) in task_from_global_count()
172 self.metrics.task_to_global_count.load(Acquire) in task_to_global_count()
199 let (_, head) = unwrap(self.front.load(Acquire)); in is_empty()
200 let rear = self.rear.load(Acquire); in is_empty()
205 let mut head = self.front.load(Acquire);
238 let front = self.front.load(Acquir
[all...]
H A Dsleeper.rs140 let union_num = self.0.load(Ordering::SeqCst); in load_state()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dwatch.rs109 if self.channel.rx_cnt.load(Acquire) == 0 { in send()
142 let (value_version, _) = self.channel.state.load(); in subscribe()
166 self.channel.rx_cnt.load(Acquire) in receiver_count()
305 let (value_version, is_closed) = self.channel.state.load(); in is_notified()
313 let (value_version, is_closed) = self.channel.state.load();
436 let (value_version, _) = self.channel.state.load(); in borrow()
474 let (value_version, _) = self.channel.state.load(); in borrow_notify()
524 fn load(&self) -> (usize, bool) { in load() functions
525 let state = self.0.load(Acquire); in load()
561 let (value_version, is_closed) = self.state.load(); in fmt()
[all...]
H A Doneshot.rs169 match self.channel.state.load(Acquire) { in send()
211 self.channel.state.load(Acquire) == CLOSED in is_closed()
327 match self.channel.state.load(Acquire) { in try_recv()
393 match self.channel.state.load(Acquire) { in poll()
396 if self.channel.state.load(Acquire) == SENT { in poll()
457 .field("state", &self.state.load(Acquire)) in fmt()
H A Dwake_list.rs85 if self.flag.load(Ordering::SeqCst) & NOTIFIABLE != 0 { in notify()
186 assert_eq!(wakelist.flag.load(Ordering::SeqCst), 0); in ut_wakelist_new_01()
H A Dmutex.rs259 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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dstate.rs116 self.0.load(Acquire)
342 assert_eq!(task_state.0.load(Acquire), INIT); in ut_task_state_new()
354 assert_eq!(task_state.0.load(Acquire), INIT.wrapping_sub(REF_ONE)) in ut_task_state_dec_ref()
366 assert_eq!(task_state.0.load(Acquire), INIT.wrapping_add(REF_ONE)); in ut_task_state_inc_ref()
446 let mut next_state = task_state.0.load(Acquire); in ut_task_state_turning_to_idle()
462 let mut next_state = task_state.0.load(Acquire); in ut_task_state_turning_to_idle()
469 StateAction::Success => assert_eq!(task_state.0.load(Acquire), test_state), in ut_task_state_turning_to_idle()
474 let mut next_state = task_state.0.load(Acquire); in ut_task_state_turning_to_idle()
491 let mut test_state = task_state.0.load(Acquire); in ut_task_state_turning_to_scheduling()
509 let mut next_state = task_state.0.load(Acquir in ut_task_state_turn_to_un_set_waker()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslab.rs217 if !self.pages[page_idx].allocated.load(SeqCst) { in get()
259 if page.used.load(Relaxed) != 0 || !page.allocated.load(Relaxed) { in compact()
330 if me.used.load(Relaxed) == me.len { in allocate()
542 assert_eq!(temp.pop().unwrap(), value.id.load(SeqCst)); in ut_slab_for_each()
584 assert_eq!(slab.get(address[32].0).unwrap().id.load(SeqCst), 32); in ut_slab_compact()
591 assert!(!slab.pages[1].allocated.load(SeqCst)); in ut_slab_compact()
597 assert!(slab.pages[1].allocated.load(SeqCst)); in ut_slab_compact()
598 assert_eq!(slab.pages[1].used.load(SeqCst), 1); in ut_slab_compact()
600 assert!(slab.pages[1].allocated.load(SeqCs in ut_slab_compact()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_signal/src/
H A Dcommon.rs194 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()
217 assert_eq!(value2.load(Ordering::Relaxed), 40); in ut_signal_register()
H A Dspin_rwlock.rs65 let version = self.version.load(Ordering::SeqCst) % VERSIONS;
82 let data = self.data[version].load(Ordering::SeqCst);
102 let version = self.version.load(Ordering::SeqCst);
113 while count.load(Ordering::SeqCst) != 0 {
170 let data = self.lock.data[self.version].load(Ordering::SeqCst); in deref()
/commonlibrary/c_utils/base/src/
H A Drefbase.cpp41 return atomicWeak_.load(std::memory_order_relaxed); in GetWeakRefCount()
125 "refcnt: %{public}d", objectId, this, atomicStrong_.load(std::memory_order_relaxed), in PrintRefs()
126 atomicWeak_.load(std::memory_order_relaxed), atomicRefCount_.load(std::memory_order_relaxed)); in PrintRefs()
182 return atomicRefCount_.load(std::memory_order_relaxed); in GetRefCount()
192 if (atomicRefCount_.load(std::memory_order_relaxed) > 0) { in DecRefCount()
247 int curCount = atomicStrong_.load(std::memory_order_relaxed); in IncStrongRefCount()
276 return atomicStrong_.load(std::memory_order_relaxed); in GetStrongRefCount()
319 return atomicWeak_.load(std::memory_order_relaxed); in GetWeakRefCount()
324 return atomicAttempt_.load(st in GetAttemptAcquire()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Darray.rs77 let mut tail = self.tail.load(Acquire); in prepare_send()
85 let node_index = node.index.load(Acquire); in prepare_send()
147 let node_index = node.index.load(Acquire);
159 let tail = self.tail.load(Acquire);
197 self.tail.load(Acquire) & CLOSED == CLOSED in is_close()
202 let tail = self.tail.load(Acquire) >> INDEX_SHIFT; in len()
242 let tail = self.array.tail.load(Acquire);
246 let node_index = node.index.load(Acquire);
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dschedule_io.rs112 let status_bit = Bit::from_usize(self.status.load(Acquire)); in reset()
124 let base = Bit::from_usize(self.status.load(Acquire)); in generation()
135 let curr_bit = Bit::from_usize(self.status.load(Acquire));
162 let status_bit = Bit::from_usize(self.status.load(Acquire));
196 let mut current = self.status.load(Acquire);
332 let status_bit = Bit::from_usize(schedule_io.status.load(SeqCst)); in poll_init()
345 let status_bit = Bit::from_usize(schedule_io.status.load(SeqCst)); in poll_init()
417 let status_bit = Bit::from_usize(schedule_io.status.load(Acquire)); in poll_state()
477 let status = schedule_io.status.load(Acquire); in ut_schedule_io_default()
492 let pre_status = schedule_io.status.load(Acquir in ut_schedule_io_reset()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_signal.rs49 while num.load(Acquire) < 10 {} in run_multi_thread_signal()
69 while num.load(Acquire) < 10 {} in run_multi_thread_signal()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dyield.rs35 while self.parker.load(Acquire) != 0 {} in wait_for_all()
78 let cur = val_cpy.load(Ordering::Relaxed); in sdv_yield_now_single_worker()
H A Dsignal.rs78 while num.load(Acquire) < 10 {} in sdv_signal_recv_multi_thread_test()
122 while num.load(Acquire) < 10 {} in sdv_signal_poll_recv_multi_thread_test()
/commonlibrary/ets_utils/js_concurrent_module/worker/
H A Dworker.h387 return runnerState_.load(std::memory_order_acquire) <= RUNNING; in IsNotTerminate()
392 return runnerState_.load(std::memory_order_acquire) == RUNNING; in IsRunning()
397 return runnerState_.load(std::memory_order_acquire) >= TERMINATED; in IsTerminated()
402 return runnerState_.load(std::memory_order_acquire) == TERMINATEING; in IsTerminating()
451 return hostState_.load(std::memory_order_acquire) == INACTIVE; in HostIsStop()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_signal.rs44 while num.load(Acquire) < 10 {}
93 while num.load(Acquire) < 10 {}
/commonlibrary/rust/ylong_json/src/reader/
H A Dio_reader.rs91 fn load(&mut self) -> Result<bool> { in load() functions
122 match self.load() { in next()
145 match self.load() { in peek()
157 match self.load() { in discard()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dsleep.rs303 assert_eq!(val.load(Ordering::Relaxed), 1); in ut_new_timer_sleep()
322 assert_eq!(val.load(Ordering::Relaxed), 4); in ut_new_timer_sleep()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/
H A Ddecoder.rs58 decoder.load(&mut self.holder);
H A Dencoder.rs51 encoder.load(&mut self.holder);
/commonlibrary/c_utils/base/test/fuzztest/timer_fuzzer/
H A Dtimer_fuzzer.cpp48 sleepTime, g_data.load(std::memory_order_relaxed));

Completed in 14 milliseconds

12