Lines Matching +full:default +full:- +full:tap
1 // SPDX-License-Identifier: GPL-2.0-only
34 .name = "tap",
61 return rcu_dereference(dev->rx_handler_data); in tap_dev_get_rcu()
71 * through sock_hold(&q->sk). When the macvlan_dev goes away first,
72 * q->vlan becomes inaccessible. When the files gets closed,
81 static int tap_enable_queue(struct tap_dev *tap, struct file *file, in tap_enable_queue() argument
84 int err = -EINVAL; in tap_enable_queue()
88 if (q->enabled) in tap_enable_queue()
92 rcu_assign_pointer(tap->taps[tap->numvtaps], q); in tap_enable_queue()
93 q->queue_index = tap->numvtaps; in tap_enable_queue()
94 q->enabled = true; in tap_enable_queue()
96 tap->numvtaps++; in tap_enable_queue()
102 static int tap_set_queue(struct tap_dev *tap, struct file *file, in tap_set_queue() argument
105 if (tap->numqueues == MAX_TAP_QUEUES) in tap_set_queue()
106 return -EBUSY; in tap_set_queue()
108 rcu_assign_pointer(q->tap, tap); in tap_set_queue()
109 rcu_assign_pointer(tap->taps[tap->numvtaps], q); in tap_set_queue()
110 sock_hold(&q->sk); in tap_set_queue()
112 q->file = file; in tap_set_queue()
113 q->queue_index = tap->numvtaps; in tap_set_queue()
114 q->enabled = true; in tap_set_queue()
115 file->private_data = q; in tap_set_queue()
116 list_add_tail(&q->next, &tap->queue_list); in tap_set_queue()
118 tap->numvtaps++; in tap_set_queue()
119 tap->numqueues++; in tap_set_queue()
126 struct tap_dev *tap; in tap_disable_queue() local
130 if (!q->enabled) in tap_disable_queue()
131 return -EINVAL; in tap_disable_queue()
133 tap = rtnl_dereference(q->tap); in tap_disable_queue()
135 if (tap) { in tap_disable_queue()
136 int index = q->queue_index; in tap_disable_queue()
137 BUG_ON(index >= tap->numvtaps); in tap_disable_queue()
138 nq = rtnl_dereference(tap->taps[tap->numvtaps - 1]); in tap_disable_queue()
139 nq->queue_index = index; in tap_disable_queue()
141 rcu_assign_pointer(tap->taps[index], nq); in tap_disable_queue()
142 RCU_INIT_POINTER(tap->taps[tap->numvtaps - 1], NULL); in tap_disable_queue()
143 q->enabled = false; in tap_disable_queue()
145 tap->numvtaps--; in tap_disable_queue()
161 struct tap_dev *tap; in tap_put_queue() local
164 tap = rtnl_dereference(q->tap); in tap_put_queue()
166 if (tap) { in tap_put_queue()
167 if (q->enabled) in tap_put_queue()
170 tap->numqueues--; in tap_put_queue()
171 RCU_INIT_POINTER(q->tap, NULL); in tap_put_queue()
172 sock_put(&q->sk); in tap_put_queue()
173 list_del_init(&q->next); in tap_put_queue()
179 sock_put(&q->sk); in tap_put_queue()
186 * Cache vlan->numvtaps since it can become zero during the execution
189 static struct tap_queue *tap_get_queue(struct tap_dev *tap, in tap_get_queue() argument
195 * and validate that the result isn't NULL - in case we are in tap_get_queue()
198 int numvtaps = READ_ONCE(tap->numvtaps); in tap_get_queue()
210 queue = rcu_dereference(tap->taps[rxq % numvtaps]); in tap_get_queue()
218 rxq -= numvtaps; in tap_get_queue()
220 queue = rcu_dereference(tap->taps[rxq]); in tap_get_queue()
225 queue = rcu_dereference(tap->taps[0]); in tap_get_queue()
235 void tap_del_queues(struct tap_dev *tap) in tap_del_queues() argument
240 list_for_each_entry_safe(q, tmp, &tap->queue_list, next) { in tap_del_queues()
241 list_del_init(&q->next); in tap_del_queues()
242 RCU_INIT_POINTER(q->tap, NULL); in tap_del_queues()
243 if (q->enabled) in tap_del_queues()
244 tap->numvtaps--; in tap_del_queues()
245 tap->numqueues--; in tap_del_queues()
246 sock_put(&q->sk); in tap_del_queues()
248 BUG_ON(tap->numvtaps); in tap_del_queues()
249 BUG_ON(tap->numqueues); in tap_del_queues()
251 tap->numvtaps = MAX_TAP_QUEUES; in tap_del_queues()
258 struct net_device *dev = skb->dev; in tap_handle_frame()
259 struct tap_dev *tap; in tap_handle_frame() local
264 tap = tap_dev_get_rcu(dev); in tap_handle_frame()
265 if (!tap) in tap_handle_frame()
268 q = tap_get_queue(tap, skb); in tap_handle_frame()
278 if (q->flags & IFF_VNET_HDR) in tap_handle_frame()
279 features |= tap->tap_features; in tap_handle_frame()
290 if (ptr_ring_produce(&q->ring, skb)) { in tap_handle_frame()
300 if (ptr_ring_produce(&q->ring, skb)) { in tap_handle_frame()
308 /* If we receive a partial checksum and the tap side in tap_handle_frame()
313 if (skb->ip_summed == CHECKSUM_PARTIAL && in tap_handle_frame()
319 if (ptr_ring_produce(&q->ring, skb)) { in tap_handle_frame()
326 wake_up_interruptible_poll(sk_sleep(&q->sk), EPOLLIN | EPOLLRDNORM | EPOLLRDBAND); in tap_handle_frame()
331 if (tap->count_rx_dropped) in tap_handle_frame()
332 tap->count_rx_dropped(tap); in tap_handle_frame()
343 if (tap_major->major == major) in tap_get_major()
350 int tap_get_minor(dev_t major, struct tap_dev *tap) in tap_get_minor() argument
352 int retval = -ENOMEM; in tap_get_minor()
358 retval = -EINVAL; in tap_get_minor()
362 spin_lock(&tap_major->minor_lock); in tap_get_minor()
363 retval = idr_alloc(&tap_major->minor_idr, tap, 1, TAP_NUM_DEVS, GFP_ATOMIC); in tap_get_minor()
365 tap->minor = retval; in tap_get_minor()
366 } else if (retval == -ENOSPC) { in tap_get_minor()
367 netdev_err(tap->dev, "Too many tap devices\n"); in tap_get_minor()
368 retval = -EINVAL; in tap_get_minor()
370 spin_unlock(&tap_major->minor_lock); in tap_get_minor()
378 void tap_free_minor(dev_t major, struct tap_dev *tap) in tap_free_minor() argument
388 spin_lock(&tap_major->minor_lock); in tap_free_minor()
389 if (tap->minor) { in tap_free_minor()
390 idr_remove(&tap_major->minor_idr, tap->minor); in tap_free_minor()
391 tap->minor = 0; in tap_free_minor()
393 spin_unlock(&tap_major->minor_lock); in tap_free_minor()
403 struct tap_dev *tap; in dev_get_by_tap_file() local
409 tap = NULL; in dev_get_by_tap_file()
413 spin_lock(&tap_major->minor_lock); in dev_get_by_tap_file()
414 tap = idr_find(&tap_major->minor_idr, minor); in dev_get_by_tap_file()
415 if (tap) { in dev_get_by_tap_file()
416 dev = tap->dev; in dev_get_by_tap_file()
419 spin_unlock(&tap_major->minor_lock); in dev_get_by_tap_file()
423 return tap; in dev_get_by_tap_file()
431 !test_and_clear_bit(SOCKWQ_ASYNC_NOSPACE, &sk->sk_socket->flags)) in tap_sock_write_space()
443 ptr_ring_cleanup(&q->ring, __skb_array_destroy_skb); in tap_sock_destruct()
448 struct net *net = current->nsproxy->net_ns; in tap_open()
449 struct tap_dev *tap; in tap_open() local
451 int err = -ENODEV; in tap_open()
454 tap = dev_get_by_tap_file(imajor(inode), iminor(inode)); in tap_open()
455 if (!tap) in tap_open()
458 err = -ENOMEM; in tap_open()
463 if (ptr_ring_init(&q->ring, tap->dev->tx_queue_len, GFP_KERNEL)) { in tap_open()
464 sk_free(&q->sk); in tap_open()
468 init_waitqueue_head(&q->sock.wq.wait); in tap_open()
469 q->sock.type = SOCK_RAW; in tap_open()
470 q->sock.state = SS_CONNECTED; in tap_open()
471 q->sock.file = file; in tap_open()
472 q->sock.ops = &tap_socket_ops; in tap_open()
473 sock_init_data_uid(&q->sock, &q->sk, current_fsuid()); in tap_open()
474 q->sk.sk_write_space = tap_sock_write_space; in tap_open()
475 q->sk.sk_destruct = tap_sock_destruct; in tap_open()
476 q->flags = IFF_VNET_HDR | IFF_NO_PI | IFF_TAP; in tap_open()
477 q->vnet_hdr_sz = sizeof(struct virtio_net_hdr); in tap_open()
480 * so far only KVM virtio_net uses tap, enable zero copy between in tap_open()
486 if ((tap->dev->features & NETIF_F_HIGHDMA) && (tap->dev->features & NETIF_F_SG)) in tap_open()
487 sock_set_flag(&q->sk, SOCK_ZEROCOPY); in tap_open()
489 err = tap_set_queue(tap, file, q); in tap_open()
495 /* tap groks IOCB_NOWAIT just fine, mark it as such */ in tap_open()
496 file->f_mode |= FMODE_NOWAIT; in tap_open()
498 dev_put(tap->dev); in tap_open()
504 sock_put(&q->sk); in tap_open()
506 if (tap) in tap_open()
507 dev_put(tap->dev); in tap_open()
515 struct tap_queue *q = file->private_data; in tap_release()
522 struct tap_queue *q = file->private_data; in tap_poll()
529 poll_wait(file, &q->sock.wq.wait, wait); in tap_poll()
531 if (!ptr_ring_empty(&q->ring)) in tap_poll()
534 if (sock_writeable(&q->sk) || in tap_poll()
535 (!test_and_set_bit(SOCKWQ_ASYNC_NOSPACE, &q->sock.flags) && in tap_poll()
536 sock_writeable(&q->sk))) in tap_poll()
553 if (len - linear > MAX_SKB_FRAGS * (PAGE_SIZE << PAGE_ALLOC_COSTLY_ORDER)) in tap_alloc_skb()
554 linear = len - MAX_SKB_FRAGS * (PAGE_SIZE << PAGE_ALLOC_COSTLY_ORDER); in tap_alloc_skb()
555 skb = sock_alloc_send_pskb(sk, prepad + linear, len - linear, noblock, in tap_alloc_skb()
562 skb->data_len = len - linear; in tap_alloc_skb()
563 skb->len += len - linear; in tap_alloc_skb()
577 struct tap_dev *tap; in tap_get_user() local
590 if (q->flags & IFF_VNET_HDR) { in tap_get_user()
591 vnet_hdr_len = READ_ONCE(q->vnet_hdr_sz); in tap_get_user()
593 hdr_len = tun_vnet_hdr_get(vnet_hdr_len, q->flags, from, &vnet_hdr); in tap_get_user()
599 len -= vnet_hdr_len; in tap_get_user()
602 err = -EINVAL; in tap_get_user()
606 if (msg_control && sock_flag(&q->sk, SOCK_ZEROCOPY)) { in tap_get_user()
622 skb = tap_alloc_skb(&q->sk, TAP_RESERVE, copylen, in tap_get_user()
639 skb->protocol = eth_hdr(skb)->h_proto; in tap_get_user()
642 tap = rcu_dereference(q->tap); in tap_get_user()
643 if (!tap) { in tap_get_user()
648 skb->dev = tap->dev; in tap_get_user()
651 err = tun_vnet_hdr_to_skb(q->flags, skb, &vnet_hdr); in tap_get_user()
662 if (eth_type_vlan(skb->protocol) && in tap_get_user()
663 vlan_get_protocol_and_depth(skb, skb->protocol, &depth) != 0) in tap_get_user()
671 uarg->ops->complete(NULL, uarg, false); in tap_get_user()
683 tap = rcu_dereference(q->tap); in tap_get_user()
684 if (tap && tap->count_tx_dropped) in tap_get_user()
685 tap->count_tx_dropped(tap); in tap_get_user()
693 struct file *file = iocb->ki_filp; in tap_write_iter()
694 struct tap_queue *q = file->private_data; in tap_write_iter()
697 if ((file->f_flags & O_NONBLOCK) || (iocb->ki_flags & IOCB_NOWAIT)) in tap_write_iter()
713 if (q->flags & IFF_VNET_HDR) { in tap_put_user()
716 vnet_hdr_len = READ_ONCE(q->vnet_hdr_sz); in tap_put_user()
718 ret = tun_vnet_hdr_from_skb(q->flags, NULL, skb, &vnet_hdr); in tap_put_user()
727 total += skb->len; in tap_put_user()
734 veth.h_vlan_proto = skb->vlan_proto; in tap_put_user()
750 skb->len - vlan_offset); in tap_put_user()
773 prepare_to_wait(sk_sleep(&q->sk), &wait, in tap_do_read()
777 skb = ptr_ring_consume(&q->ring); in tap_do_read()
781 ret = -EAGAIN; in tap_do_read()
785 ret = -ERESTARTSYS; in tap_do_read()
792 finish_wait(sk_sleep(&q->sk), &wait); in tap_do_read()
807 struct file *file = iocb->ki_filp; in tap_read_iter()
808 struct tap_queue *q = file->private_data; in tap_read_iter()
812 if ((file->f_flags & O_NONBLOCK) || (iocb->ki_flags & IOCB_NOWAIT)) in tap_read_iter()
818 iocb->ki_pos = ret; in tap_read_iter()
824 struct tap_dev *tap; in tap_get_tap_dev() local
827 tap = rtnl_dereference(q->tap); in tap_get_tap_dev()
828 if (tap) in tap_get_tap_dev()
829 dev_hold(tap->dev); in tap_get_tap_dev()
831 return tap; in tap_get_tap_dev()
834 static void tap_put_tap_dev(struct tap_dev *tap) in tap_put_tap_dev() argument
836 dev_put(tap->dev); in tap_put_tap_dev()
841 struct tap_queue *q = file->private_data; in tap_ioctl_set_queue()
842 struct tap_dev *tap; in tap_ioctl_set_queue() local
845 tap = tap_get_tap_dev(q); in tap_ioctl_set_queue()
846 if (!tap) in tap_ioctl_set_queue()
847 return -EINVAL; in tap_ioctl_set_queue()
850 ret = tap_enable_queue(tap, file, q); in tap_ioctl_set_queue()
854 ret = -EINVAL; in tap_ioctl_set_queue()
856 tap_put_tap_dev(tap); in tap_ioctl_set_queue()
862 struct tap_dev *tap; in set_offload() local
866 tap = rtnl_dereference(q->tap); in set_offload()
867 if (!tap) in set_offload()
868 return -ENOLINK; in set_offload()
870 features = tap->dev->features; in set_offload()
889 /* tun/tap driver inverts the usage for TSO offloads, where in set_offload()
893 * For tap, we have to invert it to mean the same thing. in set_offload()
895 * user-space will not receive TSO frames. in set_offload()
903 /* tap_features are the same as features on tun/tap and in set_offload()
906 tap->tap_features = feature_mask; in set_offload()
907 if (tap->update_features) in set_offload()
908 tap->update_features(tap, features); in set_offload()
914 * provide compatibility with generic tun/tap interface
919 struct tap_queue *q = file->private_data; in tap_ioctl()
920 struct tap_dev *tap; in tap_ioctl() local
933 if (get_user(u, &ifr->ifr_flags)) in tap_ioctl()
934 return -EFAULT; in tap_ioctl()
938 ret = -EINVAL; in tap_ioctl()
940 q->flags = (q->flags & ~TAP_IFFEATURES) | u; in tap_ioctl()
946 tap = tap_get_tap_dev(q); in tap_ioctl()
947 if (!tap) { in tap_ioctl()
949 return -ENOLINK; in tap_ioctl()
953 u = q->flags; in tap_ioctl()
954 if (copy_to_user(&ifr->ifr_name, tap->dev->name, IFNAMSIZ) || in tap_ioctl()
955 put_user(u, &ifr->ifr_flags)) in tap_ioctl()
956 ret = -EFAULT; in tap_ioctl()
957 tap_put_tap_dev(tap); in tap_ioctl()
962 if (get_user(u, &ifr->ifr_flags)) in tap_ioctl()
963 return -EFAULT; in tap_ioctl()
971 return -EFAULT; in tap_ioctl()
976 return -EFAULT; in tap_ioctl()
978 return -EINVAL; in tap_ioctl()
980 q->sk.sk_sndbuf = s; in tap_ioctl()
988 return -EINVAL; in tap_ioctl()
997 tap = tap_get_tap_dev(q); in tap_ioctl()
998 if (!tap) { in tap_ioctl()
1000 return -ENOLINK; in tap_ioctl()
1003 netif_get_mac_address((struct sockaddr *)&ss, dev_net(tap->dev), in tap_ioctl()
1004 tap->dev->name); in tap_ioctl()
1005 if (copy_to_user(&ifr->ifr_name, tap->dev->name, IFNAMSIZ) || in tap_ioctl()
1006 copy_to_user(&ifr->ifr_hwaddr, &ss, sizeof(ifr->ifr_hwaddr))) in tap_ioctl()
1007 ret = -EFAULT; in tap_ioctl()
1008 tap_put_tap_dev(tap); in tap_ioctl()
1013 if (copy_from_user(&ss, &ifr->ifr_hwaddr, sizeof(ifr->ifr_hwaddr))) in tap_ioctl()
1014 return -EFAULT; in tap_ioctl()
1016 tap = tap_get_tap_dev(q); in tap_ioctl()
1017 if (!tap) { in tap_ioctl()
1019 return -ENOLINK; in tap_ioctl()
1021 if (tap->dev->addr_len > sizeof(ifr->ifr_hwaddr)) in tap_ioctl()
1022 ret = -EINVAL; in tap_ioctl()
1024 ret = dev_set_mac_address_user(tap->dev, &ss, NULL); in tap_ioctl()
1025 tap_put_tap_dev(tap); in tap_ioctl()
1029 default: in tap_ioctl()
1030 return tun_vnet_ioctl(&q->vnet_hdr_sz, &q->flags, cmd, sp); in tap_ioctl()
1047 struct virtio_net_hdr *gso = xdp->data_hard_start; in tap_get_user_xdp()
1048 int buflen = xdp->frame_sz; in tap_get_user_xdp()
1050 struct tap_dev *tap; in tap_get_user_xdp() local
1054 if (unlikely(xdp->data_end - xdp->data < ETH_HLEN)) { in tap_get_user_xdp()
1055 err = -EINVAL; in tap_get_user_xdp()
1059 if (q->flags & IFF_VNET_HDR) in tap_get_user_xdp()
1060 vnet_hdr_len = READ_ONCE(q->vnet_hdr_sz); in tap_get_user_xdp()
1062 skb = build_skb(xdp->data_hard_start, buflen); in tap_get_user_xdp()
1064 err = -ENOMEM; in tap_get_user_xdp()
1068 skb_reserve(skb, xdp->data - xdp->data_hard_start); in tap_get_user_xdp()
1069 skb_put(skb, xdp->data_end - xdp->data); in tap_get_user_xdp()
1073 skb->protocol = eth_hdr(skb)->h_proto; in tap_get_user_xdp()
1076 err = tun_vnet_hdr_to_skb(q->flags, skb, gso); in tap_get_user_xdp()
1082 if (eth_type_vlan(skb->protocol) && in tap_get_user_xdp()
1083 vlan_get_protocol_and_depth(skb, skb->protocol, &depth) != 0) in tap_get_user_xdp()
1087 tap = rcu_dereference(q->tap); in tap_get_user_xdp()
1088 if (tap) { in tap_get_user_xdp()
1089 skb->dev = tap->dev; in tap_get_user_xdp()
1103 tap = rcu_dereference(q->tap); in tap_get_user_xdp()
1104 if (tap && tap->count_tx_dropped) in tap_get_user_xdp()
1105 tap->count_tx_dropped(tap); in tap_get_user_xdp()
1114 struct tun_msg_ctl *ctl = m->msg_control; in tap_sendmsg()
1118 if (m->msg_controllen == sizeof(struct tun_msg_ctl) && in tap_sendmsg()
1119 ctl && ctl->type == TUN_MSG_PTR) { in tap_sendmsg()
1120 for (i = 0; i < ctl->num; i++) { in tap_sendmsg()
1121 xdp = &((struct xdp_buff *)ctl->ptr)[i]; in tap_sendmsg()
1127 return tap_get_user(q, ctl ? ctl->ptr : NULL, &m->msg_iter, in tap_sendmsg()
1128 m->msg_flags & MSG_DONTWAIT); in tap_sendmsg()
1135 struct sk_buff *skb = m->msg_control; in tap_recvmsg()
1139 return -EINVAL; in tap_recvmsg()
1141 ret = tap_do_read(q, &m->msg_iter, flags & MSG_DONTWAIT, skb); in tap_recvmsg()
1143 m->msg_flags |= MSG_TRUNC; in tap_recvmsg()
1153 return PTR_RING_PEEK_CALL(&q->ring, __skb_array_len_with_tag); in tap_peek_len()
1170 if (file->f_op != &tap_fops) in tap_get_socket()
1171 return ERR_PTR(-EINVAL); in tap_get_socket()
1172 q = file->private_data; in tap_get_socket()
1174 return ERR_PTR(-EBADFD); in tap_get_socket()
1175 return &q->sock; in tap_get_socket()
1183 if (file->f_op != &tap_fops) in tap_get_ptr_ring()
1184 return ERR_PTR(-EINVAL); in tap_get_ptr_ring()
1185 q = file->private_data; in tap_get_ptr_ring()
1187 return ERR_PTR(-EBADFD); in tap_get_ptr_ring()
1188 return &q->ring; in tap_get_ptr_ring()
1192 int tap_queue_resize(struct tap_dev *tap) in tap_queue_resize() argument
1194 struct net_device *dev = tap->dev; in tap_queue_resize()
1197 int n = tap->numqueues; in tap_queue_resize()
1202 return -ENOMEM; in tap_queue_resize()
1204 list_for_each_entry(q, &tap->queue_list, next) in tap_queue_resize()
1205 rings[i++] = &q->ring; in tap_queue_resize()
1208 dev->tx_queue_len, GFP_KERNEL, in tap_queue_resize()
1222 return -ENOMEM; in tap_list_add()
1224 tap_major->major = MAJOR(major); in tap_list_add()
1226 idr_init(&tap_major->minor_idr); in tap_list_add()
1227 spin_lock_init(&tap_major->minor_lock); in tap_list_add()
1229 tap_major->device_name = device_name; in tap_list_add()
1231 list_add_tail_rcu(&tap_major->next, &major_list); in tap_list_add()
1245 tap_cdev->owner = module; in tap_create_cdev()
1272 if (tap_major->major == MAJOR(major)) { in tap_destroy_cdev()
1273 idr_destroy(&tap_major->minor_idr); in tap_destroy_cdev()
1274 list_del_rcu(&tap_major->next); in tap_destroy_cdev()
1281 MODULE_DESCRIPTION("Common library for drivers implementing the TAP interface");