| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| D | mpsc_test.rs | 38 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_test() localVariable
74 let _ = ylong_runtime::block_on(handle); in sdv_unbounded_send_recv_timeout_test() localVariable
96 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_recv_test() localVariable
138 let _ = ylong_runtime::block_on(handle); in sdv_bounded_send_timeout_recv_timeout_test() localVariable
198 let _ = tx.send(i); in sdv_mpsc_len() localVariable
202 let _ = rx.try_recv(); in sdv_mpsc_len() localVariable
206 let _ = rx.try_recv(); in sdv_mpsc_len() localVariable
212 let _ = tx.try_send(i); in sdv_mpsc_len() localVariable
216 let _ = rx.try_recv(); in sdv_mpsc_len() localVariable
220 let _ = rx.try_recv(); in sdv_mpsc_len() localVariable
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/bin/ |
| D | ylong_runtime_async_benchmark.rs | 101 let _ = runtime.block_on(handle1); in main() localVariable
102 let _ = runtime.block_on(handle2); in main() localVariable
103 let _ = runtime.block_on(handle3); in main() localVariable
104 let _ = runtime.block_on(handle4); in main() localVariable
105 let _ = runtime.block_on(handle5); in main() localVariable
106 let _ = runtime.block_on(handle6); in main() localVariable
107 let _ = runtime.block_on(handle7); in main() localVariable
108 let _ = runtime.block_on(handle8); in main() localVariable
109 let _ = runtime.block_on(handle9); in main() localVariable
110 let _ = runtime.block_on(handle10); in main() localVariable
|
| D | ylong_tokio_tcp_perf.rs | 120 let _ = match socket.read(&mut buf).await { in main() localVariable
135 let _ = socket.write(b"hello client").await.unwrap(); in main() localVariable
164 let _ = match socket.read(&mut buf).await { in main() localVariable
179 let _ = socket.write(b"hello client").await.unwrap(); in main() localVariable
|
| D | ylong_tokio_spawn.rs | 60 let _ = ylong_runtime::block_on(handle); in ylong_spawn() localVariable
78 let _ = runtime.block_on(handle); in tokio_spawn() localVariable
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | async_read.rs | 43 cx: &mut Context<'_>, in poll_read()
44 buf: &mut ReadBuf<'_>, in poll_read()
52 cx: &mut Context<'_>, in poll_read()
53 buf: &mut ReadBuf<'_>, in poll_read()
63 cx: &mut Context<'_>, in poll_read()
64 buf: &mut ReadBuf<'_>, in poll_read()
78 cx: &mut Context<'_>, in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
212 _cx: &mut Context<'_>, in poll_read()
213 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | async_seek.rs | 40 cx: &mut Context<'_>, in poll_seek()
51 cx: &mut Context<'_>, in poll_seek()
61 cx: &mut Context<'_>, in poll_seek()
71 cx: &mut Context<'_>, in poll_seek()
138 fn rewind(&mut self) -> SeekTask<'_, Self> in rewind()
169 fn stream_position(&mut self) -> SeekTask<'_, Self> in stream_position()
|
| D | async_write.rs | 42 cx: &mut Context<'_>, in poll_write()
52 cx: &mut Context<'_>, in poll_write_vectored()
53 bufs: &[IoSlice<'_>], in poll_write_vectored()
153 cx: &mut Context<'_>, in poll_write()
161 cx: &mut Context<'_>, in poll_write_vectored()
162 bufs: &[IoSlice<'_>], in poll_write_vectored()
274 fn flush(&mut self) -> FlushTask<'_, Self> in flush()
290 fn shutdown(&mut self) -> ShutdownTask<'_, Self> in shutdown()
|
| D | stdin.rs | 48 cx: &mut Context<'_>, in poll_read()
49 buf: &mut ReadBuf<'_>, in poll_read()
109 fn as_fd(&self) -> BorrowedFd<'_> { in as_fd()
126 fn as_handle(&self) -> BorrowedHandle<'_> { in as_handle()
|
| D | stderr.rs | 64 fn as_fd(&self) -> BorrowedFd<'_> { in as_fd()
81 fn as_handle(&self) -> BorrowedHandle<'_> { in as_handle()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | split.rs | 32 cx: &mut Context<'_>, in poll_read()
33 buf: &mut ReadBuf<'_>, in poll_read()
42 cx: &mut Context<'_>, in poll_write()
50 cx: &mut Context<'_>, in poll_write_vectored()
51 bufs: &[IoSlice<'_>], in poll_write_vectored()
78 cx: &mut Context<'_>, in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
88 cx: &mut Context<'_>, in poll_write()
96 cx: &mut Context<'_>, in poll_write_vectored()
97 bufs: &[IoSlice<'_>], in poll_write_vectored()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/examples/ |
| D | async_http.rs | 23 let _ = client_send().await.unwrap(); in main() localVariable
26 let _ = ylong_runtime::block_on(handle); in main() localVariable
43 let _ = Downloader::console(response).download().await; in client_send() localVariable
|
| D | async_http_multi.rs | 34 let _ = Downloader::console(response).download().await; in main() localVariable
38 let _ = ylong_runtime::block_on(handle); in main() localVariable
|
| D | async_https_outside.rs | 33 let _ = h.await; in main() localVariable
64 let _ = Downloader::console(response).download().await; in req() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | mix.rs | 35 cx: &mut Context<'_>, in poll_read()
36 buf: &mut ReadBuf<'_>, in poll_read()
52 ctx: &mut Context<'_>, in poll_write()
|
| D | c_ssl_stream.rs | 29 fn with_context<F, R>(self: Pin<&mut Self>, ctx: &mut Context<'_>, f: F) -> R in with_context()
86 ctx: &mut Context<'_>, in poll_read()
87 buf: &mut ReadBuf<'_>, in poll_read()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| D | ylong_tokio_schedule.rs | 36 let _ = runtime.block_on(handler).unwrap(); localVariable
58 let _ = ylong_runtime::block_on(handler).unwrap(); localVariable
|
| D | ylong_tokio_mutex.rs | 47 let _ = runtime.block_on(handler).unwrap(); localVariable
75 let _ = ylong_runtime::block_on(handler).unwrap(); localVariable
|
| D | ylong_tokio_rwlock.rs | 75 let _ = ylong_runtime::block_on(handle); in ylong_rwlock_read() localVariable
124 let _ = ylong_runtime::block_on(handle); in ylong_rwlock_write() localVariable
181 let _ = ylong_runtime::block_on(handle); in ylong_rwlock_write_read() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| D | operator.rs | 29 cx: &mut Context<'_>, in poll_download()
39 _cx: &mut Context<'_>, in poll_progress()
82 cx: &mut Context<'_>, in poll_download()
90 cx: &mut Context<'_>, in poll_progress()
139 _cx: &mut Context<'_>, in poll_download()
148 _cx: &mut Context<'_>, in poll_progress()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/buffered/ |
| D | async_buf_writer.rs | 208 cx: &mut Context<'_>, in poll_write()
226 cx: &mut Context<'_>, in poll_write_vectored()
227 mut bufs: &[IoSlice<'_>], in poll_write_vectored()
298 cx: &mut Context<'_>, in poll_seek()
310 cx: &mut Context<'_>, in poll_read()
311 buf: &mut ReadBuf<'_>, in poll_read()
|
| D | async_buf_reader.rs | 183 cx: &mut Context<'_>, in poll_read()
184 buf: &mut ReadBuf<'_>, in poll_read()
223 cx: &mut Context<'_>, in poll_seek()
254 cx: &mut Context<'_>, in poll_write()
263 cx: &mut Context<'_>, in poll_write_vectored()
264 bufs: &[IoSlice<'_>], in poll_write_vectored()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| D | socket.rs | 53 let _ = unsafe { closesocket(socket) }; in create_socket() localVariable
77 let _ = unsafe { net::UdpSocket::from_raw_socket(self.socket as RawSocket) }; in close() localVariable
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| D | error.rs | 84 let bytes = CStr::from_ptr(data as *const _).to_bytes(); in get() constant
109 let bytes = CStr::from_ptr(data as *const _).to_bytes(); in get() constant
151 let bytes = CStr::from_ptr(lib_error as *const _).to_bytes(); in fmt() constant
162 let bytes = unsafe { core::ffi::CStr::from_ptr(func_error as *const _).to_bytes() }; in fmt() constant
181 let bytes = CStr::from_ptr(reason_error as *const _).to_bytes(); in fmt() constant
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | operator.rs | 55 _cx: &mut Context<'_>, in poll_progress()
81 cx: &mut Context<'_>, in poll_progress()
114 _cx: &mut Context<'_>, in poll_progress()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| D | redirect.rs | 216 let _ = headers.remove("authorization"); in remove_sensitive_headers() localVariable
217 let _ = headers.remove("cookie"); in remove_sensitive_headers() localVariable
218 let _ = headers.remove("cookie2"); in remove_sensitive_headers() localVariable
219 let _ = headers.remove("proxy_authorization"); in remove_sensitive_headers() localVariable
220 let _ = headers.remove("www_authenticate"); in remove_sensitive_headers() localVariable
247 let _ = request.headers_mut().remove(header_name); in update_header_and_method() localVariable
|