Home
last modified time | relevance | path

Searched refs:readReq (Results 1 – 25 of 28) sorted by relevance

12

/ohos5.0/base/hiviewdfx/hiview/plugins/event_store/event_export/task/export/
H A Devent_export_task.cpp78 if (!InitReadRequest(readReq)) { in OnTaskRun()
95 if (!readHandler->HandleRequest(readReq)) { in OnTaskRun()
97 readReq->beginSeq, readReq->endSeq); in OnTaskRun()
102 readReq->endSeq); in OnTaskRun()
126 if (readReq == nullptr) { in InitReadRequest()
135 if (readReq->beginSeq >= readReq->endSeq) { in InitReadRequest()
137 readReq->beginSeq, readReq->endSeq); in InitReadRequest()
140 if (!ParseExportEventList(readReq->eventList) || readReq->eventList.empty()) { in InitReadRequest()
144 readReq->moduleName = config_->moduleName; in InitReadRequest()
145 readReq->maxSize = config_->maxSize; in InitReadRequest()
[all …]
H A Devent_read_handler.cpp35 auto readReq = BaseRequest::DownCastTo<EventReadRequest>(req); in HandleRequest() local
36 int64_t exportBeginSeq = readReq->beginSeq; in HandleRequest()
37 int64_t exportEndSeq = readReq->endSeq; in HandleRequest()
47 if (!QuerySysEventInRange(queryRange, readReq->eventList, in HandleRequest()
48 [this, &readReq] (bool isQueryCompleted) { in HandleRequest()
49 … auto writeReq = std::make_shared<EventWriteRequest>(readReq->moduleName, cachedSysEvents_, in HandleRequest()
50 readReq->exportDir, isQueryCompleted, readReq->maxSize); in HandleRequest()
/ohos5.0/drivers/peripheral/usb/test/unittest/host_sdk/
H A Dusb_host_sdk_if_test_io.cpp188 g_acm->readReq[i] = UsbAllocRequest(g_acm->data_devHandle, 0, g_acm->readSize); in AcmGetRequest()
189 EXPECT_NE(nullptr, g_acm->readReq[i]); in AcmGetRequest()
228 ret = UsbFillRequest(g_acm->readReq[i], g_acm->data_devHandle, &readParmas); in AcmFillReadRequest()
372 ret = UsbSubmitRequestSync(g_acm->readReq[i]);
439 ret = UsbSubmitRequestAsync(g_acm->readReq[i]);
455 ret = UsbCancelRequest(g_acm->readReq[i]);
530 ret = UsbSubmitRequestAsync(g_acm->readReq[0]);
545 ret = UsbSubmitRequestAsync(g_acm->readReq[0]);
H A Dusb_raw_sdk_if_test_io.cpp330 EXPECT_NE(nullptr, g_acm->readReq[i]); in AcmRawAllocRequest()
392 ret = UsbRawFillBulkRequest(g_acm->readReq[i], g_acm->devHandle, &reqData); in AcmRawFillReadReq()
691 reqData.data = ((UsbRawRequest *)g_acm->readReq[i])->buffer;
697 ret = UsbRawSendBulkRequest(g_acm->readReq[i], g_acm->devHandle, &reqData);
719 reqData.data = ((UsbRawRequest *)g_acm->readReq[i])->buffer;
747 reqData.data = ((UsbRawRequest *)g_acm->readReq[i])->buffer;
753 ret = UsbRawSendBulkRequest(g_acm->readReq[i], NULL, &reqData);
771 ret = UsbRawSendBulkRequest(g_acm->readReq[i], g_acm->devHandle, NULL);
917 ret = UsbRawFillBulkRequest(g_acm->readReq[i], g_acm->devHandle, &reqData);
978 ret = UsbRawSubmitRequest(g_acm->readReq[i]);
[all …]
H A Dusb_raw_sdk_if_test.cpp1195 g_acm->readReq[i] = UsbRawAllocRequest(NULL, 0, g_acm->dataInEp->maxPacketSize);
1196 EXPECT_EQ(nullptr, g_acm->readReq[i]);
1211 g_acm->readReq[i] = UsbRawAllocRequest(g_acm->devHandle, 0, g_acm->dataInEp->maxPacketSize);
1212 …((struct UsbHostRequest *)(g_acm->readReq[i]))->devHandle = (struct UsbDeviceHandle *)g_acm->devHa…
1213 EXPECT_NE(nullptr, g_acm->readReq[i]);
1298 ret = UsbRawFreeRequest(g_acm->readReq[i]);
1362 g_acm->readReq[i] = UsbRawAllocRequest(g_acm->devHandle, 0, g_acm->dataInEp->maxPacketSize);
1363 EXPECT_NE(nullptr, g_acm->readReq[i]);
1693 ret = UsbRawFillBulkRequest(g_acm->readReq[i], g_acm->devHandle, &reqData);
2065 ret = UsbRawFillBulkRequest(g_acm->readReq[i], g_acm->devHandle, &reqData);
H A Dusb_host_sdk_if_test.cpp1076 g_acm->readReq[i] = UsbAllocRequest(NULL, 0, g_acm->readSize);
1077 EXPECT_EQ(nullptr, g_acm->readReq[i]);
1094 g_acm->readReq[i] = UsbAllocRequest(g_acm->data_devHandle, 0, g_acm->readSize);
1095 EXPECT_NE(nullptr, g_acm->readReq[i]);
1111 ret = UsbFreeRequest(g_acm->readReq[i]);
1283 g_acm->readReq[i] = UsbAllocRequest(g_acm->data_devHandle, 0, g_acm->readSize);
1284 EXPECT_NE(nullptr, g_acm->readReq[i]);
1337 ret = UsbFillRequest(g_acm->readReq[i], g_acm->data_devHandle, &readParmas);
1467 ret = UsbFillRequest(g_acm->readReq[i], g_acm->data_devHandle, &readParmas);
H A Dusb_host_sdk_if_test.h94 struct UsbRequest *readReq[ACM_NR]; member
H A Dusb_raw_sdk_if_test.h97 struct UsbRawRequest *readReq[ACM_NR]; member
/ohos5.0/drivers/hdf_core/framework/test/unittest/model/usb/host/src/
H A Dusb_raw_test.c192 if (rawAcm->readReq[i]) { in CheckRawSdkIfAllocRequest003()
208 if (rawAcm->readReq[i] == NULL) { in CheckRawSdkIfAllocRequest004()
449 int32_t ret = UsbRawFreeRequest(rawAcm->readReq[i]); in CheckRawSdkIfFreeRequest002()
454 rawAcm->readReq[i] = NULL; in CheckRawSdkIfFreeRequest002()
522 if (rawAcm->readReq[i] == NULL) { in CheckRawSdkIfAllocRequest009()
1456 reqData.data = ((struct UsbRawRequest *)rawAcm->readReq[0])->buffer; in CheckRawSdkIfSendBulkRequest002()
1476 reqData.data = ((struct UsbRawRequest *)rawAcm->readReq[0])->buffer; in CheckRawSdkIfSendBulkRequest003()
1496 reqData.data = ((struct UsbRawRequest *)rawAcm->readReq[0])->buffer; in CheckRawSdkIfSendBulkRequest004()
1499 int32_t ret = UsbRawSendBulkRequest(rawAcm->readReq[0], NULL, &reqData); in CheckRawSdkIfSendBulkRequest004()
1699 int32_t ret = UsbRawSubmitRequest(rawAcm->readReq[i]); in CheckRawSdkIfSubmitRequest002()
[all …]
H A Dusb_test.c833 g_acm->readReq[i] = UsbAllocRequest(NULL, 0, g_acm->readSize); in CheckHostSdkIfAllocRequest001()
834 if (g_acm->readReq[i] == NULL) { in CheckHostSdkIfAllocRequest001()
847 g_acm->readReq[i] = UsbAllocRequest(g_acm->data_devHandle, 0, g_acm->readSize); in CheckHostSdkIfAllocRequest002()
848 if (g_acm->readReq[i] == NULL) { in CheckHostSdkIfAllocRequest002()
859 int32_t ret = UsbFreeRequest(g_acm->readReq[i]); in CheckHostSdkIfFreeRequest001()
864 g_acm->readReq[i] = NULL; in CheckHostSdkIfFreeRequest001()
1173 g_acm->readReq[i] = UsbAllocRequest(g_acm->data_devHandle, 0, g_acm->readSize); in CheckHostSdkIfAllocRequest009()
1174 if (g_acm->readReq[i] == NULL) { in CheckHostSdkIfAllocRequest009()
1321 int32_t ret = UsbSubmitRequestSync(g_acm->readReq[0]); in CheckHostSdkIfSubmitRequestSync001()
1474 int32_t ret = UsbSubmitRequestAsync(g_acm->readReq[0]); in CheckHostSdkIfSubmitRequestAsync001()
[all …]
/ohos5.0/drivers/peripheral/usb/serial/src/
H A Dusb_serial_rawapi.c547 if (acm->readReq[i]->status != USB_REQUEST_COMPLETED) { in UsbSerialRead()
549 __func__, __LINE__, i, acm->readReq[i]->status); in UsbSerialRead()
673 ret = UsbRawSubmitRequest(acm->readReq[i]); in SerialOpen()
1159 acm->readReq[i] = UsbRawAllocRequest(acm->devHandle, 0, size); in UsbAllocReadRequests()
1160 if (!acm->readReq[i]) { in UsbAllocReadRequests()
1172 int32_t ret = UsbRawFillBulkRequest(acm->readReq[i], acm->devHandle, &reqData); in UsbAllocReadRequests()
1192 if (acm->readReq[i]) { in UsbFreeReadRequests()
1193 UsbRawFreeRequest(acm->readReq[i]); in UsbFreeReadRequests()
1194 acm->readReq[i] = NULL; in UsbFreeReadRequests()
H A Dusb_serial.c573 if (acm->readReq[i]->compInfo.status != USB_REQUEST_COMPLETED) { in UsbSerialRead()
575 __func__, __LINE__, i, acm->readReq[i]->compInfo.status); in UsbSerialRead()
923 ret = UsbSubmitRequestAsync(acm->readReq[i]); in SerialOpen()
1416 int32_t ret = UsbCancelRequest(acm->readReq[i]); in AcmFreeReadRequests()
1422 if (acm->readReq[i]) { in AcmFreeReadRequests()
1423 UsbFreeRequest(acm->readReq[i]); in AcmFreeReadRequests()
1424 acm->readReq[i] = NULL; in AcmFreeReadRequests()
1454 …acm->readReq[i] = UsbAllocRequest(InterfaceIdToHandle(acm, acm->dataInPipe->interfaceId), 0, acm->… in AcmAllocReadRequests()
1455 if (!acm->readReq[i]) { in AcmAllocReadRequests()
1469 …ret = UsbFillRequest(acm->readReq[i], InterfaceIdToHandle(acm, acm->dataInPipe->interfaceId), &rea… in AcmAllocReadRequests()
/ohos5.0/drivers/peripheral/usb/net/src/
H A Dcdc_ether.c288 if (ecm->readReq[i]->compInfo.status != USB_REQUEST_COMPLETED) { in EcmRead()
290 __func__, __LINE__, i, ecm->readReq[i]->compInfo.status); in EcmRead()
361 ret = UsbSubmitRequestAsync(ecm->readReq[i]); in EcmOpen()
387 ret = UsbCancelRequest(ecm->readReq[i]); in EcmClostRelease()
916 …ecm->readReq[i] = UsbAllocRequest(InterfaceIdToHandle(ecm, ecm->dataInPipe->interfaceId), 0, ecm->… in EcmAllocReadReq()
917 if (!ecm->readReq[i]) { in EcmAllocReadReq()
932 …UsbFillRequest(ecm->readReq[i], InterfaceIdToHandle(ecm, ecm->dataInPipe->interfaceId), &readParma… in EcmAllocReadReq()
944 ret = UsbFreeRequest(ecm->readReq[i]); in EcmFreeReadReq()
H A Dusb_net_host.c551 usbNet->readReq[i] = UsbRawAllocRequest(usbNet->devHandle, 0, size); in UsbnetHostAllocReadRequests()
552 if (!usbNet->readReq[i]) { in UsbnetHostAllocReadRequests()
565 int32_t ret = UsbRawFillBulkRequest(usbNet->readReq[i], usbNet->devHandle, &reqData); in UsbnetHostAllocReadRequests()
583 if (usbNet->readReq[i]) { in UsbnetHostFreeReadRequests()
584 UsbRawFreeRequest(usbNet->readReq[i]); in UsbnetHostFreeReadRequests()
585 usbNet->readReq[i] = NULL; in UsbnetHostFreeReadRequests()
789 ret = UsbRawSubmitRequest(usbNet->readReq[i]); in UsbnetHostAllocRequests()
/ohos5.0/base/hiviewdfx/hiview/plugins/event_store/event_export/task/include/
H A Devent_export_task.h37 bool InitReadRequest(std::shared_ptr<EventReadRequest> readReq) const;
/ohos5.0/drivers/peripheral/usb/sample/host/include/
H A Dusbhost_sdkraw_speed.h111 struct UsbRawRequest *readReq[ACM_NR]; member
H A Dusbhost_sdkapi_speed.h109 struct UsbRequest *readReq[ACM_NR]; member
/ohos5.0/drivers/peripheral/usb/sample/host/liteos_test/include/
H A Dusbhost_sdkraw_speed.h106 struct UsbRawRequest *readReq[ACM_NR]; member
H A Dusbhost_nosdk_speed.h103 struct UsbRequest *readReq[ACM_NR]; member
H A Dusbhost_sdkapi_speed.h106 struct UsbRequest *readReq[ACM_NR]; member
/ohos5.0/drivers/peripheral/usb/net/include/
H A Dcdc_ether.h98 struct UsbRequest *readReq[ECM_NR]; member
H A Dusb_net_host.h117 struct UsbRawRequest *readReq[USBNET_NR]; member
/ohos5.0/drivers/peripheral/usb/serial/include/
H A Dusb_serial_rawapi.h121 struct UsbRawRequest *readReq[ACM_NR]; member
H A Dusb_serial.h113 struct UsbRequest *readReq[ACM_NR]; member
/ohos5.0/docs/zh-cn/device-dev/driver/
H A Ddriver-peripherals-usb-des.md645 // 分配待发送的readReq IO Request对象
646 …acm->readReq[i] = UsbAllocRequest(InterfaceIdToHandle(acm, acm->dataInPipe->interfaceId), 0, acm->…
647 if (!acm->readReq[i]) {
648 HDF_LOGE("readReq request failed\n");
661 // 根据readParams填充预先分配待发送的readReq IO Request对象
662 …ret = UsbFillRequest(acm->readReq[i], InterfaceIdToHandle(acm, acm->dataInPipe->interfaceId), &rea…
868 ret = AcmAllocReadRequests((struct AcmDevice *)acm); // 分配并填充readReq IO Request对象
1223 acm->readReq[i] = UsbRawAllocRequest(acm->devHandle, 0, size);
1224 if (!acm->readReq[i]) {
1225 HDF_LOGE("readReq request failed\n");
[all …]

12