Lines Matching refs:req
60 struct UsbFnRequest *req = NULL;
65 req = DLIST_FIRST_ENTRY(pool, struct UsbFnRequest, list);
66 if (req == NULL) {
69 len = DataFifoRead(&port->writeFifo, req->buf, port->acm->dataInPipe.maxPacketSize);
73 req->length = len;
74 DListRemove(&req->list);
76 ret = UsbFnSubmitRequestAsync(req);
80 DListInsertTail(&req->list, pool);
97 struct UsbFnRequest *req = NULL;
104 req = DLIST_FIRST_ENTRY(pool, struct UsbFnRequest, list);
105 DListRemove(&req->list);
106 req->length = out->maxPacketSize;
107 ret = UsbFnSubmitRequestAsync(req);
110 DListInsertTail(&req->list, pool);
127 struct UsbFnRequest *req;
129 req = DLIST_FIRST_ENTRY(queue, struct UsbFnRequest, list);
130 switch (req->status) {
138 HDF_LOGV("%{public}s: unexpected status %{public}d", __func__, req->status);
142 if (g_inFifo && req->actual) {
143 uint32_t size = req->actual;
144 uint8_t *data = req->buf;
155 DListRemove(&req->list);
156 DListInsertTail(&req->list, &port->readPool);
167 struct UsbFnRequest *req = NULL;
169 req = DLIST_FIRST_ENTRY(head, struct UsbFnRequest, list);
170 DListRemove(&req->list);
171 (void)UsbFnCancelRequest(req);
172 (void)UsbFnFreeRequest(req);
185 static void UsbSerialReadComplete(uint8_t pipe, struct UsbFnRequest *req)
187 struct UsbSerial *port = (struct UsbSerial *)req->context;
188 if ((!g_isReadDone) && g_isStartRead && req->status == USB_REQUEST_COMPLETED) {
189 g_readCnt += req->actual;
196 DListInsertTail(&req->list, &port->readQueue);
299 static void UsbSerialWriteComplete(uint8_t pipe, struct UsbFnRequest *req)
301 struct UsbSerial *port = (struct UsbSerial *)req->context;
304 DListInsertTail(&req->list, &port->writePool);
307 switch (req->status) {
315 HDF_LOGV("%{public}s: unexpected status %{public}d", __func__, req->status);
325 struct UsbFnRequest *req = NULL;
329 req = UsbFnAllocRequest(acm->dataIface.handle, acm->dataOutPipe.id, acm->dataOutPipe.maxPacketSize);
330 if (!req) {
334 req->complete = UsbSerialReadComplete;
335 req->context = port;
336 DListInsertTail(&req->list, head);
346 struct UsbFnRequest *req = NULL;
350 req = UsbFnAllocRequest(acm->dataIface.handle, acm->dataInPipe.id, acm->dataInPipe.maxPacketSize);
351 if (!req) {
355 req->complete = UsbSerialWriteComplete;
356 req->context = port;
357 DListInsertTail(&req->list, head);
507 static void UsbSerialWriteSpeedComplete(uint8_t pipe, struct UsbFnRequest *req)
509 switch (req->status) {
511 g_writeCnt += req->actual;
517 UsbFnFreeRequest(req);
518 req = NULL;
520 if (memset_s(req->buf, req->length, 'a', req->length) != EOK) {
524 UsbFnSubmitRequestAsync(req);
531 HDF_LOGD("%{public}s: req->status = %{public}d", __func__, req->status);
937 static void AcmCtrlComplete(uint8_t pipe, struct UsbFnRequest *req)
939 if (req == NULL) {
942 struct CtrlInfo *ctrlInfo = (struct CtrlInfo *)req->context;
947 if (req->status != USB_REQUEST_COMPLETED) {
948 HDF_LOGD("%{public}s: ctrl completion error %{public}d", __func__, req->status);
953 struct UsbCdcLineCoding *value = req->buf;
954 if (req->actual == sizeof(*value)) {
964 DListInsertTail(&req->list, &acm->ctrlPool);
970 struct UsbFnRequest *req = NULL;
984 req = UsbFnAllocCtrlRequest(
986 if (req == NULL) {
989 req->complete = AcmCtrlComplete;
990 req->context = ctrlInfo;
991 DListInsertTail(&req->list, head);
1003 struct UsbFnRequest *req = NULL;
1006 req = DLIST_FIRST_ENTRY(head, struct UsbFnRequest, list);
1007 DListRemove(&req->list);
1008 OsalMemFree(req->context);
1009 (void)UsbFnFreeRequest(req);
1015 static void AcmNotifyComplete(uint8_t pipe, struct UsbFnRequest *req)
1017 struct UsbAcmDevice *acm = (struct UsbAcmDevice *)req->context;
1027 if (req->status == PENDING_FLAG) {
1030 acm->notifyReq = req;
1091 struct UsbFnRequest *req = NULL;
1095 req = DLIST_FIRST_ENTRY(pool, struct UsbFnRequest, list);
1096 DListRemove(&req->list);
1098 return req;
1106 struct UsbFnRequest *req = NULL;
1112 req = AcmGetCtrlReq(acm);
1113 if (req == NULL) {
1130 if (memcpy_s(req->buf, ret, &acm->lineCoding, ret) != EOK) {
1144 ctrlInfo = (struct CtrlInfo *)req->context;
1146 req->length = (uint32_t)ret;
1147 ret = UsbFnSubmitRequestAsync(req);
1241 struct UsbFnRequest *req = acm->notifyReq;
1245 if (req == NULL || req->buf == NULL) {
1246 HDF_LOGE("%{public}s: req is null", __func__);
1252 req->length = sizeof(*notify) + length;
1254 notify = (struct UsbCdcNotification *)req->buf;
1266 ret = UsbFnSubmitRequestAsync(req);
1269 acm->notifyReq = req;