19 #include <sys/types.h> 23 #include <linux/if_tun.h> 24 #include <sys/ioctl.h> 25 #include <linux/virtio_net.h> 26 #include <linux/vhost.h> 27 #include <sys/eventfd.h> 30 #include <linux/netlink.h> 31 #include <linux/rtnetlink.h> 44 #define _IOCTL(fd,a,...) \ 45 if (ioctl (fd, a, __VA_ARGS__) < 0) \ 47 err = clib_error_return_unix (0, "ioctl(" #a ")"); \ 66 if (strncmp (netns,
"pid:", 4) == 0)
67 s =
format (0,
"/proc/%u/ns/net%c", atoi (netns + 4), 0);
68 else if (netns[0] ==
'/')
69 s =
format (0,
"%s%c", netns, 0);
71 s =
format (0,
"/var/run/netns/%s%c", netns, 0);
73 fd = open ((
char *) s, O_RDONLY);
89 int old_netns_fd = -1;
92 struct vhost_memory *vhost_mem = 0;
102 args->
rv = VNET_API_ERROR_INVALID_INTERFACE;
120 args->
rv = VNET_API_ERROR_UNSPECIFIED;
127 memset (&ifr, 0,
sizeof (ifr));
135 if ((vif->
fd = open (
"/dev/vhost-net", O_RDWR | O_NONBLOCK)) < 0)
137 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_1;
146 args->
rv = VNET_API_ERROR_UNSUPPORTED;
148 "VIRTIO_NET_F_MRG_RXBUF feature");
152 if ((vif->
remote_features & (1ULL << VIRTIO_RING_F_INDIRECT_DESC)) == 0)
154 args->
rv = VNET_API_ERROR_UNSUPPORTED;
156 "VIRTIO_RING_F_INDIRECT_DESC feature");
162 args->
rv = VNET_API_ERROR_UNSUPPORTED;
164 "VIRTIO_F_VERSION_1 features");
168 vif->
features |= 1ULL << VIRTIO_NET_F_MRG_RXBUF;
169 vif->
features |= 1ULL << VIRTIO_F_VERSION_1;
170 vif->
features |= 1ULL << VIRTIO_RING_F_INDIRECT_DESC;
172 _IOCTL (vif->
fd, VHOST_SET_FEATURES, &vif->
features);
174 if ((vif->
tap_fd = open (
"/dev/net/tun", O_RDWR | O_NONBLOCK)) < 0)
176 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_2;
181 ifr.ifr_flags = IFF_TAP | IFF_NO_PI | IFF_ONE_QUEUE | IFF_VNET_HDR;
182 _IOCTL (vif->
tap_fd, TUNSETIFF, (
void *) &ifr);
185 unsigned int offload = 0;
186 hdrsz =
sizeof (
struct virtio_net_hdr_v1);
187 _IOCTL (vif->
tap_fd, TUNSETOFFLOAD, offload);
188 _IOCTL (vif->
tap_fd, TUNSETVNETHDRSZ, &hdrsz);
189 _IOCTL (vif->
fd, VHOST_SET_OWNER, 0);
196 old_netns_fd = open (
"/proc/self/ns/net", O_RDONLY);
199 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_2;
208 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
211 if (setns (fd, CLONE_NEWNET) == -1)
213 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_3;
221 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_3;
236 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
248 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
259 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
272 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
284 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
292 args->
rv = VNET_API_ERROR_NETLINK_ERROR;
299 if (setns (old_netns_fd, CLONE_NEWNET) == -1)
301 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_2;
309 i =
sizeof (
struct vhost_memory) + sizeof (struct vhost_memory_region);
311 memset (vhost_mem, 0, i);
312 vhost_mem->nregions = 1;
313 vhost_mem->regions[0].memory_size = (1ULL << 47) - 4096;
314 _IOCTL (vif->
fd, VHOST_SET_MEM_TABLE, vhost_mem);
318 args->
rv = VNET_API_ERROR_INIT_FAILED;
324 args->
rv = VNET_API_ERROR_INIT_FAILED;
332 rnd = (
u32) (now * 1e6);
335 memcpy (args->
mac_addr + 2, &rnd, sizeof (rnd));
362 args->
rv = VNET_API_ERROR_INVALID_REGISTRATION;
378 vif->
flags |= VIRTIO_IF_FLAG_ADMIN_UP;
390 args->
rv = VNET_API_ERROR_SYSCALL_ERROR_3;
403 if (old_netns_fd != -1)
404 close (old_netns_fd);
419 return VNET_API_ERROR_INVALID_SW_IF_INDEX;
441 memset (vif, 0,
sizeof (*vif));
460 memset (tapid, 0,
sizeof (*tapid));
466 strlen ((
const char *) hi->
name)));
480 strlen ((
const char *) vif->
net_ns)));
497 *out_tapids = r_tapids;
u32 per_interface_next_index
clib_error_t * vnet_netlink_set_link_addr(int ifindex, u8 *mac)
#define vec_foreach_index(var, v)
Iterate over vector indices.
vlib_node_registration_t virtio_input_node
(constructor) VLIB_REGISTER_NODE (virtio_input_node)
#define hash_set(h, key, value)
sll srl srl sll sra u16x4 i
static u32 virtio_eth_flag_change(vnet_main_t *vnm, vnet_hw_interface_t *hi, u32 flags)
clib_error_t * vnet_netlink_set_link_state(int ifindex, int up)
clib_error_t * vnet_hw_interface_set_flags(vnet_main_t *vnm, u32 hw_if_index, u32 flags)
ip4_address_t host_ip4_addr
#define hash_unset(h, key)
ip4_address_t host_ip4_addr
void ethernet_delete_interface(vnet_main_t *vnm, u32 hw_if_index)
vnet_main_t * vnet_get_main(void)
static vnet_hw_interface_t * vnet_get_sup_hw_interface(vnet_main_t *vnm, u32 sw_if_index)
static f64 vlib_time_now(vlib_main_t *vm)
static vnet_hw_interface_t * vnet_get_hw_interface(vnet_main_t *vnm, u32 hw_if_index)
vnet_device_class_t virtio_device_class
#define vec_add2(V, P, N)
Add N elements to end of vector V, return pointer to new elements in P.
#define VNET_HW_INTERFACE_FLAG_LINK_UP
clib_error_t * vnet_netlink_set_link_name(int ifindex, char *new_ifname)
#define pool_get(P, E)
Allocate an object E from a pool P (unspecified alignment).
int tap_dump_ifs(tap_interface_details_t **out_tapids)
static void clib_spinlock_free(clib_spinlock_t *p)
static vnet_sw_interface_t * vnet_get_hw_sw_interface(vnet_main_t *vnm, u32 hw_if_index)
clib_error_t * vnet_netlink_set_link_netns(int ifindex, int netns_fd, char *new_ifname)
#define pool_foreach(VAR, POOL, BODY)
Iterate through pool.
#define VLIB_INIT_FUNCTION(x)
u32 last_used_interface_id
int tap_delete_if(vlib_main_t *vm, u32 sw_if_index)
#define clib_error_return(e, args...)
static void clib_spinlock_init(clib_spinlock_t *p)
#define pool_elt_at_index(p, i)
Returns pointer to element at given index.
#define clib_error_return_unix(e, args...)
#define pool_put(P, E)
Free an object E in pool P.
ip6_address_t host_ip6_addr
#define VNET_HW_INTERFACE_FLAG_SUPPORTS_INT_MODE
static int ethernet_mac_address_is_zero(u8 *mac)
static int open_netns_fd(char *netns)
#define vec_free(V)
Free vector's memory (no header).
ip6_address_t host_ip6_addr
#define clib_memcpy(a, b, c)
#define hash_create(elts, value_bytes)
void vnet_hw_interface_assign_rx_thread(vnet_main_t *vnm, u32 hw_if_index, u16 queue_id, uword thread_index)
clib_error_t * virtio_vring_init(vlib_main_t *vm, virtio_if_t *vif, u16 idx, u16 sz)
static void clib_mem_free(void *p)
clib_error_t * ethernet_register_interface(vnet_main_t *vnm, u32 dev_class_index, u32 dev_instance, u8 *address, u32 *hw_if_index_return, ethernet_flag_change_function_t flag_change)
clib_error_t * virtio_vring_free(vlib_main_t *vm, virtio_if_t *vif, u32 idx)
unsigned int if_nametoindex(const char *ifname)
static void * clib_mem_alloc(uword size)
virtio_main_t virtio_main
clib_error_t * vnet_netlink_add_ip6_addr(int ifindex, void *addr, int pfx_len)
void tap_create_if(vlib_main_t *vm, tap_create_if_args_t *args)
clib_error_t * vnet_netlink_add_ip4_addr(int ifindex, void *addr, int pfx_len)
int vnet_hw_interface_unassign_rx_thread(vnet_main_t *vnm, u32 hw_if_index, u16 queue_id)
static u32 random_u32(u32 *seed)
32-bit random number generator
TAP interface details struct.
static vlib_thread_main_t * vlib_get_thread_main()
clib_error_t * vnet_sw_interface_set_flags(vnet_main_t *vnm, u32 sw_if_index, u32 flags)
int vnet_hw_interface_set_rx_mode(vnet_main_t *vnm, u32 hw_if_index, u16 queue_id, vnet_hw_interface_rx_mode mode)
static void vnet_hw_interface_set_input_node(vnet_main_t *vnm, u32 hw_if_index, u32 node_index)
uword * dev_instance_by_interface_id
clib_error_t * vnet_netlink_set_link_master(int ifindex, char *master_ifname)
static clib_error_t * tap_init(vlib_main_t *vm)