Lines Matching defs:requestSync
360 UsbdRequestSync *requestSync = UsbdDispatcher::UsbdFindRequestSync(port, interfaceId, pipeAddr);
361 if (requestSync != nullptr) {
362 *request = requestSync;
384 requestSync = UsbdDispatcher::UsbdRequestSyncAlloc();
385 if (requestSync == nullptr) {
390 ret = UsbdDispatcher::UsbdRequestSyncInit(port, ifHandle, &pipe, requestSync);
393 int32_t tRet = UsbdDispatcher::UsbdRequestSyncRelease(requestSync);
394 requestSync = nullptr;
400 *request = requestSync;
413 UsbdRequestSync *requestSync = UsbdDispatcher::UsbdFindRequestSync(port, interfaceId, pipeAddr);
414 if (requestSync != nullptr) {
415 struct UsbIfRequest *requestObj = (struct UsbIfRequest *)requestSync->request;
417 *request = requestSync;
444 requestSync = UsbdDispatcher::UsbdRequestSyncAlloc();
445 if (requestSync == nullptr) {
450 ret = UsbdDispatcher::UsbdRequestSyncInitwithLength(port, ifHandle, &pipe, length, requestSync);
453 UsbdDispatcher::UsbdRequestSyncRelease(requestSync);
454 requestSync = nullptr;
457 *request = requestSync;
462 int32_t timeout, uint8_t *buffer, uint32_t size, uint32_t *actlength, UsbdRequestSync *requestSync)
464 if (requestSync == nullptr || requestSync->request == nullptr || buffer == nullptr || actlength == nullptr ||
473 OsalMutexLock(&requestSync->lock);
475 ret = UsbFillRequest(requestSync->request, requestSync->ifHandle, &requestSync->params);
478 OsalMutexUnlock(&requestSync->lock);
481 requestSync->params.timeout = static_cast<uint32_t>(timeout);
482 struct UsbIfRequest* requestObj = (struct UsbIfRequest *)requestSync->request;
486 ret = UsbSubmitRequestSync(requestSync->request);
488 ret = memcpy_s(buffer + tcur, size - tcur, requestSync->request->compInfo.buffer,
489 requestSync->request->compInfo.actualLength);
492 OsalMutexUnlock(&requestSync->lock);
495 tcur += requestSync->request->compInfo.actualLength;
497 OsalMutexUnlock(&requestSync->lock);
504 HostDevice *port, UsbdRequestSync *requestSync, const uint8_t *buffer, uint32_t length, int32_t timeout)
506 if (port == nullptr || requestSync == nullptr || buffer == nullptr || length < 1) {
513 OsalMutexLock(&requestSync->lock);
515 requestSync->params.timeout = initTimeout;
516 requestSync->params.userData = port;
518 uint32_t msize = static_cast<uint32_t>(requestSync->pipe.maxPacketSize);
521 requestSync->params.dataReq.buffer = static_cast<unsigned char *>(const_cast<uint8_t *>(buffer) + tcur);
522 requestSync->params.dataReq.length = tsize;
524 ret = UsbFillRequest(requestSync->request, requestSync->ifHandle, &requestSync->params);
530 ret = UsbSubmitRequestSync(requestSync->request);
537 OsalMutexUnlock(&requestSync->lock);
1480 UsbdRequestSync *requestSync = nullptr;
1481 int32_t ret = UsbdFindRequestSyncAndCreat(port, pipe.intfId, pipe.endpointId, &requestSync);
1482 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1486 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_IN ||
1487 (requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK && requestSync->pipe.pipeType != USB_PIPE_TYPE_INTERRUPT)) {
1491 ret = UsbdBulkReadSyncBase(timeout, tbuf, tsize, &actlength, requestSync);
1524 UsbdRequestSync *requestSync = nullptr;
1525 int32_t ret = UsbdFindRequestSyncAndCreatwithLength(port, pipe.intfId, pipe.endpointId, length, &requestSync);
1526 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1532 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_IN ||
1533 (requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK && requestSync->pipe.pipeType != USB_PIPE_TYPE_INTERRUPT)) {
1539 ret = UsbdBulkReadSyncBase(timeout, tbuf, tsize, &actlength, requestSync);
1562 UsbdRequestSync *requestSync = nullptr;
1563 int32_t ret = UsbdFindRequestSyncAndCreat(port, pipe.intfId, pipe.endpointId, &requestSync);
1564 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1568 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_OUT ||
1569 (requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK && requestSync->pipe.pipeType != USB_PIPE_TYPE_INTERRUPT)) {
1573 ret = UsbdBulkWriteSyncBase(port, requestSync, data.data(), data.size(), timeout);
1709 UsbdRequestSync *requestSync = nullptr;
1710 int32_t ret = UsbdFindRequestSyncAndCreat(port, pipe.intfId, pipe.endpointId, &requestSync);
1711 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1715 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_IN || requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK) {
1719 ret = UsbdBulkReadSyncBase(timeout, tbuf, tsize, &actlength, requestSync);
1740 UsbdRequestSync *requestSync = nullptr;
1741 int32_t ret = UsbdFindRequestSyncAndCreat(port, pipe.intfId, pipe.endpointId, &requestSync);
1742 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1746 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_OUT || requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK) {
1750 ret = UsbdBulkWriteSyncBase(port, requestSync, data.data(), data.size(), timeout);
1765 UsbdRequestSync *requestSync = nullptr;
1766 int32_t ret = UsbdFindRequestSyncAndCreat(port, pipe.intfId, pipe.endpointId, &requestSync);
1767 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1768 HDF_LOGE("%{public}s:UsbdFindRequestSyncAndCreat failed of requestSync is nullptr", __func__);
1772 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_IN || requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK) {
1777 ret = UsbdBulkReadSyncBase(timeout, tbuf, tsize, &actlength, requestSync);
1798 UsbdRequestSync *requestSync = nullptr;
1799 int32_t ret = UsbdFindRequestSyncAndCreat(port, pipe.intfId, pipe.endpointId, &requestSync);
1800 if (ret != HDF_SUCCESS || requestSync == nullptr) {
1805 if (requestSync->pipe.pipeDirection != USB_PIPE_DIRECTION_OUT || requestSync->pipe.pipeType != USB_PIPE_TYPE_BULK) {
1810 ret = UsbdBulkWriteSyncBase(port, requestSync, data.data(), data.size(), timeout);