Home
last modified time | relevance | path

Searched defs:self (Results 1 – 25 of 206) sorted by relevance

123456789

/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/udp/
Dudp_socket.rs62 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/
Dudp_socket.rs137 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/
Dindex.rs22 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/
Dstream.rs101 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/
Dtask_handle.rs59 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/
Dopen_options.rs78 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()
Dfile_buf.rs39 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/
Dclient.rs112 &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/
Dstream.rs166 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 …]
Ddatagram.rs91 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/
Dclient.rs120 &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/
Dmulti.rs147 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 …]
Dpart.rs75 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/
Dtable.rs43 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/
Dparker.rs51 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()
Dworker.rs37 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/
Dencoder.rs37 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 …]
Dserializer_compact.rs33 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/
Dlinked_list.rs102 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 …]
Dvec.rs104 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/
Dudp.rs79 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/
Ddatagram.rs98 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/
Dmulti.rs133 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/
Dpoll.rs37 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/
Dmod.rs154 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()

123456789