| /commonlibrary/rust/ylong_json/src/ |
| D | encoder.rs | 37 pub(crate) fn encode(&mut self, value: &JsonValue) -> Result<(), Error> { in encode()
44 fn encode_value(&mut self, value: &JsonValue) -> Result<(), Error> { in encode_value()
56 fn add_tab(&mut self) -> Result<(), Error> { in add_tab()
64 fn encode_null(&mut self) -> Result<(), Error> { in encode_null()
69 fn encode_boolean(&mut self, boolean: &bool) -> Result<(), Error> { in encode_boolean()
74 fn encode_number(&mut self, number: &Number) -> Result<(), Error> { in encode_number()
79 fn encode_key(&mut self, key: &str) -> Result<(), Error> { in encode_key()
85 fn encode_string(&mut self, string: &CString) -> Result<(), Error> { in encode_string()
93 fn encode_string(&mut self, string: &str) -> Result<(), Error> { in encode_string()
98 fn encode_array(&mut self, array: &Array) -> Result<(), Error> { in encode_array()
[all …]
|
| D | serializer_compact.rs | 38 fn flush(&mut self) -> std::io::Result<()> { in flush()
57 pub fn to_writer<T, W>(value: &T, writer: &mut W) -> Result<(), Error> in to_writer()
92 fn serialize_bool(self, v: bool) -> Result<(), Error> { in serialize_bool()
100 fn serialize_i8(self, v: i8) -> Result<(), Error> { in serialize_i8()
104 fn serialize_i16(self, v: i16) -> Result<(), Error> { in serialize_i16()
108 fn serialize_i32(self, v: i32) -> Result<(), Error> { in serialize_i32()
112 fn serialize_i64(self, v: i64) -> Result<(), Error> { in serialize_i64()
117 fn serialize_u8(self, v: u8) -> Result<(), Error> { in serialize_u8()
121 fn serialize_u16(self, v: u16) -> Result<(), Error> { in serialize_u16()
125 fn serialize_u32(self, v: u32) -> Result<(), Error> { in serialize_u32()
[all …]
|
| /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/unix/udp/ |
| D | udp_socket.rs | 134 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
288 pub fn set_broadcast(&self, on: bool) -> io::Result<()> { in set_broadcast()
342 pub fn set_multicast_loop_v4(&self, multicast_loop_v4: bool) -> io::Result<()> { in set_multicast_loop_v4()
356 pub fn set_multicast_ttl_v4(&self, multicast_ttl_v4: u32) -> io::Result<()> { in set_multicast_ttl_v4()
368 pub fn set_multicast_loop_v6(&self, multicast_loop_v6: bool) -> io::Result<()> { in set_multicast_loop_v6()
373 pub fn join_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in join_multicast_v4()
378 pub fn join_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32) -> io::Result<()> { in join_multicast_v6()
383 pub fn leave_multicast_v4(&self, multiaddr: &Ipv4Addr, interface: &Ipv4Addr) -> io::Result<()> { in leave_multicast_v4()
388 pub fn leave_multicast_v6(&self, multiaddr: &Ipv6Addr, interface: u32) -> io::Result<()> { in leave_multicast_v6()
479 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 150 ) -> Poll<Result<(), DispatchErrorKind>> { in manage_pending_state()
166 fn poll_recv_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_recv_request()
210 fn poll_input_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_input_request()
232 ) -> Result<(), DispatchErrorKind> { in input_stream_frame()
260 fn poll_send_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_frame()
294 ) -> Poll<Result<(), DispatchErrorKind>> { in poll_recv_frame()
329 fn recv_settings_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_settings_frame()
380 fn recv_ping_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_ping_frame()
402 ) -> Poll<Result<(), H2Error>> { in recv_go_away_frame()
444 ) -> Poll<Result<(), H2Error>> { in recv_reset_frame()
[all …]
|
| D | output.rs | 79 fn poll_read_frame(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_read_frame()
141 fn poll_blocked_task(&mut self, cx: &mut Context<'_>) -> Poll<Result<(), DispatchErrorKind>> { in poll_blocked_task()
165 ) -> Poll<Result<(), DispatchErrorKind>> { in poll_iterator_frames()
198 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_error()
212 ) -> Poll<Result<(), DispatchErrorKind>> { in transmit_message()
231 fn update_settings(&mut self, frame: &Frame) -> Result<(), H2Error> { in update_settings()
240 fn update_decoder_settings(&mut self) -> Result<(), H2Error> { in update_decoder_settings()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/interceptor/ |
| D | mod.rs | 91 fn intercept_connection(&self, _info: ConnDetail) -> Result<(), HttpClientError> { in intercept_connection()
96 fn intercept_input(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in intercept_input()
101 fn intercept_output(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in intercept_output()
106 fn intercept_request(&self, _request: &Request) -> Result<(), HttpClientError> { in intercept_request()
111 fn intercept_response(&self, _response: &Response) -> Result<(), HttpClientError> { in intercept_response()
116 fn intercept_retry(&self, _error: &HttpClientError) -> Result<(), HttpClientError> { in intercept_retry()
121 fn intercept_redirect_request(&self, _request: &Request) -> Result<(), HttpClientError> { in intercept_redirect_request()
129 ) -> Result<(), HttpClientError> { in intercept_redirect_response()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| D | pty.rs | 62 ) -> io::Result<()> { in resize()
183 ) -> Poll<io::Result<()>> { in poll_read()
197 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
201 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
219 pub(crate) fn session_leader(&self) -> impl FnMut() -> io::Result<()> { in session_leader()
233 ) -> Poll<io::Result<()>> { in poll_read()
260 ) -> io::Result<()> { in resize()
274 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
278 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_shutdown()
292 ) -> Poll<io::Result<()>> { in poll_read()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/ |
| D | kqueue.rs | 47 pub fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in select()
75 pub fn register(&self, fd: RawFd, token: Token, interests: Interest) -> io::Result<()> { in register()
93 pub fn reregister(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in reregister()
114 pub fn deregister(&self, fd: i32) -> io::Result<()> { in deregister()
137 pub fn register_waker(&self, token: Token) -> io::Result<()> { in register_waker()
150 pub fn wake(&self, token: Token) -> io::Result<()> { in wake()
162 fn kevent_notify(&self, mut event: Event) -> io::Result<()> { in kevent_notify()
174 fn kevent_register(kq: RawFd, events: &mut [Event]) -> io::Result<()> { in kevent_register()
195 fn kevent_check_error(events: &mut [Event], ignored: &[i64]) -> io::Result<()> { in kevent_check_error()
|
| D | epoll.rs | 54 pub fn select(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in select()
76 pub fn register(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in register()
89 pub fn reregister(&self, fd: i32, token: Token, interests: Interest) -> io::Result<()> { in reregister()
102 pub fn deregister(&self, fd: i32) -> io::Result<()> { in deregister()
124 fn fmt(&self, fmt: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() method
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/tcp/ |
| D | stream.rs | 101 pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> { in set_nodelay()
154 pub fn set_linger(&self, linger: Option<Duration>) -> io::Result<()> { in set_linger()
169 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
195 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown()
239 fn flush(&mut self) -> io::Result<()> { in flush()
267 fn flush(&mut self) -> io::Result<()> { in flush()
274 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
285 ) -> io::Result<()> { in register()
289 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
|
| D | socket.rs | 50 pub(crate) fn set_reuse(&self, is_reuse: bool) -> io::Result<()> { in set_reuse()
65 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind()
73 pub(crate) fn listen(self, max_connect: c_int) -> io::Result<()> { in listen()
119 pub(crate) fn set_sock_linger(fd: Fd, duration: Option<Duration>) -> io::Result<()> { in set_sock_linger()
|
| D | listener.rs | 137 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
181 ) -> io::Result<()> { in register()
185 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister()
195 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/ |
| D | udp.rs | 77 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
83 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
508 pub async fn readable(&self) -> io::Result<()> { in readable()
532 pub async fn writable(&self) -> io::Result<()> { in writable()
609 pub fn set_broadcast(&self, on: bool) -> io::Result<()> { in set_broadcast()
649 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
708 pub fn set_multicast_loop_v4(&self, multicast_loop_v4: bool) -> io::Result<()> { in set_multicast_loop_v4()
722 pub fn set_multicast_ttl_v4(&self, multicast_ttl_v4: u32) -> io::Result<()> { in set_multicast_ttl_v4()
734 pub fn set_multicast_loop_v6(&self, multicast_loop_v6: bool) -> io::Result<()> { in set_multicast_loop_v6()
739 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/windows/tcp/ |
| D | stream.rs | 123 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown()
138 pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> { in set_nodelay()
191 pub fn set_linger(&self, linger: Option<Duration>) -> io::Result<()> { in set_linger()
206 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
263 fn fmt(&self, f: &mut Formatter<'_>) -> fmt::Result { in fmt()
325 ) -> io::Result<()> { in register()
330 fn deregister(&mut self, _selector: &Selector) -> io::Result<()> { in deregister()
|
| D | socket.rs | 64 pub(crate) fn bind(&self, addr: SocketAddr) -> io::Result<()> { in bind()
77 pub(crate) fn listen(self, backlog: u32) -> io::Result<()> { in listen()
92 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<()> { in connect()
144 pub(crate) fn set_sock_linger(socket: RawSocket, linger: Option<Duration>) -> io::Result<()> { in set_sock_linger()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/tcp/ |
| D | stream.rs | 66 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
154 pub async fn readable(&self) -> io::Result<()> { in readable()
221 pub async fn writable(&self) -> io::Result<()> { in writable()
329 pub fn set_nodelay(&self, nodelay: bool) -> io::Result<()> { in set_nodelay()
381 pub fn set_linger(&self, linger: Option<Duration>) -> io::Result<()> { in set_linger()
427 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
562 pub fn shutdown(&self, how: Shutdown) -> io::Result<()> { in shutdown()
593 pub fn fchown(&self, uid: uid_t, gid: gid_t) -> io::Result<()> { in fchown()
603 ) -> Poll<io::Result<()>> { in poll_read()
629 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<io::Result<()>> { in poll_flush()
[all …]
|
| /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
117 pub(crate) fn set_min_proto_version(&mut self, version: SslVersion) -> Result<(), ErrorStack> { in set_min_proto_version()
131 pub(crate) fn set_max_proto_version(&mut self, version: SslVersion) -> Result<(), ErrorStack> { in set_max_proto_version()
149 pub(crate) fn set_ca_file<P>(&mut self, file: P) -> Result<(), ErrorStack> in set_ca_file()
162 pub(crate) fn set_cipher_list(&mut self, list: &str) -> Result<(), ErrorStack> { in set_cipher_list()
173 pub(crate) fn set_cipher_suites(&mut self, list: &str) -> Result<(), ErrorStack> { in set_cipher_suites()
193 ) -> Result<(), ErrorStack> in set_certificate_file()
210 pub(crate) fn set_certificate_chain_file<P>(&mut self, file: P) -> Result<(), ErrorStack> in set_certificate_chain_file()
236 pub(crate) fn set_alpn_protos(&mut self, protocols: &[u8]) -> Result<(), ErrorStack> { in set_alpn_protos()
272 pub(crate) fn set_sigalgs_list(&mut self) -> Result<(), ErrorStack> { in set_sigalgs_list()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | reader.rs | 115 pub fn read_all<B: Body>(&mut self, body: &mut B) -> Result<(), HttpClientError> { in read_all()
165 fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError>; in write()
170 fn progress(&mut self, filled: usize) -> Result<(), BodyProcessError>; in progress()
178 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
204 fn write(&mut self, data: &[u8]) -> Result<(), BodyProcessError> { in write()
209 fn progress(&mut self, filled: usize) -> Result<(), BodyProcessError> { in progress()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| D | stream.rs | 202 pub async fn readable(&self) -> Result<()> { in readable()
271 pub async fn writable(&self) -> Result<()> { in writable()
332 pub fn shutdown(&self, how: Shutdown) -> Result<()> { in shutdown()
342 ) -> Poll<Result<()>> { in poll_read()
364 fn poll_flush(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_flush()
368 fn poll_shutdown(self: Pin<&mut Self>, _cx: &mut Context<'_>) -> Poll<Result<()>> { in poll_shutdown()
375 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/ |
| 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()
|
| D | c_ssl_stream.rs | 78 fn poll_connect(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<Result<(), ssl::SslError>> { in poll_connect()
83 pub(crate) async fn connect(mut self: Pin<&mut Self>) -> Result<(), ssl::SslError> { in connect()
97 ) -> Poll<io::Result<()>> { in poll_read()
130 fn poll_flush(self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_flush()
134 fn poll_shutdown(mut self: Pin<&mut Self>, ctx: &mut Context) -> Poll<io::Result<()>> { in poll_shutdown()
|
| /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_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_signal/src/ |
| D | lib.rs | 97 pub fn deregister_signal_action(sig_num: c_int) -> io::Result<()> { in deregister_signal_action()
112 pub fn deregister_signal_hook(sig_num: c_int) -> io::Result<()> { in deregister_signal_hook()
|