| /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 | 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_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 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_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_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_runtime/ylong_io/src/sys/unix/uds/ |
| D | stream.rs | 166 pub fn shutdown(&self, how: std::net::Shutdown) -> io::Result<()> { in shutdown() 172 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read() 176 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored() 182 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write() 186 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored() 195 fn read(&mut self, buf: &mut [u8]) -> io::Result<usize> { in read() 200 fn read_vectored(&mut self, bufs: &mut [IoSliceMut<'_>]) -> io::Result<usize> { in read_vectored() 207 fn write(&mut self, buf: &[u8]) -> io::Result<usize> { in write() 212 fn write_vectored(&mut self, bufs: &[IoSlice<'_>]) -> io::Result<usize> { in write_vectored() 224 fn fmt(&self, f: &mut std::fmt::Formatter<'_>) -> std::fmt::Result { in fmt() [all …]
|
| D | datagram.rs | 91 pub fn connect<P: AsRef<Path>>(&self, path: P) -> io::Result<()> { in connect() 178 pub fn recv_from(&self, buf: &mut [u8]) -> io::Result<(usize, net::SocketAddr)> { in recv_from() 196 pub fn recv(&self, buf: &mut [u8]) -> io::Result<usize> { in recv() 215 pub fn send_to<P: AsRef<Path>>(&self, buf: &[u8], path: P) -> io::Result<usize> { in send_to() 233 pub fn send(&self, buf: &[u8]) -> io::Result<usize> { in send() 269 pub fn shutdown(&self, how: std::net::Shutdown) -> io::Result<()> { in shutdown() 276 &mut self, in register() 285 &mut self, in reregister() 293 fn deregister(&mut self, selector: &Selector) -> io::Result<()> { in deregister() 303 fn fmt(&self, f: &mut fmt::Formatter<'_>) -> fmt::Result { in fmt()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | client.rs | 120 &self, in request() 157 &self, in retry_send_request() 171 &self, in send_request_retryable() 181 &self, in redirect_request() 218 &self, in send_request_with_uri() 260 &self, in http2_request() 295 pub(crate) fn set_retry(&mut self, retryable: bool) { in set_retry() 389 pub fn http2_settings(mut self, config: H2Config) -> Self { in http2_settings() 407 pub fn request_timeout(mut self, timeout: Timeout) -> Self { in request_timeout() 424 pub fn connect_timeout(mut self, timeout: Timeout) -> Self { in connect_timeout() [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/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_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() 122 fn park_on_condvar(&self) { in park_on_condvar() 152 fn park_on_condvar_timeout(&self, duration: Duration) { in park_on_condvar_timeout() 188 fn unpark(&self, handle: Arc<Handle>) { in unpark() 209 fn release(&self) { in release()
|
| 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_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_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_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_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/ |
| 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_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
| D | mod.rs | 154 pub fn try_send(&self, value: T) -> Result<(), TrySendError<T>> { in try_send() 183 pub async fn send(&self, value: T) -> Result<(), SendError<T>> { in send() 217 pub async fn send_timeout(&self, value: T, time: Duration) -> Result<(), SendTimeoutError<T>> { in send_timeout() 260 pub fn is_same(&self, other: &Self) -> bool { in is_same() 309 fn drop(&mut self) { in drop() 412 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() 471 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout() 515 pub fn close(&mut self) { in close() 521 fn drop(&mut self) { in drop()
|