cregit-Linux how code gets into the kernel

Release 4.15 net/l2tp/l2tp_eth.c

Directory: net/l2tp
/*
 * L2TPv3 ethernet pseudowire driver
 *
 * Copyright (c) 2008,2009,2010 Katalix Systems Ltd
 *
 *      This program is free software; you can redistribute it and/or
 *      modify it under the terms of the GNU General Public License
 *      as published by the Free Software Foundation; either version
 *      2 of the License, or (at your option) any later version.
 */


#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt

#include <linux/module.h>
#include <linux/skbuff.h>
#include <linux/socket.h>
#include <linux/hash.h>
#include <linux/l2tp.h>
#include <linux/in.h>
#include <linux/etherdevice.h>
#include <linux/spinlock.h>
#include <net/sock.h>
#include <net/ip.h>
#include <net/icmp.h>
#include <net/udp.h>
#include <net/inet_common.h>
#include <net/inet_hashtables.h>
#include <net/tcp_states.h>
#include <net/protocol.h>
#include <net/xfrm.h>
#include <net/net_namespace.h>
#include <net/netns/generic.h>
#include <linux/ip.h>
#include <linux/ipv6.h>
#include <linux/udp.h>

#include "l2tp_core.h"

/* Default device name. May be overridden by name specified by user */

#define L2TP_ETH_DEV_NAME	"l2tpeth%d"

/* via netdev_priv() */

struct l2tp_eth {
	
struct l2tp_session	*session;
	
atomic_long_t		tx_bytes;
	
atomic_long_t		tx_packets;
	
atomic_long_t		tx_dropped;
	
atomic_long_t		rx_bytes;
	
atomic_long_t		rx_packets;
	
atomic_long_t		rx_errors;
};

/* via l2tp_session_priv() */

struct l2tp_eth_sess {
	
struct net_device __rcu *dev;
};



static int l2tp_eth_dev_init(struct net_device *dev) { eth_hw_addr_random(dev); eth_broadcast_addr(dev->broadcast); netdev_lockdep_set_classes(dev); return 0; }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman2477.42%116.67%
Eric Dumazet516.13%350.00%
Joe Perches13.23%116.67%
Danny Kukawka13.23%116.67%
Total31100.00%6100.00%


static void l2tp_eth_dev_uninit(struct net_device *dev) { struct l2tp_eth *priv = netdev_priv(dev); struct l2tp_eth_sess *spriv; spriv = l2tp_session_priv(priv->session); RCU_INIT_POINTER(spriv->dev, NULL); /* No need for synchronize_net() here. We're called by * unregister_netdev*(), which does the synchronisation for us. */ }

Contributors

PersonTokensPropCommitsCommitProp
Guillaume Nault3066.67%150.00%
James Chapman1533.33%150.00%
Total45100.00%2100.00%


static int l2tp_eth_dev_xmit(struct sk_buff *skb, struct net_device *dev) { struct l2tp_eth *priv = netdev_priv(dev); struct l2tp_session *session = priv->session; unsigned int len = skb->len; int ret = l2tp_xmit_skb(session, skb, session->hdr_len); if (likely(ret == NET_XMIT_SUCCESS)) { atomic_long_add(len, &priv->tx_bytes); atomic_long_inc(&priv->tx_packets); } else { atomic_long_inc(&priv->tx_dropped); } return NETDEV_TX_OK; }

Contributors

PersonTokensPropCommitsCommitProp
Eric Dumazet5656.00%375.00%
James Chapman4444.00%125.00%
Total100100.00%4100.00%


static void l2tp_eth_get_stats64(struct net_device *dev, struct rtnl_link_stats64 *stats) { struct l2tp_eth *priv = netdev_priv(dev); stats->tx_bytes = (unsigned long) atomic_long_read(&priv->tx_bytes); stats->tx_packets = (unsigned long) atomic_long_read(&priv->tx_packets); stats->tx_dropped = (unsigned long) atomic_long_read(&priv->tx_dropped); stats->rx_bytes = (unsigned long) atomic_long_read(&priv->rx_bytes); stats->rx_packets = (unsigned long) atomic_long_read(&priv->rx_packets); stats->rx_errors = (unsigned long) atomic_long_read(&priv->rx_errors); }

Contributors

PersonTokensPropCommitsCommitProp
Eric Dumazet9779.51%250.00%
Dominik Heidler2419.67%125.00%
Stephen Hemminger10.82%125.00%
Total122100.00%4100.00%

static const struct net_device_ops l2tp_eth_netdev_ops = { .ndo_init = l2tp_eth_dev_init, .ndo_uninit = l2tp_eth_dev_uninit, .ndo_start_xmit = l2tp_eth_dev_xmit, .ndo_get_stats64 = l2tp_eth_get_stats64, .ndo_set_mac_address = eth_mac_addr, }; static struct device_type l2tpeth_type = { .name = "l2tpeth", };
static void l2tp_eth_dev_setup(struct net_device *dev) { SET_NETDEV_DEVTYPE(dev, &l2tpeth_type); ether_setup(dev); dev->priv_flags &= ~IFF_TX_SKB_SHARING; dev->features |= NETIF_F_LLTX; dev->netdev_ops = &l2tp_eth_netdev_ops; dev->needs_free_netdev = true; }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman2754.00%120.00%
Guillaume Nault816.00%120.00%
Neil Horman714.00%120.00%
Eric Dumazet612.00%120.00%
David S. Miller24.00%120.00%
Total50100.00%5100.00%


static void l2tp_eth_dev_recv(struct l2tp_session *session, struct sk_buff *skb, int data_len) { struct l2tp_eth_sess *spriv = l2tp_session_priv(session); struct net_device *dev; struct l2tp_eth *priv; if (session->debug & L2TP_MSG_DATA) { unsigned int length; length = min(32u, skb->len); if (!pskb_may_pull(skb, length)) goto error; pr_debug("%s: eth recv\n", session->name); print_hex_dump_bytes("", DUMP_PREFIX_OFFSET, skb->data, length); } if (!pskb_may_pull(skb, ETH_HLEN)) goto error; secpath_reset(skb); /* checksums verified by L2TP */ skb->ip_summed = CHECKSUM_NONE; skb_dst_drop(skb); nf_reset(skb); rcu_read_lock(); dev = rcu_dereference(spriv->dev); if (!dev) goto error_rcu; priv = netdev_priv(dev); if (dev_forward_skb(dev, skb) == NET_RX_SUCCESS) { atomic_long_inc(&priv->rx_packets); atomic_long_add(data_len, &priv->rx_bytes); } else { atomic_long_inc(&priv->rx_errors); } rcu_read_unlock(); return; error_rcu: rcu_read_unlock(); error: kfree_skb(skb); }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman14465.75%120.00%
Guillaume Nault3515.98%120.00%
Eric Dumazet3315.07%240.00%
Joe Perches73.20%120.00%
Total219100.00%5100.00%


static void l2tp_eth_delete(struct l2tp_session *session) { struct l2tp_eth_sess *spriv; struct net_device *dev; if (session) { spriv = l2tp_session_priv(session); rtnl_lock(); dev = rtnl_dereference(spriv->dev); if (dev) { unregister_netdevice(dev); rtnl_unlock(); module_put(THIS_MODULE); } else { rtnl_unlock(); } } }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman5171.83%133.33%
Guillaume Nault1521.13%133.33%
Eric Dumazet57.04%133.33%
Total71100.00%3100.00%

#if IS_ENABLED(CONFIG_L2TP_DEBUGFS)
static void l2tp_eth_show(struct seq_file *m, void *arg) { struct l2tp_session *session = arg; struct l2tp_eth_sess *spriv = l2tp_session_priv(session); struct net_device *dev; rcu_read_lock(); dev = rcu_dereference(spriv->dev); if (!dev) { rcu_read_unlock(); return; } dev_hold(dev); rcu_read_unlock(); seq_printf(m, " interface %s\n", dev->name); dev_put(dev); }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman5059.52%150.00%
Guillaume Nault3440.48%150.00%
Total84100.00%2100.00%

#endif
static void l2tp_eth_adjust_mtu(struct l2tp_tunnel *tunnel, struct l2tp_session *session, struct net_device *dev) { unsigned int overhead = 0; struct dst_entry *dst; u32 l3_overhead = 0; /* if the encap is UDP, account for UDP header size */ if (tunnel->encap == L2TP_ENCAPTYPE_UDP) { overhead += sizeof(struct udphdr); dev->needed_headroom += sizeof(struct udphdr); } if (session->mtu != 0) { dev->mtu = session->mtu; dev->needed_headroom += session->hdr_len; return; } lock_sock(tunnel->sock); l3_overhead = kernel_sock_ip_overhead(tunnel->sock); release_sock(tunnel->sock); if (l3_overhead == 0) { /* L3 Overhead couldn't be identified, this could be * because tunnel->sock was NULL or the socket's * address family was not IPv4 or IPv6, * dev mtu stays at 1500. */ return; } /* Adjust MTU, factor overhead - underlay L3, overlay L2 hdr * UDP overhead, if any, was already factored in above. */ overhead += session->hdr_len + ETH_HLEN + l3_overhead; /* If PMTU discovery was enabled, use discovered MTU on L2TP device */ dst = sk_dst_get(tunnel->sock); if (dst) { /* dst_mtu will use PMTU if found, else fallback to intf MTU */ u32 pmtu = dst_mtu(dst); if (pmtu != 0) dev->mtu = pmtu; dst_release(dst); } session->mtu = dev->mtu - overhead; dev->mtu = session->mtu; dev->needed_headroom += session->hdr_len; }

Contributors

PersonTokensPropCommitsCommitProp
R. Parameswaran205100.00%2100.00%
Total205100.00%2100.00%


static int l2tp_eth_create(struct net *net, struct l2tp_tunnel *tunnel, u32 session_id, u32 peer_session_id, struct l2tp_session_cfg *cfg) { unsigned char name_assign_type; struct net_device *dev; char name[IFNAMSIZ]; struct l2tp_session *session; struct l2tp_eth *priv; struct l2tp_eth_sess *spriv; int rc; if (cfg->ifname) { strlcpy(name, cfg->ifname, IFNAMSIZ); name_assign_type = NET_NAME_USER; } else { strcpy(name, L2TP_ETH_DEV_NAME); name_assign_type = NET_NAME_ENUM; } session = l2tp_session_create(sizeof(*spriv), tunnel, session_id, peer_session_id, cfg); if (IS_ERR(session)) { rc = PTR_ERR(session); goto err; } dev = alloc_netdev(sizeof(*priv), name, name_assign_type, l2tp_eth_dev_setup); if (!dev) { rc = -ENOMEM; goto err_sess; } dev_net_set(dev, net); dev->min_mtu = 0; dev->max_mtu = ETH_MAX_MTU; l2tp_eth_adjust_mtu(tunnel, session, dev); priv = netdev_priv(dev); priv->session = session; session->recv_skb = l2tp_eth_dev_recv; session->session_close = l2tp_eth_delete; #if IS_ENABLED(CONFIG_L2TP_DEBUGFS) session->show = l2tp_eth_show; #endif spriv = l2tp_session_priv(session); l2tp_session_inc_refcount(session); rtnl_lock(); /* Register both device and session while holding the rtnl lock. This * ensures that l2tp_eth_delete() will see that there's a device to * unregister, even if it happened to run before we assign spriv->dev. */ rc = l2tp_session_register(session, tunnel); if (rc < 0) { rtnl_unlock(); goto err_sess_dev; } rc = register_netdevice(dev); if (rc < 0) { rtnl_unlock(); l2tp_session_delete(session); l2tp_session_dec_refcount(session); free_netdev(dev); return rc; } strlcpy(session->ifname, dev->name, IFNAMSIZ); rcu_assign_pointer(spriv->dev, dev); rtnl_unlock(); l2tp_session_dec_refcount(session); __module_get(THIS_MODULE); return 0; err_sess_dev: l2tp_session_dec_refcount(session); free_netdev(dev); err_sess: kfree(session); err: return rc; }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman22861.46%215.38%
Guillaume Nault11330.46%538.46%
Jarod Wilson123.23%17.69%
R. Parameswaran92.43%17.69%
David S. Miller41.08%17.69%
Eric Dumazet30.81%17.69%
Tom Gundersen10.27%17.69%
Javier Martinez Canillas10.27%17.69%
Total371100.00%13100.00%

static const struct l2tp_nl_cmd_ops l2tp_eth_nl_cmd_ops = { .session_create = l2tp_eth_create, .session_delete = l2tp_session_delete, };
static int __init l2tp_eth_init(void) { int err = 0; err = l2tp_nl_register_ops(L2TP_PWTYPE_ETH, &l2tp_eth_nl_cmd_ops); if (err) goto err; pr_info("L2TP ethernet pseudowire support (L2TPv3)\n"); return 0; err: return err; }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman4295.45%133.33%
Joe Perches12.27%133.33%
Guillaume Nault12.27%133.33%
Total44100.00%3100.00%


static void __exit l2tp_eth_exit(void) { l2tp_nl_unregister_ops(L2TP_PWTYPE_ETH); }

Contributors

PersonTokensPropCommitsCommitProp
James Chapman14100.00%1100.00%
Total14100.00%1100.00%

module_init(l2tp_eth_init); module_exit(l2tp_eth_exit); MODULE_LICENSE("GPL"); MODULE_AUTHOR("James Chapman <jchapman@katalix.com>"); MODULE_DESCRIPTION("L2TP ethernet pseudowire driver"); MODULE_VERSION("1.0"); MODULE_ALIAS_L2TP_PWTYPE(5);

Overall Contributors

PersonTokensPropCommitsCommitProp
James Chapman80050.47%26.06%
Guillaume Nault24915.71%721.21%
Eric Dumazet22814.38%824.24%
R. Parameswaran22314.07%26.06%
Dominik Heidler241.51%13.03%
Joe Perches161.01%26.06%
Jarod Wilson120.76%13.03%
David S. Miller100.63%26.06%
Neil Horman70.44%13.03%
Stephen Hemminger60.38%26.06%
Alexander Couzens50.32%13.03%
Javier Martinez Canillas20.13%13.03%
Julia Lawall10.06%13.03%
Danny Kukawka10.06%13.03%
Tom Gundersen10.06%13.03%
Total1585100.00%33100.00%
Directory: net/l2tp
Information contained on this website is for historical information purposes only and does not indicate or represent copyright ownership.
Created with cregit.