| /commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_rwlock.rs | 56 let lock = lock.clone(); in tokio_rwlock_read()
57 handlers.push(rt.spawn(tokio_rwlock_task(lock.clone()))); in tokio_rwlock_read()
81 let lock = lock.clone(); in ylong_rwlock_read()
82 handlers.push(ylong_runtime::spawn(ylong_rwlock_task(lock.clone()))); in ylong_rwlock_read()
105 let lock = lock.clone(); in tokio_rwlock_write()
106 handlers.push(rt.spawn(tokio_rwlock_write_task(lock.clone()))); in tokio_rwlock_write()
130 let lock = lock.clone(); in ylong_rwlock_write()
131 handlers.push(ylong_runtime::spawn(ylong_rwlock_write_task(lock.clone()))); in ylong_rwlock_write()
153 let _lock_in = lock.clone(); in tokio_rwlock_write_read()
157 let lock_in = lock.clone(); in tokio_rwlock_write_read()
[all...] |
| H A D | ylong_tokio_multi_threaded.rs | 61 $fn(&runtime, send.clone());
98 let runtime_clone = runtime.clone(); in chained_spawn()
106 let runtime_clone = runtime.clone(); in chained_spawn()
108 let sender = send.clone(); in chained_spawn()
110 let runtime_iter_clone = runtime_clone.clone(); in chained_spawn()
150 let sender = send.clone(); in chained_spawn()
|
| H A D | ylong_tokio_uds.rs | 40 let mut uds = tokioUnixStream::connect(addr.clone()).await;
42 uds = tokioUnixStream::connect(addr.clone()).await;
62 handlers.push(runtime.spawn($server(addr.clone())));
63 handlers.push(runtime.spawn($client(addr.clone())));
94 let mut uds = UnixStream::connect(addr.clone()).await;
96 uds = UnixStream::connect(addr.clone()).await;
116 handlers.push(ylong_runtime::spawn($server(addr.clone())));
117 handlers.push(ylong_runtime::spawn($client(addr.clone())));
|
| H A D | ylong_tokio_udp.rs | 140 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_recv()
141 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_recv()
223 let sender = tokioUdpSocket::bind(sender_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from()
224 let receiver = tokioUdpSocket::bind(receiver_addr.clone()).await.unwrap(); in tokio_udp_send_to_recv_from()
228 .send_to(b"Hello", receiver_addr.clone()) in tokio_udp_send_to_recv_from()
236 assert_eq!(addr.to_string(), sender_addr.clone()); in tokio_udp_send_to_recv_from()
|
| H A D | ylong_tokio_tcp.rs | 39 let mut tcp = tokioTcpStream::connect(addr.clone()).await;
41 tcp = tokioTcpStream::connect(addr.clone()).await;
63 handlers.push(runtime.spawn($server(addr.clone())));
64 handlers.push(runtime.spawn($client(addr.clone())));
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/ |
| H A D | pool.rs | 64 uri.scheme().unwrap().clone(),
65 uri.authority().unwrap().clone(),
74 self.config.clone(),
75 self.connector.clone(),
114 fn clone(&self) -> Self { in clone() functions
116 list: self.list.clone(), in clone()
119 h2_conn: self.h2_conn.clone(), in clone()
122 h3_conn: self.h3_conn.clone(), in clone()
303 Some(ref host) => host.clone(),
306 let port = alt_svc.port.clone();
[all...] |
| /commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/ |
| H A D | pool.rs | 41 uri.scheme().unwrap().clone(),
42 uri.authority().unwrap().clone(),
47 .conn(|| self.connector.clone().connect(&uri))
64 fn clone(&self) -> Self { in clone() functions
66 list: self.list.clone(), in clone()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/ |
| H A D | current_thread.rs | 209 RawWakerVTable::new(clone, wake, wake_by_ref, drop);
211 fn clone(ptr: *const ()) -> RawWaker { in clone() functions
215 mem::forget(parker.clone()); in clone()
247 Parker::new(self.driver.clone(), self.handle.clone()) in get_parker()
276 parker_list.push(parker.clone());
279 let waker = waker(parker.clone());
426 let finished_clone = finished.clone(); in ut_current_thread_run_queue()
428 let notify1_clone = notify1.clone(); in ut_current_thread_run_queue()
434 let finished_clone = finished.clone(); in ut_current_thread_run_queue()
[all...] |
| H A D | async_pool.rs | 103 item.unpark(self.handle.clone()); in wake_up_all()
137 .unpark(self.handle.clone());
164 inner: local_run_queue.inner.clone(),
393 if let Some(f) = inner.after_start.clone() { in async_thread_proc()
398 let (lock, cvar) = &*(inner.shutdown_handle.clone()); in async_thread_proc()
407 if let Some(f) = inner.before_stop.clone() { in async_thread_proc()
422 after_start: builder.common.after_start.clone(),
423 before_stop: builder.common.before_stop.clone(),
424 worker_name: builder.common.worker_name.clone(),
440 Box::new(worker::Inner::new(local_queue, Parker::new(driver.clone()))); in create_async_thread_pool()
[all...] |
| H A D | block_on.rs | 21 RawWakerVTable::new(clone, wake, wake_by_ref, drop);
23 fn clone(ptr: *const ()) -> RawWaker { in clone() functions
27 mem::forget(thread.clone()); in clone()
66 let data = Arc::into_raw(self.inner.clone()).cast::<()>();
|
| H A D | blocking_pool.rs | 67 after_start: builder.after_start.clone(), in new()
68 before_stop: builder.before_stop.clone(), in new()
179 let inner = self.inner.clone(); in create_permanent_threads()
239 let inner = self.inner.clone(); in spawn()
463 let spawner_inner_clone = blocking_pool.inner.clone(); in ut_blocking_pool_shutdown()
472 let spawner_inner_clone = blocking_pool.inner.clone(); in ut_blocking_pool_shutdown()
484 /// 1. self.inner.is_permanent == true, self.inner.worker_name.clone() !=
486 /// 2. self.inner.is_permanent == true, self.inner.worker_name.clone() ==
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/ |
| H A D | pool.rs | 42 Entry::Occupied(conns) => conns.get().clone(),
43 Entry::Vacant(e) => e.insert(create_fn()).clone(),
73 uri.scheme().unwrap().clone(), in ut_pool_get()
74 uri.authority().unwrap().clone(), in ut_pool_get()
|
| H A D | request.rs | 54 fn clone(&self) -> Self { in clone() functions
56 cell: self.cell.clone(), in clone()
|
| H A D | alt_svc.rs | 49 Some(vec.clone())
91 src_host: src_host.clone(), in parse_alt_svc()
110 let key = PoolKey::new(scheme.clone(), authority.clone());
|
| H A D | dispatcher.rs | 143 inner: self.inner.clone(), in dispatch()
314 let controller = StreamController::new(streams, shutdown_flag.clone());
354 let send_settings_sync = settings_sync.clone(); in launch()
366 let recv_settings_sync = settings_sync.clone(); in launch()
387 let sender = self.sender.clone(); in dispatch()
388 let handle = Http2Conn::new(self.allowed_cache, self.io_shutdown.clone(), sender); in dispatch()
483 let sender = sender.clone();
750 conn.clone(),
758 io_shutdown.clone(),
759 io_goaway.clone(),
[all...] |
| H A D | normalizer.rs | 67 Some(host) => host.clone(),
78 scheme = req_scheme.clone()
99 new_uri = new_uri.path(path.clone());
104 new_uri = new_uri.query(query.clone());
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | semaphore_test.rs | 30 let sem2 = sem.clone(); in sdv_auto_release_sem_acquire_test()
82 let sem2 = sem.clone(); in sdv_auto_release_sem_close_test()
107 let sem2 = sem.clone(); in sdv_auto_release_sem_stress_test()
142 let sem2 = sem.clone(); in sdv_async_stress_test()
186 let sem2 = sem.clone(); in sdv_acquire_test()
|
| /commonlibrary/rust/ylong_http/ylong_http/src/body/mime/encode/ |
| H A D | multi.rs | 137 .push_back(MultiStage::Boundary(boundary.clone()));
157 self.push_end_boundary(boundary.clone());
159 self.push_middle_boundary(boundary.clone());
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime_macros/src/ |
| H A D | lib.rs | 47 group_inner.extend(tuple_parser.except.clone()); in tuple_form()
50 group_inner.extend(tuple_parser.default.clone()); in tuple_form()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/ |
| H A D | sleep.rs | 145 let waker = Box::new(cx.waker().clone());
244 this.inner.timer.set_waker(cx.waker().clone());
295 let val_cpy = val.clone(); in ut_new_timer_sleep()
304 let val_cpy2 = val.clone(); in ut_new_timer_sleep()
305 let val_cpy3 = val.clone(); in ut_new_timer_sleep()
306 let val_cpy4 = val.clone(); in ut_new_timer_sleep()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/ |
| H A D | mod.rs | 51 (Tx::new(channel.clone()), Rx::new(channel))
59 fn clone(&self) -> Self { in clone() functions
62 inner: self.inner.clone(), in clone()
|
| /commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/ |
| H A D | mutex.rs | 250 let mutex1 = mutex.clone(); in ut_mutex_try_lock_02()
252 let flag_clone = flag.clone(); in ut_mutex_try_lock_02()
254 let lock_flag_clone = lock_flag.clone(); in ut_mutex_try_lock_02()
|
| H A D | watch.rs | 55 channel: channel.clone(), in channel()
145 channel: self.channel.clone(), in subscribe()
161 /// let rx3 = rx.clone();
363 self.channel.waker_list.insert(cx.waker().clone());
489 /// let rx2 = rx.clone();
498 fn clone(&self) -> Self { in clone() functions
501 channel: self.channel.clone(), in clone()
658 let rx3 = rx.clone(); in receiver_count()
|
| /commonlibrary/rust/ylong_http/ylong_http_client/src/util/config/ |
| H A D | settings.rs | 500 assert_eq!(redirect.clone(), redirect_10) in ut_redirect_clone()
503 /// UT test cases for `Retry::clone`.
507 /// 2. Creates another `Retry` by `Redirect::clone`.
512 assert_eq!(retry.clone(), retry) in ut_retry_clone()
537 /// UT test cases for `Timeout::clone`.
541 /// 2. Creates another `Timeout` by `Timeout::clone`.
546 assert_eq!(timeout.clone(), timeout) in ut_timeout_clone()
586 /// UT test cases for `Proxy::clone`.
590 /// 2. Creates another `Proxy` by `Timeout::clone`.
599 let proxy_clone = proxy.clone(); in ut_proxy_clone()
[all...] |
| /commonlibrary/rust/ylong_runtime/ylong_runtime/examples/ |
| H A D | ylong_runtime_signal.rs | 42 let num_clone = num.clone(); in run_multi_thread_signal()
61 let num_clone = num.clone(); in run_multi_thread_signal()
|