Home
last modified time | relevance | path

Searched defs:T (Results 1 – 25 of 70) sorted by relevance

123

/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/bounded/
Dmod.rs117 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()
Darray.rs58 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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
Dmod.rs98 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()
Dqueue.rs56 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()
/commonlibrary/rust/ylong_json/src/
Dlinked_list.rs53 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
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()
170 pub(crate) fn back_mut(&mut self) -> Option<&mut T> { in back_mut()
[all …]
/commonlibrary/rust/ylong_http/ylong_http/src/request/
Dmod.rs107 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()
196 pub fn connect<T>(uri: T) -> RequestBuilder in connect()
214 pub fn options<T>(uri: T) -> RequestBuilder in options()
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()
[all …]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
Dmod.rs191 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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
Dmod.rs97 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()
Draw.rs198 fn new(task: T, scheduler: Weak<S>) -> Self { in new()
289 unsafe fn get_result<T, S>(ptr: NonNull<Header>, res: *mut ()) in get_result()
299 unsafe fn drop_ref<T, S>(ptr: NonNull<Header>) in drop_ref()
308 unsafe fn set_waker<T, S>(ptr: NonNull<Header>, cur_state: usize, waker: *const ()) -> bool in set_waker()
318 unsafe fn drop_join_handle<T, S>(ptr: NonNull<Header>) in drop_join_handle()
448 task: T, in new()
473 pub(crate) fn inner(&self) -> &Inner<T, S> { in inner()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/
Darray.rs18 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()
Dvec.rs39 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()
Dslice.rs16 impl<T> ParSplit for &[T] { implementation
31 impl<'a, T> ParSplit for &'a mut [T] { implementation
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
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()
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()
430 fn take_value_sent(&self) -> Result<T, RecvError> { in take_value_sent()
440 fn take_value(&self) -> Option<T> { in take_value()
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()
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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/
Dfutures.rs40 pub fn poll_fn<T, F>(f: F) -> PollFn<F> in poll_fn()
42 F: FnMut(&mut Context<'_>) -> Poll<T>, in poll_fn()
Dspawn.rs60 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()
/commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/
Dstack.rs45 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()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/io/
Dseek_task.rs30 pub(crate) fn new(seek: &'a mut T, pos: io::SeekFrom) -> SeekTask<'a, T> { in new() argument
/commonlibrary/rust/ylong_http/ylong_http/src/response/
Dmod.rs59 pub fn body(&self) -> &T { in body()
64 pub fn body_mut(&mut self) -> &mut T { in body_mut()
69 pub fn into_parts(self) -> (ResponsePart, T) { in into_parts() argument
74 pub fn from_raw_parts(part: ResponsePart, body: T) -> Response<T> { in from_raw_parts()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
Dslots.rs32 fn new(val: T, prev: usize, next: usize) -> Entry<T> { in new()
129 pub fn pop_front(&mut self) -> Option<T> { in pop_front()
166 pub fn remove(&mut self, key: usize) -> Result<T, SlotsError> { in remove()
226 pub fn with_capacity(capacity: usize) -> Slots<T> { in with_capacity()
289 fn next(&mut self) -> Option<(usize, &'a T)> { in next()
309 fn get(&self, key: usize) -> Option<&T> { in get()
Dslab.rs93 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()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
Dsocket.rs77 fn pair<T: FromRawFd>(socket_type: libc::c_int) -> io::Result<(T, T)> { in pair() argument
/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
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()

123