| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/progress/ |
| D | rate_limit.rs | 35 pub(crate) fn set_speed_limit(&mut self, config: SpeedConfig) { in set_speed_limit()
71 pub(crate) async fn max_send_speed_limit(&mut self, size: usize) { in max_send_speed_limit()
75 pub(crate) fn delay_max_recv_speed_limit(&mut self, size: usize) { in delay_max_recv_speed_limit()
80 pub(crate) fn delay_max_send_speed_limit(&mut self, size: usize) { in delay_max_send_speed_limit()
84 pub(crate) fn min_send_speed_limit(&mut self, size: usize) -> Result<(), HttpClientError> { in min_send_speed_limit()
88 pub(crate) fn reset_send_pending_timeout(&mut self) { in reset_send_pending_timeout()
92 pub(crate) fn min_recv_speed_limit(&mut self, size: usize) -> Result<(), HttpClientError> { in min_recv_speed_limit()
96 pub(crate) fn reset_recv_pending_timeout(&mut self) { in reset_recv_pending_timeout()
100 pub(crate) fn poll_max_recv_delay_time(&mut self, cx: &mut Context<'_>) -> Poll<()> { in poll_max_recv_delay_time()
104 pub(crate) fn poll_recv_pending_timeout(&mut self, cx: &mut Context<'_>) -> bool { in poll_recv_pending_timeout()
[all …]
|
| /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/unix/udp/ |
| D | udp_socket.rs | 134 pub fn set_ttl(&self, ttl: u32) -> io::Result<()> { in set_ttl()
178 pub fn send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in send_to()
211 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
232 pub fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
261 pub fn connect(self, addr: SocketAddr) -> io::Result<ConnectedUdpSocket> { in connect() argument
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()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/monitor/ |
| D | time_group.rs | 49 pub(crate) fn set_dns_start(&mut self, start: Instant) { in set_dns_start()
53 pub(crate) fn set_dns_end(&mut self, end: Instant) { in set_dns_end()
60 pub(crate) fn set_tcp_start(&mut self, start: Instant) { in set_tcp_start()
64 pub(crate) fn set_tcp_end(&mut self, end: Instant) { in set_tcp_end()
72 pub(crate) fn set_quic_start(&mut self, start: Instant) { in set_quic_start()
77 pub(crate) fn set_quic_end(&mut self, end: Instant) { in set_quic_end()
85 pub(crate) fn set_tls_start(&mut self, start: Instant) { in set_tls_start()
90 pub(crate) fn set_tls_end(&mut self, end: Instant) { in set_tls_end()
97 pub(crate) fn set_transfer_start(&mut self, start: Instant) { in set_transfer_start()
101 pub(crate) fn set_transfer_end(&mut self, end: Instant) { in set_transfer_end()
[all …]
|
| /commonlibrary/rust/ylong_json/src/value/ |
| D | index.rs | 22 fn index_into<'a>(&self, value: &'a JsonValue) -> &'a JsonValue; in index_into()
25 fn index_into_mut<'a>(&self, value: &'a mut JsonValue) -> &'a mut JsonValue; in index_into_mut()
28 fn index_remove(&self, value: &mut JsonValue) -> Option<JsonValue>; in index_remove()
62 fn index_into<'a>(&self, value: &'a JsonValue) -> &'a JsonValue { in index_into()
107 fn index_into_mut<'a>(&self, value: &'a mut JsonValue) -> &'a mut JsonValue { in index_into_mut()
136 fn index_remove(&self, value: &mut JsonValue) -> Option<JsonValue> { in index_remove()
173 fn index_into<'a>(&self, value: &'a JsonValue) -> &'a JsonValue { in index_into()
216 fn index_into_mut<'a>(&self, value: &'a mut JsonValue) -> &'a mut JsonValue { in index_into_mut()
258 fn index_remove(&self, value: &mut JsonValue) -> Option<JsonValue> { in index_remove()
268 fn index_into<'a>(&self, value: &'a JsonValue) -> &'a JsonValue { in index_into()
[all …]
|
| /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()
215 pub fn peek(&self, buf: &mut [u8]) -> io::Result<usize> { in peek()
221 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
225 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
231 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
235 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
245 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| D | task_handle.rs | 59 fn finish(self, state: usize, output: Result<T::Output, ScheduleError>) { in finish() argument
78 pub(crate) fn release(self) { in release() argument
82 pub(crate) fn drop_ref(self) { in drop_ref() argument
89 pub(crate) fn get_result(self, out: &mut Poll<std::result::Result<T::Output, ScheduleError>>) { in get_result() argument
93 pub(crate) fn drop_join_handle(self) { in drop_join_handle() argument
107 fn set_waker_inner(&self, des_waker: Waker, cur_state: usize) -> Result<usize, usize> { in set_waker_inner()
131 pub(crate) fn set_waker(self, cur: usize, des_waker: &Waker) -> bool { in set_waker() argument
172 pub(crate) fn run(self) { in run() argument
219 pub(crate) unsafe fn shutdown(self) { in shutdown() argument
230 pub(crate) fn wake(self) { in wake() argument
[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()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| D | client.rs | 107 &self, in request()
115 &self, in retry_send_request()
129 &self, in send_request_retryable()
137 &self, in redirect_request()
160 &self, in send_request_with_uri()
246 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
263 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
280 pub fn redirect(mut self, redirect: Redirect) -> Self { in redirect()
297 pub fn proxy(mut self, proxy: Proxy) -> Self { in proxy()
341 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/util/interceptor/ |
| D | mod.rs | 43 fn intercept_connection(&self, _info: ConnDetail) -> Result<(), HttpClientError> { in intercept_connection()
48 fn intercept_input(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in intercept_input()
53 fn intercept_output(&self, _bytes: &[u8]) -> Result<(), HttpClientError> { in intercept_output()
58 fn intercept_request(&self, _request: &Request) -> Result<(), HttpClientError> { in intercept_request()
63 fn intercept_response(&self, _response: &Response) -> Result<(), HttpClientError> { in intercept_response()
68 fn intercept_retry(&self, _error: &HttpClientError) -> Result<(), HttpClientError> { in intercept_retry()
73 fn intercept_redirect_request(&self, _request: &Request) -> Result<(), HttpClientError> { in intercept_redirect_request()
79 &self, in intercept_redirect_response()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/builder/ |
| D | multi_thread_builder.rs | 93 pub fn max_worker_num_by_qos(mut self, qos: Qos, num: u32) -> Self { in max_worker_num_by_qos()
104 pub fn worker_name(mut self, name: String) -> Self { in worker_name()
123 pub fn worker_num(self, core_pool_size: usize) -> Self { in worker_num() argument
131 pub fn is_affinity(self, _is_affinity: bool) -> Self { in is_affinity() argument
139 pub fn schedule_algo(self, _schedule_algo: ScheduleAlgo) -> Self { in schedule_algo() argument
147 pub fn after_start<F>(self, _f: F) -> Self in after_start()
158 pub fn before_stop<F>(self, _f: F) -> Self in before_stop()
169 pub fn blocking_permanent_thread_num(self, _blocking_permanent_thread_num: u8) -> Self { in blocking_permanent_thread_num() argument
180 pub fn max_blocking_pool_size(self, _max_blocking_pool_size: u8) -> Self { in max_blocking_pool_size() argument
189 pub fn keep_alive_time(self, _keep_alive_time: Duration) -> Self { in keep_alive_time() argument
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 146 &mut self, in manage_pending_state()
159 fn poll_recv_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_recv_request()
197 fn poll_input_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_input_request()
216 &mut self, in input_stream_frame()
250 &mut self, in deal_poll_body_error()
263 fn poll_send_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_frame()
295 &mut self, in poll_recv_frame()
333 fn recv_settings_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_settings_frame()
383 fn recv_ping_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in recv_ping_frame()
402 &mut self, in recv_go_away_frame()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | client.rs | 160 pub async fn request(&self, request: Request) -> Result<Response, HttpClientError> { in request()
201 pub fn total_timeout(&mut self, timeout: Timeout) { in total_timeout()
207 async fn send_request(&self, request: RequestArc) -> Result<Response, HttpClientError> { in send_request()
216 &self, in send_unformatted_request()
230 async fn connect_to(&self, uri: &Uri) -> Result<TimeInfoConn<C::Stream>, HttpClientError> { in connect_to()
243 &self, in send_request_on_conn()
266 &self, in redirect()
392 pub fn total_timeout(mut self, timeout: Timeout) -> Self { in total_timeout()
410 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
427 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 | 77 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
83 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
164 pub async fn connect<A: ToSocketAddrs>(self, addr: A) -> io::Result<ConnectedUdpSocket> { in connect()
232 pub async fn send_to<A: ToSocketAddrs>(&self, buf: &[u8], target: A) -> io::Result<usize> { in send_to()
274 pub fn try_send_to(&self, buf: &[u8], target: SocketAddr) -> io::Result<usize> { in try_send_to()
308 &self, in poll_send_to()
345 pub async fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in recv_from()
381 pub fn try_recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in try_recv_from()
407 pub async fn peek_from(&self, buf: &mut [u8]) -> io::Result<(usize, SocketAddr)> { in peek_from()
433 pub 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_http/ylong_http_client/src/util/h3/ |
| D | stream_manager.rs | 82 &mut self, in poll_recv_signal()
100 &mut self, in poll_recv_request()
118 &mut self, in send_inst_to_peer()
135 &mut self, in transmit_error()
143 fn poll_input_request(&mut self, cx: &mut Context<'_>) -> Result<(), DispatchErrorKind> { in poll_input_request()
159 &mut self, in input_stream_frame()
210 fn poll_send_header(&mut self, id: u64, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_header()
254 fn poll_send_frame(&mut self, id: u64, frame: Option<Frame>) -> Result<(), DispatchErrorKind> { in poll_send_frame()
280 &mut self, in poll_read_body()
299 pub(crate) fn init(&mut self, config: H3Config) -> Result<(), DispatchErrorKind> { in init()
[all …]
|
| D | streams.rs | 87 &mut self, in transmit_message()
161 &mut self, in new_unidirectional_stream()
183 &mut self, in send_frame()
239 &mut self, in send_error()
306 &mut self, in set_peer_qpack_encode_stream_id()
321 pub(crate) fn set_peer_control_stream_id(&mut self, id: u64) -> Result<(), DispatchErrorKind> { in set_peer_control_stream_id()
335 &mut self, in set_peer_qpack_decode_stream_id()
351 pub(crate) fn set_goaway_id(&mut self, id: u64) -> Result<(), DispatchErrorKind> { in set_goaway_id()
363 pub(crate) fn get_header(&mut self, id: u64) -> Result<Option<Frame>, DispatchErrorKind> { in get_header()
373 pub(crate) fn frame_acceptable(&mut self, id: u64) -> bool { in frame_acceptable()
[all …]
|
| /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()
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()
139 fn encode_object(&mut self, object: &Object) -> Result<(), Error> { in encode_object()
177 pub(crate) fn encode(&mut self, value: &JsonValue) -> Result<(), Error> { in encode()
[all …]
|
| D | serializer_compact.rs | 33 fn write(&mut self, buf: &[u8]) -> std::io::Result<usize> { in write()
92 fn serialize_bool(self, v: bool) -> Result<(), Error> { in serialize_bool() argument
100 fn serialize_i8(self, v: i8) -> Result<(), Error> { in serialize_i8() argument
104 fn serialize_i16(self, v: i16) -> Result<(), Error> { in serialize_i16() argument
108 fn serialize_i32(self, v: i32) -> Result<(), Error> { in serialize_i32() argument
112 fn serialize_i64(self, v: i64) -> Result<(), Error> { in serialize_i64() argument
117 fn serialize_u8(self, v: u8) -> Result<(), Error> { in serialize_u8() argument
121 fn serialize_u16(self, v: u16) -> Result<(), Error> { in serialize_u16() argument
125 fn serialize_u32(self, v: u32) -> Result<(), Error> { in serialize_u32() argument
129 fn serialize_u64(self, v: u64) -> Result<(), Error> { in serialize_u64() argument
[all …]
|
| /commonlibrary/rust/ylong_json/src/value/object/ |
| D | linked_list.rs | 102 pub fn contains_key(&self, key: &str) -> bool { in contains_key()
117 pub fn insert(&mut self, key: String, value: JsonValue) { in insert()
134 pub fn remove(&mut self, key: &str) -> Option<JsonValue> { in remove()
177 pub fn get(&self, key: &str) -> Option<&JsonValue> { in get()
194 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut()
214 pub fn get_node(&self, key: &str) -> Option<&Node<(String, JsonValue)>> { in get_node()
233 pub fn get_node_mut(&mut self, key: &str) -> Option<&mut Node<(String, JsonValue)>> { in get_node_mut()
246 pub(crate) fn get_key_mut_maybe_insert(&mut self, key: &str) -> &mut JsonValue { in get_key_mut_maybe_insert()
271 fn get_cursor(&self, key: &str) -> Option<Cursor<'_, (String, JsonValue)>> { in get_cursor()
284 fn get_cursor_mut(&mut self, key: &str) -> Option<CursorMut<'_, (String, JsonValue)>> { in get_cursor_mut()
[all …]
|
| /commonlibrary/rust/ylong_http/ylong_http/src/h3/qpack/ |
| D | table.rs | 52 pub(crate) fn search_in_static(&self, header: &NameField, value: &str) -> TableIndex { in search_in_static()
57 &self, in search_in_dynamic()
65 pub(crate) fn find_field_static(&self, index: usize) -> Option<(NameField, String)> { in find_field_static()
72 pub(crate) fn find_field_name_static(&self, index: usize) -> Option<NameField> { in find_field_name_static()
76 pub(crate) fn find_field_dynamic(&self, index: usize) -> Option<(NameField, String)> { in find_field_dynamic()
80 pub(crate) fn find_field_name_dynamic(&self, index: usize) -> Option<NameField> { in find_field_name_dynamic()
137 pub(crate) fn update_capacity(&mut self, new_cap: usize) -> Option<usize> { in update_capacity()
157 pub(crate) fn track_field(&mut self, index: usize) { in track_field()
165 pub(crate) fn untracked_field(&mut self, index: usize) { in untracked_field()
174 pub(crate) fn increase_known_receive_count(&mut self, increment: usize) { in increase_known_receive_count()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/ |
| D | stream.rs | 157 pub fn shutdown(&self, how: std::net::Shutdown) -> io::Result<()> { in shutdown()
163 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
167 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
173 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
177 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
186 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read()
191 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored()
198 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write()
203 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored()
215 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/net/sys/unix/ |
| D | datagram.rs | 98 pub async fn ready(&self, interest: Interest) -> Result<Ready> { in ready()
168 pub fn try_recv(&self, buf: &mut [u8]) -> Result<usize> { in try_recv()
236 pub fn try_send(&self, buf: &[u8]) -> Result<usize> { in try_send()
307 pub fn connect<P: AsRef<Path>>(&self, path: P) -> Result<()> { in connect()
325 pub async fn send(&self, buf: &[u8]) -> Result<usize> { in send()
347 pub async fn send_to<P: AsRef<Path>>(&self, buf: &[u8], path: P) -> Result<usize> { in send_to()
369 pub async fn recv(&self, buf: &mut [u8]) -> Result<usize> { in recv()
391 pub async fn recv_from(&self, buf: &mut [u8]) -> Result<(usize, net::SocketAddr)> { in recv_from()
429 pub fn shutdown(&self, how: std::net::Shutdown) -> Result<()> { in shutdown()
435 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | parker.rs | 51 pub(crate) fn park(&mut self) { in park()
55 pub(crate) fn unpark(&self, handle: Arc<Handle>) { in unpark()
63 pub(crate) fn release(&self) { in release()
74 fn park(&self) { in park()
99 fn park_on_driver(&self, driver: &mut Driver) -> ParkFlag { in park_on_driver()
123 fn park_on_condvar_timeout(&self, duration: Option<Duration>) { in park_on_condvar_timeout()
165 fn unpark(&self, handle: Arc<Handle>) { in unpark()
186 fn release(&self) { in release()
|