Home
last modified time | relevance | path

Searched refs:Release (Results 1 - 23 of 23) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dstate.rs328 use std::sync::atomic::Ordering::{Acquire, Release};
449 task_state.0.store(next_state, Release); in ut_task_state_turning_to_idle()
465 task_state.0.store(next_state, Release); in ut_task_state_turning_to_idle()
477 task_state.0.store(next_state, Release); in ut_task_state_turning_to_idle()
512 task_state.0.store(next_state, Release); in ut_task_state_turn_to_un_set_waker()
520 task_state.0.store(next_state, Release); in ut_task_state_turn_to_un_set_waker()
528 task_state.0.store(next_state, Release); in ut_task_state_turn_to_un_set_waker()
548 task_state.0.store(next_state, Release); in ut_task_state_turn_to_set_waker()
556 task_state.0.store(next_state, Release); in ut_task_state_turn_to_set_waker()
564 task_state.0.store(next_state, Release); in ut_task_state_turn_to_set_waker()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_signal.rs15 use std::sync::atomic::Ordering::{Acquire, Release};
45 num_clone.fetch_add(1, Release); in run_multi_thread_signal()
64 num_clone.fetch_add(1, Release); in run_multi_thread_signal()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Datomic_waker.rs17 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
57 self.state.store(IDLE, Release);
80 self.state.fetch_and(!WAKING, Release);
H A Dwatch.rs19 use std::sync::atomic::Ordering::{Acquire, Release};
143 self.channel.rx_cnt.fetch_add(1, Release); in subscribe()
499 self.channel.rx_cnt.fetch_add(1, Release); in clone()
509 self.channel.rx_cnt.fetch_sub(1, Release); in drop()
521 self.0.fetch_add(1 << VERSION_SHIFT, Release); in version_update()
532 self.0.fetch_or(CLOSED, Release); in close()
H A Dsemaphore_inner.rs19 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
85 let prev = self.permits.fetch_add(1 << PERMIT_SHIFT, Release);
97 self.permits.store(1 << PERMIT_SHIFT, Release);
106 let prev = self.permits.fetch_add(permits << PERMIT_SHIFT, Release);
149 self.permits.fetch_or(CLOSED, Release);
H A Drwlock.rs20 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
115 if self.read_count.fetch_add(1, Release) < 0 {
173 let read_count = self.read_count.fetch_sub(MAX_READS, Release);
177 if read_count >= 0 && self.read_wait.fetch_add(read_count, Release) != -read_count {
259 if self.0.read_count.fetch_sub(1, Release) < 0 in unlock()
260 && self.0.read_wait.fetch_sub(1, Release) == 1 in unlock()
304 let read_count = self.0.read_count.fetch_add(MAX_READS, Release) + MAX_READS; in drop()
H A Doneshot.rs47 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release, SeqCst};
433 self.state.store(CLOSED, Release); in take_value_sent()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dqueue.rs18 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
53 self.next.store(ptr::null_mut(), Release); in reclaim()
138 self.tail.block.store(next_block, Release); in send_inner()
139 self.tail.index.fetch_add(1 << INDEX_SHIFT, Release); in send_inner()
146 node.has_value.store(true, Release); in send_inner()
238 self.tail.index.fetch_or(CLOSED, Release); in close()
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dyield.rs14 use std::sync::atomic::Ordering::{Acquire, Release};
39 self.parker.fetch_sub(1, Release); in wake_one()
H A Dsignal.rs20 use std::sync::atomic::Ordering::{Acquire, Release};
74 num_clone.fetch_add(1, Release); in sdv_signal_recv_multi_thread_test()
118 num_clone.fetch_add(1, Release); in sdv_signal_poll_recv_multi_thread_test()
H A Dsync.rs19 use std::sync::atomic::Ordering::{Acquire, Release};
478 num3.fetch_add(1, Release); in sdv_waiter_with_wake_all()
/commonlibrary/c_utils/base/include/
H A Dunique_fd.h133 int Release() in Release() function in OHOS::final
173 int rhsfd = rhs.Release(); in UniqueFdAddDeletor()
189 int rhsfd = rhs.Release(); in operator =()
/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/
H A Dylong_tokio_signal.rs40 num_clone.fetch_add(1, Release);
89 num_clone.fetch_add(1, Release);
130 use std::sync::atomic::Ordering::{Acquire, Release};
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
H A Darray.rs19 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release};
111 node.index.fetch_sub(1, Release);
154 node.index.fetch_add(self.capacity + 1, Release);
191 self.tail.fetch_or(CLOSED, Release); in close()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dcurrent_thread.rs320 use std::sync::atomic::Ordering::{Acquire, Release};
430 finished_clone.fetch_add(1, Release); in ut_current_thread_run_queue()
438 finished_clone.fetch_add(1, Release); in ut_current_thread_run_queue()
457 finished_clone.fetch_add(1, Release); in ut_current_thread_run_queue()
465 finished_clone.fetch_add(1, Release); in ut_current_thread_run_queue()
H A Dqueue.rs18 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release, SeqCst};
307 match self.front.compare_exchange(prev, next, Release, Acquire) {
504 inner_buf.rear.store(curr, Release);
H A Dblocking_pool.rs256 Release,
302 return (WaitState::Release, shared); in wait_temporary()
330 (WaitState::Release, guard) => return (true, guard), in wait()
H A Dasync_pool.rs612 use std::sync::atomic::Ordering::{Acquire, Release};
736 executor_mng_info.is_cancel.store(false, Release); in ut_executor_mng_info_is_cancel()
738 executor_mng_info.is_cancel.store(true, Release); in ut_executor_mng_info_is_cancel()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/
H A Dschedule_io.rs21 use std::sync::atomic::Ordering::{AcqRel, Acquire, Release, SeqCst};
118 self.status.store(next.as_usize(), Release); in reset()
464 use std::sync::atomic::Ordering::{Acquire, Release};
508 schedule_io.status.store(0x7f000000, Release); in ut_schedule_io_generation()
534 schedule_io.status.store(0x0000000f, Release); in ut_schedule_io_clear_readiness()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs19 use std::sync::atomic::Ordering::{Acquire, Release, SeqCst};
56 self.is_registered.store(true, Release);
/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_unique_fd_test.cpp168 ASSERT_EQ(ufd2.Release(), fd); in HWTEST_F()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs169 self.inner.shutdown.store(true, Ordering::Release);
175 self.inner.occupied.store(false, Ordering::Release) in drop()
458 self.io_shutdown.store(true, Ordering::Release);
/commonlibrary/c_utils/base/test/benchmarktest/unique_fd_benchmark_test/
H A Dunique_fd_benchmark_test.cpp229 int fd = ufd.Release(); in BENCHMARK_F()

Completed in 16 milliseconds