Lines Matching defs:cQueuedUrbs
62 unsigned cQueuedUrbs;
553 if ( pPriv->cQueuedUrbs <= 0
574 if (pPriv->cQueuedUrbs + pPriv->cPendingUrbs + 1 > pPriv->cAllocatedUrbs)
598 pPriv->paHandles[pPriv->cQueuedUrbs + i] = pPriv->aPendingUrbs[i]->overlapped.hEvent;
599 pPriv->paQueuedUrbs[pPriv->cQueuedUrbs + i] = pPriv->aPendingUrbs[i];
601 pPriv->cQueuedUrbs += pPriv->cPendingUrbs;
603 pPriv->paHandles[pPriv->cQueuedUrbs] = pPriv->hEventWakeup;
604 pPriv->paHandles[pPriv->cQueuedUrbs + 1] = INVALID_HANDLE_VALUE;
614 * so racing the cQueuedUrbs access/modification can not occur.
619 unsigned cQueuedUrbs = ASMAtomicReadU32((volatile uint32_t *)&pPriv->cQueuedUrbs);
622 DWORD rc = WaitForMultipleObjects(cQueuedUrbs + 1, pPriv->paHandles, FALSE, cMilliesWait);
625 if (rc == WAIT_OBJECT_0 + cQueuedUrbs)
632 if (rc >= WAIT_OBJECT_0 && rc < WAIT_OBJECT_0 + cQueuedUrbs)
642 cQueuedUrbs = --pPriv->cQueuedUrbs;
643 if (cQueuedUrbs != iUrb)
646 for (unsigned i=iUrb;i<cQueuedUrbs;i++)
652 pPriv->paHandles[cQueuedUrbs] = pPriv->hEventWakeup;
653 pPriv->paHandles[cQueuedUrbs + 1] = INVALID_HANDLE_VALUE;
654 pPriv->paQueuedUrbs[cQueuedUrbs] = NULL;
656 Assert(cQueuedUrbs == pPriv->cQueuedUrbs);
686 || (rc >= WAIT_ABANDONED_0 && rc < WAIT_ABANDONED_0 + cQueuedUrbs))
687 AssertMsgFailed(("USB: WaitForMultipleObjects %d objects failed with rc=%d and last error %d\n", cQueuedUrbs, rc, GetLastError()));