Home
last modified time | relevance | path

Searched refs:Mutex (Results 1 - 25 of 36) sorted by relevance

12

/base/request/request/pre_download/native/src/cache/
H A Dmanage.rs19 use std::sync::{Arc, LazyLock, Mutex, Once, RwLock};
28 caches: Mutex<HashMap<String, Arc<Cache>>>,
29 ram_cache_queue: Mutex<VecDeque<String>>,
30 file_cache_queue: Mutex<VecDeque<String>>,
31 handler: Mutex<Handler>,
37 caches: Mutex::new(HashMap::new()), in new()
38 ram_cache_queue: Mutex::new(VecDeque::new()), in new()
39 file_cache_queue: Mutex::new(VecDeque::new()), in new()
40 handler: Mutex::new(Handler::new(DEFAULT_RAM_CACHE_SIZE)), in new()
/base/security/device_security_level/baselib/utils/include/
H A Dutils_mutex.h40 typedef struct Mutex { struct
42 } Mutex; typedef
44 inline static void InitMutex(Mutex *mutex) in InitMutex()
49 inline static void InitRecursiveMutex(Mutex *mutex) in InitRecursiveMutex()
57 inline static void LockMutex(Mutex *mutex) in LockMutex()
65 inline static void UnlockMutex(Mutex *mutex) in UnlockMutex()
H A Dutils_state_machine.h46 Mutex mutex;
/base/security/asset/services/common/src/
H A Dcounter.rs19 use std::sync::{Arc, Mutex};
32 pub fn get_instance() -> Arc<Mutex<Counter>> { in get_instance()
33 static mut INSTANCE: Option<Arc<Mutex<Counter>>> = None; in get_instance()
34 unsafe { INSTANCE.get_or_insert_with(|| Arc::new(Mutex::new(Counter::new()))).clone() } in get_instance()
/base/security/asset/services/core_service/src/
H A Dunload_handler.rs19 use std::sync::{Arc, Mutex};
36 pub(crate) fn get_instance() -> Arc<Mutex<UnloadHandler>> {
37 static mut INSTANCE: Option<Arc<Mutex<UnloadHandler>>> = None;
38 unsafe { INSTANCE.get_or_insert_with(|| Arc::new(Mutex::new(UnloadHandler::new()))).clone() }
/base/hiviewdfx/faultloggerd/interfaces/rust/stacktrace/
H A Dlib.rs21 use std::sync::Mutex;
23 static TRACE_MUTEX : Mutex<i32> = Mutex::new(0);
/base/security/asset/services/crypto_manager/src/
H A Dcrypto_manager.rs20 sync::{Arc, Mutex},
41 pub fn get_instance() -> Arc<Mutex<CryptoManager>> { in get_instance()
42 static mut INSTANCE: Option<Arc<Mutex<CryptoManager>>> = None; in get_instance()
43 unsafe { INSTANCE.get_or_insert_with(|| Arc::new(Mutex::new(CryptoManager::new()))).clone() } in get_instance()
/base/security/asset/services/db_key_operator/src/
H A Dlib.rs23 use std::sync::Mutex;
26 static GEN_KEY_MUTEX: Mutex<()> = Mutex::new(());
27 static GET_DB_KEY_MUTEX: Mutex<()> = Mutex::new(());
/base/request/request/services/src/manage/
H A Ddatabase.rs18 use std::sync::{Arc, Mutex, Once};
41 user_file_tasks: Mutex<HashMap<u32, Arc<RequestTask>>>,
64 user_file_tasks: Mutex::new(HashMap::new()),
81 user_file_tasks: Mutex::new(HashMap::new()),
H A Daccount.rs15 use std::sync::{Mutex, Once};
31 pub(crate) static BACKGROUND_ACCOUNTS: Mutex<Option<Vec<i32>>> = Mutex::new(None);
/base/request/request/services/src/
H A Dlib.rs92 DB_LOCK = std::sync::Mutex::new(());
112 static mut DB_LOCK: std::sync::Mutex<()> = std::sync::Mutex::new(());
H A Dability.rs17 use std::sync::{Arc, Mutex};
54 task_manager: Mutex<Option<TaskManagerTx>>,
63 task_manager: Mutex::new(None), in new()
/base/request/request/services/src/manage/scheduler/queue/
H A Dkeeper.rs14 use std::sync::{Arc, Mutex};
28 inner: Arc<Mutex<Inner>>,
43 inner: Arc::new(Mutex::new(Inner {
/base/msdp/device_status/rust/services/sys/src/
H A Dservice.rs23 use std::sync::{ Mutex, Once };
63 service_impl: Mutex<FusionServiceImpl>,
/base/request/request/services/src/task/
H A Drequest_task.rs16 use std::sync::{Mutex, MutexGuard};
51 pub(crate) mime_type: Mutex<String>,
52 pub(crate) progress: Mutex<Progress>,
53 pub(crate) status: Mutex<TaskStatus>,
54 pub(crate) code: Mutex<Vec<Reason>>,
61 pub(crate) running_result: Mutex<Option<Result<(), Reason>>>,
169 mime_type: Mutex::new(String::new()),
170 progress: Mutex::new(progress),
172 status: Mutex::new(status),
173 code: Mutex
[all...]
/base/security/device_security_level/services/sa/lite/small/
H A Ddslm_ipc_process.h36 Mutex *mutex;
/base/security/device_security_level/interfaces/inner_api/src/lite/mini/
H A Ddevice_security_level_inner.c21 static inline Mutex *GetMutex(void) in GetMutex()
23 static Mutex mutex = INITED_MUTEX; in GetMutex()
/base/security/asset/services/db_operator/src/
H A Ddatabase.rs20 use std::{collections::HashMap, ffi::CStr, fs, ptr::null_mut, sync::Mutex};
52 pub(crate) mtx: Mutex<i32>,
58 static ref SPLIT_DB_LOCK_MAP: Mutex<HashMap<i32, &'static UserDbLock>> = Mutex::new(HashMap::new());
59 static ref USER_DB_LOCK_MAP: Mutex<HashMap<(i32, String), &'static UserDbLock>> = Mutex::new(HashMap::new());
68 let nf = Box::new(UserDbLock { mtx: Mutex::new(user_id) });
85 let nf = Box::new(UserDbLock { mtx: Mutex::new(user_id) });
/base/security/device_security_level/services/sa/lite/mini/
H A Ddslm_inner_process.h42 Mutex *mutex;
/base/security/device_security_level/services/dslm/
H A Ddslm_device_list.c36 static inline Mutex *GetDeviceListMutex(void) in GetDeviceListMutex()
38 static Mutex mutex = INITED_MUTEX; in GetDeviceListMutex()
/base/msdp/device_status/rust/ipc/server/src/
H A Dfusion_ipc_delegator.rs25 use std::sync::Mutex;
41 plugin_mgr: Mutex<Cell<PluginManager>>,
47 plugin_mgr: Mutex::new(Cell::new(PluginManager::default())) in new()
/base/msdp/device_status/rust/frameworks/client/src/
H A Dframeworks.rs21 use std::sync::{ Mutex, Once };
199 pub struct FusionFrameworks(Mutex<Client>);
/base/msdp/device_status/rust/subsystem/dsoftbus/sys/src/
H A Ddsoftbus.rs22 use std::sync::{Once, Mutex, Arc, Condvar};
147 operation_mutex: Mutex<HashMap<String, i32>>,
149 wait_cond: Arc<(Mutex<bool>, Condvar)>,
483 self.wait_cond = Arc::new((Mutex::new(false), Condvar::new())); in wait_session_opend()
788 dsoftbus_impl: Mutex<Inner>,
/base/msdp/device_status/rust/modules/scheduler/test/src/
H A Dlib.rs21 use std::sync::{ Arc, Condvar, Mutex };
94 inner: Mutex<EpollHandlerImpl>,
109 inner: Mutex::new(EpollHandlerImpl { in new()
/base/msdp/device_status/rust/modules/scheduler/sys/src/
H A Dscheduler.rs27 use std::sync::{ Arc, Mutex };
154 handlers: Mutex<BTreeMap<RawFd, EpollHandler>>,
167 handlers: Mutex::default(), in new()

Completed in 11 milliseconds

12