Home
last modified time | relevance | path

Searched defs:a (Results 1 – 25 of 41) sorted by relevance

12

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/pariter/
Dmod.rs84 fn for_each<'a, F>( in for_each()
89 F: Fn(Self::Item) + Send + Copy + Sync + 'a, in for_each()
90 Self: 'a, in for_each()
99 ) -> Pin<Box<dyn std::future::Future<Output = Result<Self::Item, ScheduleError>> + Send + 'a>> in sum()
109 fn drive<'a, C>( in drive()
112 ) -> Pin<Box<dyn std::future::Future<Output = Result<C::Output, ScheduleError>> + Send + 'a>> in drive()
115 C: Consumer<Self> + Send + Sync + 'a, in drive()
Dzip.rs34 a: A, field
/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/
Dbuilder.rs41 let mut a = xc.lock().unwrap(); in sdv_set_builder_after_start() localVariable
50 let a = x.lock().unwrap(); in sdv_set_builder_after_start() localVariable
70 let mut a = xc.lock().unwrap(); in sdv_set_builder_before_stop() localVariable
79 let a = x.lock().unwrap(); in sdv_set_builder_before_stop() localVariable
Dpar_iter.rs25 let a = vec![1, 2, 3, 4, 5, 6, 7, 8, 9, 10]; in sdv_par_iter_test() localVariable
Dselect.rs80 let mut a = None; in sdv_new_select_channel() localVariable
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
Dasync_read.rs111 fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadTask<'a, Self> { in read()
130 fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExactTask<'a, Self> { in read_exact()
148 fn read_to_end<'a>(&'a mut self, buf: &'a mut Vec<u8>) -> ReadToEndTask<'a, Self> { in read_to_end()
167 fn read_to_string<'a>(&'a mut self, dst: &'a mut String) -> ReadToStringTask<'a, Self> { in read_to_string()
Dwrite_task.rs44 pub(crate) fn new(writer: &'a mut W, buf: &'a [u8]) -> WriteTask<'a, W> { in new()
84 pub(crate) fn new(writer: &'a mut W, bufs: &'a [IoSlice<'b>]) -> WriteVectoredTask<'a, 'b, W> { in new()
125 pub(crate) fn new(writer: &'a mut W, buf: &'a [u8]) -> WriteAllTask<'a, W> { in new()
166 pub(crate) fn new(writer: &'a mut W) -> FlushTask<'a, W> { in new()
191 pub(crate) fn new(writer: &'a mut W) -> ShutdownTask<'a, W> { in new()
Dasync_write.rs206 fn write<'a>(&'a mut self, buf: &'a [u8]) -> WriteTask<'a, Self> in write()
230 fn write_vectored<'a, 'b>( in write_vectored()
233 ) -> WriteVectoredTask<'a, 'b, Self> in write_vectored()
255 fn write_all<'a>(&'a mut self, buf: &'a [u8]) -> WriteAllTask<'a, Self> in write_all()
Dasync_buf_read.rs106 fn read_until<'a>(&'a mut self, byte: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, Self> in read_until()
125 fn read_line<'a>(&'a mut self, buf: &'a mut String) -> ReadLineTask<'a, Self> in read_line()
Dread_task.rs47 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadTask<'a, R> { in new()
87 pub(crate) fn new(reader: &'a mut R, buf: &'a mut Vec<u8>) -> ReadToEndTask<'a, R> { in new()
158 pub(crate) fn new(reader: &'a mut R, dst: &'a mut String) -> ReadToStringTask<'a, R> { in new()
232 pub(crate) fn new(reader: &'a mut R, buf: &'a mut [u8]) -> ReadExactTask<'a, R> { in new()
282 pub(crate) fn new(reader: &'a mut R, delim: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, R> { in new()
350 pub(crate) fn new(reader: &'a mut R, buf: &'a mut String) -> ReadLineTask<'a, R> { in new()
Dseek_task.rs30 pub(crate) fn new(seek: &'a mut T, pos: io::SeekFrom) -> SeekTask<'a, T> { in new()
Dread_buf.rs39 pub fn new(buf: &'a mut [u8]) -> ReadBuf<'a> { in new()
53 ) -> ReadBuf<'a> { in create()
/commonlibrary/rust/ylong_http/ylong_http/src/request/uri/
Dpercent_encoding.rs70 fn parse_scheme<'a>(&mut self, mut origin: UrlChars<'a>) -> Result<UrlChars<'a>, HttpError> { in parse_scheme()
86 fn parse_double_slash<'a>(&mut self, origin: UrlChars<'a>) -> Result<UrlChars<'a>, HttpError> { in parse_double_slash()
106 fn parse_userinfo<'a>(&mut self, mut origin: UrlChars<'a>) -> Result<UrlChars<'a>, HttpError> { in parse_userinfo()
151 fn parse_authority<'a>(&mut self, mut origin: UrlChars<'a>) -> Result<UrlChars<'a>, HttpError> { in parse_authority()
172 fn parse_path<'a>(&mut self, mut origin: UrlChars<'a>) -> Result<UrlChars<'a>, HttpError> { in parse_path()
218 fn parse_query<'a>(&mut self, mut origin: UrlChars<'a>) -> Result<UrlChars<'a>, HttpError> { in parse_query()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
Dtimer.rs201 let mut a = 0; in ut_new_timer_base() localVariable
226 let mut a = 0; in ut_new_timer_timeout() localVariable
255 let mut a = xc.lock().unwrap(); in ut_new_timer_schedule() localVariable
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
Doperator.rs50 fn download<'a, 'b>(&'a mut self, data: &'b [u8]) -> DownloadFuture<'a, 'b, Self> in download()
64 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
66 Self: Unpin + Sized + 'a, in progress()
/commonlibrary/rust/ylong_runtime/ylong_runtime/examples/
Dylong_runtime_worker_stack_overflow.rs24 let a = [0; 20000]; in main() localVariable
Dylong_runtime_task_starvation.rs34 let a = 0; in main() localVariable
/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/common/
Dmulti.rs200 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()
263 pub fn list_mut(&mut self) -> &mut Vec<XPart<'a>> { in list_mut()
537 pub fn build(self) -> Result<MimeMulti<'a>, HttpError> { in build()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
Drwlock.rs373 let a = lock.read().await; in ut_rwlock_read_01() localVariable
397 let a = lock.read().await; in ut_rwlock_read_02() localVariable
426 let mut a = lock.try_write().unwrap(); in ut_rwlock_try_read_02() localVariable
447 let mut a = lock.write().await; in ut_rwlock_write_01() localVariable
511 let mut a = lock.try_write().unwrap(); in ut_rwlock_try_write_02() localVariable
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
Doperator.rs63 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
65 Self: Unpin + Sized + 'a, in progress()
/commonlibrary/rust/ylong_http/ylong_http/src/body/
Dmod.rs290 fn data<'a, 'b>(&'a mut self, buf: &'b mut [u8]) -> DataFuture<'a, 'b, Self> in data()
292 Self: 'a, in data()
348 fn trailer<'a>(&'a mut self) -> TrailerFuture<'a, Self> in trailer()
350 Self: 'a, in trailer()
Dchunk.rs735 fn new<'a>(iter: core::slice::Iter<'a, Chunk<'a>>) -> ChunksIter<'a> { in new()
786 fn push<'a: 'b>(&mut self, chunk: Chunk<'a>) { in push()
959 pub fn decode<'a>(&mut self, buf: &'a [u8]) -> Result<(Chunks<'a>, &'a [u8]), HttpError> { in decode()
993 chunk: Chunk<'a>, in match_decode_result()
1092 fn decode_size<'a>(&mut self, buf: &'a [u8]) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in decode_size()
1152 ) -> Chunk<'a> { in sized_chunk()
1166 ) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in decode_special_char()
1185 fn skip_extension<'a>(&mut self, buf: &'a [u8]) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in skip_extension()
1194 fn skip_trailer_ext<'a>(&mut self, buf: &'a [u8]) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in skip_trailer_ext()
1219 fn skip_chunk_ext<'a>(&mut self, buf: &'a [u8]) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in skip_chunk_ext()
[all …]
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
Dbio.rs47 pub(crate) fn from_byte(buf: &'a [u8]) -> Result<BioSlice<'a>, ErrorStack> { in from_byte()
134 unsafe fn get_state<'a, S: 'a>(bio: *mut BIO) -> &'a mut StreamState<S> { in get_state()
148 pub(crate) unsafe fn get_stream_ref<'a, S: 'a>(bio: *mut BIO) -> &'a S { in get_stream_ref()
153 pub(crate) unsafe fn get_stream_mut<'a, S: 'a>(bio: *mut BIO) -> &'a mut S { in get_stream_mut()
/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()
268 mut part_encoder: MimePartEncoder<'a>, in sync_mimepart_encode()
/commonlibrary/c_utils/base/include/
Dpubdef.h43 #define ARRAY_SIZE(a) (sizeof((a)) / sizeof((a[0]))) argument

12