| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| D | udp_socket.rs | 170 pub fn set_broadcast(&self, on: bool) -> io::Result<()> { in set_broadcast()
204 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
254 pub fn set_multicast_loop_v4(&self, multicast_loop_v4: bool) -> io::Result<()> { in set_multicast_loop_v4()
268 pub fn set_multicast_ttl_v4(&self, multicast_ttl_v4: u32) -> io::Result<()> { in set_multicast_ttl_v4()
280 pub fn set_multicast_loop_v6(&self, multicast_loop_v6: bool) -> io::Result<()> { in set_multicast_loop_v6()
285 pub fn join_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in join_multicast_v4()
290 pub fn join_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32) -> io::Result<()> { in join_multicast_v6()
295 pub fn leave_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in leave_multicast_v4()
300 pub fn leave_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32) -> io::Result<()> { in leave_multicast_v6()
389 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/udp/ |
| D | udp_socket.rs | 137 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
291 pub fn set_broadcast(&self, on: bool) -> io::Result<()> { in set_broadcast()
345 pub fn set_multicast_loop_v4(&self, multicast_loop_v4: bool) -> io::Result<()> { in set_multicast_loop_v4()
359 pub fn set_multicast_ttl_v4(&self, multicast_ttl_v4: u32) -> io::Result<()> { in set_multicast_ttl_v4()
371 pub fn set_multicast_loop_v6(&self, multicast_loop_v6: bool) -> io::Result<()> { in set_multicast_loop_v6()
376 pub fn join_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in join_multicast_v4()
381 pub fn join_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32) -> io::Result<()> { in join_multicast_v6()
386 pub fn leave_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in leave_multicast_v4()
391 pub fn leave_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32) -> io::Result<()> { in leave_multicast_v6()
482 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 79 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
85 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
512 pub async fn readable(&self) -> io::Result<()> { in readable()
536 pub async fn writable(&self) -> io::Result<()> { in writable()
613 pub fn set_broadcast(&self, on: bool) -> io::Result<()> { in set_broadcast()
653 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
712 pub fn set_multicast_loop_v4(&self, multicast_loop_v4: bool) -> io::Result<()> { in set_multicast_loop_v4()
726 pub fn set_multicast_ttl_v4(&self, multicast_ttl_v4: u32) -> io::Result<()> { in set_multicast_ttl_v4()
738 pub fn set_multicast_loop_v6(&self, multicast_loop_v6: bool) -> io::Result<()> { in set_multicast_loop_v6()
743 pub fn join_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in join_multicast_v4()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/ |
| D | epoll.rs | 53 pub fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in select()
75 pub fn register(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in register()
88 pub fn reregister(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in reregister()
101 pub fn deregister(&self, fd: i32) -> io::Result<()> { in deregister()
138 fn fmt(&self, fmt: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() method
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/linux/tcp/ |
| D | stream.rs | 99 pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> { in set_nodelay()
130 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
156 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown()
200 fn flush(&mut self) -> io::Result<()> { in flush()
228 fn flush(&mut self) -> io::Result<()> { in flush()
235 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
246 ) -> io::Result<()> { in register()
255 ) -> io::Result<()> { in reregister()
259 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
| D | listener.rs | 119 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
163 ) -> io::Result<()> { in register()
172 ) -> io::Result<()> { in reregister()
176 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
186 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | source.rs | 34 ) -> io::Result<()>; in register()
43 ) -> io::Result<()>; in reregister()
46 fn deregister(&mut self, selector: &Selector) -> io::Result<()>; in deregister()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| D | stream.rs | 121 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown()
136 pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> { in set_nodelay()
167 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
224 fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result { in fmt()
286 ) -> io::Result<()> { in register()
296 ) -> io::Result<()> { in reregister()
300 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister()
|
| D | listener.rs | 121 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
150 ) -> io::Result<()> { in register()
160 ) -> io::Result<()> { in reregister()
164 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister()
174 fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result { in fmt()
|
| D | socket.rs | 61 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind()
74 pub(crate) fn listen(self, backlog: u32) -> io::Result<()> { in listen()
90 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<()> { in connect()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | stream.rs | 65 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
153 pub async fn readable(&self) -> io::Result<()> { in readable()
220 pub async fn writable(&self) -> io::Result<()> { in writable()
328 pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> { in set_nodelay()
373 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
508 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown()
518 ) -> Poll<io::Result<()>> { in poll_read()
544 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
548 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
|
| D | split.rs | 34 ) -> Poll<std::io::Result<()>> { in poll_read()
60 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
64 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
80 ) -> Poll<std::io::Result<()>> { in poll_read()
106 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
110 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ssl/ |
| D | ctx.rs | 57 fn fmt(&self, fmt: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt() method
116 pub(crate) fn set_min_proto_version(&mut self, version: SslVersion) -> Result<(), ErrorStack> { in set_min_proto_version()
130 pub(crate) fn set_max_proto_version(&mut self, version: SslVersion) -> Result<(), ErrorStack> { in set_max_proto_version()
148 pub(crate) fn set_ca_file<P>(&mut self, file: P) -> Result<(), ErrorStack> in set_ca_file()
169 pub(crate) fn set_cipher_list(&mut self, list: &str) -> Result<(), ErrorStack> { in set_cipher_list()
180 pub(crate) fn set_cipher_suites(&mut self, list: &str) -> Result<(), ErrorStack> { in set_cipher_suites()
200 ) -> Result<(), ErrorStack> in set_certificate_file()
225 pub(crate) fn set_certificate_chain_file<P>(&mut self, file: P) -> Result<(), ErrorStack> in set_certificate_chain_file()
245 pub(crate) fn set_alpn_protos(&mut self, protocols: &[u8]) -> Result<(), ErrorStack> { in set_alpn_protos()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| D | c_ssl_stream.rs | 69 fn poll_connect(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), ssl::SslError>> { in poll_connect()
74 pub(crate) async fn connect(mut self: Pin<&mut Self>) -> Result<(), ssl::SslError> { in connect()
88 ) -> Poll<io::Result<()>> { in poll_read()
121 fn poll_flush(self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
125 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_shutdown()
|
| D | mix.rs | 37 ) -> Poll<std::io::Result<()>> { in poll_read()
61 fn poll_flush(mut self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_flush()
68 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context<'_>) -> Poll<std::io::Result<()>> { in poll_shutdown()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | reader.rs | 117 pub fn read_all<B: Body>(&mut self, body: &mut B) -> Result<(), HttpClientError> { in read_all()
167 fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError>; in write()
172 fn progress(&mut self, filled: usize) -> Result<(), BodyProcessError>; in progress()
180 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
206 fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError> { in write()
211 fn progress(&mut self, filled: usize) -> Result<(), BodyProcessError> { in progress()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | error.rs | 24 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
36 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
53 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
73 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| D | async_read.rs | 45 ) -> Poll<io::Result<()>>; in poll_read()
54 ) -> Poll<io::Result<()>> { in poll_read()
65 ) -> Poll<io::Result<()>> { in poll_read()
80 ) -> Poll<io::Result<()>> { in poll_read()
214 ) -> Poll<io::Result<()>> { in poll_read()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| D | x509.rs | 111 fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result { in fmt() method
118 fn fmt(&self, fmt: &mut fmt::Formatter) -> fmt::Result { in fmt() method
141 pub(crate) fn add_cert(&mut self, cert: X509) -> Result<(), ErrorStack> { in add_cert()
162 pub(crate) fn set_host(&mut self, host: &str) -> Result<(), ErrorStack> { in set_host()
169 pub(crate) fn set_ip(&mut self, ip_addr: IpAddr) -> Result<(), ErrorStack> { in set_ip()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h2/hpack/ |
| D | decoder.rs | 55 pub(crate) fn decode(&mut self, buf: &[u8]) -> Result<(), H2Error> { in decode()
113 fn update(&mut self, repr: Representation) -> Result<(), H2Error> { in update()
132 fn update_indexed(&mut self, index: usize) -> Result<(), H2Error> { in update_indexed()
142 fn update_literal_with_indexing(&mut self, name: Name, value: Vec<u8>) -> Result<(), H2Error> { in update_literal_with_indexing()
154 ) -> Result<(), H2Error> { in update_literal_without_indexing()
162 fn update_literal_never_indexing(&mut self, name: Name, value: Vec<u8>) -> Result<(), H2Error> { in update_literal_never_indexing()
166 fn check_header_list_size(&mut self, key: &Header, value: &String) -> Result<(), H2Error> { in check_header_list_size()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| D | mod.rs | 165 pub async fn download(&mut self) -> Result<(), HttpClientError> { in download()
181 async fn limited_download(&mut self) -> Result<(), HttpClientError> { in limited_download()
213 fn check_timeout(&mut self) -> Result<(), HttpClientError> { in check_timeout()
226 async fn show_progress(&mut self) -> Result<(), HttpClientError> { in show_progress()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | async_dir.rs | 59 pub async fn create_dir<P: AsRef<Path>>(path: P) -> io::Result<()> { in create_dir()
88 pub async fn create_dir_all<P: AsRef<Path>>(path: P) -> io::Result<()> { in create_dir_all()
118 pub async fn remove_dir<P: AsRef<Path>>(path: P) -> io::Result<()> { in remove_dir()
144 pub async fn remove_dir_all<P: AsRef<Path>>(path: P) -> io::Result<()> { in remove_dir_all()
206 pub async fn remove_file<P: AsRef<Path>>(path: P) -> io::Result<()> { in remove_file()
237 pub async fn rename<P: AsRef<Path>, Q: AsRef<Path>>(from: P, to: Q) -> io::Result<()> { in rename()
344 pub async fn write<P: AsRef<Path>, C: AsRef<[u8]>>(path: P, contents: C) -> io::Result<()> { in write()
401 pub async fn hard_link<P: AsRef<Path>, Q: AsRef<Path>>(original: P, link: Q) -> io::Result<()> { in hard_link()
516 pub async fn set_permissions<P: AsRef<Path>>(path: P, perm: Permissions) -> io::Result<()> { in set_permissions()
|
| D | async_file.rs | 177 pub async fn set_permissions(&self, perm: Permissions) -> io::Result<()> { in set_permissions()
205 pub async fn sync_all(&self) -> io::Result<()> { in sync_all()
235 pub async fn sync_data(&self) -> io::Result<()> { in sync_data()
269 pub async fn set_len(&self, size: u64) -> io::Result<()> { in set_len()
398 ) -> Poll<io::Result<()>> { in poll_read()
503 fn poll_flush(mut self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
507 fn poll_shutdown(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
513 fn poll_flush(&mut self, cx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/ |
| D | error.rs | 95 fn fmt(&self, f: &mut Formatter<'_>) -> core::fmt::Result { in fmt()
106 fn fmt(&self, f: &mut Formatter<'_>) -> core::fmt::Result { in fmt()
188 fn fmt(&self, f: &mut Formatter<'_>) -> core::fmt::Result { in fmt()
194 fn fmt(&self, f: &mut Formatter<'_>) -> core::fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| D | operator.rs | 58 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
84 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
117 ) -> Poll<Result<(), HttpClientError>> { in poll_progress()
|