| /kernel/uniproton/src/core/ipc/queue/ |
| H A D | prt_queue_del.c | 21 OS_SEC_L4_TEXT U32 PRT_QueueDelete(U32 queueId) in PRT_QueueDelete() argument
|
| H A D | prt_queue_minor.c | 37 OS_SEC_L2_TEXT U32 PRT_QueueGetUsedPeak(U32 queueId, U32 *queueUsedNum) in PRT_QueueGetUsedPeak() argument
60 OS_SEC_L2_TEXT U32 PRT_QueueGetNodeNum(U32 queueId, U32 taskPid, U32 *queueNum) in PRT_QueueGetNodeNum() argument
|
| H A D | prt_queue_init.c | 60 OS_SEC_L4_TEXT U32 OsQueueCreatParaCheck(U16 nodeNum, U16 nodeSize, const U32 *queueId) in OsQueueCreatParaCheck() argument
76 OS_SEC_L4_TEXT U32 OsQueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId) in OsQueueCreate() argument
127 OS_SEC_L4_TEXT U32 PRT_QueueCreate(U16 nodeNum, U16 maxNodeSize, U32 *queueId) in PRT_QueueCreate() argument
|
| H A D | prt_queue.c | 129 OS_SEC_L4_TEXT U32 PRT_QueueRead(U32 queueId, void *bufferAddr, U32 *len, U32 timeOut) in PRT_QueueRead() argument
263 OS_SEC_L4_TEXT U32 PRT_QueueWrite(U32 queueId, void *bufferAddr, U32 bufferSize, U32 timeOut, U32 prio) in PRT_QueueWrite() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/test/src/api/ |
| H A D | DeferredCallbackTest.cpp | 184 auto queueId = interface_cast<IObjectInstance>(q)->GetInstanceId(); in HWTEST_F() local
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/ |
| H A D | event_handler.h | 170 bool Subscribe(const Event<EventType>& event, Func func, const BASE_NS::Uid& queueId) in Subscribe() argument
64 EventHandler( const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) EventHandler() argument
84 EventHandler( const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) EventHandler() argument
144 Subscribe( const Event<EventType>& event, const typename EventType::InterfaceTypePtr& func, const BASE_NS::Uid& queueId) Subscribe() argument
191 Subscribe(const BASE_NS::shared_ptr<IEvent>& event, Func func, const BASE_NS::Uid& queueId) Subscribe() argument
[all...] |
| H A D | timer.h | 58 Timer(const TimeSpan& interval, Func func, TimerType type, const BASE_NS::Uid& queueId) in Timer() argument
112 bool Start(const TimeSpan& interval, Func func, TimerType type, const BASE_NS::Uid& queueId) in Start() argument
187 inline ITaskQueue::Token SingleShotTimer(const TimeSpan& interval, Func func, const BASE_NS::Uid& queueId) in SingleShotTimer() argument
|
| /foundation/graphic/graphic_3d/lume/metaobject/include/meta/api/property/ |
| H A D | property_event_handler.h | 49 bool Subscribe(const IProperty::ConstPtr& property, const CallableTypePtr& onInvoked, const BASE_NS::Uid& queueId) in Subscribe() argument
61 bool Subscribe(const IProperty::ConstPtr& property, Func func, const BASE_NS::Uid& queueId) in Subscribe() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/cmsis/ |
| H A D | queue_adapter.c | 26 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout)
in QUEUE_Put() argument
36 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout)
in QUEUE_Pop() argument
46 int QUEUE_Destroy(MQueueId queueId)
in QUEUE_Destroy() argument
|
| /foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| H A D | task_manager.h | 39 MQueueId queueId;
member
|
| H A D | task_manager.c | 46 MQueueId queueId = (MQueueId)QUEUE_Create(name, sizeof(Exchange), config->queueSize);
in SAMGR_CreateFixedTaskPool() local
|
| H A D | message.c | 87 int32 SAMGR_MsgRecv(MQueueId queueId, uint8 *interMsg, uint32 size)
in SAMGR_MsgRecv() argument
180 SharedSend(MQueueId queueId, Exchange *exchange, int initRef) SharedSend() argument
[all...] |
| /foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/ |
| H A D | message.h | 83 MQueueId queueId; member
|
| /foundation/resourceschedule/ffrt/src/queue/ |
| H A D | queue_strategy.h | 31 static T* DequeBatch(const uint32_t queueId, const uint64_t now,
in DequeBatch() argument
55 static T* DequeSingleByPriority(const uint32_t queueId,
in DequeSingleByPriority() argument
77 static T* DequeSingleAgainstStarvation(const uint32_t queueId,
in DequeSingleAgainstStarvation() argument
|
| H A D | base_queue.h | 103 static std::atomic_uint32_t queueId;
member in ffrt::BaseQueue
|
| H A D | queue_monitor.cpp | 80 void QueueMonitor::RegisterQueueId(uint32_t queueId, QueueHandler* queueStruct) in RegisterQueueId() argument
106 void QueueMonitor::ResetQueueInfo(uint32_t queueId) in ResetQueueInfo() argument
115 ResetQueueStruct(uint32_t queueId) ResetQueueStruct() argument
123 UpdateQueueInfo(uint32_t queueId, const uint64_t &taskId) UpdateQueueInfo() argument
136 QueryQueueStatus(uint32_t queueId) QueryQueueStatus() argument
162 ResetTaskTimestampAfterWarning(uint32_t queueId, const uint64_t &taskId) ResetTaskTimestampAfterWarning() argument
[all...] |
| /foundation/systemabilitymgr/samgr_lite/samgr/adapter/posix/ |
| H A D | queue_adapter.c | 46 int QUEUE_Put(MQueueId queueId, const void *element, uint8 pri, int timeout)
in QUEUE_Put() argument
61 int QUEUE_Pop(MQueueId queueId, void *element, uint8 *pri, int timeout)
in QUEUE_Pop() argument
76 int QUEUE_Destroy(MQueueId queueId)
in QUEUE_Destroy() argument
|
| /third_party/skia/third_party/externals/dawn/src/dawn_wire/server/ |
| H A D | ServerQueue.cpp | 29 bool Server::DoQueueOnSubmittedWorkDone(ObjectId queueId, in DoQueueOnSubmittedWorkDone() argument
48 bool Server::DoQueueWriteBuffer(ObjectId queueId, in DoQueueWriteBuffer() argument
76 bool Server::DoQueueWriteTexture(ObjectId queueId, in DoQueueWriteTexture() argument
|
| /base/telephony/core_service/utils/common/src/ |
| H A D | tel_event_queue.cpp | 119 void TelEventQueue::SubmitInner(int32_t queueId) in SubmitInner() argument
146 void TelEventQueue::SubmitToFFRT(int32_t queueId, AppExecFwk::InnerEvent::TimePoint handleTime, int64_t delayTime) in SubmitToFFRT() argument
230 AppExecFwk::InnerEvent::Pointer TelEventQueue::PopEvent(int32_t queueId, bool &isNeedSubmit) in PopEvent() argument
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_thread.c | 137 static BtmProcessingQueue *FindProcessingQueueById(uint8_t queueId) in FindProcessingQueueById() argument
186 int BTM_CreateProcessingQueue(uint8_t queueId, uint16_t size) in BTM_CreateProcessingQueue() argument
203 int BTM_DeleteProcessingQueue(uint8_t queueId) in BTM_DeleteProcessingQueue() argument
229 int BTM_RunTaskInProcessingQueue(uint8_t queueId, void (*task)(void *context), void *context) in BTM_RunTaskInProcessingQueue() argument
[all...] |
| /foundation/graphic/graphic_3d/lume/metaobject/src/ |
| H A D | startable_object_controller.cpp | 293 void StartableObjectController::RunTasks(const BASE_NS::Uid& queueId) in RunTasks() argument
324 bool StartableObjectController::ProcessOps(const BASE_NS::Uid& queueId) in ProcessOps() argument
350 AddOperation(StartableOperation&& operation, const BASE_NS::Uid& queueId) AddOperation() argument
420 SetTickableQueueuId(const BASE_NS::Uid& queueId) SetTickableQueueuId() argument
[all...] |
| H A D | object_registry.cpp | 535 bool ObjectRegistry::RegisterTaskQueue(const ITaskQueue::Ptr& queue, const BASE_NS::Uid& queueId) in RegisterTaskQueue() argument
550 bool ObjectRegistry::UnregisterTaskQueue(const BASE_NS::Uid& queueId) in UnregisterTaskQueue() argument
[all...] |
| /kernel/liteos_m/kal/cmsis/ |
| H A D | cmsis_liteos2.c | 1245 UINT32 queueId;
in osMessageQueueNew() local
|