插拔USB设备后HarmonyOS 鸿蒙Next usb_host服务必进死循环

插拔USB设备后HarmonyOS 鸿蒙Next usb_host服务必进死循环 OHM 4.1.7.3、使用USBDDK、dayu开发板与其它多款投产的OHM设备上，我们测试出如下必现问题：

1. 先后打开两个USB设备（不同种类的设备），然后拔除先打开的设备，就再也不能打开新USB设备了；
2. 插拔最后打开的USB设备不会有问题；
3. 交换两个设备所接USB口、交换打开顺序，仍必现；
4. 当前发现是usb_host服务进死循环了，导致新打开操作卡在OH_Usb_ClaimInterface调;
5. 重启系统或手动重启usb_host该服务可以恢复;

最简示例，打开USB设备代码

#define LOG_TAG "tagUSBTest"
#include <usb/usb_ddk_types.h>
#include <usb/usb_ddk_api.h>
#define GET_DEV_HANDLE(busNum, devID) ((uint64_t)busNum << 32 | devID & 0xFFFFFFFF)
static int g_initUSBDDK = -1;
static uint64_t openDevice(int iBus, int iDev) {
    if (g_initUSBDDK < 0) {
        g_initUSBDDK = OH_Usb_Init();
    }
    uint64_t l_uTemp = GET_DEV_HANDLE(iBus, iDev);

    struct UsbDeviceDescriptor l_desc = {};
    int l_iRet = OH_Usb_GetDeviceDescriptor(l_uTemp, &l_desc);
    OH_LOG_INFO("Found usb-%d-%d:vid_%4x&pid_%4x", iBus, iDev, l_desc.idVendor, l_desc.idProduct);

    uint64_t l_hInterface = 0;
    if (0 == l_iRet) {
        l_iRet = OH_Usb_ClaimInterface(l_uTemp, 0, &l_hInterface);
        OH_LOG_INFO("Open usb-%d-%d = %d", iBus, iDev, l_iRet);
    }
    return l_hInterface;
}

static napi_value OpenDeviceA(napi_env env, napi_callback_info info) {
    napi_value l_result;
    uint64_t l_h = openDevice(4, 2);
    napi_create_int64(env, l_h, &l_result);
    return l_result;
}

static napi_value OpenDeviceB(napi_env env, napi_callback_info info) {
    napi_value l_result;
    uint64_t l_h = openDevice(5, 2);
    napi_create_int64(env, l_h, &l_result);
    return l_result;
}

触发故障后，usb_host会在Hilog中不停打印 “IoAsyncReceiveProcess RawHandleRequest failed ret: -202”

追查代码发现 usb_io_manage.c文件中的IoAsyncReceiveProcess 调用对错误码-202的处理会形成死循环调用

调用链为IoAsyncReceiveProcess -->usb_raw_api_library.c:RawHandleRequest–>linux_adapter.c:AdapterUrbCompleteHandle 返回 -202

usb_io_manage.c:

static int32_t IoAsyncReceiveProcess(const void *interfacePoolArg)
{
    if (interfacePoolArg == NULL) {
        HDF_LOGE("%s: invalid param", __func__);
        return HDF_ERR_INVALID_PARAM;
    }

    struct UsbInterfacePool *interfacePool = (struct UsbInterfacePool *)interfacePoolArg;
    if (RawRegisterSignal() != HDF_SUCCESS) {
        HDF_LOGE("%s:%d RawRegisterSignal error", __func__, __LINE__);
    }

    while (true) {
        if (!interfacePool->ioProcessTid) {
            interfacePool->ioProcessTid = RawGetTid();
        }

        if (interfacePool->device == NULL) {
            HDF_LOGE("%s:%d interfacePool->device is NULL!", __func__, __LINE__);
            OsalMSleep(USB_IO_SLEEP_MS_TIME);
            continue;
        }

        if (interfacePool->device->devHandle == NULL) {
            HDF_LOGE("%s:%d interfacePool->device->devHandle is NULL!", __func__, __LINE__);
            OsalMSleep(USB_IO_SLEEP_MS_TIME);
            continue;
        }

        if (interfacePool->ioProcessStopStatus != USB_POOL_PROCESS_RUNNING) {
            break;
        }

        int32_t ret = RawHandleRequest(interfacePool->device->devHandle);
        if (ret < 0) {
            HDF_LOGE("%s RawHandleRequest failed ret: %d", __func__, ret);
            OsalMSleep(USB_IO_SLEEP_MS_TIME);
            continue;  // 100ms 死循环
        }
    }

    OsalMutexLock(&interfacePool->ioStopLock);
    interfacePool->ioProcessStopStatus = USB_POOL_PROCESS_STOPED;
    OsalSemPost(&interfacePool->submitRequestQueue.sem);
    OsalMutexUnlock(&interfacePool->ioStopLock);

    return HDF_SUCCESS;
}

usb_raw_api_library.c:

int32_t RawHandleRequest(const struct UsbDeviceHandle *devHandle)
{
    struct UsbOsAdapterOps *osAdapterOps = UsbAdapterGetOps();
    int32_t ret;

    if (!osAdapterOps->urbCompleteHandle) {
        return HDF_ERR_NOT_SUPPORT;
    }

    ret = osAdapterOps->urbCompleteHandle(devHandle);
    if (ret < 0) {}

    return ret;
}

linux_adapter.c:

static int32_t AdapterUrbCompleteHandle(const struct UsbDeviceHandle *devHandle)
{
    struct UsbAdapterUrb *urb = NULL;
    struct UsbHostRequest *request = NULL;
    int32_t ret;

    if (devHandle == NULL) {
        HDF_LOGE("%s:%d invalid parameter", __func__, __LINE__);
        return HDF_ERR_INVALID_PARAM;
    }

    ret = ioctl(devHandle->fd, USBDEVFS_REAPURB, &urb);
    if (ret < 0) {
        if (errno == EAGAIN) {
            return 1;
        }
        if (errno == ENODEV) {
            return HDF_DEV_ERR_NO_DEVICE; // 这里返回了 -202
        }

        return HDF_ERR_IO;
    }
}