Home
last modified time | relevance | path

Searched refs:count (Results 1 - 25 of 49) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
H A Dselect.rs37 let mut count = 0; in sdv_new_select_basic() variables
40 count += a; in sdv_new_select_basic()
43 count += b; in sdv_new_select_basic()
47 count = 3; in sdv_new_select_basic()
50 count = 4; in sdv_new_select_basic()
54 assert_eq!(count, 2); in sdv_new_select_basic()
102 /// 2. Checks whether the 'count' is correct.
106 let mut count = 0u8; in sdv_new_select_biased() variables
111 _ = async {}, if count < 1 => { in sdv_new_select_biased()
112 count in sdv_new_select_biased()
159 let mut count = 0; sdv_new_select_match() variables
198 let mut count = 0; sdv_new_select_precondition() variables
[all...]
/commonlibrary/c_utils/base/src/
H A Drwlock.cpp34 int count; in LockRead() local
38 while ((count = lockCount_) == LOCK_STATUS_WRITE || writeWaitCount_ > 0) {} in LockRead()
39 } while (!lockCount_.compare_exchange_weak(count, count + 1)); in LockRead()
43 while ((count = lockCount_) == LOCK_STATUS_WRITE) {} in LockRead()
44 } while (!lockCount_.compare_exchange_weak(count, count + 1)); in LockRead()
H A Ddatetime_ex.cpp30 return totalSeconds.time_since_epoch().count(); in GetSecondsSince1970ToNow()
42 return totalSeconds.time_since_epoch().count(); in GetSecondsSince1970ToPointTime()
59 return totalDays.time_since_epoch().count(); in GetDaysSince1970ToNow()
H A Drefbase.cpp75 // RefTracker will save the information about the count of RefBase,
266 // we should update the current count here. in DecStrongRefCount()
393 // the object destroyed on strong reference count reduce to zero. in AttemptIncStrongRef()
453 * RISK: If there is a reference count on the left of the equal sign,
454 * it may cause a reference count exception
617 int count = 0; in AttemptAcquire() local
618 if (refs_->AttemptIncStrongRef(objectId, count)) { in AttemptAcquire()
620 if (count == INITIAL_PRIMARY_VALUE) { in AttemptAcquire()
632 int count = 0; in AttemptIncStrongRef() local
633 bool ret = refs_->AttemptIncStrongRef(objectId, count); in AttemptIncStrongRef()
[all...]
H A Dobserver.cpp29 if (obs.count(o) > 0) { in AddObserver()
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/
H A Dpart.rs174 let mut count = 0; in data() variables
175 while count != buf.len() { in data()
178 PartStatus::Headers => self.headers_encode(&mut buf[count..]), in data()
179 PartStatus::Crlf => self.crlf_encode(&mut buf[count..]), in data()
180 PartStatus::Body => self.body_sync_encode(&mut buf[count..]), in data()
181 PartStatus::End => return Ok(count), in data()
183 count += encode_size?; in data()
185 Ok(count) in data()
197 let mut count = 0; in poll_data() variables
198 while count ! in poll_data()
[all...]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dqueue.rs111 pub(crate) fn count(&self) -> u64 {
112 self.inner.count()
140 count: AtomicU64,
159 fn count(&self) -> u64 { in count() functions
160 self.metrics.count.load(Acquire) in count()
190 count: AtomicU64::new(0), in new()
284 self.metrics.count.fetch_add(1, AcqRel);
303 let count = LOCAL_QUEUE_CAP / 2;
305 let next = wrap(front, front.wrapping_add(count as u16));
314 let mut tmp_buf = Vec::with_capacity(count);
352 let mut count = loop { global() variables
487 let mut count = 1; global() variables
[all...]
H A Dworker.rs226 pub(crate) count: u32,
238 count: 0,
252 self.count = self.count.wrapping_add(1); in increment_count()
265 if self.count & GLOBAL_PERIODIC_INTERVAL as u32 == 0 { in periodic_check()
/commonlibrary/ets_utils/js_concurrent_module/common/helper/
H A Dhitrace_helper.h22 #define HITRACE_HELPER_COUNT_TRACE(msg, count) CountTrace(HITRACE_TAG_COMMONLIBRARY, msg, count)
27 #define HITRACE_HELPER_COUNT_TRACE(msg, count)
H A Derror_helper.h169 static std::vector<std::string> SplitErrorFileInfo(const std::string& input, char delimiter, int count) in SplitErrorFileInfo() argument
178 while (pos != std::string::npos && count > 0) { in SplitErrorFileInfo()
182 count--; in SplitErrorFileInfo()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
H A Dfastrand.rs49 let mut count = 0; in seed() variables
51 count += 1; in seed()
53 hasher.write_usize(count); in seed()
H A Dselect.rs76 /// let mut count = 0;
79 /// count += a;
83 /// count += b;
95 /// assert_eq!(count, 2);
137 /// let mut count = 0u8;
142 /// _ = async {}, if count < 1 => {
143 /// count += 1;
144 /// assert_eq!(count, 1);
146 /// _ = async {}, if count < 2 => {
147 /// count
[all...]
/commonlibrary/c_utils/base/test/benchmarktest/timer_benchmark_test/
H A Dtimer_benchmark_test.cpp257 void DoFunc(Utils::Timer &timer, int &count) in DoFunc() argument
261 [&timer, &count]() { in DoFunc()
262 count += 1; in DoFunc()
263 if (count > MAX_COUNT) { in DoFunc()
266 DoFunc(timer, count); in DoFunc()
273 void DoFunc2(Utils::Timer &timer, int &count) in DoFunc2() argument
277 [&timer, &count]() { in DoFunc2()
278 count += 1; in DoFunc2()
279 if (count > MAX_COUNT) { in DoFunc2()
282 DoFunc2(timer, count); in DoFunc2()
[all...]
/commonlibrary/c_utils/base/test/unittest/common/
H A Dutils_timer_test.cpp282 void DoFunc(Utils::Timer &timer, int &count) in DoFunc() argument
285 [&timer, &count]() { in DoFunc()
286 count += 1; in DoFunc()
287 if (count > 9) { in DoFunc()
290 DoFunc(timer, count); in DoFunc()
296 void DoFunc2(Utils::Timer &timer, int &count) in DoFunc2() argument
299 [&timer, &count]() { in DoFunc2()
300 count += 1; in DoFunc2()
301 if (count > 9) { in DoFunc2()
304 DoFunc2(timer, count); in DoFunc2()
[all...]
H A Dutils_event_test.cpp1102 void DoFunc(Timer &timer, int &count) in DoFunc() argument
1105 [&timer, &count]() { in DoFunc()
1106 count = count + 1; in DoFunc()
1107 if (count > 9) { // 9: recursion depth in DoFunc()
1110 DoFunc(timer, count); in DoFunc()
1116 void DoFunc2(Timer &timer, int &count) in DoFunc2() argument
1119 [&timer, &count]() { in DoFunc2()
1120 count = count in DoFunc2()
[all...]
/commonlibrary/ets_utils/platform/default/
H A Dprocess_helper.cpp80 int count = 1; in GetProcessStartRealtime() local
83 if (count == 22) { // 22 : starttime in GetProcessStartRealtime()
92 count++; in GetProcessStartRealtime()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
H A Dylong_runtime_create_thread_fail.rs21 let mut count = 0; in main() variables
23 count += 1; in main()
24 println!("{count}"); in main()
/commonlibrary/rust/ylong_http/ylong_http/src/h1/request/
H A Dencoder.rs255 let mut count = 0; in encode() variables
256 while count != dst.len() { in encode()
257 count += match self.encode_status { in encode()
258 EncodeState::Method => self.method_encode(&mut dst[count..]), in encode()
259 EncodeState::MethodSp => self.method_sp_encode(&mut dst[count..]), in encode()
260 EncodeState::Uri => self.uri_encode(&mut dst[count..]), in encode()
261 EncodeState::UriSp => self.uri_sp_encode(&mut dst[count..]), in encode()
262 EncodeState::Version => self.version_encode(&mut dst[count..]), in encode()
263 EncodeState::VersionCrlf => self.version_crlf_encode(&mut dst[count..]), in encode()
264 EncodeState::Header => self.header_encode(&mut dst[count in encode()
[all...]
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
H A Dpercent_encoding.rs88 let mut count = 0; variables
92 count += 1;
99 if count == 2 {
/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dchunk.rs225 let mut count = 0; in data() variables
226 while count != buf.len() { in data()
228 DataState::Partial => self.bytes_encode(&mut buf[count..]), in data()
229 DataState::Complete => self.trailer_encode(&mut buf[count..]), in data()
230 DataState::Finish => return Ok(count), in data()
232 count += encode_size; in data()
242 let mut count = 0; in data() variables
243 while count != buf.len() { in data()
252 self.chunk_encode(&mut buf[count..]) in data()
254 DataState::Complete => self.trailer_encode(&mut buf[count in data()
273 let mut count = 0; poll_data() variables
300 let mut count = 0; poll_data() variables
[all...]
/commonlibrary/ets_utils/js_util_module/util/
H A Djs_uuid.cpp223 unsigned char *count = static_cast<unsigned char*>(data); in DoParseUUID() local
225 *count = ConvertBits(buffer); in DoParseUUID()
226 count++; in DoParseUUID()
/commonlibrary/rust/ylong_runtime/ylong_signal/src/
H A Dspin_rwlock.rs89 // count before acquire the data, the writer will not release the
112 let count = &self.version_holder_count[version];
113 while count.load(Ordering::SeqCst) != 0 {
/commonlibrary/ets_utils/js_concurrent_module/utils/locks/
H A Dasync_lock.cpp251 uint32_t count = --refCount_; in DecRefCount() local
252 if (count == 0) { in DecRefCount()
262 return count; in DecRefCount()
/commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/
H A Devent_benchmark_test.cpp1282 void DoFunc(Timer &timer, int &count) in DoFunc() argument
1286 [&timer, &count]() { in DoFunc()
1287 count += 1; in DoFunc()
1288 if (count > RECURSION_DEPTH) { in DoFunc()
1291 DoFunc(timer, count); in DoFunc()
1297 void DoFunc2(Timer &timer, int &count) in DoFunc2() argument
1301 [&timer, &count]() { in DoFunc2()
1302 count += 1; in DoFunc2()
1303 if (count > RECURSION_DEPTH) { in DoFunc2()
1306 DoFunc2(timer, count); in DoFunc2()
[all...]
/commonlibrary/ets_utils/js_sys_module/console/
H A Dconsole.cpp81 size_t count = 1; in ParseLogContent() local
83 if (count >= size) { in ParseLogContent()
99 ret += params[count++]; in ParseLogContent()
117 for (; count < size; ++count) { in ParseLogContent()
119 ret += params[count]; in ParseLogContent()
660 (std::chrono::high_resolution_clock::now().time_since_epoch()).count(); in Time()
674 (std::chrono::high_resolution_clock::now().time_since_epoch()).count(); in TimeLog()
692 (std::chrono::high_resolution_clock::now().time_since_epoch()).count(); in TimeEnd()
785 DECLARE_NAPI_DEFAULT_PROPERTY_FUNCTION("count", Coun in InitConsoleModule()
[all...]

Completed in 15 milliseconds

12