Searched refs:msgQueue (Results 1 – 14 of 14) sorted by relevance
203 if ((msgQueue == NULL) || (request == NULL)) { in UsbIoSendRequest()208 OsalMutexLock((struct OsalMutex *)&msgQueue->mutex); in UsbIoSendRequest()210 OsalMutexUnlock((struct OsalMutex *)&msgQueue->mutex); in UsbIoSendRequest()212 OsalSemPost((struct OsalSem *)&msgQueue->sem); in UsbIoSendRequest()222 if ((msgQueue == NULL) || (request == NULL)) { in UsbIoGetRequest()233 if (DListIsEmpty(&msgQueue->entry)) { in UsbIoGetRequest()238 OsalMutexLock((struct OsalMutex *)&msgQueue->mutex); in UsbIoGetRequest()239 if (msgQueue->entry.next == NULL || msgQueue->entry.next->prev == NULL || in UsbIoGetRequest()240 msgQueue->entry.prev == NULL || msgQueue->entry.prev->next == NULL) { in UsbIoGetRequest()242 OsalMutexUnlock((struct OsalMutex *)&msgQueue->mutex); in UsbIoGetRequest()[all …]
32 int32_t UsbIoSendRequest(const struct UsbMessageQueue *msgQueue, const struct UsbHostRequest *reque…33 HDF_STATUS UsbIoGetRequest(const struct UsbMessageQueue *msgQueue, struct UsbHostRequest **request);
110 auto* msgQueue = TaskManager::GetInstance().GetMessageQueue(req); in ExecuteCallback() local111 if (msgQueue == nullptr) { in ExecuteCallback()115 ExecuteCallbackInner(*msgQueue); in ExecuteCallback()120 auto* msgQueue = TaskManager::GetInstance().GetMessageQueueFromCallbackInfo(callbackInfo); in ExecuteCallbackTask() local121 if (msgQueue == nullptr) { in ExecuteCallbackTask()125 ExecuteCallbackInner(*msgQueue); in ExecuteCallbackTask()128 void TaskPool::ExecuteCallbackInner(MsgQueue& msgQueue) in ExecuteCallbackInner() argument130 while (!msgQueue.IsEmpty()) { in ExecuteCallbackInner()131 auto resultInfo = msgQueue.DeQueue(); in ExecuteCallbackInner()
66 static void ExecuteCallbackInner(MsgQueue& msgQueue);
224 cntlr->msgQueue = PlatformQueueCreate(MmcMsgHandleDefault, threadName, cntlr); in MmcCntlrQueueCreate()225 if (cntlr->msgQueue == NULL) { in MmcCntlrQueueCreate()229 ret = PlatformQueueStart(cntlr->msgQueue); in MmcCntlrQueueCreate()232 PlatformQueueDestroy(cntlr->msgQueue); in MmcCntlrQueueCreate()279 PlatformQueueDestroy(cntlr->msgQueue); in MmcCntlrUninit()351 (void)PlatformQueueAddMsg(cntlr->msgQueue, &mmcMsg->msg); in MmcCntlrPostMsg()
287 …cntlr->msgQueue = PlatformQueueCreate(HdmiEventMsgHandleDefault, "PlatformHdmiWorkerThread", cntlr… in HdmiCntlrInit()288 if (cntlr->msgQueue == NULL) { in HdmiCntlrInit()292 ret = PlatformQueueStart(cntlr->msgQueue); in HdmiCntlrInit()295 PlatformQueueDestroy(cntlr->msgQueue); in HdmiCntlrInit()
29 (void)PlatformQueueAddMsg(cntlr->msgQueue, &event->msg); in HdmiEventPostMsg()
640 int32_t msgQueue = 0; in RecvHttpProbeResponse() local641 while ((curlMsg = curl_multi_info_read(curlMulti_, &msgQueue)) != nullptr) { in RecvHttpProbeResponse()
62 struct PlatformQueue *msgQueue; member
203 struct PlatformQueue *msgQueue; member
291 struct PlatformQueue *msgQueue;
270 struct PlatformQueue *msgQueue;
271 struct PlatformQueue *msgQueue;
255 struct PlatformQueue *msgQueue;