Home
last modified time | relevance | path

Searched defs:T (Results 1 – 25 of 73) 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()
440 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv()
471 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()
108 pub(crate) fn write(&self, index: usize, value: T) { in write()
121 pub(crate) fn try_send(&self, value: T) -> Result<(), TrySendError<T>> { in try_send()
132 pub(crate) async fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
144 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv()
169 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()
320 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv()
350 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()
123 pub(crate) fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
171 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv()
202 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.rs102 pub fn get<T>(uri: T) -> RequestBuilder in get()
120 pub fn head<T>(uri: T) -> RequestBuilder in head()
138 pub fn post<T>(uri: T) -> RequestBuilder in post()
155 pub fn put<T>(uri: T) -> RequestBuilder in put()
173 pub fn delete<T>(uri: T) -> RequestBuilder in delete()
191 pub fn connect<T>(uri: T) -> RequestBuilder in connect()
209 pub fn options<T>(uri: T) -> RequestBuilder in options()
227 pub fn trace<T>(uri: T) -> RequestBuilder in trace()
403 pub fn body(&self) -> &T { in body()
417 pub fn body_mut(&mut self) -> &mut T { in body_mut()
[all …]
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/task/
Dmod.rs89 pub(crate) fn create_task<T, S>( in create_task()
92 task: T, in create_task()
106 pub(crate) fn create_raw_task<T, S>( in create_raw_task()
109 task: T, in create_raw_task()
139 pub fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
149 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
Draw.rs142 fn new(task: T, scheduler: Weak<S>) -> Self { in new()
233 unsafe fn run<T, S>(ptr: NonNull<Header>) -> bool in run()
243 unsafe fn schedule<T, S>(ptr: NonNull<Header>, flag: bool) in schedule()
256 unsafe fn get_result<T, S>(ptr: NonNull<Header>, res: *mut ()) in get_result()
266 unsafe fn drop_ref<T, S>(ptr: NonNull<Header>) in drop_ref()
275 unsafe fn set_waker<T, S>(ptr: NonNull<Header>, cur_state: usize, waker: *const ()) -> bool in set_waker()
285 unsafe fn drop_join_handle<T, S>(ptr: NonNull<Header>) in drop_join_handle()
295 unsafe fn release<T, S>(ptr: NonNull<Header>) in release()
304 unsafe fn cancel<T, S>(ptr: NonNull<Header>) in cancel()
313 fn create_vtable<T, S>() -> &'static TaskVirtualTable in create_vtable()
[all …]
/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()
117 pub(crate) fn iter(&self) -> StackRefIter<T> { in iter()
178 fn into_iter(self) -> IntoStackIter<T> { in into_iter()
/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()
Dslice.rs16 impl<T> ParSplit for &[T] { implementation
31 impl<'a, T> ParSplit for &'a mut [T] { implementation
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()
/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()
145 pub fn subscribe(&self) -> Receiver<T> { in subscribe()
218 fn new(value: RwLockReadGuard<'a, T>, is_notified: bool) -> ValueRef<'a, T> { in new() argument
439 pub fn borrow(&self) -> ValueRef<'_, T> { in borrow() argument
481 pub fn borrow_notify(&mut self) -> ValueRef<'_, T> { in borrow_notify() argument
556 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()
95 pub async fn lock(&self) -> MutexGuard<'_, T> { in lock() argument
122 pub fn try_lock(&self) -> Result<MutexGuard<'_, T>, LockError> { in try_lock() argument
135 pub fn get_mut(&mut self) -> &mut T { in get_mut()
179 fn deref_mut(&mut self) -> &mut T { in deref_mut()
Drwlock.rs79 pub fn new(t: T) -> RwLock<T> { in new()
113 pub async fn read(&self) -> RwLockReadGuard<'_, T> { in read() argument
135 pub fn try_read(&self) -> Result<RwLockReadGuard<'_, T>, LockError> { in try_read() argument
175 pub async fn write(&self) -> RwLockWriteGuard<'_, T> { in write() argument
203 pub fn try_write(&self) -> Result<RwLockWriteGuard<'_, T>, LockError> { in try_write() argument
250 pub fn get_mut(&mut self) -> &mut T { in get_mut()
283 fn deref(&self) -> &T { in deref()
336 fn deref_mut(&mut self) -> &mut T { in deref_mut()
/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
Dadapter.rs87 Method: TryFrom<T>, in method()
97 Uri: TryFrom<T>, in url()
106 Version: TryFrom<T>, in version()
158 pub fn body<T>(self, body: T) -> Result<Request<T>, HttpClientError> { in body() method
171 pub fn multipart<T>(self, body: T) -> Result<Request<T>, HttpClientError> in multipart()
/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.rs21 pub(crate) fn spawn_blocking<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_blocking()
33 pub(crate) fn spawn_async<T, R>(builder: &TaskBuilder, task: T) -> JoinHandle<R> in spawn_async()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
Dmod.rs183 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()
192 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R> in spawn_with_attr()
229 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking()
266 pub fn block_on<T, R>(&self, task: T) -> R in block_on()
/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.rs60 pub fn body(&self) -> &T { in body()
65 pub fn body_mut(&mut self) -> &mut T { in body_mut()
70 pub fn into_parts(self) -> (ResponsePart, T) { in into_parts() argument
75 pub fn from_raw_parts(part: ResponsePart, body: T) -> Response<T> { in from_raw_parts()
/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
Dslots.rs33 fn new(val: T, prev: usize, next: usize) -> Entry<T> { in new()
130 pub fn pop_front(&mut self) -> Option<T> { in pop_front()
167 pub fn remove(&mut self, key: usize) -> Result<T, SlotsError> { in remove()
230 pub fn with_capacity(capacity: usize) -> Slots<T> { in with_capacity()
293 fn next(&mut self) -> Option<(usize, &'a T)> { in next()
313 fn get(&self, key: usize) -> Option<&T> { in get()
Dslab.rs93 fn deref(&self) -> &T { in deref()
168 pub fn handle(&self) -> Slab<T> { in handle()
184 pub unsafe fn allocate(&self) -> Option<(Address, Ref<T>)> { in allocate()
196 pub fn for_each(&mut self, mut f: impl FnMut(&T)) { in for_each()
212 pub fn get(&mut self, addr: Address) -> Option<&T> { in get()
314 fn release(&self, value: *const Value<T>) { in release()
328 unsafe fn allocate(me: &Arc<Page<T>>) -> Option<(Address, Ref<T>)> { in allocate()
439 fn gen_ref(&self, page: &Arc<Page<T>>) -> Ref<T> { in gen_ref()
456 unsafe fn release(&self) -> Arc<Page<T>> { in release()
/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/unix/uds/
Dsocket.rs79 fn pair<T: FromRawFd>(flag: libc::c_int) -> io::Result<(T, T)> { in pair() argument

123