Home
last modified time | relevance | path

Searched refs:AtomicBool (Results 1 – 19 of 19) sorted by relevance

/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/
H A Dregistry.rs18 use std::sync::atomic::AtomicBool;
30 notify: AtomicBool,
32 is_registered: AtomicBool,
40 notify: AtomicBool::new(false), in default()
42 is_registered: AtomicBool::new(false), in default()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/
H A Ddispatcher.rs65 use std::sync::atomic::{AtomicBool, Ordering};
87 pub(crate) occupied: AtomicBool,
89 pub(crate) shutdown: AtomicBool,
99 occupied: AtomicBool::new(false), in new()
100 shutdown: AtomicBool::new(false), in new()
154 use std::sync::atomic::{AtomicBool, AtomicU32, Ordering};
214 pub(crate) io_shutdown: Arc<AtomicBool>,
226 pub(crate) io_shutdown: Arc<AtomicBool>,
233 pub(crate) io_shutdown: Arc<AtomicBool>,
292 let shutdown_flag = Arc::new(AtomicBool::new(false)); in new()
[all …]
/ohos5.0/base/request/request/services/src/task/
H A Dupload.rs17 use std::sync::atomic::{AtomicBool, Ordering};
143 abort_flag: Arc<AtomicBool>, in build_stream_request() argument
178 abort_flag: Arc<AtomicBool>, in build_multipart_request() argument
305 abort_flag: Arc<AtomicBool>, in upload_inner() argument
358 abort_flag: Arc<AtomicBool>, in upload_one_file() argument
362 F: Fn(Arc<RequestTask>, usize, Arc<AtomicBool>) -> Option<Request>, in upload_one_file()
445 use std::sync::atomic::AtomicBool;
579 upload(task.clone(), Arc::new(AtomicBool::new(false))).await; in ut_upload_basic()
600 upload(task.clone(), Arc::new(AtomicBool::new(false))).await; in ut_upload_begins()
620 upload(task.clone(), Arc::new(AtomicBool::new(false))).await; in ut_upload_ends()
[all …]
H A Doperator.rs16 use std::sync::atomic::{AtomicBool, Ordering};
40 pub(crate) abort_flag: Arc<AtomicBool>,
44 pub(crate) fn new(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) -> Self { in new()
H A Ddownload.rs16 use std::sync::atomic::{AtomicBool, Ordering};
60 abort_flag: Arc<AtomicBool>, in build_downloader() argument
72 pub(crate) async fn download(task: Arc<RequestTask>, abort_flag: Arc<AtomicBool>) { in download() argument
114 abort_flag: Arc<AtomicBool>, in download_inner() argument
H A Drequest_task.rs15 use std::sync::atomic::{AtomicBool, AtomicI64, AtomicU32, AtomicU64, Ordering};
64 pub(crate) upload_resume: AtomicBool,
184 upload_resume: AtomicBool::new(upload_resume), in new()
246 upload_resume: AtomicBool::new(upload_resume), in new_by_info()
/ohos5.0/base/request/request/services/src/manage/scheduler/queue/
H A Dmod.rs17 use std::sync::atomic::{AtomicBool, Ordering};
90 let abort_flag = Arc::new(AtomicBool::new(false)); in try_restart()
218 let abort_flag = Arc::new(AtomicBool::new(false)); in reschedule_inner()
249 abort_flag: Arc<AtomicBool>,
254 fn new(abort_flag: Arc<AtomicBool>, join_handle: JoinHandle<()>) -> Self { in new() argument
H A Drunning_task.rs15 use std::sync::atomic::AtomicBool;
44 pub(crate) async fn run(self, abort_flag: Arc<AtomicBool>) { in run() argument
/ohos5.0/base/request/request/services/src/
H A Dability.rs16 use std::sync::atomic::{AtomicBool, Ordering};
55 remote_busy: Arc<AtomicBool>,
62 remote_busy: Arc::new(AtomicBool::new(false)), in new()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/
H A Dmutex.rs187 use std::sync::atomic::{AtomicBool, Ordering};
251 let flag = Arc::new(AtomicBool::new(true)); in ut_mutex_try_lock_02()
253 let lock_flag = Arc::new(AtomicBool::new(true)); in ut_mutex_try_lock_02()
/ohos5.0/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dscheduler.rs28 use std::sync::atomic::{ AtomicBool, Ordering };
122 is_running: Arc<AtomicBool>,
126 fn new(epoll: Arc<Epoll>, is_running: Arc<AtomicBool>) -> Self in new()
481 is_running: Arc<AtomicBool>,
490 let is_running = Arc::new(AtomicBool::new(true)); in new()
/ohos5.0/base/request/request/services/src/manage/
H A Daccount.rs14 use std::sync::atomic::{AtomicBool, AtomicI32, Ordering};
32 static UPDATE_FLAG: AtomicBool = AtomicBool::new(false);
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/time/
H A Dwheel.rs18 use std::sync::atomic::AtomicBool;
47 result: AtomicBool,
64 result: AtomicBool::new(false), in new()
/ohos5.0/base/request/request/services/src/service/
H A Dstub.rs15 use std::sync::atomic::{AtomicBool, Ordering};
36 pub(crate) remote_busy: Arc<AtomicBool>,
45 remote_busy: Arc<AtomicBool>, in new() argument
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_io/src/sys/windows/
H A Dselector.rs22 use std::sync::atomic::{AtomicBool, Ordering};
84 polling: AtomicBool,
98 polling: AtomicBool::new(false), in new()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/sync/mpsc/unbounded/
H A Dqueue.rs19 use std::sync::atomic::{AtomicBool, AtomicPtr, AtomicUsize};
35 has_value: AtomicBool,
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/util/
H A Dslab.rs57 use std::sync::atomic::{AtomicBool, AtomicUsize};
290 pub allocated: AtomicBool,
381 allocated: AtomicBool::new(false), in default()
/ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/executor/
H A Dasync_pool.rs16 use std::sync::atomic::AtomicBool;
42 is_cancel: AtomicBool,
75 is_cancel: AtomicBool::new(false), in new()
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/conn/
H A Dhttp2.rs446 use std::sync::atomic::AtomicBool; in ut_http2_body_poll_read()
458 let shutdown = Arc::new(AtomicBool::new(false)); in ut_http2_body_poll_read()