Home
last modified time | relevance | path

Searched +defs:_ +defs:T (Results 1 – 25 of 35) sorted by relevance

12

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
H A Dasync_seek.rs40 cx: &mut Context<'_>, in poll_seek()
51 cx: &mut Context<'_>, in poll_seek()
61 cx: &mut Context<'_>, in poll_seek()
68 impl<T: AsyncSeek + Unpin + ?Sized> AsyncSeek for &mut T { implementation
71 cx: &mut Context<'_>, in poll_seek()
78 impl<T: AsyncSeek + ?Sized> AsyncSeekExt for T {} implementation
138 fn rewind(&mut self) -> SeekTask<'_, Self> in rewind()
169 fn stream_position(&mut self) -> SeekTask<'_, Self> in stream_position()
H A Dasync_read.rs43 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()
60 impl<T: AsyncRead + Unpin + ?Sized> AsyncRead for &mut T { implementation
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()
212 _cx: &mut Context<'_>, in poll_read()
[all …]
H A Dasync_write.rs42 cx: &mut Context<'_>, in poll_write()
52 cx: &mut Context<'_>, in poll_write_vectored()
53 bufs: &[IoSlice<'_>], in poll_write_vectored()
143 impl<T: AsyncWrite + Unpin + ?Sized> AsyncWrite for &mut T { implementation
153 cx: &mut Context<'_>, in poll_write()
161 cx: &mut Context<'_>, in poll_write_vectored()
162 bufs: &[IoSlice<'_>], in poll_write_vectored()
274 fn flush(&mut self) -> FlushTask<'_, Self> in flush()
290 fn shutdown(&mut self) -> ShutdownTask<'_, Self> in shutdown()
/ohos5.0/commonlibrary/rust/ylong_json/src/
H A Dlinked_list.rs95 pub(crate) fn iter(&self) -> Iter<'_, T> { in iter() argument
106 pub(crate) fn iter_mut(&mut self) -> IterMut<'_, T> { in iter_mut() argument
117 pub(crate) fn cursor_front(&self) -> Cursor<'_, T> { in cursor_front() argument
127 pub(crate) fn cursor_front_mut(&mut self) -> CursorMut<'_, T> { in cursor_front_mut() argument
138 pub(crate) fn cursor_back(&self) -> Cursor<'_, T> { in cursor_back() argument
149 pub(crate) fn cursor_back_mut(&mut self) -> CursorMut<'_, T> { in cursor_back_mut() argument
160 pub(crate) fn back(&self) -> Option<&T> { in back()
270 let _ = self.pop_back(); in drop() localVariable
300 pub(crate) fn into_element(self) -> T { in into_element()
334 fn next(&mut self) -> Option<&'a T> { in next()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/io/
H A Dsplit.rs51 pub(crate) fn split<T>(stream: T) -> (Reader<T>, Writer<T>) in split()
73 cx: &mut Context<'_>, in poll_read()
74 buf: &mut ReadBuf<'_>, in poll_read()
84 cx: &mut Context<'_>, in poll_write()
93 cx: &mut Context<'_>, in poll_write_vectored()
94 bufs: &[IoSlice<'_>], in poll_write_vectored()
116 fn stream(&mut self) -> Pin<&mut T> { in stream()
124 fn get_lock(&self, cx: &mut Context<'_>) -> Poll<StreamGuard<T>> { in get_lock()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/request/
H A Dmod.rs107 pub fn get<T>(uri: T) -> RequestBuilder in get()
125 pub fn head<T>(uri: T) -> RequestBuilder in head()
160 pub fn put<T>(uri: T) -> RequestBuilder in put()
408 pub fn body(&self) -> &T { in body()
524 Method: TryFrom<T>, in method()
546 Uri: TryFrom<T>, in url()
567 Version: TryFrom<T>, in version()
726 let _ = new_headers.insert("accept", "text/html"); in ut_request_builder_build() localVariable
727 let _ = new_headers.append("accept", "application/xml"); in ut_request_builder_build() localVariable
766 let _ = request.headers_mut().insert("accept", "application/xml"); in ut_request_builder_build_2() localVariable
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/connector/
H A Dstream.rs44 cx: &mut Context<'_>, in poll_read()
45 buf: &mut ReadBuf<'_>, in poll_read()
58 cx: &mut Context<'_>, in poll_write()
85 pub fn new(io: T, detail: ConnDetail) -> HttpStream<T> { in new()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
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()
621 let _ = block_on(handle1); in send_notified_await() localVariable
H A Drwlock.rs79 pub fn new(t: T) -> RwLock<T> { in new()
114 pub async fn read(&self) -> RwLockReadGuard<'_, T> { in read() argument
136 pub fn try_read(&self) -> Result<RwLockReadGuard<'_, T>, LockError> { in try_read() argument
169 pub async fn write(&self) -> RwLockWriteGuard<'_, T> { in write() argument
197 pub fn try_write(&self) -> Result<RwLockWriteGuard<'_, T>, LockError> { in try_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()
H A Dmutex.rs67 pub fn new(t: T) -> Mutex<T> { in new()
96 pub async fn lock(&self) -> MutexGuard<'_, T> { in lock() argument
123 pub fn try_lock(&self) -> Result<MutexGuard<'_, T>, LockError> { in try_lock() argument
136 pub fn get_mut(&mut self) -> &mut T { in get_mut()
180 fn deref_mut(&mut self) -> &mut T { in deref_mut()
H A Doneshot.rs84 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()
376 let _ = self in close() localVariable
430 fn take_value_sent(&self) -> Result<T, RecvError> { in take_value_sent()
440 fn take_value(&self) -> Option<T> { in take_value()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ssl_stream/
H A Dc_ssl_stream.rs29 fn with_context<F, R>(self: Pin<&mut Self>, ctx: &mut Context<'_>, f: F) -> R in with_context()
95 ctx: &mut Context<'_>, in poll_read()
96 buf: &mut ReadBuf<'_>, in poll_read()
163 fn check_result_to_poll<T>(r: Result<T, ssl::SslError>) -> Poll<Result<T, ssl::SslError>> { in check_result_to_poll()
H A Dwrapper.rs34 unsafe fn inner(&mut self) -> (Pin<&mut S>, &mut Context<'_>) { in inner()
82 pub(crate) fn check_io_to_poll<T>(r: io::Result<T>) -> Poll<io::Result<T>> { in check_io_to_poll()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/uploader/
H A Doperator.rs57 _cx: &mut Context<'_>, in poll_progress()
77 impl<T> UploadOperator for &mut T implementation
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 Doperator.rs55 _cx: &mut Context<'_>, in poll_progress()
75 impl<T> UploadOperator for &mut T implementation
81 cx: &mut Context<'_>, in poll_progress()
114 _cx: &mut Context<'_>, in poll_progress()
/ohos5.0/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Doperator.rs65 cx: &mut Context<'_>, in poll_download()
74 _cx: &mut Context<'_>, in poll_progress()
105 impl<T> DownloadOperator for &mut T implementation
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 Doperator.rs29 cx: &mut Context<'_>, in poll_download()
39 _cx: &mut Context<'_>, in poll_progress()
76 impl<T> DownloadOperator for &mut T implementation
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/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dclient.rs108 mut request: Request<T>, in request()
116 mut request: Request<T>, in retry_send_request()
130 request: &mut Request<T>, in send_request_retryable()
139 request: &mut Request<T>, in redirect_request()
162 request: &mut Request<T>, in send_request_with_uri()
561 let _ = Client::default(); in ut_client_new() localVariable
562 let _ = Client::new(); in ut_client_new() localVariable
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/process/sys/unix/
H A Dchild.rs105 fn set_nonblock<T: AsRawFd>(fd: &mut T, block: bool) -> io::Result<()> { in set_nonblock()
142 cx: &mut Context<'_>, in poll_write()
150 cx: &mut Context<'_>, in poll_write_vectored()
151 bufs: &[IoSlice<'_>], in poll_write_vectored()
172 cx: &mut Context<'_>, in poll_read()
173 buf: &mut ReadBuf<'_>, in poll_read()
186 fn as_fd(&self) -> BorrowedFd<'_> { in as_fd()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http/src/
H A Dheaders.rs429 pub fn iter(&self) -> HeaderValueIter<'_> { in iter()
447 pub fn iter_mut(&mut self) -> HeaderValueIterMut<'_> { in iter_mut()
669 pub fn get<T>(&self, name: T) -> Option<&HeaderValue> in get()
696 pub fn get_mut<T>(&mut self, name: T) -> Option<&mut HeaderValue> in get_mut()
781 let _ = v.insert(value); in append() localVariable
805 pub fn remove<T>(&mut self, name: T) -> Option<HeaderValue> in remove()
829 pub fn iter(&self) -> HeadersIter<'_> { in iter()
848 pub fn iter_mut(&mut self) -> HeadersIterMut<'_> { in iter_mut()
1227 let _ = new_headers.append("ACCEPT", "text/html"); in ut_change_headers_info() localVariable
1248 let _ = new_headers.insert( in ut_change_headers_info() localVariable
/ohos5.0/base/request/request/services/src/utils/
H A Dmod.rs43 pub(crate) fn get(self) -> Option<T> { in get()
71 let _ = write!(res, "\r\n"); in hashmap_to_string() localVariable
73 let _ = write!(res, "{k}\t{v}"); in hashmap_to_string() localVariable
90 pub(crate) fn split_string(str: &mut str) -> std::str::Split<'_, &str> { in split_string() argument
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dasync_pool.rs477 let _ = set_current_affinity(cpu_id); in create_async_thread_pool() localVariable
548 task: T, in spawn_with_ref()
689 pub(crate) fn create_task<T, S>( in create_task()
692 task: T, in create_task()
771 let _ = thread::spawn(move || { in ut_executor_mng_info_cancel() localVariable
801 let _ = thread::spawn(move || { in ut_executor_mng_info_wake_up_all() localVariable
838 let _ = thread::spawn(move || { in ut_executor_mng_info_wake_up_rand_one() localVariable
874 let _ = thread::spawn(move || { in ut_executor_mng_info_wake_up_if_one_task_left() localVariable
928 let _ = thread::spawn(move || { in ut_executor_mng_info_from_woken_to_sleep() localVariable
986 let _ = AsyncPoolSpawner::new(&thread_pool_builder.is_affinity(false)).unwrap(); in ut_async_pool_spawner_create_async_thread_pool_001() localVariable
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp1.rs225 mut body: T, in encode_body()
283 cx: &mut Context<'_>, in poll_read()
284 buf: &mut ReadBuf<'_>, in poll_read()
/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()
262 let _ = block_on(handle); in ut_new_timer_schedule() localVariable
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslab.rs84 let _ = (*self.value).release(); in drop() localVariable
93 fn deref(&self) -> &T { in deref()
169 pub fn handle(&self) -> Slab<T> { in handle()
185 pub unsafe fn allocate(&self) -> Option<(Address, Ref<T>)> { in allocate()
197 pub fn for_each(&mut self, mut f: impl FnMut(&T)) { in for_each()
213 pub fn get(&mut self, addr: Address) -> Option<&T> { in get()
315 fn release(&self, value: *const Value<T>) { in release()
329 unsafe fn allocate(me: &Arc<Page<T>>) -> Option<(Address, Ref<T>)> { in allocate()
428 fn gen_ref(&self, page: &Arc<Page<T>>) -> Ref<T> { in gen_ref()
445 unsafe fn release(&self) -> Arc<Page<T>> { in release()

12