| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
| H A D | async_read.rs | 43 cx: &mut Context<'_>, in poll_read()
44 buf: &mut ReadBuf<'_>, in poll_read()
52 cx: &mut Context<'_>, in poll_read()
53 buf: &mut ReadBuf<'_>, in poll_read()
63 cx: &mut Context<'_>, in poll_read()
64 buf: &mut ReadBuf<'_>, in poll_read()
78 cx: &mut Context<'_>, in poll_read()
79 buf: &mut ReadBuf<'_>, in poll_read()
111 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()
[all …]
|
| H A D | async_write.rs | 42 cx: &mut Context<'_>, in poll_write()
52 cx: &mut Context<'_>, in poll_write_vectored()
53 bufs: &[IoSlice<'_>], in poll_write_vectored()
153 cx: &mut Context<'_>, in poll_write()
161 cx: &mut Context<'_>, in poll_write_vectored()
162 bufs: &[IoSlice<'_>], in poll_write_vectored()
206 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()
[all …]
|
| H A D | read_task.rs | 47 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()
101 cx: &mut Context<'_>, in poll_read_to_end()
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()
255 let _ = match Pin::new(&mut reader).poll_read(cx, &mut this.buf) { in poll() localVariable
282 pub(crate) fn new(reader: &'a mut R, delim: u8, buf: &'a mut Vec<u8>) -> ReadUtilTask<'a, R> { in new()
297 cx: &mut Context<'_>, in poll_read_until()
350 pub(crate) fn new(reader: &'a mut R, buf: &'a mut String) -> ReadLineTask<'a, R> { in new()
452 cx: &mut Context<'_>, in poll_next_line()
|
| H A D | read_buf.rs | 39 pub fn new(buf: &'a mut [u8]) -> ReadBuf<'a> { in new()
53 ) -> ReadBuf<'a> { in create()
63 pub fn uninit(buf: &mut [MaybeUninit<u8>]) -> ReadBuf<'_> { in uninit()
92 pub fn take(&mut self, n: usize) -> ReadBuf<'_> { in take()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/ |
| H A D | operator.rs | 65 cx: &mut Context<'_>, in poll_download()
74 _cx: &mut Context<'_>, in poll_progress()
82 fn download<'a, 'b>(&'a mut self, data: &'b [u8]) -> DownloadFuture<'a, 'b, Self> in download()
93 fn progress<'a>(&'a mut self, downloaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
95 Self: Unpin + Sized + 'a, in progress()
111 cx: &mut Context<'_>, in poll_download()
119 cx: &mut Context<'_>, in poll_progress()
170 _cx: &mut Context<'_>, in poll_download()
179 _cx: &mut Context<'_>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/ |
| H A D | operator.rs | 29 cx: &mut Context<'_>, in poll_download()
39 _cx: &mut Context<'_>, in poll_progress()
50 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()
82 cx: &mut Context<'_>, in poll_download()
90 cx: &mut Context<'_>, in poll_progress()
139 _cx: &mut Context<'_>, in poll_download()
151 _cx: &mut Context<'_>, in poll_progress()
|
| /ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/ |
| H A D | operator.rs | 57 _cx: &mut Context<'_>, in poll_progress()
65 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
67 Self: Unpin + Sized + 'a, in progress()
83 cx: &mut Context<'_>, in poll_progress()
116 _cx: &mut Context<'_>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/ |
| H A D | operator.rs | 55 _cx: &mut Context<'_>, in poll_progress()
63 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
65 Self: Unpin + Sized + 'a, in progress()
81 cx: &mut Context<'_>, in poll_progress()
114 _cx: &mut Context<'_>, in poll_progress()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | rwlock.rs | 114 pub async fn read(&self) -> RwLockReadGuard<'_, T> { in read()
136 pub fn try_read(&self) -> Result<RwLockReadGuard<'_, T>, LockError> { in try_read()
169 pub async fn write(&self) -> RwLockWriteGuard<'_, T> { in write()
197 pub fn try_write(&self) -> Result<RwLockWriteGuard<'_, T>, LockError> { in try_write()
373 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
|
| H A D | watch.rs | 214 fn new(value: RwLockReadGuard<'a, T>, is_notified: bool) -> ValueRef<'a, T> { in new()
435 pub fn borrow(&self) -> ValueRef<'_, T> { in borrow()
473 pub fn borrow_notify(&mut self) -> ValueRef<'_, T> { in borrow_notify()
621 let _ = block_on(handle1); in send_notified_await() localVariable
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | timer.rs | 201 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
262 let _ = block_on(handle); in ut_new_timer_schedule() localVariable
|
| /ohos5.0/base/request/request/services/src/ |
| H A D | lib.rs | 78 let _ = std::fs::create_dir("test_files/"); in test_init() localVariable
83 pub(crate) fn lock_database<'a>() -> DatabaseLock<'a> { in lock_database()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/ |
| H A D | mod.rs | 229 cx: &mut Context<'_>, in poll_data()
290 fn data<'a, 'b>(&'a mut self, buf: &'b mut [u8]) -> DataFuture<'a, 'b, Self> in data()
292 Self: 'a, in data()
301 _cx: &mut Context<'_>, in poll_trailer()
348 fn trailer<'a>(&'a mut self) -> TrailerFuture<'a, Self> in trailer()
350 Self: 'a, in trailer()
|
| H A D | chunk.rs | 196 _cx: &mut Context<'_>, in poll_partial()
270 _cx: &mut Context<'_>, in poll_data()
296 _cx: &mut Context<'_>, in poll_data()
735 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()
993 chunk: Chunk<'a>, in match_decode_result()
1072 let _ = trailer_headers.insert::<HeaderName, HeaderValue>( in get_trailer() localVariable
1152 ) -> Chunk<'a> { in sized_chunk()
1166 ) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in decode_special_char()
1304 ) -> Result<(Chunk<'a>, &'a [u8]), HttpError> { in decode_trailer_data()
[all …]
|
| H A D | text.rs | 197 _cx: &mut Context<'_>, in poll_data()
217 cx: &mut Context<'_>, in poll_data()
346 pub fn decode<'a>(&mut self, buf: &'a [u8]) -> (Text<'a>, &'a [u8]) { in decode()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A 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()
268 mut part_encoder: MimePartEncoder<'a>, in sync_mimepart_encode()
313 cx: &mut Context<'_>, in poll_data()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | blocking_pool.rs | 96 let _ = handle.1.join(); in shutdown() localVariable
261 fn wait_permanent(&'a self, mut shared: MutexGuard<'a, Shared>) -> (bool, MutexGuard<Shared>) { in wait_permanent()
276 mut shared: MutexGuard<'a, Shared>, in wait_temporary()
310 mut shared: MutexGuard<'a, Shared>, in wait()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
| H A D | join_set.rs | 280 pub fn build_task(&mut self) -> Builder<'_, R> { in build_task()
325 let _ = entry.in_done.replace(false); in poll_join_next() localVariable
352 pub(crate) fn new(set: &'a mut JoinSet<R>) -> Builder<'a, R> { in new()
|
| /ohos5.0/foundation/multimedia/camera_framework/frameworks/js/camera_napi/demo/hvigor/ |
| H A D | hvigor-wrapper.js | 16 …_process"),r=require("crypto"),n="undefined"!=typeof globalThis?globalThis:"undefined"!=typeof win… variable
|
| /ohos5.0/foundation/arkui/advanced_ui_component/interface/treeview/ |
| H A D | treeview.js | 17 …var s, a = arguments.length, d = a < 3 ? t : null === i ? i = Object.getOwnPropertyDescriptor(t, o… variable
87 class a { class
305 constructor(e, t, o, i, s, a) { argument
2208 let _ = f; variable
2326 function _(e) { class
2753 const a = (t, o) => { constant
|
| /ohos5.0/foundation/distributeddatamgr/pasteboard/services/dialog/PasteboardDialog/hvigor/ |
| H A D | hvigor-wrapper.js | 15 …"fs"),r=require("child_process"),u=require("process"),o=require("tty"),i=require("util"),s=require… variable
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/application/hvigor/ |
| H A D | hvigor-wrapper.js | 15 …"fs"),r=require("child_process"),u=require("process"),o=require("tty"),i=require("util"),s=require… variable
|
| /ohos5.0/base/useriam/face_auth/ui/Settings_FaceAuth/hvigor/ |
| H A D | hvigor-wrapper.js | 16 …"fs"),r=require("child_process"),u=require("process"),o=require("tty"),i=require("util"),s=require… variable
|