| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | sync.rs | 73 let mut n = mutex1.lock().await; in sdv_concurrency_with_mutex1() localVariable
81 let mut n = mutex2.lock().await; in sdv_concurrency_with_mutex1() localVariable
89 let mut n = mutex3.lock().await; in sdv_concurrency_with_mutex1() localVariable
97 let mut n = mutex4.lock().await; in sdv_concurrency_with_mutex1() localVariable
105 let mut n = mutex5.lock().await; in sdv_concurrency_with_mutex1() localVariable
128 let mut n = mutex.lock().await; in sdv_concurrency_with_mutex2() localVariable
135 let n = mutex.lock().await; in sdv_concurrency_with_mutex2() localVariable
153 let mut n = m1.lock().await; in sdv_concurrency_with_mutex3() localVariable
166 let n = mutex.lock().await; in sdv_concurrency_with_mutex3() localVariable
190 let mut n = mutex.lock().await; in sdv_concurrency_with_mutex4() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_runtime_async_benchmark.rs | 30 let n = client.write(&buf).await.unwrap(); in run_client() localVariable
33 let n = client.read(&mut buf).await.unwrap(); in run_client() localVariable
44 let n = server.read(&mut buf).await.unwrap(); in run_server() localVariable
48 let n = server.write(&buf).await.unwrap(); in run_server() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | stdio.rs | 69 let n = cmp::min(buf.len(), MAX_BUF); in clone_from() localVariable
75 let n = cmp::min(self.len(), buf.remaining()); in clone_into() localVariable
128 let n = buf_inner.clone_from(buf); localVariable
149 let n = res?; localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_mutex.rs | 50 let n = mutex.lock().await; localVariable
78 let n = mutex.lock().await; localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | file_buf.rs | 40 let n = std::cmp::min(self.remaining(), buf.remaining()); in append_to() localVariable
55 let n = std::cmp::min(other.len(), MAX_BUF_LEN); in append() localVariable
|
| D | async_file.rs | 475 let n = w_buf.append(buf); in poll_write() localVariable
|
| /commonlibrary/c_utils/base/src/ |
| D | timer_event_handler.cpp | 100 ssize_t n = ::read(GetHandle(), &expirations, sizeof(expirations)); in TimeOut() local
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | connector.rs | 170 let n = conn in tunnel() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | connector.rs | 197 let n = conn.read(&mut buf[pos..]).await?; in tunnel() localVariable
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| D | js_uuid.cpp | 116 int n = 0xb; // down of numerical range in GenerateUuid() local
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_event_test.cpp | 302 ssize_t n = ::read(GetFd(), &expirations, sizeof(expirations)); in TimeOut() local
907 ssize_t n = ::read(handler_->GetFd(), &expirations, sizeof(expirations)); in TimeOut() local
|
| D | utils_refbase_test.cpp | 322 for (int n = 0; n < 1; n++) { variable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| D | mod.rs | 559 let mut n = rng.get(); in xor_shift() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | queue.rs | 358 let mut n = src_rear.wrapping_sub(src_front_real); in steal_into() localVariable
|