| /ohos5.0/base/security/device_security_level/baselib/utils/src/ |
| H A D | utils_work_queue.c | 31 typedef struct WorkQueue { struct
40 } WorkQueue; typedef
51 WorkQueue *queue = (WorkQueue *)data; in WorkQueueThread()
91 WorkQueue *CreateWorkQueue(uint32_t capacity, const char *name) in CreateWorkQueue()
93 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue()
97 (void)memset_s(queue, sizeof(WorkQueue), 0, sizeof(WorkQueue)); in CreateWorkQueue()
129 WorkQueue *CreateWorkQueue(uint32_t capacity, const char *name) in CreateWorkQueue()
132 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue()
136 (void)memset_s(queue, sizeof(WorkQueue), 0, sizeof(WorkQueue)); in CreateWorkQueue()
189 uint32_t DestroyWorkQueue(WorkQueue *queue) in DestroyWorkQueue()
[all …]
|
| /ohos5.0/foundation/resourceschedule/work_scheduler/services/native/src/ |
| H A D | work_queue.cpp | 111 void WorkQueue::Push(shared_ptr<WorkStatus> workStatus) in Push()
125 bool WorkQueue::Remove(shared_ptr<WorkStatus> workStatus) in Remove()
135 uint32_t WorkQueue::GetSize() in GetSize()
152 shared_ptr<WorkStatus> WorkQueue::Find(string workId) in Find()
197 list<shared_ptr<WorkStatus>> WorkQueue::GetWorkList() in GetWorkList()
203 void WorkQueue::RemoveUnReady() in RemoveUnReady()
211 int32_t WorkQueue::GetRunningCount() in GetRunningCount()
250 void WorkQueue::GetWorkIdStr(string& result) in GetWorkIdStr()
258 void WorkQueue::Dump(string& result) in Dump()
266 void WorkQueue::ClearAll() in ClearAll()
[all …]
|
| H A D | work_queue_manager.cpp | 60 queueMap_.emplace(it.first, make_shared<WorkQueue>()); in AddWork()
118 shared_ptr<WorkQueue> workQueue = queueMap_.at(conditionType); in GetReayQueue()
123 shared_ptr<WorkQueue> workQueue = it.second; in GetReayQueue()
156 shared_ptr<WorkQueue> workQueue = queueMap_.at(conditionType); in PrintWorkStatus()
168 shared_ptr<WorkQueue> workQueue = it.second; in PrintAllWorkStatus()
|
| H A D | work_policy_manager.cpp | 60 conditionReadyQueue_ = std::make_shared<WorkQueue>(); in WorkPolicyManager()
146 uidQueueMap_.emplace(uid, make_shared<WorkQueue>()); in AddWork()
|
| /ohos5.0/base/security/device_security_level/baselib/utils/include/ |
| H A D | utils_work_queue.h | 34 typedef struct WorkQueue WorkQueue; typedef
38 uint32_t QueueWork(WorkQueue *queue, WorkProcess process, uint8_t *data, uint32_t length);
40 WorkQueue *CreateWorkQueue(uint32_t capacity, const char *name);
42 uint32_t DestroyWorkQueue(WorkQueue *queue);
|
| /ohos5.0/foundation/resourceschedule/work_scheduler/services/native/include/ |
| H A D | work_queue.h | 27 class WorkQueue {
29 explicit WorkQueue() = default;
30 ~WorkQueue() = default;
|
| H A D | work_policy_manager.h | 305 std::map<int32_t, std::shared_ptr<WorkQueue>> uidQueueMap_;
307 std::shared_ptr<WorkQueue> conditionReadyQueue_;
|
| H A D | work_queue_manager.h | 130 std::map<WorkCondition::Type, std::shared_ptr<WorkQueue>> queueMap_;
|
| /ohos5.0/base/security/device_security_level/baselib/msglib/src/lite/ |
| H A D | messenger_impl.c | 34 WorkQueue *processQueue;
44 …WorkQueue *processQueue = CreateWorkQueue(MESSENGER_PROCESS_QUEUE_SIZE, MESSENGER_PROCESS_QUEUE_NA… in CreateMessengerImpl()
|
| H A D | messenger_device_status_manager.c | 37 WorkQueue *queue;
87 WorkQueue *queue = instance->queue; in ProcessDeviceStatusReceiver()
172 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager()
|
| H A D | messenger_device_session_manager.h | 30 bool InitDeviceSessionManager(WorkQueue *queue, const MessengerConfig *config);
|
| H A D | messenger_device_session_manager.c | 46 WorkQueue *queue;
108 WorkQueue *queue = instance->queue; in OnSessionMessageReceived()
311 bool InitDeviceSessionManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSessionManager()
|
| /ohos5.0/base/security/device_security_level/baselib/msglib/src/standard/ |
| H A D | messenger_impl.c | 34 WorkQueue *processQueue;
43 …WorkQueue *processQueue = CreateWorkQueue(MESSENGER_PROCESS_QUEUE_SIZE, MESSENGER_PROCESS_QUEUE_NA… in CreateMessengerImpl()
|
| H A D | messenger_device_status_manager.cpp | 48 void Reset(const std::string &pkgName, WorkQueue *queue, StateReceiver deviceStatusReceiver) in Reset()
65 WorkQueue *GetQueue() const in GetQueue()
72 WorkQueue *queue_ {nullptr};
275 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager()
|
| H A D | messenger_device_socket_manager.h | 30 bool InitDeviceSocketManager(WorkQueue *queue, const MessengerConfig *config);
|
| H A D | messenger_device_socket_manager.c | 47 WorkQueue *queue;
117 WorkQueue *queue = instance->queue; in OnSocketMessageReceived()
452 bool InitDeviceSocketManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSocketManager()
|
| /ohos5.0/base/security/device_security_level/baselib/msglib/src/common/ |
| H A D | messenger_device_status_manager.h | 34 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat…
|
| /ohos5.0/base/security/device_security_level/test/dslm_unit_test/ |
| H A D | dslm_test.cpp | 2029 …WorkQueue *processQueue = CreateWorkQueue(MESSENGER_PROCESS_QUEUE_SIZE, MESSENGER_PROCESS_QUEUE_NA…
|