/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/ |
H A D | mod.rs | 117 pub fn bounded_channel<T>(number: usize) -> (BoundedSender<T>, BoundedReceiver<T>) { in bounded_channel() 124 fn new(channel: Tx<Array<T>>) -> BoundedSender<T> { in new() 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() 315 fn new(channel: Rx<Array<T>>) -> BoundedReceiver<T> { in new() 377 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() 412 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() 439 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() 470 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout()
|
H A D | array.rs | 58 pub(crate) fn new(capacity: usize) -> Array<T> { in new() 105 pub(crate) fn write(&self, index: usize, value: T) { in write() 119 pub(crate) fn try_send(&self, value: T) -> Result<(), TrySendError<T>> { in try_send() 130 pub(crate) async fn send(&self, value: T) -> Result<(), SendError<T>> { in send() 142 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() 168 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/ |
H A D | mod.rs | 98 pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>) { in unbounded_channel() argument 105 fn new(channel: Tx<Queue<T>>) -> UnboundedSender<T> { in new() 122 pub fn send(&self, value: T) -> Result<(), SendError<T>> { in send() 197 fn new(channel: Rx<Queue<T>>) -> UnboundedReceiver<T> { in new() 259 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() 293 pub fn poll_recv(&mut self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv() 319 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv() 349 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout()
|
H A D | queue.rs | 56 fn try_insert(&self, ptr: *mut Block<T>) -> Result<(), *mut Block<T>> { in try_insert() 66 fn insert(&self, ptr: *mut Block<T>) { in insert() 129 block: &Block<T>, in send_inner() 130 new_block: Option<Box<Block<T>>>, in send_inner() 131 value: T, in send_inner() 150 pub(crate) fn send(&self, value: T) -> Result<(), SendError<T>> { in send() 185 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv() 219 pub(crate) fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv()
|
/ohos5.0/commonlibrary/rust/ylong_json/src/ |
H A D | linked_list.rs | 53 pub(crate) fn push_back(&mut self, value: T) { in push_back() 73 pub(crate) fn pop_back(&mut self) -> Option<T> { in pop_back() 95 pub(crate) fn iter(&self) -> Iter<'_, T> { in iter() argument 160 pub(crate) fn back(&self) -> Option<&T> { in back() 300 pub(crate) fn into_element(self) -> T { in into_element() 334 fn next(&mut self) -> Option<&'a T> { in next() 352 fn last(mut self) -> Option<&'a T> { in last() 359 fn next_back(&mut self) -> Option<&'a T> { in next_back() 383 fn next(&mut self) -> Option<&'a mut T> { in next() 401 fn last(mut self) -> Option<&'a mut T> { in last() [all …]
|
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/c_adapter/ |
H A D | mod.rs | 119 pub(crate) fn new(inner: T, tar_type: SafetyCheckId) -> SafeCffiWrapper<T> { in new() 126 pub(crate) fn into_ptr(self) -> *mut SafeCffiWrapper<T> { in into_ptr() 131 src: *mut SafeCffiWrapper<T>, in from_ptr() 133 ) -> Option<SafeCffiWrapper<T>> { in from_ptr() 141 src: *const SafeCffiWrapper<T>, in get_inner_ref() 143 ) -> Option<&'static T> { in get_inner_ref() 154 src: *mut SafeCffiWrapper<T>, in get_inner_mut() 156 ) -> Option<&'static mut T> { in get_inner_mut() 166 pub(crate) unsafe fn get_inner(src: *mut SafeCffiWrapper<T>, typ: SafetyCheckId) -> Option<T> { in get_inner()
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/ |
H A D | mod.rs | 107 pub fn get<T>(uri: T) -> RequestBuilder in get() 125 pub fn head<T>(uri: T) -> RequestBuilder in head() 143 pub fn post<T>(uri: T) -> RequestBuilder in post() 160 pub fn put<T>(uri: T) -> RequestBuilder in put() 178 pub fn delete<T>(uri: T) -> RequestBuilder in delete() 232 pub fn trace<T>(uri: T) -> RequestBuilder in trace() 408 pub fn body(&self) -> &T { in body() 422 pub fn body_mut(&mut self) -> &mut T { in body_mut() 524 Method: TryFrom<T>, in method() 546 Uri: TryFrom<T>, in url() [all …]
|
/ohos5.0/foundation/ai/neural_network_runtime/frameworks/native/neural_network_runtime/ |
H A D | ops_registry.h | 49 #define CREATE_FUNC(T) ([]()->std::unique_ptr<OpsBuilder> {return std::make_unique<T>();}) argument 50 #define REGISTER_OPS(T, opsType) static OpsRegistry::Registrar g_##T(opsType, CREATE_FUNC(T)) argument
|
/ohos5.0/base/msdp/device_status/rust/ipc/server/src/ |
H A D | fusion_ipc_server.rs | 34 fn on_start<T: ISystemAbility + IMethod>(ability: &T) { in on_start() 54 fn on_stop<T: ISystemAbility + IMethod>(ability: &T) { in on_stop()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
H A D | array.rs | 18 fn into_par_iter(self) -> super::ParIter<&'a [T]> { in into_par_iter() 25 fn into_par_iter(self) -> ParIter<&'a mut [T]> { in into_par_iter()
|
H A D | slice.rs | 16 impl<T> ParSplit for &[T] { implementation 31 impl<'a, T> ParSplit for &'a mut [T] { implementation
|
H A D | vec.rs | 39 fn into_par_iter(self) -> ParIter<&'a [T]> { in into_par_iter() 46 fn into_par_iter(self) -> ParIter<&'a mut [T]> { in into_par_iter()
|
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/platform/eventhandler/ |
H A D | inner_event.h | 173 static inline Pointer Get(uint32_t innerEventId, int64_t param, std::unique_ptr<T, D> &&object) in Get() 189 static inline Pointer Get(uint32_t innerEventId, int64_t param, std::unique_ptr<T, D> &object) in Get() 455 static inline size_t CalculateSmartPtrTypeId(const T &) in CalculateSmartPtrTypeId() 467 static inline size_t CalculateSmartPtrTypeId(const std::shared_ptr<T> &) in CalculateSmartPtrTypeId() 473 static inline size_t CalculateSmartPtrTypeId(const std::weak_ptr<T> &) in CalculateSmartPtrTypeId() 479 static inline size_t CalculateSmartPtrTypeId(const std::unique_ptr<T, D> &) in CalculateSmartPtrTypeId() 485 static inline size_t CalculateSmartPtrTypeId(const std::unique_ptr<T[], D> &) in CalculateSmartPtrTypeId()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
H A D | mod.rs | 191 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn() 200 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R> in spawn_with_attr() 237 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking() 277 pub fn block_on<T, R>(&self, task: T) -> R in block_on() 285 fn block_on_inner<T, R>(&self, task: T) -> R in block_on_inner() 325 fn block_on_inner<T, R>(&self, task: T) -> R in block_on_inner()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/ |
H A D | mod.rs | 97 pub(crate) fn create_task<T, S>( in create_task() 100 task: T, in create_task() 114 pub(crate) fn create_raw_task<T, S>( in create_raw_task() 117 task: T, in create_raw_task() 141 pub fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn() 151 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/ |
H A D | futures.rs | 40 pub fn poll_fn<T, F>(f: F) -> PollFn<F> in poll_fn() 42 F: FnMut(&mut Context<'_>) -> Poll<T>, in poll_fn()
|
H A D | spawn.rs | 60 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking() 73 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_async()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
H A D | oneshot.rs | 84 pub fn channel<T>() -> (Sender<T>, Receiver<T>) { in channel() 165 pub fn send(self, value: T) -> Result<(), T> { in send() argument 326 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv() 430 fn take_value_sent(&self) -> Result<T, RecvError> { in take_value_sent() 440 fn take_value(&self) -> Option<T> { in take_value()
|
H A D | watch.rs | 52 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 D | compatible_check.cpp | 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() 257 const std::function<int(T,T)>& cmpFunc, Plugin::ValueType& outValue) in DDCapabilityCheck() 296 … uint8_t flags, std::function<int(T, T)> cmpFunc, Plugin::ValueType& outValue) in FixedNumericalCapabilityCheck() 313 …const Plugin::ValueType& value1, uint8_t flags, std::function<int(T, T)> cmpFunc, Plugin::ValueTyp… in IntervalNumericalCapabilityCheck() [all …]
|
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
H A D | stack.rs | 45 fn deref(&self) -> &StackRef<T> { in deref() 51 fn deref_mut(&mut self) -> &mut StackRef<T> { in deref_mut() 57 fn as_ref(&self) -> &StackRef<T> { in as_ref() 63 fn borrow(&self) -> &StackRef<T> { in borrow() 107 pub(crate) fn pop(&mut self) -> Option<T> { in pop() 171 fn into_iter(self) -> IntoStackIter<T> { in into_iter()
|
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/ |
H A D | seek_task.rs | 30 pub(crate) fn new(seek: &'a mut T, pos: io::SeekFrom) -> SeekTask<'a, T> { in new() argument
|
/ohos5.0/foundation/arkui/ace_engine/frameworks/bridge/declarative_frontend/engine/ |
H A D | js_ref_ptr.h | 37 JSRefPtrImpl(const JSRefPtrImpl<T, ImplDetail>& rhs) : object_(rhs.object_) {} in JSRefPtrImpl() 38 JSRefPtrImpl(JSRefPtrImpl<T, ImplDetail>&& rhs) : object_(std::move(rhs.object_)) {} in JSRefPtrImpl() function
|
/ohos5.0/base/hiviewdfx/hiview/base/utility/include/ |
H A D | string_util.h | 112 std::string ConvertToUTF8(const std::basic_string<T, std::char_traits<T>, std::allocator<T>> &sourc… in ConvertToUTF8()
|
/ohos5.0/base/telephony/core_service/frameworks/js/napi/ |
H A D | napi_parameter_util.h | 28 napi_valuetype GetInputArgvType(T *) in GetInputArgvType() argument 34 napi_valuetype GetInputArgvType(T *) in GetInputArgvType() argument 40 napi_valuetype GetInputArgvType(T *) in GetInputArgvType() argument 46 napi_valuetype GetInputArgvType(T *) in GetInputArgvType() argument 52 napi_valuetype GetInputArgvType(T *) in GetInputArgvType() argument
|