br2684.c 20.7 KB
Newer Older
L
Linus Torvalds 已提交
1
/*
2 3 4 5 6 7
 * Ethernet netdevice using ATM AAL5 as underlying carrier
 * (RFC1483 obsoleted by RFC2684) for Linux
 *
 * Authors: Marcell GAL, 2000, XDSL Ltd, Hungary
 *          Eric Kinzie, 2006-2007, US Naval Research Laboratory
 */
L
Linus Torvalds 已提交
8 9 10 11 12 13 14 15 16 17 18 19 20 21

#include <linux/module.h>
#include <linux/init.h>
#include <linux/kernel.h>
#include <linux/list.h>
#include <linux/netdevice.h>
#include <linux/skbuff.h>
#include <linux/etherdevice.h>
#include <linux/rtnetlink.h>
#include <linux/ip.h>
#include <asm/uaccess.h>
#include <net/arp.h>
#include <linux/atm.h>
#include <linux/atmdev.h>
22
#include <linux/capability.h>
L
Linus Torvalds 已提交
23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43
#include <linux/seq_file.h>

#include <linux/atmbr2684.h>

#include "common.h"

#ifdef SKB_DEBUG
static void skb_debug(const struct sk_buff *skb)
{
#define NUM2PRINT 50
	char buf[NUM2PRINT * 3 + 1];	/* 3 chars per byte */
	int i = 0;
	for (i = 0; i < skb->len && i < NUM2PRINT; i++) {
		sprintf(buf + i * 3, "%2.2x ", 0xff & skb->data[i]);
	}
	printk(KERN_DEBUG "br2684: skb: %s\n", buf);
}
#else
#define skb_debug(skb)	do {} while (0)
#endif

E
Eric Kinzie 已提交
44 45 46 47 48 49 50 51 52 53 54
#define BR2684_ETHERTYPE_LEN	2
#define BR2684_PAD_LEN		2

#define LLC		0xaa, 0xaa, 0x03
#define SNAP_BRIDGED	0x00, 0x80, 0xc2
#define SNAP_ROUTED	0x00, 0x00, 0x00
#define PID_ETHERNET	0x00, 0x07
#define ETHERTYPE_IPV4	0x08, 0x00
#define ETHERTYPE_IPV6	0x86, 0xdd
#define PAD_BRIDGED	0x00, 0x00

55 56 57
static const unsigned char ethertype_ipv4[] = { ETHERTYPE_IPV4 };
static const unsigned char ethertype_ipv6[] = { ETHERTYPE_IPV6 };
static const unsigned char llc_oui_pid_pad[] =
58
			{ LLC, SNAP_BRIDGED, PID_ETHERNET, PAD_BRIDGED };
59 60
static const unsigned char llc_oui_ipv4[] = { LLC, SNAP_ROUTED, ETHERTYPE_IPV4 };
static const unsigned char llc_oui_ipv6[] = { LLC, SNAP_ROUTED, ETHERTYPE_IPV6 };
L
Linus Torvalds 已提交
61 62

enum br2684_encaps {
63
	e_vc = BR2684_ENCAPS_VC,
L
Linus Torvalds 已提交
64 65 66 67
	e_llc = BR2684_ENCAPS_LLC,
};

struct br2684_vcc {
68
	struct atm_vcc *atmvcc;
L
Linus Torvalds 已提交
69
	struct net_device *device;
70 71
	/* keep old push, pop functions for chaining */
	void (*old_push) (struct atm_vcc * vcc, struct sk_buff * skb);
72
	void (*old_pop)(struct atm_vcc *vcc, struct sk_buff *skb);
L
Linus Torvalds 已提交
73 74 75 76 77 78 79 80 81 82 83 84
	enum br2684_encaps encaps;
	struct list_head brvccs;
#ifdef CONFIG_ATM_BR2684_IPFILTER
	struct br2684_filter filter;
#endif /* CONFIG_ATM_BR2684_IPFILTER */
	unsigned copies_needed, copies_failed;
};

struct br2684_dev {
	struct net_device *net_dev;
	struct list_head br2684_devs;
	int number;
85
	struct list_head brvccs;	/* one device <=> one vcc (before xmas) */
L
Linus Torvalds 已提交
86
	int mac_was_set;
E
Eric Kinzie 已提交
87
	enum br2684_payload payload;
L
Linus Torvalds 已提交
88 89 90 91 92 93 94 95 96 97 98 99 100 101 102
};

/*
 * This lock should be held for writing any time the list of devices or
 * their attached vcc's could be altered.  It should be held for reading
 * any time these are being queried.  Note that we sometimes need to
 * do read-locking under interrupt context, so write locking must block
 * the current CPU's interrupts
 */
static DEFINE_RWLOCK(devs_lock);

static LIST_HEAD(br2684_devs);

static inline struct br2684_dev *BRPRIV(const struct net_device *net_dev)
{
103
	return (struct br2684_dev *)netdev_priv(net_dev);
L
Linus Torvalds 已提交
104 105 106 107 108 109 110 111 112
}

static inline struct net_device *list_entry_brdev(const struct list_head *le)
{
	return list_entry(le, struct br2684_dev, br2684_devs)->net_dev;
}

static inline struct br2684_vcc *BR2684_VCC(const struct atm_vcc *atmvcc)
{
113
	return (struct br2684_vcc *)(atmvcc->user_back);
L
Linus Torvalds 已提交
114 115 116 117 118 119 120 121 122 123 124 125 126 127 128 129 130 131 132 133 134 135 136 137 138 139 140 141 142 143 144
}

static inline struct br2684_vcc *list_entry_brvcc(const struct list_head *le)
{
	return list_entry(le, struct br2684_vcc, brvccs);
}

/* Caller should hold read_lock(&devs_lock) */
static struct net_device *br2684_find_dev(const struct br2684_if_spec *s)
{
	struct list_head *lh;
	struct net_device *net_dev;
	switch (s->method) {
	case BR2684_FIND_BYNUM:
		list_for_each(lh, &br2684_devs) {
			net_dev = list_entry_brdev(lh);
			if (BRPRIV(net_dev)->number == s->spec.devnum)
				return net_dev;
		}
		break;
	case BR2684_FIND_BYIFNAME:
		list_for_each(lh, &br2684_devs) {
			net_dev = list_entry_brdev(lh);
			if (!strncmp(net_dev->name, s->spec.ifname, IFNAMSIZ))
				return net_dev;
		}
		break;
	}
	return NULL;
}

145 146 147 148 149 150 151 152 153 154 155 156 157 158 159 160
/* chained vcc->pop function.  Check if we should wake the netif_queue */
static void br2684_pop(struct atm_vcc *vcc, struct sk_buff *skb)
{
	struct br2684_vcc *brvcc = BR2684_VCC(vcc);
	struct net_device *net_dev = skb->dev;

	pr_debug("br2684_pop(vcc %p ; net_dev %p )\n", vcc, net_dev);
	brvcc->old_pop(vcc, skb);

	if (!net_dev)
		return;

	if (atm_may_send(vcc, 0))
		netif_wake_queue(net_dev);

}
L
Linus Torvalds 已提交
161 162 163 164 165
/*
 * Send a packet out a particular vcc.  Not to useful right now, but paves
 * the way for multiple vcc's per itf.  Returns true if we can send,
 * otherwise false
 */
S
Stephen Hemminger 已提交
166
static int br2684_xmit_vcc(struct sk_buff *skb, struct net_device *dev,
167
			   struct br2684_vcc *brvcc)
L
Linus Torvalds 已提交
168
{
S
Stephen Hemminger 已提交
169
	struct br2684_dev *brdev = BRPRIV(dev);
L
Linus Torvalds 已提交
170 171
	struct atm_vcc *atmvcc;
	int minheadroom = (brvcc->encaps == e_llc) ? 10 : 2;
E
Eric Kinzie 已提交
172

L
Linus Torvalds 已提交
173 174 175 176 177 178 179 180 181 182
	if (skb_headroom(skb) < minheadroom) {
		struct sk_buff *skb2 = skb_realloc_headroom(skb, minheadroom);
		brvcc->copies_needed++;
		dev_kfree_skb(skb);
		if (skb2 == NULL) {
			brvcc->copies_failed++;
			return 0;
		}
		skb = skb2;
	}
E
Eric Kinzie 已提交
183 184 185 186

	if (brvcc->encaps == e_llc) {
		if (brdev->payload == p_bridged) {
			skb_push(skb, sizeof(llc_oui_pid_pad));
187 188
			skb_copy_to_linear_data(skb, llc_oui_pid_pad,
						sizeof(llc_oui_pid_pad));
E
Eric Kinzie 已提交
189 190 191 192 193
		} else if (brdev->payload == p_routed) {
			unsigned short prot = ntohs(skb->protocol);

			skb_push(skb, sizeof(llc_oui_ipv4));
			switch (prot) {
194 195 196 197 198 199 200 201 202 203 204
			case ETH_P_IP:
				skb_copy_to_linear_data(skb, llc_oui_ipv4,
							sizeof(llc_oui_ipv4));
				break;
			case ETH_P_IPV6:
				skb_copy_to_linear_data(skb, llc_oui_ipv6,
							sizeof(llc_oui_ipv6));
				break;
			default:
				dev_kfree_skb(skb);
				return 0;
E
Eric Kinzie 已提交
205 206
			}
		}
207 208 209
	} else { /* e_vc */
		if (brdev->payload == p_bridged) {
			skb_push(skb, 2);
E
Eric Kinzie 已提交
210
			memset(skb->data, 0, 2);
211 212 213
		} else { /* p_routed */
			skb_pull(skb, ETH_HLEN);
		}
E
Eric Kinzie 已提交
214
	}
L
Linus Torvalds 已提交
215 216 217
	skb_debug(skb);

	ATM_SKB(skb)->vcc = atmvcc = brvcc->atmvcc;
218
	pr_debug("atm_skb(%p)->vcc(%p)->dev(%p)\n", skb, atmvcc, atmvcc->dev);
L
Linus Torvalds 已提交
219 220
	atomic_add(skb->truesize, &sk_atm(atmvcc)->sk_wmem_alloc);
	ATM_SKB(skb)->atm_options = atmvcc->atm_options;
S
Stephen Hemminger 已提交
221 222
	dev->stats.tx_packets++;
	dev->stats.tx_bytes += skb->len;
L
Linus Torvalds 已提交
223
	atmvcc->send(atmvcc, skb);
224 225 226 227 228 229 230 231

	if (!atm_may_send(atmvcc, 0)) {
		netif_stop_queue(brvcc->device);
		/*check for race with br2684_pop*/
		if (atm_may_send(atmvcc, 0))
			netif_start_queue(brvcc->device);
	}

L
Linus Torvalds 已提交
232 233 234
	return 1;
}

235 236
static inline struct br2684_vcc *pick_outgoing_vcc(const struct sk_buff *skb,
						   const struct br2684_dev *brdev)
L
Linus Torvalds 已提交
237
{
238
	return list_empty(&brdev->brvccs) ? NULL : list_entry_brvcc(brdev->brvccs.next);	/* 1 vcc/dev right now */
L
Linus Torvalds 已提交
239 240
}

241 242
static netdev_tx_t br2684_start_xmit(struct sk_buff *skb,
				     struct net_device *dev)
L
Linus Torvalds 已提交
243 244 245 246
{
	struct br2684_dev *brdev = BRPRIV(dev);
	struct br2684_vcc *brvcc;

E
Eric Dumazet 已提交
247
	pr_debug("br2684_start_xmit, skb_dst(skb)=%p\n", skb_dst(skb));
L
Linus Torvalds 已提交
248 249 250
	read_lock(&devs_lock);
	brvcc = pick_outgoing_vcc(skb, brdev);
	if (brvcc == NULL) {
251
		pr_debug("no vcc attached to dev %s\n", dev->name);
S
Stephen Hemminger 已提交
252 253
		dev->stats.tx_errors++;
		dev->stats.tx_carrier_errors++;
L
Linus Torvalds 已提交
254 255 256
		/* netif_stop_queue(dev); */
		dev_kfree_skb(skb);
		read_unlock(&devs_lock);
257
		return NETDEV_TX_OK;
L
Linus Torvalds 已提交
258
	}
S
Stephen Hemminger 已提交
259
	if (!br2684_xmit_vcc(skb, dev, brvcc)) {
L
Linus Torvalds 已提交
260 261 262
		/*
		 * We should probably use netif_*_queue() here, but that
		 * involves added complication.  We need to walk before
263 264 265
		 * we can run.
		 *
		 * Don't free here! this pointer might be no longer valid!
L
Linus Torvalds 已提交
266
		 */
S
Stephen Hemminger 已提交
267 268
		dev->stats.tx_errors++;
		dev->stats.tx_fifo_errors++;
L
Linus Torvalds 已提交
269 270
	}
	read_unlock(&devs_lock);
271
	return NETDEV_TX_OK;
L
Linus Torvalds 已提交
272 273 274 275 276 277 278 279
}

/*
 * We remember when the MAC gets set, so we don't override it later with
 * the ESI of the ATM card of the first VC
 */
static int br2684_mac_addr(struct net_device *dev, void *p)
{
280
	int err = eth_mac_addr(dev, p);
L
Linus Torvalds 已提交
281 282 283 284 285 286 287
	if (!err)
		BRPRIV(dev)->mac_was_set = 1;
	return err;
}

#ifdef CONFIG_ATM_BR2684_IPFILTER
/* this IOCTL is experimental. */
288
static int br2684_setfilt(struct atm_vcc *atmvcc, void __user * arg)
L
Linus Torvalds 已提交
289 290 291 292 293 294 295 296 297
{
	struct br2684_vcc *brvcc;
	struct br2684_filter_set fs;

	if (copy_from_user(&fs, arg, sizeof fs))
		return -EFAULT;
	if (fs.ifspec.method != BR2684_FIND_BYNOTHING) {
		/*
		 * This is really a per-vcc thing, but we can also search
298
		 * by device.
L
Linus Torvalds 已提交
299 300 301 302
		 */
		struct br2684_dev *brdev;
		read_lock(&devs_lock);
		brdev = BRPRIV(br2684_find_dev(&fs.ifspec));
303
		if (brdev == NULL || list_empty(&brdev->brvccs) || brdev->brvccs.next != brdev->brvccs.prev)	/* >1 VCC */
L
Linus Torvalds 已提交
304 305 306 307 308 309 310 311 312 313 314 315 316 317
			brvcc = NULL;
		else
			brvcc = list_entry_brvcc(brdev->brvccs.next);
		read_unlock(&devs_lock);
		if (brvcc == NULL)
			return -ESRCH;
	} else
		brvcc = BR2684_VCC(atmvcc);
	memcpy(&brvcc->filter, &fs.filter, sizeof(brvcc->filter));
	return 0;
}

/* Returns 1 if packet should be dropped */
static inline int
A
Al Viro 已提交
318
packet_fails_filter(__be16 type, struct br2684_vcc *brvcc, struct sk_buff *skb)
L
Linus Torvalds 已提交
319 320
{
	if (brvcc->filter.netmask == 0)
321
		return 0;	/* no filter in place */
322
	if (type == htons(ETH_P_IP) &&
323
	    (((struct iphdr *)(skb->data))->daddr & brvcc->filter.
L
Linus Torvalds 已提交
324 325
	     netmask) == brvcc->filter.prefix)
		return 0;
326
	if (type == htons(ETH_P_ARP))
L
Linus Torvalds 已提交
327
		return 0;
328 329 330
	/*
	 * TODO: we should probably filter ARPs too.. don't want to have
	 * them returning values that don't make sense, or is that ok?
L
Linus Torvalds 已提交
331 332 333 334 335 336 337
	 */
	return 1;		/* drop */
}
#endif /* CONFIG_ATM_BR2684_IPFILTER */

static void br2684_close_vcc(struct br2684_vcc *brvcc)
{
338
	pr_debug("removing VCC %p from dev %p\n", brvcc, brvcc->device);
L
Linus Torvalds 已提交
339 340 341 342 343 344 345 346 347 348 349 350 351 352 353 354
	write_lock_irq(&devs_lock);
	list_del(&brvcc->brvccs);
	write_unlock_irq(&devs_lock);
	brvcc->atmvcc->user_back = NULL;	/* what about vcc->recvq ??? */
	brvcc->old_push(brvcc->atmvcc, NULL);	/* pass on the bad news */
	kfree(brvcc);
	module_put(THIS_MODULE);
}

/* when AAL5 PDU comes in: */
static void br2684_push(struct atm_vcc *atmvcc, struct sk_buff *skb)
{
	struct br2684_vcc *brvcc = BR2684_VCC(atmvcc);
	struct net_device *net_dev = brvcc->device;
	struct br2684_dev *brdev = BRPRIV(net_dev);

355
	pr_debug("br2684_push\n");
L
Linus Torvalds 已提交
356 357 358 359 360

	if (unlikely(skb == NULL)) {
		/* skb==NULL means VCC is being destroyed */
		br2684_close_vcc(brvcc);
		if (list_empty(&brdev->brvccs)) {
361
			write_lock_irq(&devs_lock);
L
Linus Torvalds 已提交
362
			list_del(&brdev->br2684_devs);
363
			write_unlock_irq(&devs_lock);
L
Linus Torvalds 已提交
364
			unregister_netdev(net_dev);
365
			free_netdev(net_dev);
L
Linus Torvalds 已提交
366 367 368 369 370 371
		}
		return;
	}

	skb_debug(skb);
	atm_return(atmvcc, skb->truesize);
372
	pr_debug("skb from brdev %p\n", brdev);
L
Linus Torvalds 已提交
373
	if (brvcc->encaps == e_llc) {
E
Eric Kinzie 已提交
374 375 376 377 378 379

		if (skb->len > 7 && skb->data[7] == 0x01)
			__skb_trim(skb, skb->len - 4);

		/* accept packets that have "ipv[46]" in the snap header */
		if ((skb->len >= (sizeof(llc_oui_ipv4)))
380 381 382 383 384 385 386
		    &&
		    (memcmp
		     (skb->data, llc_oui_ipv4,
		      sizeof(llc_oui_ipv4) - BR2684_ETHERTYPE_LEN) == 0)) {
			if (memcmp
			    (skb->data + 6, ethertype_ipv6,
			     sizeof(ethertype_ipv6)) == 0)
387
				skb->protocol = htons(ETH_P_IPV6);
388 389 390
			else if (memcmp
				 (skb->data + 6, ethertype_ipv4,
				  sizeof(ethertype_ipv4)) == 0)
391
				skb->protocol = htons(ETH_P_IP);
392 393
			else
				goto error;
E
Eric Kinzie 已提交
394 395 396
			skb_pull(skb, sizeof(llc_oui_ipv4));
			skb_reset_network_header(skb);
			skb->pkt_type = PACKET_HOST;
397 398 399 400 401
			/*
			 * Let us waste some time for checking the encapsulation.
			 * Note, that only 7 char is checked so frames with a valid FCS
			 * are also accepted (but FCS is not checked of course).
			 */
E
Eric Kinzie 已提交
402
		} else if ((skb->len >= sizeof(llc_oui_pid_pad)) &&
403
			   (memcmp(skb->data, llc_oui_pid_pad, 7) == 0)) {
E
Eric Kinzie 已提交
404 405
			skb_pull(skb, sizeof(llc_oui_pid_pad));
			skb->protocol = eth_type_trans(skb, net_dev);
406 407
		} else
			goto error;
L
Linus Torvalds 已提交
408

409 410 411 412 413 414 415
	} else { /* e_vc */
		if (brdev->payload == p_routed) {
			struct iphdr *iph;

			skb_reset_network_header(skb);
			iph = ip_hdr(skb);
			if (iph->version == 4)
416
				skb->protocol = htons(ETH_P_IP);
417
			else if (iph->version == 6)
418
				skb->protocol = htons(ETH_P_IPV6);
419 420 421 422 423 424 425 426 427
			else
				goto error;
			skb->pkt_type = PACKET_HOST;
		} else { /* p_bridged */
			/* first 2 chars should be 0 */
			if (*((u16 *) (skb->data)) != 0)
				goto error;
			skb_pull(skb, BR2684_PAD_LEN);
			skb->protocol = eth_type_trans(skb, net_dev);
L
Linus Torvalds 已提交
428 429 430 431
		}
	}

#ifdef CONFIG_ATM_BR2684_IPFILTER
432 433
	if (unlikely(packet_fails_filter(skb->protocol, brvcc, skb)))
		goto dropped;
L
Linus Torvalds 已提交
434 435 436
#endif /* CONFIG_ATM_BR2684_IPFILTER */
	skb->dev = net_dev;
	ATM_SKB(skb)->vcc = atmvcc;	/* needed ? */
437
	pr_debug("received packet's protocol: %x\n", ntohs(skb->protocol));
L
Linus Torvalds 已提交
438
	skb_debug(skb);
439 440 441
	/* sigh, interface is down? */
	if (unlikely(!(net_dev->flags & IFF_UP)))
		goto dropped;
S
Stephen Hemminger 已提交
442 443
	net_dev->stats.rx_packets++;
	net_dev->stats.rx_bytes += skb->len;
L
Linus Torvalds 已提交
444 445
	memset(ATM_SKB(skb), 0, sizeof(struct atm_skb_data));
	netif_rx(skb);
446 447 448
	return;

dropped:
S
Stephen Hemminger 已提交
449
	net_dev->stats.rx_dropped++;
450 451
	goto free_skb;
error:
S
Stephen Hemminger 已提交
452
	net_dev->stats.rx_errors++;
453 454 455
free_skb:
	dev_kfree_skb(skb);
	return;
L
Linus Torvalds 已提交
456 457
}

458 459 460 461 462
/*
 * Assign a vcc to a dev
 * Note: we do not have explicit unassign, but look at _push()
 */
static int br2684_regvcc(struct atm_vcc *atmvcc, void __user * arg)
L
Linus Torvalds 已提交
463
{
464
	struct sk_buff_head queue;
L
Linus Torvalds 已提交
465 466
	int err;
	struct br2684_vcc *brvcc;
467
	struct sk_buff *skb, *tmp;
D
David S. Miller 已提交
468
	struct sk_buff_head *rq;
L
Linus Torvalds 已提交
469 470 471
	struct br2684_dev *brdev;
	struct net_device *net_dev;
	struct atm_backend_br2684 be;
D
David S. Miller 已提交
472
	unsigned long flags;
L
Linus Torvalds 已提交
473 474 475

	if (copy_from_user(&be, arg, sizeof be))
		return -EFAULT;
476
	brvcc = kzalloc(sizeof(struct br2684_vcc), GFP_KERNEL);
L
Linus Torvalds 已提交
477 478 479 480 481 482
	if (!brvcc)
		return -ENOMEM;
	write_lock_irq(&devs_lock);
	net_dev = br2684_find_dev(&be.ifspec);
	if (net_dev == NULL) {
		printk(KERN_ERR
483
		       "br2684: tried to attach to non-existant device\n");
L
Linus Torvalds 已提交
484 485 486 487 488 489 490 491 492 493 494 495 496 497 498
		err = -ENXIO;
		goto error;
	}
	brdev = BRPRIV(net_dev);
	if (atmvcc->push == NULL) {
		err = -EBADFD;
		goto error;
	}
	if (!list_empty(&brdev->brvccs)) {
		/* Only 1 VCC/dev right now */
		err = -EEXIST;
		goto error;
	}
	if (be.fcs_in != BR2684_FCSIN_NO || be.fcs_out != BR2684_FCSOUT_NO ||
	    be.fcs_auto || be.has_vpiid || be.send_padding || (be.encaps !=
499 500 501 502
							       BR2684_ENCAPS_VC
							       && be.encaps !=
							       BR2684_ENCAPS_LLC)
	    || be.min_size != 0) {
L
Linus Torvalds 已提交
503 504 505
		err = -EINVAL;
		goto error;
	}
506 507
	pr_debug("br2684_regvcc vcc=%p, encaps=%d, brvcc=%p\n", atmvcc,
		 be.encaps, brvcc);
L
Linus Torvalds 已提交
508 509 510 511 512 513 514 515 516 517 518 519
	if (list_empty(&brdev->brvccs) && !brdev->mac_was_set) {
		unsigned char *esi = atmvcc->dev->esi;
		if (esi[0] | esi[1] | esi[2] | esi[3] | esi[4] | esi[5])
			memcpy(net_dev->dev_addr, esi, net_dev->addr_len);
		else
			net_dev->dev_addr[2] = 1;
	}
	list_add(&brvcc->brvccs, &brdev->brvccs);
	write_unlock_irq(&devs_lock);
	brvcc->device = net_dev;
	brvcc->atmvcc = atmvcc;
	atmvcc->user_back = brvcc;
520
	brvcc->encaps = (enum br2684_encaps)be.encaps;
L
Linus Torvalds 已提交
521
	brvcc->old_push = atmvcc->push;
522
	brvcc->old_pop = atmvcc->pop;
L
Linus Torvalds 已提交
523 524
	barrier();
	atmvcc->push = br2684_push;
525
	atmvcc->pop = br2684_pop;
D
David S. Miller 已提交
526

527
	__skb_queue_head_init(&queue);
D
David S. Miller 已提交
528 529 530
	rq = &sk_atm(atmvcc)->sk_receive_queue;

	spin_lock_irqsave(&rq->lock, flags);
531
	skb_queue_splice_init(rq, &queue);
D
David S. Miller 已提交
532 533
	spin_unlock_irqrestore(&rq->lock, flags);

534 535
	skb_queue_walk_safe(&queue, skb, tmp) {
		struct net_device *dev = skb->dev;
D
David S. Miller 已提交
536

537 538
		dev->stats.rx_bytes -= skb->len;
		dev->stats.rx_packets--;
D
David S. Miller 已提交
539

540
		br2684_push(atmvcc, skb);
L
Linus Torvalds 已提交
541 542 543
	}
	__module_get(THIS_MODULE);
	return 0;
544
      error:
L
Linus Torvalds 已提交
545 546 547 548 549
	write_unlock_irq(&devs_lock);
	kfree(brvcc);
	return err;
}

550 551 552 553 554 555 556
static const struct net_device_ops br2684_netdev_ops = {
	.ndo_start_xmit 	= br2684_start_xmit,
	.ndo_set_mac_address	= br2684_mac_addr,
	.ndo_change_mtu		= eth_change_mtu,
	.ndo_validate_addr	= eth_validate_addr,
};

L
Linus Torvalds 已提交
557 558 559 560 561
static void br2684_setup(struct net_device *netdev)
{
	struct br2684_dev *brdev = BRPRIV(netdev);

	ether_setup(netdev);
562
	brdev->net_dev = netdev;
L
Linus Torvalds 已提交
563

564
	netdev->netdev_ops = &br2684_netdev_ops;
L
Linus Torvalds 已提交
565 566 567 568

	INIT_LIST_HEAD(&brdev->brvccs);
}

E
Eric Kinzie 已提交
569 570 571 572 573 574
static void br2684_setup_routed(struct net_device *netdev)
{
	struct br2684_dev *brdev = BRPRIV(netdev);
	brdev->net_dev = netdev;

	netdev->hard_header_len = 0;
575 576

	netdev->netdev_ops = &br2684_netdev_ops;
E
Eric Kinzie 已提交
577 578 579 580 581 582 583 584
	netdev->addr_len = 0;
	netdev->mtu = 1500;
	netdev->type = ARPHRD_PPP;
	netdev->flags = IFF_POINTOPOINT | IFF_NOARP | IFF_MULTICAST;
	netdev->tx_queue_len = 100;
	INIT_LIST_HEAD(&brdev->brvccs);
}

585
static int br2684_create(void __user * arg)
L
Linus Torvalds 已提交
586 587 588 589 590
{
	int err;
	struct net_device *netdev;
	struct br2684_dev *brdev;
	struct atm_newif_br2684 ni;
E
Eric Kinzie 已提交
591
	enum br2684_payload payload;
L
Linus Torvalds 已提交
592

593
	pr_debug("br2684_create\n");
L
Linus Torvalds 已提交
594 595 596 597

	if (copy_from_user(&ni, arg, sizeof ni)) {
		return -EFAULT;
	}
E
Eric Kinzie 已提交
598 599 600 601 602

	if (ni.media & BR2684_FLAG_ROUTED)
		payload = p_routed;
	else
		payload = p_bridged;
603
	ni.media &= 0xffff;	/* strip flags */
E
Eric Kinzie 已提交
604

L
Linus Torvalds 已提交
605 606 607 608 609 610
	if (ni.media != BR2684_MEDIA_ETHERNET || ni.mtu != 1500) {
		return -EINVAL;
	}

	netdev = alloc_netdev(sizeof(struct br2684_dev),
			      ni.ifname[0] ? ni.ifname : "nas%d",
E
Eric Kinzie 已提交
611
			      (payload == p_routed) ?
612
			      br2684_setup_routed : br2684_setup);
L
Linus Torvalds 已提交
613 614 615 616 617
	if (!netdev)
		return -ENOMEM;

	brdev = BRPRIV(netdev);

618
	pr_debug("registered netdev %s\n", netdev->name);
L
Linus Torvalds 已提交
619 620 621 622 623 624 625 626 627
	/* open, stop, do_ioctl ? */
	err = register_netdev(netdev);
	if (err < 0) {
		printk(KERN_ERR "br2684_create: register_netdev failed\n");
		free_netdev(netdev);
		return err;
	}

	write_lock_irq(&devs_lock);
E
Eric Kinzie 已提交
628
	brdev->payload = payload;
L
Linus Torvalds 已提交
629 630 631 632 633 634 635 636 637 638 639 640
	brdev->number = list_empty(&br2684_devs) ? 1 :
	    BRPRIV(list_entry_brdev(br2684_devs.prev))->number + 1;
	list_add_tail(&brdev->br2684_devs, &br2684_devs);
	write_unlock_irq(&devs_lock);
	return 0;
}

/*
 * This handles ioctls actually performed on our vcc - we must return
 * -ENOIOCTLCMD for any unrecognized ioctl
 */
static int br2684_ioctl(struct socket *sock, unsigned int cmd,
641
			unsigned long arg)
L
Linus Torvalds 已提交
642 643 644
{
	struct atm_vcc *atmvcc = ATM_SD(sock);
	void __user *argp = (void __user *)arg;
645
	atm_backend_t b;
L
Linus Torvalds 已提交
646 647

	int err;
648
	switch (cmd) {
L
Linus Torvalds 已提交
649
	case ATM_SETBACKEND:
650
	case ATM_NEWBACKENDIF:
L
Linus Torvalds 已提交
651 652 653 654 655 656 657 658 659 660 661 662 663 664 665 666 667 668
		err = get_user(b, (atm_backend_t __user *) argp);
		if (err)
			return -EFAULT;
		if (b != ATM_BACKEND_BR2684)
			return -ENOIOCTLCMD;
		if (!capable(CAP_NET_ADMIN))
			return -EPERM;
		if (cmd == ATM_SETBACKEND)
			return br2684_regvcc(atmvcc, argp);
		else
			return br2684_create(argp);
#ifdef CONFIG_ATM_BR2684_IPFILTER
	case BR2684_SETFILT:
		if (atmvcc->push != br2684_push)
			return -ENOIOCTLCMD;
		if (!capable(CAP_NET_ADMIN))
			return -EPERM;
		err = br2684_setfilt(atmvcc, argp);
669

L
Linus Torvalds 已提交
670 671 672 673 674 675 676
		return err;
#endif /* CONFIG_ATM_BR2684_IPFILTER */
	}
	return -ENOIOCTLCMD;
}

static struct atm_ioctl br2684_ioctl_ops = {
677 678
	.owner = THIS_MODULE,
	.ioctl = br2684_ioctl,
L
Linus Torvalds 已提交
679 680 681
};

#ifdef CONFIG_PROC_FS
682
static void *br2684_seq_start(struct seq_file *seq, loff_t * pos)
683
	__acquires(devs_lock)
L
Linus Torvalds 已提交
684 685
{
	read_lock(&devs_lock);
686
	return seq_list_start(&br2684_devs, *pos);
L
Linus Torvalds 已提交
687 688
}

689
static void *br2684_seq_next(struct seq_file *seq, void *v, loff_t * pos)
L
Linus Torvalds 已提交
690
{
691
	return seq_list_next(v, &br2684_devs, pos);
L
Linus Torvalds 已提交
692 693 694
}

static void br2684_seq_stop(struct seq_file *seq, void *v)
695
	__releases(devs_lock)
L
Linus Torvalds 已提交
696 697 698 699 700 701
{
	read_unlock(&devs_lock);
}

static int br2684_seq_show(struct seq_file *seq, void *v)
{
702
	const struct br2684_dev *brdev = list_entry(v, struct br2684_dev,
703
						    br2684_devs);
L
Linus Torvalds 已提交
704 705 706
	const struct net_device *net_dev = brdev->net_dev;
	const struct br2684_vcc *brvcc;

J
Johannes Berg 已提交
707
	seq_printf(seq, "dev %.16s: num=%d, mac=%pM (%s)\n",
708 709
		   net_dev->name,
		   brdev->number,
J
Johannes Berg 已提交
710
		   net_dev->dev_addr,
711
		   brdev->mac_was_set ? "set" : "auto");
L
Linus Torvalds 已提交
712 713

	list_for_each_entry(brvcc, &brdev->brvccs, brvccs) {
E
Eric Kinzie 已提交
714
		seq_printf(seq, "  vcc %d.%d.%d: encaps=%s payload=%s"
715 716 717 718 719 720
			   ", failed copies %u/%u"
			   "\n", brvcc->atmvcc->dev->number,
			   brvcc->atmvcc->vpi, brvcc->atmvcc->vci,
			   (brvcc->encaps == e_llc) ? "LLC" : "VC",
			   (brdev->payload == p_bridged) ? "bridged" : "routed",
			   brvcc->copies_failed, brvcc->copies_needed);
L
Linus Torvalds 已提交
721 722 723
#ifdef CONFIG_ATM_BR2684_IPFILTER
#define b1(var, byte)	((u8 *) &brvcc->filter.var)[byte]
#define bs(var)		b1(var, 0), b1(var, 1), b1(var, 2), b1(var, 3)
724 725 726
		if (brvcc->filter.netmask != 0)
			seq_printf(seq, "    filter=%d.%d.%d.%d/"
				   "%d.%d.%d.%d\n", bs(prefix), bs(netmask));
L
Linus Torvalds 已提交
727 728 729 730 731 732 733
#undef bs
#undef b1
#endif /* CONFIG_ATM_BR2684_IPFILTER */
	}
	return 0;
}

734
static const struct seq_operations br2684_seq_ops = {
L
Linus Torvalds 已提交
735
	.start = br2684_seq_start,
736 737 738
	.next = br2684_seq_next,
	.stop = br2684_seq_stop,
	.show = br2684_seq_show,
L
Linus Torvalds 已提交
739 740 741 742 743 744 745
};

static int br2684_proc_open(struct inode *inode, struct file *file)
{
	return seq_open(file, &br2684_seq_ops);
}

746
static const struct file_operations br2684_proc_ops = {
747 748 749 750
	.owner = THIS_MODULE,
	.open = br2684_proc_open,
	.read = seq_read,
	.llseek = seq_lseek,
L
Linus Torvalds 已提交
751 752 753 754
	.release = seq_release,
};

extern struct proc_dir_entry *atm_proc_root;	/* from proc.c */
755
#endif /* CONFIG_PROC_FS */
L
Linus Torvalds 已提交
756 757 758 759 760

static int __init br2684_init(void)
{
#ifdef CONFIG_PROC_FS
	struct proc_dir_entry *p;
761 762
	p = proc_create("br2684", 0, atm_proc_root, &br2684_proc_ops);
	if (p == NULL)
L
Linus Torvalds 已提交
763 764 765 766 767 768 769 770 771 772 773 774 775 776 777 778 779 780 781 782 783 784 785 786 787 788 789
		return -ENOMEM;
#endif
	register_atm_ioctl(&br2684_ioctl_ops);
	return 0;
}

static void __exit br2684_exit(void)
{
	struct net_device *net_dev;
	struct br2684_dev *brdev;
	struct br2684_vcc *brvcc;
	deregister_atm_ioctl(&br2684_ioctl_ops);

#ifdef CONFIG_PROC_FS
	remove_proc_entry("br2684", atm_proc_root);
#endif

	while (!list_empty(&br2684_devs)) {
		net_dev = list_entry_brdev(br2684_devs.next);
		brdev = BRPRIV(net_dev);
		while (!list_empty(&brdev->brvccs)) {
			brvcc = list_entry_brvcc(brdev->brvccs.next);
			br2684_close_vcc(brvcc);
		}

		list_del(&brdev->br2684_devs);
		unregister_netdev(net_dev);
790
		free_netdev(net_dev);
L
Linus Torvalds 已提交
791 792 793 794 795 796 797 798 799
	}
}

module_init(br2684_init);
module_exit(br2684_exit);

MODULE_AUTHOR("Marcell GAL");
MODULE_DESCRIPTION("RFC2684 bridged protocols over ATM/AAL5");
MODULE_LICENSE("GPL");