Home
last modified time | relevance | path

Searched refs:cur (Results 1 - 16 of 16) sorted by relevance

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Dstate.rs54 pub(crate) fn is_canceled(cur: usize) -> bool {
55 cur & CANCELED == CANCELED
59 pub(crate) fn is_care_join_handle(cur: usize) -> bool {
60 cur & CARE_JOIN_HANDLE == CARE_JOIN_HANDLE
64 pub(crate) fn is_finished(cur: usize) -> bool {
65 cur & FINISHED == FINISHED
69 pub(crate) fn is_set_waker(cur: usize) -> bool {
70 cur & JOIN_WAKER == JOIN_WAKER
74 pub(crate) fn is_scheduling(cur: usize) -> bool {
75 cur
124 let mut cur = self.get_current_state(); global() variables
151 let mut cur = self.get_current_state(); global() variables
177 let mut cur = self.get_current_state(); global() variables
215 let mut cur = self.get_current_state(); global() variables
241 let mut cur = self.get_current_state(); global() variables
263 let mut cur = self.get_current_state(); global() variables
298 let mut cur = self.get_current_state(); global() variables
[all...]
H A Dtask_handle.rs67 let cur = match self.header().state.turning_to_finish() { in finish()
68 Ok(cur) => cur, in finish()
72 if state::is_set_waker(cur) { in finish()
131 pub(crate) fn set_waker(self, cur: usize, des_waker: &Waker) -> bool {
132 let res = if state::is_set_waker(cur) {
148 .and_then(|cur| self.set_waker_inner(des_waker.clone(), cur))
150 self.set_waker_inner(des_waker.clone(), cur)
153 if let Err(cur)
[all...]
H A Djoin_handle.rs83 let cur = self.raw.header().state.get_current_state();
87 .set_waker(cur, (waker as *const Waker).cast::<()>())
105 let cur = self.raw.header().state.get_current_state();
107 state::is_care_join_handle(cur),
111 if state::is_finished(cur) {
118 let is_finished = self.raw.set_waker(cur, cx.waker() as *const _ as *mut ());
/commonlibrary/c_utils/base/src/
H A Dio_event_reactor.cpp173 for (IOEventHandler* cur = ioHandlers_[target->fd_].head.get(); cur != nullptr; cur = cur->next_) { in HasHandler()
174 if (cur == target) { in HasHandler()
206 for (IOEventHandler* cur = ioHandlers_[fd].head.get(); cur != nullptr; cur = cur->next_) { in UpdateToDemultiplexer()
207 emask |= cur in UpdateToDemultiplexer()
[all...]
H A Dunicode_ex.cpp155 char* cur = utf8Str; in StrncpyStr16ToStr8() local
172 Utf32CodePointToUtf8(reinterpret_cast<uint8_t*>(cur), utf32, len); in StrncpyStr16ToStr8()
173 cur += len; in StrncpyStr16ToStr8()
176 *cur = '\0'; in StrncpyStr16ToStr8()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/representation/
H A Dencoder.rs71 // `cur` is used to record the current write position of `dst`.
72 let mut cur = 0; variables
76 match state.encode(&mut dst[cur..]) {
77 Ok(size) => cur += size,
92 Some(TableIndex::Header(index)) => Indexed::new(index).encode(&mut dst[cur..]),
96 Indexing::new(index, v.into_bytes(), use_huffman).encode(&mut dst[cur..])
106 .encode(&mut dst[cur..])
110 Ok(size) => cur += size,
120 cur
400 ($item: expr, $dst: expr, $cur
441 let mut cur = 0; encode() variables
484 let mut cur = 0; encode() variables
512 let mut cur = 0; encode() variables
546 let mut cur = 0; encode() variables
[all...]
/commonlibrary/rust/ylong_json/src/reader/
H A Dio_reader.rs33 cur: usize, // The position of the cursor in the current buf.
61 cur: 0,
98 self.cur = 0; in load()
107 if self.cur > cacher.pre { in update_cache()
110 .extend_from_slice(&self.buf[cacher.pre..self.cur]); in update_cache()
112 cacher.pre = self.cur; in update_cache()
121 if self.cur == self.buf.len() { in next()
129 let ch = self.buf[self.cur]; in next()
130 self.cur += 1; in next()
144 if self.cur in peek()
[all...]
/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_mapped_file_test.cpp140 char* cur = mf.Begin(); in TestFileStatusAndRead() local
141 for (; cur <= mf.End(); cur++) { in TestFileStatusAndRead()
142 readout.push_back(*cur); in TestFileStatusAndRead()
147 *(cur) = 'E'; in TestFileStatusAndRead()
148 EXPECT_EQ((*cur), 'E'); in TestFileStatusAndRead()
155 for (char* cur = mf.Begin(); cur <= mf.End(); cur++) { in TestFileReadAndWrite()
156 readout.push_back(*cur); in TestFileReadAndWrite()
807 char* cur = mf.Begin(); HWTEST_F() local
907 char* cur = mf.Begin(); HWTEST_F() local
[all...]
H A Dutils_timer_test.cpp256 int64_t cur = CurMs(); in SleepLoopFunc() local
257 EXPECT_GE(cur - pre, desiredVal); in SleepLoopFunc()
H A Dutils_event_test.cpp1046 int64_t cur = CurMs(); in SleepLoop() local
1047 EXPECT_GE(cur - pre, desiredVal); in SleepLoop()
/commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/
H A Dencoder.rs82 let mut cur = 0; in ut_hpack_encoder() variables
87 cur += _encoder.encode(&mut vec[cur..]); in ut_hpack_encoder()
89 assert_eq!(cur, $len); in ut_hpack_encoder()
/commonlibrary/c_utils/base/test/benchmarktest/mapped_benchmark_test/
H A Dmapped_benchmark_test.cpp139 for (char* cur = mf.Begin(); cur <= mf.End(); cur++) { in ReadFromMappedFile()
140 readout.push_back(*cur); in ReadFromMappedFile()
264 for (char* cur = mf.Begin(); *cur != '\0'; cur++) { in BENCHMARK_F()
265 readout.push_back(*cur); in BENCHMARK_F()
328 for (char* cur = mf.Begin(); cur < in BENCHMARK_F()
628 char* cur = mf.Begin(); BENCHMARK_F() local
690 char* cur = mf.Begin(); BENCHMARK_F() local
843 char* cur = mf.Begin(); BENCHMARK_F() local
951 char* cur = mf.Begin(); BENCHMARK_F() local
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dyield.rs78 let cur = val_cpy.load(Ordering::Relaxed); in sdv_yield_now_single_worker()
79 assert!(cur > 100); in sdv_yield_now_single_worker()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dworker.rs105 let _guard = CURRENT_WORKER.with(|cur| {
106 let prev_ctx = cur.get();
107 cur.set((&cur_context as *const WorkerContext).cast::<()>());
/commonlibrary/c_utils/base/test/benchmarktest/timer_benchmark_test/
H A Dtimer_benchmark_test.cpp240 int64_t cur = CurMs(); in BENCHMARK_F() local
241 AssertGreaterThanOrEqual(cur - pre, 10, in BENCHMARK_F()
242 "(cur - pre) was not greater than or equal to 10 as expected.", state); in BENCHMARK_F()
/commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/
H A Devent_benchmark_test.cpp1264 int64_t cur = CurMs(); in BENCHMARK_F() local
1265 AssertGreaterThanOrEqual(cur - pre, expectedTimeDiff, in BENCHMARK_F()
1266 "cur - pre was not greater than or equal to expectedTimeDiff as expected.", state); in BENCHMARK_F()

Completed in 12 milliseconds