| /base/notification/eventhandler/test/systemtest/ems_event_queue_system_test/ |
| D | ems_event_queue_system_test.cpp | 65 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
86 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
102 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
114 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
128 std::shared_ptr<EventQueue> queue = std::make_shared<EventQueue>(); variable
|
| /base/powermgr/power_manager/utils/ffrt/src/ |
| D | ffrt_utils.cpp | 31 void FFRTUtils::SubmitQueueTasks(const std::vector<FFRTTask>& tasks, FFRTQueue& queue) in SubmitQueueTasks()
41 FFRTHandle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, FFRTQueue& queue) in SubmitDelayTask()
49 …ndle FFRTUtils::SubmitDelayTask(FFRTTask& task, uint32_t delayMs, std::shared_ptr<FFRTQueue> queue) in SubmitDelayTask()
64 void FFRTUtils::CancelTask(FFRTHandle& handle, FFRTQueue& queue) in CancelTask()
69 void FFRTUtils::CancelTask(FFRTHandle& handle, std::shared_ptr<FFRTQueue> queue) in CancelTask()
|
| /base/security/device_security_level/baselib/utils/src/ |
| D | utils_work_queue.c | 51 WorkQueue *queue = (WorkQueue *)data; in WorkQueueThread() local
93 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue() local
132 WorkQueue *queue = MALLOC(sizeof(WorkQueue)); in CreateWorkQueue() local
189 uint32_t DestroyWorkQueue(WorkQueue *queue) in DestroyWorkQueue()
213 uint32_t QueueWork(WorkQueue *queue, WorkProcess process, uint8_t *data, uint32_t length) in QueueWork()
|
| /base/notification/eventhandler/frameworks/eventhandler/test/unittest/ |
| D | lib_event_handler_event_queue_test.cpp | 100 static void GetEventAndCompare(uint32_t eventId, EventQueue &queue) in GetEventAndCompare()
125 EventQueue queue; in DelayTest() local
158 EventQueue queue; in InsertPriorityTest() local
200 static void BreakQueueTest(EventQueue &queue, uint32_t eventId) in BreakQueueTest()
220 static void InsertAndGet(EventQueue &queue, InnerEvent::Pointer &event) in InsertAndGet()
238 static void InsertPriorityEvent(EventQueue &queue, size_t length) in InsertPriorityEvent()
267 static void InsertAllPriorityEvent(EventQueue &queue) in InsertAllPriorityEvent()
382 EventQueue queue; variable
406 EventQueue queue; variable
430 EventQueue queue; variable
[all …]
|
| D | lib_event_handler_event_test.cpp | 464 EventQueue queue; variable
|
| /base/powermgr/power_manager/test/apitest/inner_api/ffrt/src/ |
| D | ffrt_utils_test.cpp | 75 FFRTQueue queue("test_power_ffrt_queue"); variable
100 FFRTQueue queue("test_power_ffrt_queue"); variable
122 FFRTQueue queue("test_power_ffrt_queue"); variable
|
| /base/security/device_security_level/baselib/msglib/src/lite/ |
| D | messenger_device_status_manager.c | 37 WorkQueue *queue; member
87 WorkQueue *queue = instance->queue; in ProcessDeviceStatusReceiver() local
171 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager()
|
| D | messenger_device_session_manager.c | 46 WorkQueue *queue; member
114 WorkQueue *queue = instance->queue; in OnSessionMessageReceived() local
331 bool InitDeviceSessionManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSessionManager()
|
| /base/request/request/services/service/request/src/manager/ |
| D | qos.rs | 914 let mut queue = QosQueue::new(4); in ut_qos_init_test() localVariable
935 let mut queue = QosQueue::new(4); in ut_qos_test_basic() localVariable
980 let mut queue = QosQueue::new(1); in ut_qos_test_map_basic() localVariable
1039 let mut queue = QosQueue::new(3); in ut_qos_test_vacant() localVariable
1121 let mut queue = QosQueue::new(6); in ut_test_pop_high() localVariable
1151 let mut queue = QosQueue::new(2); in ut_test_contest() localVariable
|
| /base/security/device_security_level/baselib/msglib/src/standard/ |
| D | messenger_device_status_manager.cpp | 39 void Reset(const std::string &pkgName, WorkQueue *queue, StateReceiver deviceStatusReceiver) in Reset()
131 auto queue = DeviceStatusControlBlock::GetInstance().GetQueue(); in ProcessDeviceStatusReceiver() local
237 bool InitDeviceStatusManager(WorkQueue *queue, const char *pkgName, DeviceStatusReceiver deviceStat… in InitDeviceStatusManager()
|
| D | messenger_device_socket_manager.c | 47 WorkQueue *queue; member
123 WorkQueue *queue = instance->queue; in OnSocketMessageReceived() local
472 bool InitDeviceSocketManager(WorkQueue *queue, const MessengerConfig *config) in InitDeviceSocketManager()
|
| /base/notification/eventhandler/interfaces/inner_api/ |
| D | event_queue.h | 255 std::list<InnerEvent::Pointer> queue; member
|
| /base/update/update_app/common/src/main/ets/manager/ |
| D | UpdateManager.ts | 498 private queue: Array<Message>; property in MessageQueue
|