Lines Matching defs:stream
468 static void uasp_cleanup_one_stream(struct f_uas *fu, struct uas_stream *stream)
471 if (!stream->req_in)
474 usb_ep_free_request(fu->ep_in, stream->req_in);
475 usb_ep_free_request(fu->ep_out, stream->req_out);
476 usb_ep_free_request(fu->ep_status, stream->req_status);
478 stream->req_in = NULL;
479 stream->req_out = NULL;
480 stream->req_status = NULL;
504 uasp_cleanup_one_stream(fu, &fu->stream[i]);
515 struct uas_stream *stream = cmd->stream;
527 stream->req_in->buf = cmd->data_buf;
529 stream->req_in->buf = NULL;
530 stream->req_in->num_sgs = se_cmd->t_data_nents;
531 stream->req_in->sg = se_cmd->t_data_sg;
534 stream->req_in->is_last = 1;
535 stream->req_in->complete = uasp_status_data_cmpl;
536 stream->req_in->length = se_cmd->data_length;
537 stream->req_in->context = cmd;
547 struct uas_stream *stream = cmd->stream;
558 stream->req_status->is_last = 1;
559 stream->req_status->context = cmd;
560 stream->req_status->length = se_cmd->scsi_sense_length + 16;
561 stream->req_status->buf = iu;
562 stream->req_status->complete = uasp_status_data_cmpl;
568 struct uas_stream *stream = cmd->stream;
580 ret = usb_ep_queue(fu->ep_in, stream->req_in, GFP_ATOMIC);
586 ret = usbg_prepare_w_request(cmd, stream->req_out);
589 ret = usb_ep_queue(fu->ep_out, stream->req_out, GFP_ATOMIC);
596 ret = usb_ep_queue(fu->ep_status, stream->req_status,
619 struct uas_stream *stream = cmd->stream;
623 stream->req_status->complete = uasp_status_data_cmpl;
624 stream->req_status->context = cmd;
627 return usb_ep_queue(fu->ep_status, stream->req_status, GFP_ATOMIC);
633 struct uas_stream *stream = cmd->stream;
645 ret = usb_ep_queue(fu->ep_in, stream->req_in, GFP_ATOMIC);
657 stream->req_status->complete = uasp_status_data_cmpl;
658 stream->req_status->context = cmd;
661 stream->req_status->buf = iu;
662 stream->req_status->length = sizeof(struct iu);
664 ret = usb_ep_queue(fu->ep_status, stream->req_status,
677 struct uas_stream *stream = cmd->stream;
688 ret = usbg_prepare_w_request(cmd, stream->req_out);
691 ret = usb_ep_queue(fu->ep_out, stream->req_out, GFP_ATOMIC);
700 stream->req_status->complete = uasp_status_data_cmpl;
701 stream->req_status->context = cmd;
704 stream->req_status->buf = iu;
705 stream->req_status->length = sizeof(struct iu);
707 ret = usb_ep_queue(fu->ep_status, stream->req_status,
741 static int uasp_alloc_stream_res(struct f_uas *fu, struct uas_stream *stream)
743 stream->req_in = usb_ep_alloc_request(fu->ep_in, GFP_KERNEL);
744 if (!stream->req_in)
747 stream->req_out = usb_ep_alloc_request(fu->ep_out, GFP_KERNEL);
748 if (!stream->req_out)
751 stream->req_status = usb_ep_alloc_request(fu->ep_status, GFP_KERNEL);
752 if (!stream->req_status)
758 usb_ep_free_request(fu->ep_out, stream->req_out);
759 stream->req_out = NULL;
761 usb_ep_free_request(fu->ep_in, stream->req_in);
762 stream->req_in = NULL;
794 struct uas_stream *s = &fu->stream[i];
814 ret = uasp_alloc_stream_res(fu, &fu->stream[i]);
836 uasp_cleanup_one_stream(fu, &fu->stream[i - 1]);
1132 cmd->stream = &fu->stream[0];
1134 cmd->stream = &fu->stream[cmd->tag - 1];
1136 cmd->stream = &fu->stream[0];