1 /* 2 * Copyright (C) 2015 Karol Kosik <karo9@interia.eu> 3 * Copyright (C) 2015-2016 Samsung Electronics 4 * Igor Kotrasinski <i.kotrasinsk@samsung.com> 5 * 6 * This program is free software; you can redistribute it and/or modify 7 * it under the terms of the GNU General Public License as published by 8 * the Free Software Foundation; either version 2 of the License, or 9 * (at your option) any later version. 10 * 11 * This program is distributed in the hope that it will be useful, 12 * but WITHOUT ANY WARRANTY; without even the implied warranty of 13 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the 14 * GNU General Public License for more details. 15 * 16 * You should have received a copy of the GNU General Public License 17 * along with this program. If not, see <http://www.gnu.org/licenses/>. 18 */ 19 20 #include <net/sock.h> 21 #include <linux/list.h> 22 #include <linux/kthread.h> 23 24 #include "usbip_common.h" 25 #include "vudc.h" 26 27 static int alloc_urb_from_cmd(struct urb **urbp, 28 struct usbip_header *pdu, u8 type) 29 { 30 struct urb *urb; 31 32 if (type == USB_ENDPOINT_XFER_ISOC) 33 urb = usb_alloc_urb(pdu->u.cmd_submit.number_of_packets, 34 GFP_KERNEL); 35 else 36 urb = usb_alloc_urb(0, GFP_KERNEL); 37 38 if (!urb) 39 goto err; 40 41 usbip_pack_pdu(pdu, urb, USBIP_CMD_SUBMIT, 0); 42 43 if (urb->transfer_buffer_length > 0) { 44 urb->transfer_buffer = kzalloc(urb->transfer_buffer_length, 45 GFP_KERNEL); 46 if (!urb->transfer_buffer) 47 goto free_urb; 48 } 49 50 urb->setup_packet = kmemdup(&pdu->u.cmd_submit.setup, 8, 51 GFP_KERNEL); 52 if (!urb->setup_packet) 53 goto free_buffer; 54 55 /* 56 * FIXME - we only setup pipe enough for usbip functions 57 * to behave nicely 58 */ 59 urb->pipe |= pdu->base.direction == USBIP_DIR_IN ? 60 USB_DIR_IN : USB_DIR_OUT; 61 62 *urbp = urb; 63 return 0; 64 65 free_buffer: 66 kfree(urb->transfer_buffer); 67 urb->transfer_buffer = NULL; 68 free_urb: 69 usb_free_urb(urb); 70 err: 71 return -ENOMEM; 72 } 73 74 static int v_recv_cmd_unlink(struct vudc *udc, 75 struct usbip_header *pdu) 76 { 77 unsigned long flags; 78 struct urbp *urb_p; 79 80 spin_lock_irqsave(&udc->lock, flags); 81 list_for_each_entry(urb_p, &udc->urb_queue, urb_entry) { 82 if (urb_p->seqnum != pdu->u.cmd_unlink.seqnum) 83 continue; 84 urb_p->urb->unlinked = -ECONNRESET; 85 urb_p->seqnum = pdu->base.seqnum; 86 v_kick_timer(udc, jiffies); 87 spin_unlock_irqrestore(&udc->lock, flags); 88 return 0; 89 } 90 /* Not found, completed / not queued */ 91 spin_lock(&udc->lock_tx); 92 v_enqueue_ret_unlink(udc, pdu->base.seqnum, 0); 93 wake_up(&udc->tx_waitq); 94 spin_unlock(&udc->lock_tx); 95 spin_unlock_irqrestore(&udc->lock, flags); 96 97 return 0; 98 } 99 100 static int v_recv_cmd_submit(struct vudc *udc, 101 struct usbip_header *pdu) 102 { 103 int ret = 0; 104 struct urbp *urb_p; 105 u8 address; 106 unsigned long flags; 107 108 urb_p = alloc_urbp(); 109 if (!urb_p) { 110 usbip_event_add(&udc->ud, VUDC_EVENT_ERROR_MALLOC); 111 return -ENOMEM; 112 } 113 114 /* base.ep is pipeendpoint(pipe) */ 115 address = pdu->base.ep; 116 if (pdu->base.direction == USBIP_DIR_IN) 117 address |= USB_DIR_IN; 118 119 spin_lock_irq(&udc->lock); 120 urb_p->ep = vudc_find_endpoint(udc, address); 121 if (!urb_p->ep) { 122 /* we don't know the type, there may be isoc data! */ 123 dev_err(&udc->pdev->dev, "request to nonexistent endpoint"); 124 spin_unlock_irq(&udc->lock); 125 usbip_event_add(&udc->ud, VUDC_EVENT_ERROR_TCP); 126 ret = -EPIPE; 127 goto free_urbp; 128 } 129 urb_p->type = urb_p->ep->type; 130 spin_unlock_irq(&udc->lock); 131 132 urb_p->new = 1; 133 urb_p->seqnum = pdu->base.seqnum; 134 135 ret = alloc_urb_from_cmd(&urb_p->urb, pdu, urb_p->ep->type); 136 if (ret) { 137 usbip_event_add(&udc->ud, VUDC_EVENT_ERROR_MALLOC); 138 ret = -ENOMEM; 139 goto free_urbp; 140 } 141 142 urb_p->urb->status = -EINPROGRESS; 143 144 /* FIXME: more pipe setup to please usbip_common */ 145 urb_p->urb->pipe &= ~(11 << 30); 146 switch (urb_p->ep->type) { 147 case USB_ENDPOINT_XFER_BULK: 148 urb_p->urb->pipe |= (PIPE_BULK << 30); 149 break; 150 case USB_ENDPOINT_XFER_INT: 151 urb_p->urb->pipe |= (PIPE_INTERRUPT << 30); 152 break; 153 case USB_ENDPOINT_XFER_CONTROL: 154 urb_p->urb->pipe |= (PIPE_CONTROL << 30); 155 break; 156 case USB_ENDPOINT_XFER_ISOC: 157 urb_p->urb->pipe |= (PIPE_ISOCHRONOUS << 30); 158 break; 159 } 160 ret = usbip_recv_xbuff(&udc->ud, urb_p->urb); 161 if (ret < 0) 162 goto free_urbp; 163 164 ret = usbip_recv_iso(&udc->ud, urb_p->urb); 165 if (ret < 0) 166 goto free_urbp; 167 168 spin_lock_irqsave(&udc->lock, flags); 169 v_kick_timer(udc, jiffies); 170 list_add_tail(&urb_p->urb_entry, &udc->urb_queue); 171 spin_unlock_irqrestore(&udc->lock, flags); 172 173 return 0; 174 175 free_urbp: 176 free_urbp_and_urb(urb_p); 177 return ret; 178 } 179 180 static int v_rx_pdu(struct usbip_device *ud) 181 { 182 int ret; 183 struct usbip_header pdu; 184 struct vudc *udc = container_of(ud, struct vudc, ud); 185 186 memset(&pdu, 0, sizeof(pdu)); 187 ret = usbip_recv(ud->tcp_socket, &pdu, sizeof(pdu)); 188 if (ret != sizeof(pdu)) { 189 usbip_event_add(ud, VUDC_EVENT_ERROR_TCP); 190 if (ret >= 0) 191 return -EPIPE; 192 return ret; 193 } 194 usbip_header_correct_endian(&pdu, 0); 195 196 spin_lock_irq(&ud->lock); 197 ret = (ud->status == SDEV_ST_USED); 198 spin_unlock_irq(&ud->lock); 199 if (!ret) { 200 usbip_event_add(ud, VUDC_EVENT_ERROR_TCP); 201 return -EBUSY; 202 } 203 204 switch (pdu.base.command) { 205 case USBIP_CMD_UNLINK: 206 ret = v_recv_cmd_unlink(udc, &pdu); 207 break; 208 case USBIP_CMD_SUBMIT: 209 ret = v_recv_cmd_submit(udc, &pdu); 210 break; 211 default: 212 ret = -EPIPE; 213 pr_err("rx: unknown command"); 214 break; 215 } 216 return ret; 217 } 218 219 int v_rx_loop(void *data) 220 { 221 struct usbip_device *ud = data; 222 int ret = 0; 223 224 while (!kthread_should_stop()) { 225 if (usbip_event_happened(ud)) 226 break; 227 ret = v_rx_pdu(ud); 228 if (ret < 0) { 229 pr_warn("v_rx exit with error %d", ret); 230 break; 231 } 232 } 233 return ret; 234 } 235