Home
last modified time | relevance | path

Searched +defs:a +defs:T (Results 1 – 25 of 27) sorted by relevance

12

/ohos5.0/foundation/communication/ipc/interfaces/innerkits/rust/src/ipc_async/
H A Dmod.rs37 fn spawn<'a, F1, F2, Fut, A, B>( in spawn()
40 ) -> BoxFuture<'a, IpcResult<B>> in spawn()
46 F2: Send + 'a, in spawn()
47 Fut: Send + 'a, in spawn()
49 B: Send + 'a; in spawn()
55 fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
62 fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
H A Dipc_ylong.rs26 fn spawn<'a, F1, F2, Fut, A, B>(spawn_this: F1, after_handle: F2) -> BoxFuture<'a, IpcResult<B>> in spawn()
32 F2: Send + 'a, in spawn()
33 Fut: Send + 'a, in spawn()
35 B: Send + 'a, in spawn()
67 fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
76 fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dseek_task.rs30 pub(crate) fn new(seek: &'a mut T, pos: io::SeekFrom) -> SeekTask<'a, T> { in new() argument
H A Dasync_read.rs60 impl<T: AsyncRead + Unpin + ?Sized> AsyncRead for &mut T { implementation
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()
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()
H A Dasync_write.rs143 impl<T: AsyncWrite + Unpin + ?Sized> AsyncWrite for &mut T { implementation
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()
H A Dasync_buf_read.rs62 impl<T: AsyncBufRead + Unpin + ?Sized> AsyncBufRead for &mut T { implementation
106 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()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Drwlock.rs79 pub fn new(t: T) -> RwLock<T> { in new()
114 pub async fn read(&self) -> RwLockReadGuard<'_, T> { in read() argument
169 pub async fn write(&self) -> RwLockWriteGuard<'_, T> { in write() argument
244 pub fn get_mut(&mut self) -> &mut T { in get_mut()
277 fn deref(&self) -> &T { in deref()
330 fn deref_mut(&mut self) -> &mut T { in deref_mut()
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
[all …]
H A Dwatch.rs52 pub fn channel<T>(value: T) -> (Sender<T>, Receiver<T>) { in channel()
108 pub fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
141 pub fn subscribe(&self) -> Receiver<T> { in subscribe()
214 fn new(value: RwLockReadGuard<'a, T>, is_notified: bool) -> ValueRef<'a, T> { in new() argument
435 pub fn borrow(&self) -> ValueRef<'_, T> { in borrow() argument
473 pub fn borrow_notify(&mut self) -> ValueRef<'_, T> { in borrow_notify() argument
544 fn new(value: T) -> Channel<T> { in new()
/ohos5.0/foundation/multimedia/media_foundation/engine/pipeline/core/
H A Dcompatible_check.cpp56 [](T a, T b) { in FixInvalDiscCapValCheck()
65 return CapabilityValueCheck<T>(key, {val1, val2}, ALLOW_FIXED | ALLOW_DISCRETE, [](T a, T b) { in FixDiscCapValCheck()
122 …return std::equal(s1.begin(), s1.end(), s2.begin(), [](char a, char b) { return tolower(a) == tolo… in StringEqIgnoreCase()
161 T Max(T val1, T val2, std::function<int(T, T)> compareFunc) in Max()
170 T Min(T val1, T val2, std::function<int(T, T)> compareFunc) in Min()
180 std::function<int(T,T)>& cmpFunc, Plugin::ValueType& outValue) in FFCapabilityCheck()
191 const std::function<int(T,T)>& cmpFunc, Plugin::ValueType& outValue) in FICapabilityCheck()
204 const std::function<int(T,T)>& cmpFunc, Plugin::ValueType& outValue) in FDCapabilityCheck()
215 const std::function<int(T,T)>& cmpFunc, Plugin::ValueType& outValue) in IICapabilityCheck()
236 const std::function<int(T,T)>& cmpFunc, Plugin::ValueType& outValue) in IDCapabilityCheck()
[all …]
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dtimer.rs111 pub async fn periodic_schedule<T>(mut closure: T, repeat_time: Option<usize>, period: Duration) in periodic_schedule()
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
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/
H A Doperator.rs65 fn progress<'a>(&'a mut self, uploaded: u64, total: Option<u64>) -> ProgressFuture<'a, Self> in progress()
67 Self: Unpin + Sized + 'a, in progress()
77 impl<T> UploadOperator for &mut T implementation
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/uploader/
H A 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()
75 impl<T> UploadOperator for &mut T implementation
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Doperator.rs82 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()
105 impl<T> DownloadOperator for &mut T implementation
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/downloader/
H A 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()
76 impl<T> DownloadOperator for &mut T implementation
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/body/
H A Dmod.rs164 impl<T: Read> Body for T { implementation
290 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()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dblocking_pool.rs194 pub(crate) fn spawn_blocking<T, R>(&self, builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
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_json/src/
H A Ddeserializer.rs104 pub fn from_reader<R, T>(reader: R) -> Result<T, Error> in from_reader() argument
138 pub fn from_slice<'a, T>(slice: &'a [u8]) -> Result<T, Error> in from_slice() argument
140 T: Deserialize<'a>, in from_slice()
173 pub fn from_str<'a, T>(str: &'a str) -> Result<T, Error> in from_str() argument
175 T: Deserialize<'a>, in from_str()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
H A Djoin_set.rs164 fn spawn_inner<T>(&mut self, task: T, builder: Option<&TaskBuilder>) -> CancelHandle in spawn_inner()
352 pub(crate) fn new(set: &'a mut JoinSet<R>) -> Builder<'a, R> { in new()
/ohos5.0/foundation/multimedia/audio_framework/services/audio_policy/server/src/service/effect/
H A Daudio_effect_manager.cpp106 for (auto &a: device) { in UpdateUnsupportedDevicePost() local
557 void AddKeyValueIntoMap(std::unordered_map<T, std::string> &map, std::string &key, std::string &val… in AddKeyValueIntoMap()
/ohos5.0/foundation/multimedia/camera_framework/frameworks/js/camera_napi/demo/hvigor/
H A Dhvigor-wrapper.js16 …This?globalThis:"undefined"!=typeof window?window:"undefined"!=typeof global?global:"undefined"!=t… variable
/ohos5.0/base/security/device_auth/frameworks/deviceauth_lite/test/unittest/unittest_mock/
H A Dhuks_adapter_mock.c45 #define CREATE_STRUCT(T) \ argument
56 #define CONVERT_TO_BLOB(T, field_name) \ argument
220 static int32_t Compare(const uint8_t *a, uint32_t lenA, const uint8_t *b, uint32_t lenB) in Compare()
H A Dhuks_adapter_mock_for_pake.c45 #define CREATE_STRUCT(T) \ argument
56 #define CONVERT_TO_BLOB(T, field_name) \ argument
220 static int32_t Compare(const uint8_t *a, uint32_t lenA, const uint8_t *b, uint32_t lenB) in Compare()
/ohos5.0/foundation/arkui/advanced_ui_component/interface/treeview/
H A Dtreeview.js17 …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
2228 let T = [...this.listNode]; variable
2334 class T extends ViewPU { class
2753 const a = (t, o) => { constant
/ohos5.0/base/security/device_auth/frameworks/deviceauth_lite/source/huks_adapter/
H A Dhuks_adapter.c45 #define CREATE_STRUCT(T) \ argument
56 #define CONVERT_TO_BLOB(T, field_name) \ argument
240 static int32_t Compare(const uint8_t *a, uint32_t lenA, const uint8_t *b, uint32_t lenB) in Compare()
/ohos5.0/foundation/distributeddatamgr/pasteboard/services/dialog/PasteboardDialog/hvigor/
H A Dhvigor-wrapper.js15 …("constants"),a=require("stream"),l=require("assert"),f=require("zlib"),d=require("net"),D=require… variable

12