| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| D | bounded.rs | 113 pub fn bounded_channel<T>(number: usize) -> (BoundedSender<T>, BoundedReceiver<T>) { in bounded_channel()
120 fn new(channel: Tx<Array<T>>) -> BoundedSender<T> { in new()
150 pub fn try_send(&self, value: T) -> Result<(), TrySendError<T>> { in try_send()
179 pub async fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
213 pub async fn send_timeout(&self, value: T, time: Duration) -> Result<(), SendTimeoutError<T>> { in send_timeout()
311 fn new(channel: Rx<Array<T>>) -> BoundedReceiver<T> { in new()
373 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv()
399 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv()
430 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout()
|
| D | unbounded.rs | 94 pub fn unbounded_channel<T>() -> (UnboundedSender<T>, UnboundedReceiver<T>) { in unbounded_channel() argument
101 fn new(channel: Tx<Queue<T>>) -> UnboundedSender<T> { in new()
118 pub fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
193 fn new(channel: Rx<Queue<T>>) -> UnboundedReceiver<T> { in new()
255 pub fn try_recv(&mut self) -> Result<T, TryRecvError> { in try_recv()
280 pub async fn recv(&mut self) -> Result<T, RecvError> { in recv()
310 pub async fn recv_timeout(&mut self, time: Duration) -> Result<T, RecvTimeoutError> { in recv_timeout()
|
| D | array.rs | 59 pub(crate) fn new(capacity: usize) -> Array<T> { in new()
109 pub(crate) fn write(&self, index: usize, value: T) { in write()
122 pub(crate) fn try_send(&self, value: T) -> Result<(), TrySendError<T>> { in try_send()
133 pub(crate) async fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
145 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv()
170 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv()
186 pub(crate) async fn recv(&self) -> Result<T, RecvError> { in recv()
|
| D | queue.rs | 57 fn try_insert(&self, ptr: *mut Block<T>) -> Result<(), *mut Block<T>> { in try_insert()
67 fn insert(&self, ptr: *mut Block<T>) { in insert()
124 pub(crate) fn send(&self, value: T) -> Result<(), SendError<T>> { in send()
172 pub(crate) fn try_recv(&self) -> Result<T, TryRecvError> { in try_recv()
203 fn poll_recv(&self, cx: &mut Context<'_>) -> Poll<Result<T, RecvError>> { in poll_recv()
219 pub(crate) async fn recv(&self) -> Result<T, RecvError> { in recv()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/request/ |
| D | mod.rs | 101 pub fn get<T>(uri: T) -> RequestBuilder in get()
119 pub fn head<T>(uri: T) -> RequestBuilder in head()
137 pub fn post<T>(uri: T) -> RequestBuilder in post()
154 pub fn put<T>(uri: T) -> RequestBuilder in put()
172 pub fn delete<T>(uri: T) -> RequestBuilder in delete()
190 pub fn connect<T>(uri: T) -> RequestBuilder in connect()
208 pub fn options<T>(uri: T) -> RequestBuilder in options()
226 pub fn trace<T>(uri: T) -> RequestBuilder in trace()
402 pub fn body(&self) -> &T { in body()
416 pub fn body_mut(&mut self) -> &mut T { in body_mut()
[all …]
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/iter/parallel/ |
| 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()
|
| 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()
|
| D | slice.rs | 16 impl<T> ParSplit for &[T] { implementation
31 impl<'a, T> ParSplit for &'a mut [T] { implementation
|
| D | mod.rs | 59 impl<T: ParSplit> IntoParIter for T { implementation
75 impl<'a, T: 'a> AsParIter<'a> for T implementation
94 impl<'a, T: 'a> AsParIterMut<'a> for T implementation
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/c_openssl/ |
| 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()
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/sync/ |
| 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()
|
| D | mutex.rs | 67 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()
|
| D | rwlock.rs | 79 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_runtime/ylong_runtime/src/ |
| D | spawn.rs | 21 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()
|
| 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()
|
| D | lib.rs | 73 pub fn spawn<T, R>(task: T) -> JoinHandle<R> in spawn()
83 pub fn spawn_blocking<T, R>(task: T) -> JoinHandle<R> in spawn_blocking()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| D | adapter.rs | 87 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/task/ |
| D | raw.rs | 150 fn new(task: T, scheduler: Weak<S>) -> Self { in new()
241 unsafe fn run<T, S>(ptr: NonNull<Header>) -> bool in run()
251 unsafe fn schedule<T, S>(ptr: NonNull<Header>, flag: bool) in schedule()
264 unsafe fn get_result<T, S>(ptr: NonNull<Header>, res: *mut ()) in get_result()
274 unsafe fn drop_ref<T, S>(ptr: NonNull<Header>) in drop_ref()
283 unsafe fn set_waker<T, S>(ptr: NonNull<Header>, cur_state: usize, waker: *const ()) -> bool in set_waker()
293 unsafe fn drop_join_handle<T, S>(ptr: NonNull<Header>) in drop_join_handle()
303 unsafe fn release<T, S>(ptr: NonNull<Header>) in release()
312 unsafe fn cancel<T, S>(ptr: NonNull<Header>) in cancel()
321 fn create_vtable<T, S>() -> &'static TaskVirtualTable in create_vtable()
[all …]
|
| D | mod.rs | 89 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()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| D | mod.rs | 190 pub fn spawn<T, R>(&self, task: T) -> JoinHandle<R> in spawn()
199 pub(crate) fn spawn_with_attr<T, R>(&self, task: T, builder: &TaskBuilder) -> JoinHandle<R> in spawn_with_attr()
236 pub fn spawn_blocking<T, R>(&self, task: T) -> JoinHandle<R> in spawn_blocking()
273 pub fn block_on<T, R>(&self, task: T) -> R in block_on()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/ |
| D | slots.rs | 33 fn new(val: T, prev: usize, next: usize) -> Entry<T> { in new()
195 pub fn pop_front(&mut self) -> Option<T> { in pop_front()
232 pub fn remove(&mut self, key: usize) -> Result<T, SlotsError> { in remove()
283 pub fn get(&self, key: usize) -> Option<&T> { in get()
308 pub fn get_mut(&mut self, key: usize) -> Option<&mut T> { in get_mut()
356 pub fn iter(&self) -> SlotsIter<T> { in iter()
390 pub fn with_capacity(capacity: usize) -> Slots<T> { in with_capacity()
467 fn next(&mut self) -> Option<(usize, &'a T)> { in next()
|
| D | slab.rs | 93 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_runtime/src/io/ |
| D | seek_task.rs | 30 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/ |
| D | mod.rs | 60 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/time/ |
| D | timeout.rs | 61 fn new(value: T, sleep: Sleep) -> Timeout<T> { in new()
|