28 void stub_enqueue_ret_unlink(struct stub_device *sdev, __u32 seqnum,  in stub_enqueue_ret_unlink()  argument
35 		usbip_event_add(&sdev->ud, VDEV_EVENT_ERROR_MALLOC);  in stub_enqueue_ret_unlink()
42 	list_add_tail(&unlink->list, &sdev->unlink_tx);  in stub_enqueue_ret_unlink()
57 	struct stub_device *sdev = priv->sdev;  in stub_complete()  local
89 	spin_lock_irqsave(&sdev->priv_lock, flags);  in stub_complete()
90 	if (sdev->ud.tcp_socket == NULL) {  in stub_complete()
94 		stub_enqueue_ret_unlink(sdev, priv->seqnum, urb->status);  in stub_complete()
97 		list_move_tail(&priv->list, &sdev->priv_tx);  in stub_complete()
99 	spin_unlock_irqrestore(&sdev->priv_lock, flags);  in stub_complete()
102 	wake_up(&sdev->tx_waitq);  in stub_complete()
130 static struct stub_priv *dequeue_from_priv_tx(struct stub_device *sdev)  in dequeue_from_priv_tx()  argument
135 	spin_lock_irqsave(&sdev->priv_lock, flags);  in dequeue_from_priv_tx()
137 	list_for_each_entry_safe(priv, tmp, &sdev->priv_tx, list) {  in dequeue_from_priv_tx()
138 		list_move_tail(&priv->list, &sdev->priv_free);  in dequeue_from_priv_tx()
139 		spin_unlock_irqrestore(&sdev->priv_lock, flags);  in dequeue_from_priv_tx()
143 	spin_unlock_irqrestore(&sdev->priv_lock, flags);  in dequeue_from_priv_tx()
148 static int stub_send_ret_submit(struct stub_device *sdev)  in stub_send_ret_submit()  argument
158 	while ((priv = dequeue_from_priv_tx(sdev)) != NULL) {  in stub_send_ret_submit()
171 			dev_err(&sdev->udev->dev,  in stub_send_ret_submit()
185 			usbip_event_add(&sdev->ud, SDEV_EVENT_ERROR_MALLOC);  in stub_send_ret_submit()
232 				dev_err(&sdev->udev->dev,  in stub_send_ret_submit()
237 				usbip_event_add(&sdev->ud,  in stub_send_ret_submit()
249 				usbip_event_add(&sdev->ud,  in stub_send_ret_submit()
261 		ret = kernel_sendmsg(sdev->ud.tcp_socket, &msg,  in stub_send_ret_submit()
264 			dev_err(&sdev->udev->dev,  in stub_send_ret_submit()
269 			usbip_event_add(&sdev->ud, SDEV_EVENT_ERROR_TCP);  in stub_send_ret_submit()
279 	spin_lock_irqsave(&sdev->priv_lock, flags);  in stub_send_ret_submit()
280 	list_for_each_entry_safe(priv, tmp, &sdev->priv_free, list) {  in stub_send_ret_submit()
283 	spin_unlock_irqrestore(&sdev->priv_lock, flags);  in stub_send_ret_submit()
288 static struct stub_unlink *dequeue_from_unlink_tx(struct stub_device *sdev)  in dequeue_from_unlink_tx()  argument
293 	spin_lock_irqsave(&sdev->priv_lock, flags);  in dequeue_from_unlink_tx()
295 	list_for_each_entry_safe(unlink, tmp, &sdev->unlink_tx, list) {  in dequeue_from_unlink_tx()
296 		list_move_tail(&unlink->list, &sdev->unlink_free);  in dequeue_from_unlink_tx()
297 		spin_unlock_irqrestore(&sdev->priv_lock, flags);  in dequeue_from_unlink_tx()
301 	spin_unlock_irqrestore(&sdev->priv_lock, flags);  in dequeue_from_unlink_tx()
306 static int stub_send_ret_unlink(struct stub_device *sdev)  in stub_send_ret_unlink()  argument
317 	while ((unlink = dequeue_from_unlink_tx(sdev)) != NULL) {  in stub_send_ret_unlink()
336 		ret = kernel_sendmsg(sdev->ud.tcp_socket, &msg, iov,  in stub_send_ret_unlink()
339 			dev_err(&sdev->udev->dev,  in stub_send_ret_unlink()
342 			usbip_event_add(&sdev->ud, SDEV_EVENT_ERROR_TCP);  in stub_send_ret_unlink()
350 	spin_lock_irqsave(&sdev->priv_lock, flags);  in stub_send_ret_unlink()
352 	list_for_each_entry_safe(unlink, tmp, &sdev->unlink_free, list) {  in stub_send_ret_unlink()
357 	spin_unlock_irqrestore(&sdev->priv_lock, flags);  in stub_send_ret_unlink()
365 	struct stub_device *sdev = container_of(ud, struct stub_device, ud);  in stub_tx_loop()  local
385 		if (stub_send_ret_submit(sdev) < 0)  in stub_tx_loop()
388 		if (stub_send_ret_unlink(sdev) < 0)  in stub_tx_loop()
391 		wait_event_interruptible(sdev->tx_waitq,  in stub_tx_loop()
392 					 (!list_empty(&sdev->priv_tx) ||  in stub_tx_loop()
393 					  !list_empty(&sdev->unlink_tx) ||  in stub_tx_loop()