| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/ |
| D | udp_socket.rs | 62 pub fn connect(self, addr: SocketAddr) -> io::Result<ConnectedUdpSocket> { in connect() argument
112 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
132 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
152 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
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()
[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()
181 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
214 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
235 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
264 pub fn connect(self, addr: SocketAddr) -> io::Result<ConnectedUdpSocket> { in connect() argument
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()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/fs/ |
| D | open_options.rs | 78 pub fn read(&mut self, read: bool) -> &mut OpenOptions { in read()
102 pub fn write(&mut self, write: bool) -> &mut OpenOptions { in write()
150 pub fn append(&mut self, append: bool) -> &mut OpenOptions { in append()
180 pub fn truncate(&mut self, truncate: bool) -> &mut Self { in truncate()
206 pub fn create(&mut self, create: bool) -> &mut Self { in create()
248 pub fn create_new(&mut self, create_new: bool) -> &mut Self { in create_new()
295 pub async fn open<P: AsRef<Path>>(&self, path: P) -> io::Result<File> { in open()
|
| D | file_buf.rs | 39 pub(crate) fn append_to(&mut self, buf: &mut ReadBuf<'_>) -> usize { in append_to()
54 pub(crate) fn append(&mut self, other: &[u8]) -> usize { in append()
62 pub(crate) fn reserve(&mut self, size: usize) { in reserve()
69 pub(crate) fn read<R: Read>(&mut self, io: &mut R) -> io::Result<usize> { in read()
84 pub(crate) fn write<W: Write>(&mut self, io: &mut W) -> io::Result<()> { in write()
99 pub(crate) fn clear(&mut self) { in clear()
|
| /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()
176 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
182 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
186 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
192 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
196 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
206 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
211 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
[all …]
|
| 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<TcpListener> { in listen() argument
85 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<TcpStream> { in connect() argument
99 pub(crate) fn close(&self) { in close()
117 fn drop(&mut self) { in drop()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | task_handle.rs | 59 pub(crate) fn release(self) { in release() argument
63 pub(crate) fn drop_ref(self) { in drop_ref() argument
70 fn finish(self, state: usize, output: Result<T::Output, ScheduleError>) { in finish() argument
91 pub(crate) fn run(self) { in run() argument
138 pub(crate) fn get_result(self, out: &mut Poll<std::result::Result<T::Output, ScheduleError>>) { in get_result() argument
142 pub(crate) fn drop_join_handle(self) { in drop_join_handle() argument
156 fn set_waker_inner(&self, des_waker: Waker, cur_state: usize) -> Result<usize, usize> { in set_waker_inner()
174 pub(crate) fn set_waker(self, cur: usize, des_waker: &Waker) -> bool { in set_waker() argument
202 pub(crate) fn wake(self) { in wake() argument
207 pub(crate) fn wake_by_ref(&self) { in wake_by_ref()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | client.rs | 112 &self, in request()
120 &self, in retry_send_request()
134 &self, in send_request_retryable()
142 &self, in redirect_request()
175 &self, in send_request_with_uri()
261 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
278 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
295 pub fn redirect(mut self, redirect: Redirect) -> Self { in redirect()
312 pub fn proxy(mut self, proxy: Proxy) -> Self { in proxy()
356 pub fn max_tls_version(mut self, version: crate::util::TlsVersion) -> Self { in max_tls_version()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | client.rs | 118 &self, in request()
155 &self, in retry_send_request()
169 &self, in send_request_retryable()
179 &self, in redirect_request()
216 &self, in send_request_with_uri()
258 &self, in http2_request()
293 pub(crate) fn set_retry(&mut self, retryable: bool) { in set_retry()
387 pub fn http2_settings(mut self, config: H2Config) -> Self { in http2_settings()
405 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
422 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
[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()
166 pub async fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<ConnectedUdpSocket> { in connect()
234 pub async fn send_to<A: ToSocketAddrs>(&self, buf: &[u8], target: A) -> io::Result<usize> { in send_to()
276 pub fn try_send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in try_send_to()
310 &self, in poll_send_to()
347 pub async fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
383 pub fn try_recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_recv_from()
409 pub async fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
437 pub async fn try_peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_peek_from()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/ |
| D | multi.rs | 147 pub(crate) fn set_headers(&mut self, headers: Headers) { in set_headers()
152 &mut self, in insert_header()
167 &mut self, in append_header()
181 pub(crate) fn set_boundary(&mut self, boundary: Vec<u8>) { in set_boundary()
186 &mut self, in set_content_type()
200 pub(crate) fn add_part(&mut self, part: MimePart<'a>) { in add_part()
204 pub(crate) fn add_multi(&mut self, multi: MimeMulti<'a>) { in add_multi()
208 pub(crate) fn add_xpart(&mut self, xpart: XPart<'a>) { in add_xpart()
369 pub fn set_headers(mut self, headers: Headers) -> Self { in set_headers()
388 pub fn insert_header<N, V>(mut self, name: N, value: V) -> Self in insert_header()
[all …]
|
| D | part.rs | 75 pub(crate) fn set_headers(&mut self, headers: Headers) { in set_headers()
79 pub(crate) fn header<N, V>(&mut self, name: N, value: V) -> Result<&mut Headers, HttpError> in header()
91 &mut self, in append_header()
105 pub(crate) fn body_from_owned(&mut self, data: Vec<u8>) { in body_from_owned()
109 pub(crate) fn body_from_bytes(&mut self, data: &'a [u8]) { in body_from_bytes()
113 pub(crate) fn body_from_reader<T>(&mut self, data: T) in body_from_reader()
120 pub(crate) fn body_from_async_reader<T>(&mut self, data: T) in body_from_async_reader()
127 pub(crate) fn body_extend_from_slice(&mut self, src: &[u8]) { in body_extend_from_slice()
134 pub(crate) fn body_truncate(&mut self, len: usize) { in body_truncate()
141 pub(crate) fn body_trim_crlf_once(&mut self) { in body_trim_crlf_once()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | parker.rs | 50 pub(crate) fn park(&mut self) { in park()
54 pub(crate) fn unpark(&self, handle: Arc<Handle>) { in unpark()
62 pub(crate) fn release(&self) { in release()
73 fn park(&self) { in park()
93 fn park_on_driver(&self, driver: &mut Driver) { in park_on_driver()
115 fn park_on_condvar(&self) { in park_on_condvar()
145 fn unpark(&self, handle: Arc<Handle>) { in unpark()
166 fn release(&self) { in release()
|
| D | driver.rs | 70 pub(crate) fn run(&mut self) { in run()
79 pub(crate) fn run_once(&mut self) { in run_once()
90 pub(crate) fn wake(&self) { in wake()
106 &self, in io_register()
113 pub(crate) fn io_deregister(&self, io: &mut impl Source) -> io::Result<()> { in io_deregister()
134 pub(crate) fn timer_register(&self, clock_entry: NonNull<Clock>) -> Result<u64, Error> { in timer_register()
140 pub(crate) fn timer_cancel(&self, clock_entry: NonNull<Clock>) { in timer_cancel()
|
| D | worker.rs | 37 fn run(&mut self) { in run()
42 fn release(&mut self) { in release()
87 fn drop(&mut self) { in run_worker()
123 fn run(&self, worker_ctx: &WorkerContext) { in run()
145 fn pre_shutdown(&self, inner: &mut Inner, worker_ctx: &WorkerContext) { in pre_shutdown()
171 fn get_task(&self, inner: &mut Inner, worker_ctx: &WorkerContext) -> Option<Task> { in get_task()
182 fn check_cancel(&self, inner: &mut Inner) { in check_cancel()
186 fn park_timeout(&self, inner: &mut Inner, worker_ctx: &WorkerContext) { in park_timeout()
217 fn release(&self) { in release()
248 fn increment_count(&mut self) { in increment_count()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/ |
| D | poll.rs | 37 pub fn poll(&self, events: &mut Events, timeout: Option<Duration>) -> io::Result<()> { in poll()
42 pub fn register<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in register()
50 pub fn reregister<S>(&self, source: &mut S, token: Token, interests: Interest) -> io::Result<()> in reregister()
59 pub fn deregister<S>(&self, source: &mut S) -> io::Result<()> in deregister()
73 fn fmt(&self, fmt: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| D | multi.rs | 133 fn push_list_to_stages(&mut self, boundary: Vec<u8>, list: Vec<XPart<'a>>) { in push_list_to_stages()
164 fn push_multi_as_part(&mut self, multi: MimeMulti<'a>) { in push_multi_as_part()
172 fn push_first_boundary(&mut self, boundary: Vec<u8>) { in push_first_boundary()
181 fn push_middle_boundary(&mut self, boundary: Vec<u8>) { in push_middle_boundary()
188 fn push_end_boundary(&mut self, boundary: Vec<u8>) { in push_end_boundary()
198 fn init_src(&mut self) { in init_src()
203 fn temp_src(&mut self, stage: &MultiStage) { in temp_src()
212 fn crlf_encode(&mut self, dst: &mut [u8]) -> SizeResult { in crlf_encode()
226 fn dash_encode(&mut self, dst: &mut [u8]) -> SizeResult { in dash_encode()
239 fn boundary_encode(&mut self, dst: &mut [u8], boundary: Vec<u8>) -> SizeResult { in boundary_encode()
[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()
130 fn drop(&mut self) { in drop()
138 fn fmt(&self, fmt: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| D | waiter.rs | 82 pub async fn wait(&self) { in wait()
115 pub fn wake_one(&self) { in wake_one()
144 pub fn wake_all(&self) { in wake_all()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/ |
| D | mod.rs | 49 fn reduce(self, len: usize) -> Self; in reduce() argument
59 fn map<F, B>(self, map_op: F) -> Map<Self, F> in map()
67 fn filter<F>(self, predicate: F) -> Filter<Self, F> in filter()
75 fn zip<B>(self, another: B) -> Zip<Self, B> in zip()
85 self, in for_each()
98 self, in sum()
110 self, in drive()
128 fn consume(&self, par_iter: P) -> Self::Output; in consume()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| D | bounded.rs | 150 pub fn try_send(&self, value: T) -> Result<(), TrySendError<T>> { in try_send()
179 pub async fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
213 pub async fn send_timeout(&self, value: T, time: Duration) -> Result<(), SendTimeoutError<T>> { in send_timeout()
256 pub fn is_same(&self, other: &Self) -> bool { in is_same()
305 fn drop(&mut self) { in drop()
430 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout()
474 pub fn close(&mut self) { in close()
480 fn drop(&mut self) { in drop()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h1/response/ |
| D | decoder.rs | 212 &mut self, in decode()
227 &mut self, in version_phase()
251 &mut self, in status_code_phase()
272 &mut self, in reason_phase()
283 &mut self, in status_crlf_phase()
294 &mut self, in header_phase_with_init()
314 &mut self, in header_phase()
324 &mut self, in blank_line_phase()
341 fn decode_status_crlf<'a>(&mut self, buffer: &'a [u8]) -> Result<Option<&'a [u8]>, HttpError> { in decode_status_crlf()
356 fn decode_header<'a>(&mut self, buffer: &'a [u8]) -> Result<Option<&'a [u8]>, HttpError> { in decode_header()
[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()
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()
197 &mut self, 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()
256 pub(crate) fn set_verify(&mut self, mode: c_int) { in set_verify()
[all …]
|
| D | ssl_base.rs | 56 pub(crate) fn connect<S>(self, stream: S) -> Result<SslStream<S>, HandshakeError<S>> in connect()
83 pub(crate) fn get_error(&self, err: c_int) -> SslErrorCode { in get_error()
103 pub(crate) fn read(&mut self, buf: &mut [u8]) -> c_int { in read()
108 pub(crate) fn write(&mut self, buf: &[u8]) -> c_int { in write()
113 pub(crate) fn set_host_name_in_sni(&mut self, name: &str) -> Result<(), ErrorStack> { in set_host_name_in_sni()
128 pub(crate) fn set_verify_hostname(&mut self, host_name: &str) -> Result<(), ErrorStack> { in set_verify_hostname()
139 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/tcp/ |
| 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() argument
90 pub(crate) fn connect(self, addr: SocketAddr) -> io::Result<()> { in connect() argument
110 pub(crate) fn close(&self) { in close()
130 fn drop(&mut self) { in drop()
|