| /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_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_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_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_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_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_runtime/ylong_runtime/src/builder/ |
| D | multi_thread_builder.rs | 97 pub fn max_worker_num_by_qos(mut self, qos: Qos, num: u32) -> Self { in max_worker_num_by_qos()
108 pub fn worker_name(mut self, name: String) -> Self { in worker_name()
127 pub fn worker_num(self, core_pool_size: usize) -> Self { in worker_num() argument
135 pub fn is_affinity(self, _is_affinity: bool) -> Self { in is_affinity() argument
143 pub fn schedule_algo(self, _schedule_algo: ScheduleAlgo) -> Self { in schedule_algo() argument
151 pub fn after_start<F>(self, _f: F) -> Self in after_start()
162 pub fn before_stop<F>(self, _f: F) -> Self in before_stop()
173 pub fn blocking_permanent_thread_num(self, _blocking_permanent_thread_num: u8) -> Self { in blocking_permanent_thread_num() argument
184 pub fn max_blocking_pool_size(self, _max_blocking_pool_size: u8) -> Self { in max_blocking_pool_size() argument
193 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/buffer/ |
| D | window.rs | 38 pub(crate) fn reduce_size(&mut self, size: u32) { in reduce_size()
42 pub(crate) fn increase_size(&mut self, size: u32) -> Result<(), H2Error> { in increase_size()
54 pub(crate) fn send_data(&mut self, size: u32) { in send_data()
103 pub(crate) fn reduce_actual(&mut self, size: u32) { in reduce_actual()
107 pub(crate) fn increase_actual(&mut self, size: u32) { in increase_actual()
111 pub(crate) fn reduce_notification(&mut self, size: u32) { in reduce_notification()
115 pub(crate) fn increase_notification(&mut self, size: u32) { in increase_notification()
119 pub(crate) fn check_window_update(&mut self, id: u32) -> Option<Frame> { in check_window_update()
136 pub(crate) fn recv_data(&mut self, size: u32) { in recv_data()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| D | manager.rs | 148 &mut self, 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()
229 &mut self, in input_stream_frame()
260 fn poll_send_frame(&mut self, frame: Frame) -> Result<(), DispatchErrorKind> { in poll_send_frame()
291 &mut self, 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()
399 &mut self, in recv_go_away_frame()
441 &mut self, in recv_reset_frame()
[all …]
|
| D | streams.rs | 202 pub(crate) fn decrease_current_concurrency(&mut self) { in decrease_current_concurrency()
206 pub(crate) fn increase_current_concurrency(&mut self) { in increase_current_concurrency()
214 pub(crate) fn apply_max_concurrent_streams(&mut self, num: u32) { in apply_max_concurrent_streams()
218 pub(crate) fn apply_send_initial_window_size(&mut self, size: u32) -> Result<(), H2Error> { in apply_send_initial_window_size()
244 pub(crate) fn apply_recv_initial_window_size(&mut self, size: u32) { in apply_recv_initial_window_size()
264 pub(crate) fn release_stream_recv_window(&mut self, id: u32, size: u32) -> Result<(), H2Error> { in release_stream_recv_window()
277 pub(crate) fn release_conn_recv_window(&mut self, size: u32) -> Result<(), H2Error> { in release_conn_recv_window()
297 pub(crate) fn stream_state(&self, id: u32) -> Option<H2StreamState> { in stream_state()
301 pub(crate) fn insert(&mut self, id: u32, request: RequestWrapper) { in insert()
309 pub(crate) fn push_back_pending_send(&mut self, id: u32) { in push_back_pending_send()
[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/h3/qpack/ |
| D | table.rs | 43 pub(crate) fn find_index_static(&self, header: &Field, value: &str) -> Option<TableIndex> { in find_index_static()
50 pub(crate) fn find_index_name_static(&self, header: &Field, value: &str) -> Option<TableIndex> { in find_index_name_static()
57 pub(crate) fn find_index_dynamic(&self, header: &Field, value: &str) -> Option<TableIndex> { in find_index_dynamic()
65 &self, in find_index_name_dynamic()
75 pub(crate) fn find_field_static(&self, index: usize) -> Option<(Field, String)> { in find_field_static()
82 pub(crate) fn find_field_name_static(&self, index: usize) -> Option<Field> { in find_field_name_static()
86 pub(crate) fn find_field_dynamic(&self, index: usize) -> Option<(Field, String)> { in find_field_dynamic()
90 pub(crate) fn find_field_name_dynamic(&self, index: usize) -> Option<Field> { in find_field_name_dynamic()
129 pub(crate) fn update(&mut self, field: Field, value: String) -> Option<TableIndex> { in update()
138 &self, in have_enough_space()
[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_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 …]
|
| D | vec.rs | 104 pub fn contains_key(&self, key: &str) -> bool { in contains_key()
119 pub fn insert(&mut self, key: String, value: JsonValue) { in insert()
136 pub fn remove(&mut self, key: &str) -> Option<JsonValue> { in remove()
180 pub fn get(&self, key: &str) -> Option<&JsonValue> { in get()
197 pub fn get_mut(&mut self, key: &str) -> Option<&mut JsonValue> { in get_mut()
209 pub(crate) fn get_mut_by_position(&mut self, index: usize) -> Option<&mut JsonValue> { in get_mut_by_position()
232 fn eq(&self, other: &Self) -> bool { in eq()
246 fn fmt(&self, f: &mut Formatter<'_>) -> core::fmt::Result { in fmt()
259 fn fmt(&self, f: &mut Formatter<'_>) -> std::fmt::Result { in fmt()
|
| /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()
178 async fn send_request(&self, request: RequestArc) -> Result<Response, HttpClientError> { in send_request()
184 &self, in send_unformatted_request()
192 async fn connect_to(&self, uri: &Uri) -> Result<Conn<C::Stream>, HttpClientError> { in connect_to()
205 &self, in send_request_on_conn()
221 &self, in redirect()
346 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout()
363 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout()
380 pub fn redirect(mut self, redirect: Redirect) -> Self { in redirect()
397 pub fn sockets_owner(mut self, uid: u32, gid: u32) -> Self { in sockets_owner()
[all …]
|
| /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()
|
| /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/process/ |
| D | command.rs | 90 pub fn kill_on_drop(&mut self, kill: bool) -> &mut Command { in kill_on_drop()
110 pub fn arg<S: AsRef<OsStr>>(&mut self, arg: S) -> &mut Command { in arg()
129 pub fn args<I: IntoIterator<Item = S>, S: AsRef<OsStr>>(&mut self, args: I) -> &mut Command { in args()
148 pub fn env<K: AsRef<OsStr>, V: AsRef<OsStr>>(&mut self, key: K, val: V) -> &mut Command { in env()
178 pub fn envs<I, S, V>(&mut self, vars: I) -> &mut Command in envs()
202 pub fn env_remove<S: AsRef<OsStr>>(&mut self, key: S) -> &mut Command { in env_remove()
240 pub fn current_dir<P: AsRef<Path>>(&mut self, dir: P) -> &mut Command { in current_dir()
263 pub fn stdin<T: Into<Stdio>>(&mut self, cfg: T) -> &mut Command { in stdin()
286 pub fn stdout<T: Into<Stdio>>(&mut self, cfg: T) -> &mut Command { in stdout()
309 pub fn stderr<T: Into<Stdio>>(&mut self, cfg: T) -> &mut Command { in stderr()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/pty_process/ |
| D | command.rs | 81 pub fn arg<S: AsRef<OsStr>>(&mut self, arg: S) -> &mut PtyCommand { in arg()
101 pub fn args<I: IntoIterator<Item = S>, S: AsRef<OsStr>>(&mut self, args: I) -> &mut PtyCommand { in args()
121 pub fn env<K: AsRef<OsStr>, V: AsRef<OsStr>>(&mut self, key: K, val: V) -> &mut PtyCommand { in env()
152 pub fn envs<I, K, V>(&mut self, vars: I) -> &mut PtyCommand in envs()
176 pub fn env_remove<K: AsRef<OsStr>>(&mut self, key: K) -> &mut PtyCommand { in env_remove()
204 pub fn current_dir<P: AsRef<Path>>(&mut self, dir: P) -> &mut PtyCommand { in current_dir()
222 pub fn stdin<T: Into<Stdio>>(&mut self, cfg: T) -> &mut PtyCommand { in stdin()
241 pub fn stdout<T: Into<Stdio>>(&mut self, cfg: T) -> &mut PtyCommand { in stdout()
260 pub fn stderr<T: Into<Stdio>>(&mut self, cfg: T) -> &mut PtyCommand { in stderr()
286 pub fn spawn(&mut self, pts: &Pts) -> io::Result<Child> { in spawn()
[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()
|