Lines Matching refs:msgQueue
193 int32_t UsbIoSendRequest(const struct UsbMessageQueue *msgQueue, const struct UsbHostRequest *request)
195 if ((msgQueue == NULL) || (request == NULL)) {
200 OsalMutexLock((struct OsalMutex *)&msgQueue->mutex);
201 DListInsertTail((struct DListHead *)&request->list, (struct DListHead *)&msgQueue->entry);
202 OsalMutexUnlock((struct OsalMutex *)&msgQueue->mutex);
204 OsalSemPost((struct OsalSem *)&msgQueue->sem);
209 HDF_STATUS UsbIoGetRequest(const struct UsbMessageQueue *msgQueue, struct UsbHostRequest **request)
214 if ((msgQueue == NULL) || (request == NULL)) {
220 ret = OsalSemWait((struct OsalSem *)&msgQueue->sem, HDF_WAIT_FOREVER);
225 if (DListIsEmpty(&msgQueue->entry)) {
230 OsalMutexLock((struct OsalMutex *)&msgQueue->mutex);
231 if (msgQueue->entry.next == NULL || msgQueue->entry.next->prev == NULL || msgQueue->entry.prev == NULL || msgQueue->entry.prev->next == NULL) {
233 OsalMutexUnlock((struct OsalMutex *)&msgQueue->mutex);
236 reqEntry = DLIST_FIRST_ENTRY(&msgQueue->entry, struct UsbHostRequest, list);
241 OsalMutexUnlock((struct OsalMutex *)&msgQueue->mutex);
246 OsalMutexUnlock((struct OsalMutex *)&msgQueue->mutex);