| /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 …]
|
| D | uds_test.rs | 43 let n = stream.write(b"hello client").await.unwrap(); in sdv_uds_stream_test() localVariable
45 let n = stream.read(&mut read_buf).await.unwrap(); in sdv_uds_stream_test() localVariable
57 let n = stream.read(&mut read_buf).await.unwrap(); in sdv_uds_stream_test() localVariable
64 let n = stream.write(b"hello server").await.unwrap(); in sdv_uds_stream_test() localVariable
|
| D | udp_test.rs | 46 let n = connected_sender in sdv_udp_send_recv() localVariable
75 let n = sender in sdv_udp_send_to_recv_from() localVariable
115 let n = connected_sender in sdv_udp_recv() localVariable
288 let n = ylong_runtime::futures::poll_fn(|cx| connected_sender.poll_send(cx, b"Hello")) in sdv_udp_send_recv_poll() localVariable
391 let n = in sdv_udp_send_to_recv_from_poll() localVariable
424 let n = in sdv_udp_send_to_peek_from_poll() localVariable
|
| D | tcp_test.rs | 203 let n = client in sdv_tcp_global_runtime() localVariable
210 let n = client in sdv_tcp_global_runtime() localVariable
308 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_borrow_half() localVariable
316 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_borrow_half() localVariable
378 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_owned_half() localVariable
387 let n = read_half.read(&mut buf).await.expect("server read err"); in sdv_tcp_split_owned_half() localVariable
|
| /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/net/sys/tcp/ |
| D | split.rs | 148 let n = read_half.read(&mut buf).await.expect("server read err"); in ut_test_borrow_half() localVariable
158 let n = stream.read(&mut buf).await.expect("server read err"); in ut_test_borrow_half() localVariable
195 let n = read_half.read(&mut buf).await.expect("server read err"); in ut_test_owned_half() localVariable
205 let n = stream.read(&mut buf).await.expect("server read err"); in ut_test_owned_half() localVariable
247 let n = read_half.read(&mut buf).await.expect("server read err"); in ut_test_borrow_half_vector() localVariable
254 let n = stream.read(&mut buf).await.expect("server read err"); in ut_test_borrow_half_vector() localVariable
297 let n = read_half.read(&mut buf).await.expect("server read err"); in ut_test_owned_half_vector() localVariable
304 let n = stream.read(&mut buf).await.expect("server read err"); in ut_test_owned_half_vector() 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
223 let n = buf_inner.clone_into(&mut read_buf); in ut_test_stdio_basic() localVariable
|
| D | read_task.rs | 502 let n = f.write(&buf).await.unwrap(); in ut_io_string_result() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_io/tests/ |
| D | uds_test.rs | 61 let n = stream.write_vectored(&[slice]).unwrap(); in sdv_uds_stream_test() localVariable
150 let n = sender2.send(b"Hello"); in sdv_uds_send_recv() localVariable
154 let n = sender.send(b"Hello").expect("sender send failed"); in sdv_uds_send_recv() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_mutex.rs | 52 let n = mutex.lock().await; localVariable
82 let n = mutex.lock().await; localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | file_buf.rs | 38 let n = std::cmp::min(self.remaining(), buf.remaining()); in append_to() localVariable
53 let n = std::cmp::min(other.len(), buf_size_limit); in append() localVariable
|
| D | async_file.rs | 512 let n = w_buf.append(buf, file.buf_size_limit); 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 | 174 let n = conn in tunnel() localVariable
|
| /commonlibrary/ets_utils/js_util_module/util/ |
| D | js_uuid.cpp | 113 int n = 0xb; // down of numerical range in GenerateUuid() local
|
| /commonlibrary/ets_utils/js_concurrent_module/utils/locks/ |
| D | graph.h | 105 size_t n = e_.size(); in IsValid() local
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| D | mod.rs | 276 n: Option<bool>, field
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 1604 let n = poll_fn(|cx| connected_sender.poll_send(cx, b"Hello")) in ut_send_recv_poll() localVariable
1636 let n = poll_fn(|cx| sender.poll_send_to(cx, b"Hello", receiver_addr)) in ut_send_to_recv_from_poll() localVariable
1808 let n = poll_fn(|cx| sender.poll_send_to(cx, b"Hello", receiver_addr)) in ut_send_to_peek_from_poll() localVariable
|
| /commonlibrary/c_utils/base/test/unittest/common/ |
| D | utils_event_test.cpp | 302 ssize_t n = ::read(GetFd(), &expirations, sizeof(expirations)); in TimeOut() local
901 ssize_t n = ::read(handler_->GetFd(), &expirations, sizeof(expirations)); in TimeOut() local
|
| D | utils_refbase_test.cpp | 323 for (int n = 0; n < 1; n++) { variable
|
| /commonlibrary/c_utils/base/test/benchmarktest/event_benchmark_test/ |
| D | event_benchmark_test.cpp | 405 ssize_t n = ::read(GetFd(), &expirations, sizeof(expirations)); in TimeOut() local
1050 ssize_t n = ::read(handler_->GetFd(), &expirations, expirationSize); in TimeOut() local
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/ |
| D | mod.rs | 363 let n = conn.read(&mut buf[pos..]).await?; in tunnel() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/ |
| D | simple.rs | 581 let mut n = rng.get(); in xor_shift() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | queue.rs | 364 let mut n = src_rear.wrapping_sub(src_front_real); in steal_into() localVariable
|
| /commonlibrary/rust/ylong_json/src/ |
| D | serializer_compact.rs | 646 let n = E::Newtype(-1); in ut_serialize_enum() localVariable
|