Home
last modified time | relevance | path

Searched refs:queue (Results 1 – 25 of 50) sorted by relevance

12

/base/security/device_security_level/baselib/utils/src/
Dutils_work_queue.c50 WorkQueue *queue = (WorkQueue *)data; in WorkQueueThread() local
53 prctl(PR_SET_NAME, queue->name, 0, 0, 0); in WorkQueueThread()
55 (void)pthread_mutex_lock(&queue->mutex); in WorkQueueThread()
56 while (queue->state == RUN) { in WorkQueueThread()
57 while ((IsEmptyList(&queue->head)) && (queue->state == RUN)) { in WorkQueueThread()
58 pthread_cond_wait(&queue->cond, &queue->mutex); in WorkQueueThread()
61 if (queue->state != RUN) { in WorkQueueThread()
65 worker = LIST_ENTRY(queue->head.next, Worker, linkNode); in WorkQueueThread()
67 queue->size--; in WorkQueueThread()
69 pthread_mutex_unlock(&queue->mutex); in WorkQueueThread()
[all …]
/base/notification/eventhandler/frameworks/eventhandler/test/unittest/
Dlib_event_handler_event_queue_test.cpp100 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare() argument
102 auto event = queue.GetEvent(); in GetEventAndCompare()
125 EventQueue queue; in DelayTest() local
126 queue.Prepare(); in DelayTest()
133 queue.Insert(event); in DelayTest()
134 event = queue.GetEvent(); in DelayTest()
158 EventQueue queue; in InsertPriorityTest() local
159 queue.Prepare(); in InsertPriorityTest()
168 queue.Insert(event, priorities[i]); in InsertPriorityTest()
174 auto event = queue.GetEvent(); in InsertPriorityTest()
[all …]
/base/notification/eventhandler/test/systemtest/ems_event_queue_system_test/
Dems_event_queue_system_test.cpp65 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
66 bool ret = queue->IsQueueEmpty();
86 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
87 bool ret = queue->IsQueueEmpty();
102 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
103 bool ret = queue->IsQueueEmpty();
114 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
115 bool ret = queue->IsIdle();
128 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
129 bool ret = queue->HasInnerEvent(handler, EVENT_ID);
/base/powermgr/power_manager/utils/ffrt/src/
Dffrt_utils.cpp31 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue) in SubmitQueueTasks() argument
37 queue.submit(task); in SubmitQueueTasks()
41 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask() argument
46 return queue.submit_h(task, ffrt::task_attr().delay(us.count())); in SubmitDelayTask()
56 void FFRTUtils::CancelTask(FFRTHandle& handle, FFRTQueue& queue) in CancelTask() argument
58 queue.cancel(handle); in CancelTask()
/base/powermgr/power_manager/utils/ffrt/include/
Dffrt_utils.h38 using FFRTQueue = ffrt::queue;
60 static void SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue);
73 static FFRTHandle SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue);
94 static void CancelTask(FFRTHandle& handle, FFRTQueue& queue);
/base/powermgr/power_manager/test/apitest/inner_api/ffrt/src/
Dffrt_utils_test.cpp75 FFRTQueue queue("test_power_ffrt_queue"); variable
76 FFRTUtils::SubmitQueueTasks({task1, task2, task3}, queue); // submit batch tasks to a queue
106 FFRTQueue queue("test_power_ffrt_queue"); variable
107 FFRTUtils::SubmitDelayTask(task, 10, queue); // submit delay task to a queue
128 FFRTQueue queue("test_power_ffrt_queue"); variable
129 auto handle = FFRTUtils::SubmitDelayTask(task, 10, queue); // submit delay task to a queue
134 FFRTUtils::CancelTask(handle, queue); // cancel the delay task from the queue
/base/security/device_security_level/baselib/msglib/src/lite/
Dmessenger_device_status_manager.c37 WorkQueue *queue; member
57 .queue = NULL, in GetDeviceManagerInstance()
87 WorkQueue *queue = instance->queue; in ProcessDeviceStatusReceiver() local
88 if (queue == NULL) { in ProcessDeviceStatusReceiver()
114 ret = QueueWork(queue, ProcessDeviceStatusReceived, (uint8_t *)data, sizeof(QueueStatusData)); in ProcessDeviceStatusReceiver()
171 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager() argument
180 instance->queue = queue; in InitDeviceStatusManager()
211 instance->queue = NULL; in DeInitDeviceStatusManager()
212 DestroyWorkQueue(instance->queue); in DeInitDeviceStatusManager()
/base/security/device_security_level/baselib/utils/include/
Dutils_work_queue.h38 uint32_t QueueWork(WorkQueue *queue, WorkProcess process, uint8_t *data, uint32_t length);
42 uint32_t DestroyWorkQueue(WorkQueue *queue);
/base/notification/common_event_service/services/test/unittest/
Dcommon_event_manager_service_new_branch_test.cpp83 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
108 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
128 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
175 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
197 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
237 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
275 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
312 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
350 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
372 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
/base/security/device_security_level/baselib/msglib/src/common/
Dmessenger_device_session_manager.c46 WorkQueue *queue; member
84 .queue = NULL, in GetDeviceSessionManagerInstance()
114 WorkQueue *queue = instance->queue; in OnSessionMessageReceived() local
115 if (queue == NULL) { in OnSessionMessageReceived()
143 ret = QueueWork(queue, ProcessSessionMessageReceived, (uint8_t *)queueData, queueDataLen); in OnSessionMessageReceived()
291 bool InitDeviceSessionManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSessionManager() argument
293 if ((queue == NULL) || (config == NULL)) { in InitDeviceSessionManager()
302 inst->queue = queue; in InitDeviceSessionManager()
337 instance->queue = NULL; in DeInitDeviceSessionManager()
354 DestroyWorkQueue(instance->queue); in DeInitDeviceSessionManager()
Dmessenger_device_session_manager.h30 bool InitDeviceSessionManager(WorkQueue *queue, const MessengerConfig *config);
Dmessenger_device_status_manager.h34 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat…
/base/security/device_security_level/baselib/msglib/src/standard/
Dmessenger_device_status_manager.cpp39 void Reset(const std::string &pkgName, WorkQueue *queue, StateReceiver deviceStatusReceiver) in Reset() argument
43 queue_ = queue; in Reset()
124 auto queue = DeviceStatusControlBlock::GetInstance().GetQueue(); in ProcessDeviceStatusReceiver() local
125 if (queue == nullptr) { in ProcessDeviceStatusReceiver()
165 auto ret = QueueWork(queue, process, input, sizeof(QueueStatusData)); in ProcessDeviceStatusReceiver()
234 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager() argument
236 if (queue == nullptr || pkgName == nullptr || deviceStatusReceiver == nullptr) { in InitDeviceStatusManager()
240 DeviceStatusControlBlock::GetInstance().Reset(name, queue, deviceStatusReceiver); in InitDeviceStatusManager()
/base/notification/eventhandler/frameworks/eventhandler/src/
Devent_queue.cpp120 InsertEventsLocked(subEventQueues_[static_cast<uint32_t>(priority)].queue, event); in Insert()
167 subEventQueues_[i].queue.clear(); in RemoveAll()
234 subEventQueues_[i].queue.remove_if(filter); in Remove()
271 std::find_if(subEventQueues_[i].queue.begin(), subEventQueues_[i].queue.end(), filter); in HasInnerEvent()
272 if (iter != subEventQueues_[i].queue.end()) { in HasInnerEvent()
285 if (!CheckEventInListLocked(subEventQueues_[i].queue, now, nextWakeUpTime)) { in PickEventLocked()
313 return PopFrontEventFromListLocked(subEventQueues_[priorityIndex].queue); in PickEventLocked()
595 … for (auto it = subEventQueues_[i].queue.begin(); it != subEventQueues_[i].queue.end(); ++it) { in Dump()
627 … for (auto it = subEventQueues_[i].queue.begin(); it != subEventQueues_[i].queue.end(); ++it) { in DumpQueueInfo()
660 uint32_t queueSize = subEventQueues_[i].queue.size(); in IsQueueEmpty()
/base/update/update_app/common/src/main/ets/manager/
DUpdateManager.ts498 private queue: Array<Message>; property in MessageQueue
502 this.queue = new Array<Message>();
511 if (this.queue.length === 1) {
517 return this.queue?.length === 0;
535 this.queue.push(message);
539 if (this.queue.length !== 0) {
540 this.queue.shift();
545 if (this.queue.length !== 0) {
546 return this.queue[0];
/base/notification/common_event_service/services/test/unittest/common_event_manager_service_branch_test/
Dcommon_event_manager_service_branch_test.cpp72 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
159 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
187 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
217 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
243 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
269 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
349 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
464 comm->commonEventSrvQueue_ = std::make_shared<ffrt::queue>("CesSrvMain"); in HWTEST_F()
/base/notification/common_event_service/services/include/
Dcommon_event_control_manager.h199 std::shared_ptr<ffrt::queue> orderedQueue_ = nullptr;
200 std::shared_ptr<ffrt::queue> unorderedQueue_ = nullptr;
201 std::shared_ptr<ffrt::queue> unorderedImmediateQueue_ = nullptr;
Dability_manager_helper.h77 std::shared_ptr<ffrt::queue> ffrt_ = nullptr;
/base/hiviewdfx/hisysevent/interfaces/js/kits/napi/include/
Djs_callback_manager.h30 using TaskQueue = std::queue<std::tuple<CallbackContext*, CALLBACK_FUNC, RELEASE_FUNC>>;
/base/sensors/miscdevice/services/miscdevice_service/include/
Dmiscdevice_dump.h43 std::queue<VibrateRecord> dumpQueue_;
/base/hiviewdfx/hiview/base/running_status_logger/include/
Drunning_status_logger.h45 std::queue<LogWritingTask> logWritingTasks;
/base/inputmethod/imf/services/include/
Dmessage_handler.h80 std::queue<Message *> mQueue; // Message queue, guarded by mMutex;
/base/sensors/medical_sensor/services/medical_sensor/include/
Dclient_info.h71 std::unordered_map<uint32_t, std::queue<struct SensorEvent>> GetDataQueue();
91 std::unordered_map<uint32_t, std::queue<struct SensorEvent>> dataQueue_;
/base/inputmethod/imf/common/
Dblock_queue.h62 std::queue<T> queues_;
/base/request/request/frameworks/js/napi/include/
Dblock_queue.h61 std::queue<T> queues_;

12