bond_sysfs.c 45.3 KB
Newer Older
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21
/*
 * Copyright(c) 2004-2005 Intel Corporation. All rights reserved.
 *
 * 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.
 *
 * This program is distributed in the hope that it will be useful, but
 * WITHOUT ANY WARRANTY; without even the implied warranty of MERCHANTABILITY
 * or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU General Public License
 * for more details.
 *
 * You should have received a copy of the GNU General Public License along
 * with this program; if not, write to the Free Software Foundation, Inc.,
 * 59 Temple Place - Suite 330, Boston, MA  02111-1307, USA.
 *
 * The full GNU General Public License is included in this distribution in the
 * file called LICENSE.
 *
 */
J
Joe Perches 已提交
22 23 24

#define pr_fmt(fmt) KBUILD_MODNAME ": " fmt

25 26 27
#include <linux/kernel.h>
#include <linux/module.h>
#include <linux/device.h>
28
#include <linux/sched.h>
29 30 31 32 33 34 35 36 37 38
#include <linux/fs.h>
#include <linux/types.h>
#include <linux/string.h>
#include <linux/netdevice.h>
#include <linux/inetdevice.h>
#include <linux/in.h>
#include <linux/sysfs.h>
#include <linux/ctype.h>
#include <linux/inet.h>
#include <linux/rtnetlink.h>
39
#include <linux/etherdevice.h>
40
#include <net/net_namespace.h>
41 42
#include <net/netns/generic.h>
#include <linux/nsproxy.h>
43
#include <linux/reciprocal_div.h>
44 45

#include "bonding.h"
46

S
Stephen Hemminger 已提交
47
#define to_dev(obj)	container_of(obj, struct device, kobj)
48
#define to_bond(cd)	((struct bonding *)(netdev_priv(to_net_dev(cd))))
49 50 51 52 53

/*
 * "show" function for the bond_masters attribute.
 * The class parameter is ignored.
 */
54 55 56
static ssize_t bonding_show_bonds(struct class *cls,
				  struct class_attribute *attr,
				  char *buf)
57
{
58 59
	struct bond_net *bn =
		container_of(attr, struct bond_net, class_attr_bonding_masters);
60 61 62
	int res = 0;
	struct bonding *bond;

63
	rtnl_lock();
64

65
	list_for_each_entry(bond, &bn->dev_list, bond_list) {
66 67 68 69
		if (res > (PAGE_SIZE - IFNAMSIZ)) {
			/* not enough space for another interface name */
			if ((PAGE_SIZE - res) > 10)
				res = PAGE_SIZE - 10;
70
			res += sprintf(buf + res, "++more++ ");
71 72
			break;
		}
73
		res += sprintf(buf + res, "%s ", bond->dev->name);
74
	}
75 76
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
77 78

	rtnl_unlock();
79 80 81
	return res;
}

82
static struct net_device *bond_get_by_name(struct bond_net *bn, const char *ifname)
83 84 85
{
	struct bonding *bond;

86
	list_for_each_entry(bond, &bn->dev_list, bond_list) {
87 88 89 90 91 92
		if (strncmp(bond->dev->name, ifname, IFNAMSIZ) == 0)
			return bond->dev;
	}
	return NULL;
}

93 94 95 96 97 98 99 100
/*
 * "store" function for the bond_masters attribute.  This is what
 * creates and deletes entire bonds.
 *
 * The class parameter is ignored.
 *
 */

S
Stephen Hemminger 已提交
101
static ssize_t bonding_store_bonds(struct class *cls,
102
				   struct class_attribute *attr,
S
Stephen Hemminger 已提交
103
				   const char *buffer, size_t count)
104
{
105 106
	struct bond_net *bn =
		container_of(attr, struct bond_net, class_attr_bonding_masters);
107 108
	char command[IFNAMSIZ + 1] = {0, };
	char *ifname;
109
	int rv, res = count;
110 111 112 113 114 115 116 117

	sscanf(buffer, "%16s", command); /* IFNAMSIZ*/
	ifname = command + 1;
	if ((strlen(command) <= 1) ||
	    !dev_valid_name(ifname))
		goto err_no_cmd;

	if (command[0] == '+') {
J
Joe Perches 已提交
118
		pr_info("%s is being created...\n", ifname);
119
		rv = bond_create(bn->net, ifname);
120
		if (rv) {
121 122 123 124
			if (rv == -EEXIST)
				pr_info("%s already exists.\n", ifname);
			else
				pr_info("%s creation failed.\n", ifname);
125
			res = rv;
126
		}
127 128
	} else if (command[0] == '-') {
		struct net_device *bond_dev;
129

130
		rtnl_lock();
131
		bond_dev = bond_get_by_name(bn, ifname);
132
		if (bond_dev) {
J
Joe Perches 已提交
133
			pr_info("%s is being deleted...\n", ifname);
134 135
			unregister_netdevice(bond_dev);
		} else {
J
Joe Perches 已提交
136
			pr_err("unable to delete non-existent %s\n", ifname);
137 138 139 140 141
			res = -ENODEV;
		}
		rtnl_unlock();
	} else
		goto err_no_cmd;
142

143 144 145 146
	/* Always return either count or an error.  If you return 0, you'll
	 * get called forever, which is bad.
	 */
	return res;
147 148

err_no_cmd:
J
Joe Perches 已提交
149
	pr_err("no command found in bonding_masters. Use +ifname or -ifname.\n");
150
	return -EPERM;
151
}
152

153
/* class attribute for bond_masters file.  This ends up in /sys/class/net */
154 155 156 157 158 159 160 161
static const struct class_attribute class_attr_bonding_masters = {
	.attr = {
		.name = "bonding_masters",
		.mode = S_IWUSR | S_IRUGO,
	},
	.show = bonding_show_bonds,
	.store = bonding_store_bonds,
};
162 163 164 165

/*
 * Show the slaves in the current bond.
 */
166 167
static ssize_t bonding_show_slaves(struct device *d,
				   struct device_attribute *attr, char *buf)
168
{
169
	struct bonding *bond = to_bond(d);
170
	struct list_head *iter;
171 172
	struct slave *slave;
	int res = 0;
173

174 175 176
	if (!rtnl_trylock())
		return restart_syscall();

177
	bond_for_each_slave(bond, slave, iter) {
178 179 180 181
		if (res > (PAGE_SIZE - IFNAMSIZ)) {
			/* not enough space for another interface name */
			if ((PAGE_SIZE - res) > 10)
				res = PAGE_SIZE - 10;
182
			res += sprintf(buf + res, "++more++ ");
183 184 185 186
			break;
		}
		res += sprintf(buf + res, "%s ", slave->dev->name);
	}
187 188 189

	rtnl_unlock();

190 191
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
192

193 194 195 196
	return res;
}

/*
197
 * Set the slaves in the current bond.
198 199
 * This is supposed to be only thin wrapper for bond_enslave and bond_release.
 * All hard work should be done there.
200
 */
201 202 203
static ssize_t bonding_store_slaves(struct device *d,
				    struct device_attribute *attr,
				    const char *buffer, size_t count)
204 205 206
{
	char command[IFNAMSIZ + 1] = { 0, };
	char *ifname;
207 208
	int res, ret = count;
	struct net_device *dev;
209
	struct bonding *bond = to_bond(d);
210

211 212
	if (!rtnl_trylock())
		return restart_syscall();
213

214 215 216 217 218 219
	sscanf(buffer, "%16s", command); /* IFNAMSIZ*/
	ifname = command + 1;
	if ((strlen(command) <= 1) ||
	    !dev_valid_name(ifname))
		goto err_no_cmd;

220 221 222 223 224 225 226
	dev = __dev_get_by_name(dev_net(bond->dev), ifname);
	if (!dev) {
		pr_info("%s: Interface %s does not exist!\n",
			bond->dev->name, ifname);
		ret = -ENODEV;
		goto out;
	}
227

228 229 230
	switch (command[0]) {
	case '+':
		pr_info("%s: Adding slave %s.\n", bond->dev->name, dev->name);
231
		res = bond_enslave(bond->dev, dev);
232
		break;
S
Stephen Hemminger 已提交
233

234 235 236 237
	case '-':
		pr_info("%s: Removing slave %s.\n", bond->dev->name, dev->name);
		res = bond_release(bond->dev, dev);
		break;
238

239 240
	default:
		goto err_no_cmd;
241 242
	}

243 244 245 246
	if (res)
		ret = res;
	goto out;

247
err_no_cmd:
J
Joe Perches 已提交
248 249
	pr_err("no command found in slaves file for bond %s. Use +ifname or -ifname.\n",
	       bond->dev->name);
250 251 252
	ret = -EPERM;

out:
253
	rtnl_unlock();
254 255 256
	return ret;
}

S
Stephen Hemminger 已提交
257 258
static DEVICE_ATTR(slaves, S_IRUGO | S_IWUSR, bonding_show_slaves,
		   bonding_store_slaves);
259 260 261 262 263

/*
 * Show and set the bonding mode.  The bond interface must be down to
 * change the mode.
 */
264 265
static ssize_t bonding_show_mode(struct device *d,
				 struct device_attribute *attr, char *buf)
266
{
267
	struct bonding *bond = to_bond(d);
268 269 270

	return sprintf(buf, "%s %d\n",
			bond_mode_tbl[bond->params.mode].modename,
271
			bond->params.mode);
272 273
}

274 275 276
static ssize_t bonding_store_mode(struct device *d,
				  struct device_attribute *attr,
				  const char *buf, size_t count)
277
{
278
	int new_value, ret;
279
	struct bonding *bond = to_bond(d);
280

J
Jay Vosburgh 已提交
281
	new_value = bond_parse_parm(buf, bond_mode_tbl);
282
	if (new_value < 0)  {
J
Joe Perches 已提交
283 284
		pr_err("%s: Ignoring invalid mode value %.*s.\n",
		       bond->dev->name, (int)strlen(buf) - 1, buf);
285
		return -EINVAL;
286
	}
287 288 289 290 291 292 293 294 295
	if (!rtnl_trylock())
		return restart_syscall();

	ret = bond_option_mode_set(bond, new_value);
	if (!ret) {
		pr_info("%s: setting mode to %s (%d).\n",
			bond->dev->name, bond_mode_tbl[new_value].modename,
			new_value);
		ret = count;
296
	}
297

298
	rtnl_unlock();
299 300
	return ret;
}
S
Stephen Hemminger 已提交
301 302
static DEVICE_ATTR(mode, S_IRUGO | S_IWUSR,
		   bonding_show_mode, bonding_store_mode);
303 304

/*
S
Stephen Hemminger 已提交
305
 * Show and set the bonding transmit hash method.
306
 */
307 308 309
static ssize_t bonding_show_xmit_hash(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
310
{
311
	struct bonding *bond = to_bond(d);
312

313 314 315
	return sprintf(buf, "%s %d\n",
		       xmit_hashtype_tbl[bond->params.xmit_policy].modename,
		       bond->params.xmit_policy);
316 317
}

318 319 320
static ssize_t bonding_store_xmit_hash(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
321 322
{
	int new_value, ret = count;
323
	struct bonding *bond = to_bond(d);
324

J
Jay Vosburgh 已提交
325
	new_value = bond_parse_parm(buf, xmit_hashtype_tbl);
326
	if (new_value < 0)  {
J
Joe Perches 已提交
327
		pr_err("%s: Ignoring invalid xmit hash policy value %.*s.\n",
328 329 330 331 332
		       bond->dev->name,
		       (int)strlen(buf) - 1, buf);
		ret = -EINVAL;
	} else {
		bond->params.xmit_policy = new_value;
J
Joe Perches 已提交
333
		pr_info("%s: setting xmit hash policy to %s (%d).\n",
S
Stephen Hemminger 已提交
334 335
			bond->dev->name,
			xmit_hashtype_tbl[new_value].modename, new_value);
336
	}
337

338 339
	return ret;
}
S
Stephen Hemminger 已提交
340 341
static DEVICE_ATTR(xmit_hash_policy, S_IRUGO | S_IWUSR,
		   bonding_show_xmit_hash, bonding_store_xmit_hash);
342

343 344 345
/*
 * Show and set arp_validate.
 */
346 347 348
static ssize_t bonding_show_arp_validate(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
349
{
350
	struct bonding *bond = to_bond(d);
351 352 353

	return sprintf(buf, "%s %d\n",
		       arp_validate_tbl[bond->params.arp_validate].modename,
354
		       bond->params.arp_validate);
355 356
}

357 358 359
static ssize_t bonding_store_arp_validate(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
360
{
361
	struct bonding *bond = to_bond(d);
362
	int new_value, ret = count;
363

364 365
	if (!rtnl_trylock())
		return restart_syscall();
J
Jay Vosburgh 已提交
366
	new_value = bond_parse_parm(buf, arp_validate_tbl);
367
	if (new_value < 0) {
J
Joe Perches 已提交
368
		pr_err("%s: Ignoring invalid arp_validate value %s\n",
369
		       bond->dev->name, buf);
370 371
		ret = -EINVAL;
		goto out;
372
	}
373
	if (bond->params.mode != BOND_MODE_ACTIVEBACKUP) {
J
Joe Perches 已提交
374
		pr_err("%s: arp_validate only supported in active-backup mode.\n",
375
		       bond->dev->name);
376 377
		ret = -EINVAL;
		goto out;
378
	}
J
Joe Perches 已提交
379 380 381
	pr_info("%s: setting arp_validate to %s (%d).\n",
		bond->dev->name, arp_validate_tbl[new_value].modename,
		new_value);
382

383 384 385 386 387 388
	if (bond->dev->flags & IFF_UP) {
		if (!new_value)
			bond->recv_probe = NULL;
		else if (bond->params.arp_interval)
			bond->recv_probe = bond_arp_rcv;
	}
389
	bond->params.arp_validate = new_value;
390 391
out:
	rtnl_unlock();
392

393
	return ret;
394 395
}

S
Stephen Hemminger 已提交
396 397
static DEVICE_ATTR(arp_validate, S_IRUGO | S_IWUSR, bonding_show_arp_validate,
		   bonding_store_arp_validate);
398 399 400 401 402 403 404 405 406 407 408 409 410 411 412 413 414 415 416 417 418 419 420 421 422 423 424 425 426 427 428 429 430 431 432 433 434 435
/*
 * Show and set arp_all_targets.
 */
static ssize_t bonding_show_arp_all_targets(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
{
	struct bonding *bond = to_bond(d);
	int value = bond->params.arp_all_targets;

	return sprintf(buf, "%s %d\n", arp_all_targets_tbl[value].modename,
		       value);
}

static ssize_t bonding_store_arp_all_targets(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
{
	struct bonding *bond = to_bond(d);
	int new_value;

	new_value = bond_parse_parm(buf, arp_all_targets_tbl);
	if (new_value < 0) {
		pr_err("%s: Ignoring invalid arp_all_targets value %s\n",
		       bond->dev->name, buf);
		return -EINVAL;
	}
	pr_info("%s: setting arp_all_targets to %s (%d).\n",
		bond->dev->name, arp_all_targets_tbl[new_value].modename,
		new_value);

	bond->params.arp_all_targets = new_value;

	return count;
}

static DEVICE_ATTR(arp_all_targets, S_IRUGO | S_IWUSR,
		   bonding_show_arp_all_targets, bonding_store_arp_all_targets);
436

437 438 439 440
/*
 * Show and store fail_over_mac.  User only allowed to change the
 * value when there are no slaves.
 */
S
Stephen Hemminger 已提交
441 442 443
static ssize_t bonding_show_fail_over_mac(struct device *d,
					  struct device_attribute *attr,
					  char *buf)
444 445 446
{
	struct bonding *bond = to_bond(d);

447 448 449
	return sprintf(buf, "%s %d\n",
		       fail_over_mac_tbl[bond->params.fail_over_mac].modename,
		       bond->params.fail_over_mac);
450 451
}

S
Stephen Hemminger 已提交
452 453 454
static ssize_t bonding_store_fail_over_mac(struct device *d,
					   struct device_attribute *attr,
					   const char *buf, size_t count)
455
{
456
	int new_value, ret = count;
457 458
	struct bonding *bond = to_bond(d);

459 460 461
	if (!rtnl_trylock())
		return restart_syscall();

462
	if (bond_has_slaves(bond)) {
J
Joe Perches 已提交
463
		pr_err("%s: Can't alter fail_over_mac with slaves in bond.\n",
464
		       bond->dev->name);
465 466
		ret = -EPERM;
		goto out;
467 468
	}

469 470
	new_value = bond_parse_parm(buf, fail_over_mac_tbl);
	if (new_value < 0) {
J
Joe Perches 已提交
471
		pr_err("%s: Ignoring invalid fail_over_mac value %s.\n",
472
		       bond->dev->name, buf);
473 474
		ret = -EINVAL;
		goto out;
475 476
	}

477
	bond->params.fail_over_mac = new_value;
J
Joe Perches 已提交
478 479 480
	pr_info("%s: Setting fail_over_mac to %s (%d).\n",
		bond->dev->name, fail_over_mac_tbl[new_value].modename,
		new_value);
481

482 483 484
out:
	rtnl_unlock();
	return ret;
485 486
}

S
Stephen Hemminger 已提交
487 488
static DEVICE_ATTR(fail_over_mac, S_IRUGO | S_IWUSR,
		   bonding_show_fail_over_mac, bonding_store_fail_over_mac);
489

490 491 492 493 494 495
/*
 * Show and set the arp timer interval.  There are two tricky bits
 * here.  First, if ARP monitoring is activated, then we must disable
 * MII monitoring.  Second, if the ARP timer isn't running, we must
 * start it.
 */
496 497 498
static ssize_t bonding_show_arp_interval(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
499
{
500
	struct bonding *bond = to_bond(d);
501

502
	return sprintf(buf, "%d\n", bond->params.arp_interval);
503 504
}

505 506 507
static ssize_t bonding_store_arp_interval(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
508
{
509
	struct bonding *bond = to_bond(d);
510
	int new_value, ret = count;
511

512 513
	if (!rtnl_trylock())
		return restart_syscall();
514
	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
515
		pr_err("%s: no arp_interval value specified.\n",
516 517 518 519 520
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
521
		pr_err("%s: Invalid arp_interval value %d not in range 0-%d; rejected.\n",
522 523 524 525
		       bond->dev->name, new_value, INT_MAX);
		ret = -EINVAL;
		goto out;
	}
526
	if (BOND_NO_USES_ARP(bond->params.mode)) {
527
		pr_info("%s: ARP monitoring cannot be used with ALB/TLB/802.3ad. Only MII monitoring is supported on %s.\n",
528 529 530 531
			bond->dev->name, bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
J
Joe Perches 已提交
532 533
	pr_info("%s: Setting ARP monitoring interval to %d.\n",
		bond->dev->name, new_value);
534
	bond->params.arp_interval = new_value;
535 536 537 538 539 540 541 542 543
	if (new_value) {
		if (bond->params.miimon) {
			pr_info("%s: ARP monitoring cannot be used with MII monitoring. %s Disabling MII monitoring.\n",
				bond->dev->name, bond->dev->name);
			bond->params.miimon = 0;
		}
		if (!bond->params.arp_targets[0])
			pr_info("%s: ARP monitoring has been set up, but no ARP targets have been specified.\n",
				bond->dev->name);
544 545 546 547 548 549 550
	}
	if (bond->dev->flags & IFF_UP) {
		/* If the interface is up, we may need to fire off
		 * the ARP timer.  If the interface is down, the
		 * timer will get fired off when the open function
		 * is called.
		 */
551
		if (!new_value) {
552 553
			if (bond->params.arp_validate)
				bond->recv_probe = NULL;
554 555
			cancel_delayed_work_sync(&bond->arp_work);
		} else {
556 557 558
			/* arp_validate can be set only in active-backup mode */
			if (bond->params.arp_validate)
				bond->recv_probe = bond_arp_rcv;
559 560 561
			cancel_delayed_work_sync(&bond->mii_work);
			queue_delayed_work(bond->wq, &bond->arp_work, 0);
		}
562 563
	}
out:
564
	rtnl_unlock();
565 566
	return ret;
}
S
Stephen Hemminger 已提交
567 568
static DEVICE_ATTR(arp_interval, S_IRUGO | S_IWUSR,
		   bonding_show_arp_interval, bonding_store_arp_interval);
569 570 571 572

/*
 * Show and set the arp targets.
 */
573 574 575
static ssize_t bonding_show_arp_targets(struct device *d,
					struct device_attribute *attr,
					char *buf)
576 577
{
	int i, res = 0;
578
	struct bonding *bond = to_bond(d);
579 580 581

	for (i = 0; i < BOND_MAX_ARP_TARGETS; i++) {
		if (bond->params.arp_targets[i])
H
Harvey Harrison 已提交
582 583
			res += sprintf(buf + res, "%pI4 ",
				       &bond->params.arp_targets[i]);
584
	}
585 586
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
587 588 589
	return res;
}

590 591 592
static ssize_t bonding_store_arp_targets(struct device *d,
					 struct device_attribute *attr,
					 const char *buf, size_t count)
593
{
594
	struct bonding *bond = to_bond(d);
595
	struct list_head *iter;
596 597 598 599
	struct slave *slave;
	__be32 newtarget, *targets;
	unsigned long *targets_rx;
	int ind, i, j, ret = -EINVAL;
600

601 602 603
	if (!rtnl_trylock())
		return restart_syscall();

604
	targets = bond->params.arp_targets;
605 606 607 608 609 610
	if (!in4_pton(buf + 1, -1, (u8 *)&newtarget, -1, NULL) ||
	    IS_IP_TARGET_UNUSABLE_ADDRESS(newtarget)) {
		pr_err("%s: invalid ARP target %pI4 specified for addition\n",
		       bond->dev->name, &newtarget);
		goto out;
	}
611 612
	/* look for adds */
	if (buf[0] == '+') {
613 614 615 616
		if (bond_get_targets_ip(targets, newtarget) != -1) { /* dup */
			pr_err("%s: ARP target %pI4 is already present\n",
			       bond->dev->name, &newtarget);
			goto out;
617
		}
618

619 620
		ind = bond_get_targets_ip(targets, 0); /* first free slot */
		if (ind == -1) {
J
Joe Perches 已提交
621
			pr_err("%s: ARP target table is full!\n",
622 623 624 625
			       bond->dev->name);
			goto out;
		}

626 627
		pr_info("%s: adding ARP target %pI4.\n", bond->dev->name,
			 &newtarget);
628 629
		/* not to race with bond_arp_rcv */
		write_lock_bh(&bond->lock);
630
		bond_for_each_slave(bond, slave, iter)
631 632 633
			slave->target_last_arp_rx[ind] = jiffies;
		targets[ind] = newtarget;
		write_unlock_bh(&bond->lock);
S
Stephen Hemminger 已提交
634
	} else if (buf[0] == '-')	{
635 636 637
		ind = bond_get_targets_ip(targets, newtarget);
		if (ind == -1) {
			pr_err("%s: unable to remove nonexistent ARP target %pI4.\n",
J
Joe Perches 已提交
638
				bond->dev->name, &newtarget);
639 640
			goto out;
		}
641

642 643 644 645
		if (ind == 0 && !targets[1] && bond->params.arp_interval)
			pr_warn("%s: removing last arp target with arp_interval on\n",
				bond->dev->name);

646 647
		pr_info("%s: removing ARP target %pI4.\n", bond->dev->name,
			&newtarget);
648 649

		write_lock_bh(&bond->lock);
650
		bond_for_each_slave(bond, slave, iter) {
651 652 653 654 655 656 657
			targets_rx = slave->target_last_arp_rx;
			j = ind;
			for (; (j < BOND_MAX_ARP_TARGETS-1) && targets[j+1]; j++)
				targets_rx[j] = targets_rx[j+1];
			targets_rx[j] = 0;
		}
		for (i = ind; (i < BOND_MAX_ARP_TARGETS-1) && targets[i+1]; i++)
658 659
			targets[i] = targets[i+1];
		targets[i] = 0;
660
		write_unlock_bh(&bond->lock);
S
Stephen Hemminger 已提交
661
	} else {
J
Joe Perches 已提交
662 663
		pr_err("no command found in arp_ip_targets file for bond %s. Use +<addr> or -<addr>.\n",
		       bond->dev->name);
664 665 666 667
		ret = -EPERM;
		goto out;
	}

668
	ret = count;
669
out:
670
	rtnl_unlock();
671 672
	return ret;
}
673
static DEVICE_ATTR(arp_ip_target, S_IRUGO | S_IWUSR , bonding_show_arp_targets, bonding_store_arp_targets);
674 675 676 677 678 679

/*
 * Show and set the up and down delays.  These must be multiples of the
 * MII monitoring value, and are stored internally as the multiplier.
 * Thus, we must translate to MS for the real world.
 */
680 681 682
static ssize_t bonding_show_downdelay(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
683
{
684
	struct bonding *bond = to_bond(d);
685

686
	return sprintf(buf, "%d\n", bond->params.downdelay * bond->params.miimon);
687 688
}

689 690 691
static ssize_t bonding_store_downdelay(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
692 693
{
	int new_value, ret = count;
694
	struct bonding *bond = to_bond(d);
695

696 697
	if (!rtnl_trylock())
		return restart_syscall();
698
	if (!(bond->params.miimon)) {
J
Joe Perches 已提交
699
		pr_err("%s: Unable to set down delay as MII monitoring is disabled\n",
700 701 702 703 704 705
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
706
		pr_err("%s: no down delay value specified.\n", bond->dev->name);
707 708 709 710
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
J
Joe Perches 已提交
711
		pr_err("%s: Invalid down delay value %d not in range %d-%d; rejected.\n",
712
		       bond->dev->name, new_value, 0, INT_MAX);
713 714 715 716
		ret = -EINVAL;
		goto out;
	} else {
		if ((new_value % bond->params.miimon) != 0) {
J
Joe Perches 已提交
717
			pr_warning("%s: Warning: down delay (%d) is not a multiple of miimon (%d), delay rounded to %d ms\n",
J
Jiri Pirko 已提交
718 719 720 721
				   bond->dev->name, new_value,
				   bond->params.miimon,
				   (new_value / bond->params.miimon) *
				   bond->params.miimon);
722 723
		}
		bond->params.downdelay = new_value / bond->params.miimon;
J
Joe Perches 已提交
724 725 726
		pr_info("%s: Setting down delay to %d.\n",
			bond->dev->name,
			bond->params.downdelay * bond->params.miimon);
727 728 729 730

	}

out:
731
	rtnl_unlock();
732 733
	return ret;
}
S
Stephen Hemminger 已提交
734 735
static DEVICE_ATTR(downdelay, S_IRUGO | S_IWUSR,
		   bonding_show_downdelay, bonding_store_downdelay);
736

737 738 739
static ssize_t bonding_show_updelay(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
740
{
741
	struct bonding *bond = to_bond(d);
742

743
	return sprintf(buf, "%d\n", bond->params.updelay * bond->params.miimon);
744 745 746

}

747 748 749
static ssize_t bonding_store_updelay(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
750 751
{
	int new_value, ret = count;
752
	struct bonding *bond = to_bond(d);
753

754 755
	if (!rtnl_trylock())
		return restart_syscall();
756
	if (!(bond->params.miimon)) {
J
Joe Perches 已提交
757
		pr_err("%s: Unable to set up delay as MII monitoring is disabled\n",
758 759 760 761 762 763
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
764
		pr_err("%s: no up delay value specified.\n",
765 766 767 768 769
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
770 771
		pr_err("%s: Invalid up delay value %d not in range %d-%d; rejected.\n",
		       bond->dev->name, new_value, 0, INT_MAX);
772 773 774 775
		ret = -EINVAL;
		goto out;
	} else {
		if ((new_value % bond->params.miimon) != 0) {
J
Joe Perches 已提交
776
			pr_warning("%s: Warning: up delay (%d) is not a multiple of miimon (%d), updelay rounded to %d ms\n",
J
Jiri Pirko 已提交
777 778 779 780
				   bond->dev->name, new_value,
				   bond->params.miimon,
				   (new_value / bond->params.miimon) *
				   bond->params.miimon);
781 782
		}
		bond->params.updelay = new_value / bond->params.miimon;
J
Joe Perches 已提交
783 784 785
		pr_info("%s: Setting up delay to %d.\n",
			bond->dev->name,
			bond->params.updelay * bond->params.miimon);
786 787 788
	}

out:
789
	rtnl_unlock();
790 791
	return ret;
}
S
Stephen Hemminger 已提交
792 793
static DEVICE_ATTR(updelay, S_IRUGO | S_IWUSR,
		   bonding_show_updelay, bonding_store_updelay);
794 795 796 797 798

/*
 * Show and set the LACP interval.  Interface must be down, and the mode
 * must be set to 802.3ad mode.
 */
799 800 801
static ssize_t bonding_show_lacp(struct device *d,
				 struct device_attribute *attr,
				 char *buf)
802
{
803
	struct bonding *bond = to_bond(d);
804 805 806

	return sprintf(buf, "%s %d\n",
		bond_lacp_tbl[bond->params.lacp_fast].modename,
807
		bond->params.lacp_fast);
808 809
}

810 811 812
static ssize_t bonding_store_lacp(struct device *d,
				  struct device_attribute *attr,
				  const char *buf, size_t count)
813
{
814
	struct bonding *bond = to_bond(d);
815 816 817 818
	int new_value, ret = count;

	if (!rtnl_trylock())
		return restart_syscall();
819 820

	if (bond->dev->flags & IFF_UP) {
J
Joe Perches 已提交
821
		pr_err("%s: Unable to update LACP rate because interface is up.\n",
822 823 824 825 826 827
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

	if (bond->params.mode != BOND_MODE_8023AD) {
J
Joe Perches 已提交
828
		pr_err("%s: Unable to update LACP rate because bond is not in 802.3ad mode.\n",
829 830 831 832 833
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

J
Jay Vosburgh 已提交
834
	new_value = bond_parse_parm(buf, bond_lacp_tbl);
835 836 837

	if ((new_value == 1) || (new_value == 0)) {
		bond->params.lacp_fast = new_value;
838
		bond_3ad_update_lacp_rate(bond);
J
Joe Perches 已提交
839
		pr_info("%s: Setting LACP rate to %s (%d).\n",
S
Stephen Hemminger 已提交
840 841
			bond->dev->name, bond_lacp_tbl[new_value].modename,
			new_value);
842
	} else {
J
Joe Perches 已提交
843
		pr_err("%s: Ignoring invalid LACP rate value %.*s.\n",
S
Stephen Hemminger 已提交
844
		       bond->dev->name, (int)strlen(buf) - 1, buf);
845 846 847
		ret = -EINVAL;
	}
out:
848 849
	rtnl_unlock();

850 851
	return ret;
}
S
Stephen Hemminger 已提交
852 853
static DEVICE_ATTR(lacp_rate, S_IRUGO | S_IWUSR,
		   bonding_show_lacp, bonding_store_lacp);
854

855 856 857 858 859 860 861 862 863 864 865 866 867 868 869 870 871 872 873 874 875 876 877 878 879 880 881 882 883 884 885 886
static ssize_t bonding_show_min_links(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
{
	struct bonding *bond = to_bond(d);

	return sprintf(buf, "%d\n", bond->params.min_links);
}

static ssize_t bonding_store_min_links(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
{
	struct bonding *bond = to_bond(d);
	int ret;
	unsigned int new_value;

	ret = kstrtouint(buf, 0, &new_value);
	if (ret < 0) {
		pr_err("%s: Ignoring invalid min links value %s.\n",
		       bond->dev->name, buf);
		return ret;
	}

	pr_info("%s: Setting min links value to %u\n",
		bond->dev->name, new_value);
	bond->params.min_links = new_value;
	return count;
}
static DEVICE_ATTR(min_links, S_IRUGO | S_IWUSR,
		   bonding_show_min_links, bonding_store_min_links);

887 888 889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906
static ssize_t bonding_show_ad_select(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
{
	struct bonding *bond = to_bond(d);

	return sprintf(buf, "%s %d\n",
		ad_select_tbl[bond->params.ad_select].modename,
		bond->params.ad_select);
}


static ssize_t bonding_store_ad_select(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
{
	int new_value, ret = count;
	struct bonding *bond = to_bond(d);

	if (bond->dev->flags & IFF_UP) {
J
Joe Perches 已提交
907 908
		pr_err("%s: Unable to update ad_select because interface is up.\n",
		       bond->dev->name);
909 910 911 912 913 914 915 916
		ret = -EPERM;
		goto out;
	}

	new_value = bond_parse_parm(buf, ad_select_tbl);

	if (new_value != -1) {
		bond->params.ad_select = new_value;
J
Joe Perches 已提交
917 918 919
		pr_info("%s: Setting ad_select to %s (%d).\n",
			bond->dev->name, ad_select_tbl[new_value].modename,
			new_value);
920
	} else {
J
Joe Perches 已提交
921
		pr_err("%s: Ignoring invalid ad_select value %.*s.\n",
922 923 924 925 926 927
		       bond->dev->name, (int)strlen(buf) - 1, buf);
		ret = -EINVAL;
	}
out:
	return ret;
}
S
Stephen Hemminger 已提交
928 929
static DEVICE_ATTR(ad_select, S_IRUGO | S_IWUSR,
		   bonding_show_ad_select, bonding_store_ad_select);
930

931 932 933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954
/*
 * Show and set the number of peer notifications to send after a failover event.
 */
static ssize_t bonding_show_num_peer_notif(struct device *d,
					   struct device_attribute *attr,
					   char *buf)
{
	struct bonding *bond = to_bond(d);
	return sprintf(buf, "%d\n", bond->params.num_peer_notif);
}

static ssize_t bonding_store_num_peer_notif(struct device *d,
					    struct device_attribute *attr,
					    const char *buf, size_t count)
{
	struct bonding *bond = to_bond(d);
	int err = kstrtou8(buf, 10, &bond->params.num_peer_notif);
	return err ? err : count;
}
static DEVICE_ATTR(num_grat_arp, S_IRUGO | S_IWUSR,
		   bonding_show_num_peer_notif, bonding_store_num_peer_notif);
static DEVICE_ATTR(num_unsol_na, S_IRUGO | S_IWUSR,
		   bonding_show_num_peer_notif, bonding_store_num_peer_notif);

955 956 957 958 959 960
/*
 * Show and set the MII monitor interval.  There are two tricky bits
 * here.  First, if MII monitoring is activated, then we must disable
 * ARP monitoring.  Second, if the timer isn't running, we must
 * start it.
 */
961 962 963
static ssize_t bonding_show_miimon(struct device *d,
				   struct device_attribute *attr,
				   char *buf)
964
{
965
	struct bonding *bond = to_bond(d);
966

967
	return sprintf(buf, "%d\n", bond->params.miimon);
968 969
}

970 971 972
static ssize_t bonding_store_miimon(struct device *d,
				    struct device_attribute *attr,
				    const char *buf, size_t count)
973 974
{
	int new_value, ret = count;
975
	struct bonding *bond = to_bond(d);
976

977 978
	if (!rtnl_trylock())
		return restart_syscall();
979
	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
980
		pr_err("%s: no miimon value specified.\n",
981 982 983 984 985
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
J
Joe Perches 已提交
986
		pr_err("%s: Invalid miimon value %d not in range %d-%d; rejected.\n",
987
		       bond->dev->name, new_value, 0, INT_MAX);
988 989
		ret = -EINVAL;
		goto out;
990 991 992 993 994 995 996 997 998 999 1000 1001 1002 1003 1004 1005 1006 1007 1008 1009 1010 1011 1012 1013 1014 1015 1016 1017
	}
	pr_info("%s: Setting MII monitoring interval to %d.\n",
		bond->dev->name, new_value);
	bond->params.miimon = new_value;
	if (bond->params.updelay)
		pr_info("%s: Note: Updating updelay (to %d) since it is a multiple of the miimon value.\n",
			bond->dev->name,
			bond->params.updelay * bond->params.miimon);
	if (bond->params.downdelay)
		pr_info("%s: Note: Updating downdelay (to %d) since it is a multiple of the miimon value.\n",
			bond->dev->name,
			bond->params.downdelay * bond->params.miimon);
	if (new_value && bond->params.arp_interval) {
		pr_info("%s: MII monitoring cannot be used with ARP monitoring. Disabling ARP monitoring...\n",
			bond->dev->name);
		bond->params.arp_interval = 0;
		if (bond->params.arp_validate)
			bond->params.arp_validate = BOND_ARP_VALIDATE_NONE;
	}
	if (bond->dev->flags & IFF_UP) {
		/* If the interface is up, we may need to fire off
		 * the MII timer. If the interface is down, the
		 * timer will get fired off when the open function
		 * is called.
		 */
		if (!new_value) {
			cancel_delayed_work_sync(&bond->mii_work);
		} else {
1018 1019
			cancel_delayed_work_sync(&bond->arp_work);
			queue_delayed_work(bond->wq, &bond->mii_work, 0);
1020 1021 1022
		}
	}
out:
1023
	rtnl_unlock();
1024 1025
	return ret;
}
S
Stephen Hemminger 已提交
1026 1027
static DEVICE_ATTR(miimon, S_IRUGO | S_IWUSR,
		   bonding_show_miimon, bonding_store_miimon);
1028 1029 1030 1031 1032 1033 1034 1035

/*
 * Show and set the primary slave.  The store function is much
 * simpler than bonding_store_slaves function because it only needs to
 * handle one interface name.
 * The bond must be a mode that supports a primary for this be
 * set.
 */
1036 1037 1038
static ssize_t bonding_show_primary(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
1039 1040
{
	int count = 0;
1041
	struct bonding *bond = to_bond(d);
1042 1043

	if (bond->primary_slave)
1044
		count = sprintf(buf, "%s\n", bond->primary_slave->dev->name);
1045 1046 1047 1048

	return count;
}

1049 1050 1051
static ssize_t bonding_store_primary(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
1052
{
1053
	struct bonding *bond = to_bond(d);
1054
	struct list_head *iter;
1055
	char ifname[IFNAMSIZ];
1056
	struct slave *slave;
1057

1058 1059
	if (!rtnl_trylock())
		return restart_syscall();
1060
	block_netpoll_tx();
1061 1062 1063
	read_lock(&bond->lock);
	write_lock_bh(&bond->curr_slave_lock);

1064
	if (!USES_PRIMARY(bond->params.mode)) {
J
Joe Perches 已提交
1065 1066
		pr_info("%s: Unable to set primary slave; %s is in mode %d\n",
			bond->dev->name, bond->dev->name, bond->params.mode);
1067 1068
		goto out;
	}
1069

N
nikolay@redhat.com 已提交
1070
	sscanf(buf, "%15s", ifname); /* IFNAMSIZ */
1071

1072 1073 1074 1075 1076
	/* check to see if we are clearing primary */
	if (!strlen(ifname) || buf[0] == '\n') {
		pr_info("%s: Setting primary slave to None.\n",
			bond->dev->name);
		bond->primary_slave = NULL;
1077
		memset(bond->params.primary, 0, sizeof(bond->params.primary));
1078 1079 1080 1081
		bond_select_active_slave(bond);
		goto out;
	}

1082
	bond_for_each_slave(bond, slave, iter) {
1083 1084 1085 1086 1087 1088 1089
		if (strncmp(slave->dev->name, ifname, IFNAMSIZ) == 0) {
			pr_info("%s: Setting %s as primary slave.\n",
				bond->dev->name, slave->dev->name);
			bond->primary_slave = slave;
			strcpy(bond->params.primary, slave->dev->name);
			bond_select_active_slave(bond);
			goto out;
1090 1091
		}
	}
1092

1093 1094 1095 1096 1097 1098
	strncpy(bond->params.primary, ifname, IFNAMSIZ);
	bond->params.primary[IFNAMSIZ - 1] = 0;

	pr_info("%s: Recording %s as primary, "
		"but it has not been enslaved to %s yet.\n",
		bond->dev->name, ifname, bond->dev->name);
1099
out:
1100 1101
	write_unlock_bh(&bond->curr_slave_lock);
	read_unlock(&bond->lock);
1102
	unblock_netpoll_tx();
1103 1104
	rtnl_unlock();

1105 1106
	return count;
}
S
Stephen Hemminger 已提交
1107 1108
static DEVICE_ATTR(primary, S_IRUGO | S_IWUSR,
		   bonding_show_primary, bonding_store_primary);
1109

1110 1111 1112 1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124 1125 1126 1127 1128 1129 1130 1131 1132 1133 1134 1135
/*
 * Show and set the primary_reselect flag.
 */
static ssize_t bonding_show_primary_reselect(struct device *d,
					     struct device_attribute *attr,
					     char *buf)
{
	struct bonding *bond = to_bond(d);

	return sprintf(buf, "%s %d\n",
		       pri_reselect_tbl[bond->params.primary_reselect].modename,
		       bond->params.primary_reselect);
}

static ssize_t bonding_store_primary_reselect(struct device *d,
					      struct device_attribute *attr,
					      const char *buf, size_t count)
{
	int new_value, ret = count;
	struct bonding *bond = to_bond(d);

	if (!rtnl_trylock())
		return restart_syscall();

	new_value = bond_parse_parm(buf, pri_reselect_tbl);
	if (new_value < 0)  {
J
Joe Perches 已提交
1136
		pr_err("%s: Ignoring invalid primary_reselect value %.*s.\n",
1137 1138 1139 1140 1141 1142 1143
		       bond->dev->name,
		       (int) strlen(buf) - 1, buf);
		ret = -EINVAL;
		goto out;
	}

	bond->params.primary_reselect = new_value;
J
Joe Perches 已提交
1144
	pr_info("%s: setting primary_reselect to %s (%d).\n",
1145 1146 1147
		bond->dev->name, pri_reselect_tbl[new_value].modename,
		new_value);

1148
	block_netpoll_tx();
1149 1150 1151 1152 1153
	read_lock(&bond->lock);
	write_lock_bh(&bond->curr_slave_lock);
	bond_select_active_slave(bond);
	write_unlock_bh(&bond->curr_slave_lock);
	read_unlock(&bond->lock);
1154
	unblock_netpoll_tx();
1155 1156 1157 1158 1159 1160 1161 1162
out:
	rtnl_unlock();
	return ret;
}
static DEVICE_ATTR(primary_reselect, S_IRUGO | S_IWUSR,
		   bonding_show_primary_reselect,
		   bonding_store_primary_reselect);

1163 1164 1165
/*
 * Show and set the use_carrier flag.
 */
1166 1167 1168
static ssize_t bonding_show_carrier(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
1169
{
1170
	struct bonding *bond = to_bond(d);
1171

1172
	return sprintf(buf, "%d\n", bond->params.use_carrier);
1173 1174
}

1175 1176 1177
static ssize_t bonding_store_carrier(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
1178 1179
{
	int new_value, ret = count;
1180
	struct bonding *bond = to_bond(d);
1181 1182 1183


	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
1184
		pr_err("%s: no use_carrier value specified.\n",
1185 1186 1187 1188 1189 1190
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if ((new_value == 0) || (new_value == 1)) {
		bond->params.use_carrier = new_value;
J
Joe Perches 已提交
1191 1192
		pr_info("%s: Setting use_carrier to %d.\n",
			bond->dev->name, new_value);
1193
	} else {
J
Joe Perches 已提交
1194 1195
		pr_info("%s: Ignoring invalid use_carrier value %d.\n",
			bond->dev->name, new_value);
1196 1197
	}
out:
1198
	return ret;
1199
}
S
Stephen Hemminger 已提交
1200 1201
static DEVICE_ATTR(use_carrier, S_IRUGO | S_IWUSR,
		   bonding_show_carrier, bonding_store_carrier);
1202 1203 1204 1205 1206


/*
 * Show and set currently active_slave.
 */
1207 1208 1209
static ssize_t bonding_show_active_slave(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
1210
{
1211
	struct bonding *bond = to_bond(d);
1212
	struct net_device *slave_dev;
1213
	int count = 0;
1214

1215
	rcu_read_lock();
1216 1217 1218
	slave_dev = bond_option_active_slave_get_rcu(bond);
	if (slave_dev)
		count = sprintf(buf, "%s\n", slave_dev->name);
1219 1220
	rcu_read_unlock();

1221 1222 1223
	return count;
}

1224 1225 1226
static ssize_t bonding_store_active_slave(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
1227
{
1228
	int ret;
1229
	struct bonding *bond = to_bond(d);
1230
	char ifname[IFNAMSIZ];
1231
	struct net_device *dev;
1232

1233 1234
	if (!rtnl_trylock())
		return restart_syscall();
1235

1236
	sscanf(buf, "%15s", ifname); /* IFNAMSIZ */
1237
	if (!strlen(ifname) || buf[0] == '\n') {
1238 1239 1240 1241 1242 1243
		dev = NULL;
	} else {
		dev = __dev_get_by_name(dev_net(bond->dev), ifname);
		if (!dev) {
			ret = -ENODEV;
			goto out;
1244 1245
		}
	}
1246

1247 1248 1249
	ret = bond_option_active_slave_set(bond, dev);
	if (!ret)
		ret = count;
1250

1251
 out:
1252 1253
	rtnl_unlock();

1254
	return ret;
1255 1256

}
S
Stephen Hemminger 已提交
1257 1258
static DEVICE_ATTR(active_slave, S_IRUGO | S_IWUSR,
		   bonding_show_active_slave, bonding_store_active_slave);
1259 1260 1261 1262 1263


/*
 * Show link status of the bond interface.
 */
1264 1265 1266
static ssize_t bonding_show_mii_status(struct device *d,
				       struct device_attribute *attr,
				       char *buf)
1267
{
1268
	struct bonding *bond = to_bond(d);
1269

1270
	return sprintf(buf, "%s\n", bond->curr_active_slave ? "up" : "down");
1271
}
1272
static DEVICE_ATTR(mii_status, S_IRUGO, bonding_show_mii_status, NULL);
1273 1274 1275 1276

/*
 * Show current 802.3ad aggregator ID.
 */
1277 1278 1279
static ssize_t bonding_show_ad_aggregator(struct device *d,
					  struct device_attribute *attr,
					  char *buf)
1280 1281
{
	int count = 0;
1282
	struct bonding *bond = to_bond(d);
1283 1284 1285

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1286
		count = sprintf(buf, "%d\n",
1287
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1288
				?  0 : ad_info.aggregator_id);
1289 1290 1291 1292
	}

	return count;
}
1293
static DEVICE_ATTR(ad_aggregator, S_IRUGO, bonding_show_ad_aggregator, NULL);
1294 1295 1296 1297 1298


/*
 * Show number of active 802.3ad ports.
 */
1299 1300 1301
static ssize_t bonding_show_ad_num_ports(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
1302 1303
{
	int count = 0;
1304
	struct bonding *bond = to_bond(d);
1305 1306 1307

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1308
		count = sprintf(buf, "%d\n",
1309
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1310
				?  0 : ad_info.ports);
1311 1312 1313 1314
	}

	return count;
}
1315
static DEVICE_ATTR(ad_num_ports, S_IRUGO, bonding_show_ad_num_ports, NULL);
1316 1317 1318 1319 1320


/*
 * Show current 802.3ad actor key.
 */
1321 1322 1323
static ssize_t bonding_show_ad_actor_key(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
1324 1325
{
	int count = 0;
1326
	struct bonding *bond = to_bond(d);
1327 1328 1329

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1330
		count = sprintf(buf, "%d\n",
1331
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1332
				?  0 : ad_info.actor_key);
1333 1334 1335 1336
	}

	return count;
}
1337
static DEVICE_ATTR(ad_actor_key, S_IRUGO, bonding_show_ad_actor_key, NULL);
1338 1339 1340 1341 1342


/*
 * Show current 802.3ad partner key.
 */
1343 1344 1345
static ssize_t bonding_show_ad_partner_key(struct device *d,
					   struct device_attribute *attr,
					   char *buf)
1346 1347
{
	int count = 0;
1348
	struct bonding *bond = to_bond(d);
1349 1350 1351

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1352
		count = sprintf(buf, "%d\n",
1353
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1354
				?  0 : ad_info.partner_key);
1355 1356 1357 1358
	}

	return count;
}
1359
static DEVICE_ATTR(ad_partner_key, S_IRUGO, bonding_show_ad_partner_key, NULL);
1360 1361 1362 1363 1364


/*
 * Show current 802.3ad partner mac.
 */
1365 1366 1367
static ssize_t bonding_show_ad_partner_mac(struct device *d,
					   struct device_attribute *attr,
					   char *buf)
1368 1369
{
	int count = 0;
1370
	struct bonding *bond = to_bond(d);
1371 1372 1373

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1374
		if (!bond_3ad_get_active_agg_info(bond, &ad_info))
J
Johannes Berg 已提交
1375
			count = sprintf(buf, "%pM\n", ad_info.partner_system);
1376 1377 1378 1379
	}

	return count;
}
1380
static DEVICE_ATTR(ad_partner_mac, S_IRUGO, bonding_show_ad_partner_mac, NULL);
1381

1382 1383 1384 1385 1386 1387 1388 1389
/*
 * Show the queue_ids of the slaves in the current bond.
 */
static ssize_t bonding_show_queue_id(struct device *d,
				     struct device_attribute *attr,
				     char *buf)
{
	struct bonding *bond = to_bond(d);
1390
	struct list_head *iter;
1391 1392
	struct slave *slave;
	int res = 0;
1393 1394 1395 1396

	if (!rtnl_trylock())
		return restart_syscall();

1397
	bond_for_each_slave(bond, slave, iter) {
1398 1399
		if (res > (PAGE_SIZE - IFNAMSIZ - 6)) {
			/* not enough space for another interface_name:queue_id pair */
1400 1401 1402 1403 1404 1405 1406 1407 1408 1409
			if ((PAGE_SIZE - res) > 10)
				res = PAGE_SIZE - 10;
			res += sprintf(buf + res, "++more++ ");
			break;
		}
		res += sprintf(buf + res, "%s:%d ",
			       slave->dev->name, slave->queue_id);
	}
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
1410

1411
	rtnl_unlock();
1412

1413 1414 1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425
	return res;
}

/*
 * Set the queue_ids of the  slaves in the current bond.  The bond
 * interface must be enslaved for this to work.
 */
static ssize_t bonding_store_queue_id(struct device *d,
				      struct device_attribute *attr,
				      const char *buffer, size_t count)
{
	struct slave *slave, *update_slave;
	struct bonding *bond = to_bond(d);
1426
	struct list_head *iter;
1427
	u16 qid;
1428
	int ret = count;
1429 1430 1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450
	char *delim;
	struct net_device *sdev = NULL;

	if (!rtnl_trylock())
		return restart_syscall();

	/* delim will point to queue id if successful */
	delim = strchr(buffer, ':');
	if (!delim)
		goto err_no_cmd;

	/*
	 * Terminate string that points to device name and bump it
	 * up one, so we can read the queue id there.
	 */
	*delim = '\0';
	if (sscanf(++delim, "%hd\n", &qid) != 1)
		goto err_no_cmd;

	/* Check buffer length, valid ifname and queue id */
	if (strlen(buffer) > IFNAMSIZ ||
	    !dev_valid_name(buffer) ||
1451
	    qid > bond->dev->real_num_tx_queues)
1452 1453 1454 1455 1456 1457 1458 1459 1460
		goto err_no_cmd;

	/* Get the pointer to that interface if it exists */
	sdev = __dev_get_by_name(dev_net(bond->dev), buffer);
	if (!sdev)
		goto err_no_cmd;

	/* Search for thes slave and check for duplicate qids */
	update_slave = NULL;
1461
	bond_for_each_slave(bond, slave, iter) {
1462 1463 1464 1465 1466 1467 1468
		if (sdev == slave->dev)
			/*
			 * We don't need to check the matching
			 * slave for dups, since we're overwriting it
			 */
			update_slave = slave;
		else if (qid && qid == slave->queue_id) {
1469
			goto err_no_cmd;
1470 1471 1472 1473
		}
	}

	if (!update_slave)
1474
		goto err_no_cmd;
1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486 1487 1488 1489 1490 1491 1492 1493

	/* Actually set the qids for the slave */
	update_slave->queue_id = qid;

out:
	rtnl_unlock();
	return ret;

err_no_cmd:
	pr_info("invalid input for queue_id set for %s.\n",
		bond->dev->name);
	ret = -EPERM;
	goto out;
}

static DEVICE_ATTR(queue_id, S_IRUGO | S_IWUSR, bonding_show_queue_id,
		   bonding_store_queue_id);


1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510
/*
 * Show and set the all_slaves_active flag.
 */
static ssize_t bonding_show_slaves_active(struct device *d,
					  struct device_attribute *attr,
					  char *buf)
{
	struct bonding *bond = to_bond(d);

	return sprintf(buf, "%d\n", bond->params.all_slaves_active);
}

static ssize_t bonding_store_slaves_active(struct device *d,
					   struct device_attribute *attr,
					   const char *buf, size_t count)
{
	struct bonding *bond = to_bond(d);
1511
	int new_value, ret = count;
1512
	struct list_head *iter;
1513 1514
	struct slave *slave;

1515 1516 1517
	if (!rtnl_trylock())
		return restart_syscall();

1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535
	if (sscanf(buf, "%d", &new_value) != 1) {
		pr_err("%s: no all_slaves_active value specified.\n",
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}

	if (new_value == bond->params.all_slaves_active)
		goto out;

	if ((new_value == 0) || (new_value == 1)) {
		bond->params.all_slaves_active = new_value;
	} else {
		pr_info("%s: Ignoring invalid all_slaves_active value %d.\n",
			bond->dev->name, new_value);
		ret = -EINVAL;
		goto out;
	}
1536

1537
	bond_for_each_slave(bond, slave, iter) {
J
Jiri Pirko 已提交
1538
		if (!bond_is_active_slave(slave)) {
1539
			if (new_value)
1540
				slave->inactive = 0;
1541
			else
1542
				slave->inactive = 1;
1543 1544 1545
		}
	}
out:
1546
	rtnl_unlock();
1547
	return ret;
1548 1549 1550
}
static DEVICE_ATTR(all_slaves_active, S_IRUGO | S_IWUSR,
		   bonding_show_slaves_active, bonding_store_slaves_active);
1551

1552 1553 1554 1555
/*
 * Show and set the number of IGMP membership reports to send on link failure
 */
static ssize_t bonding_show_resend_igmp(struct device *d,
1556 1557
					struct device_attribute *attr,
					char *buf)
1558 1559 1560 1561 1562 1563 1564
{
	struct bonding *bond = to_bond(d);

	return sprintf(buf, "%d\n", bond->params.resend_igmp);
}

static ssize_t bonding_store_resend_igmp(struct device *d,
1565 1566
					 struct device_attribute *attr,
					 const char *buf, size_t count)
1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577
{
	int new_value, ret = count;
	struct bonding *bond = to_bond(d);

	if (sscanf(buf, "%d", &new_value) != 1) {
		pr_err("%s: no resend_igmp value specified.\n",
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}

1578
	if (new_value < 0 || new_value > 255) {
1579 1580 1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594
		pr_err("%s: Invalid resend_igmp value %d not in range 0-255; rejected.\n",
		       bond->dev->name, new_value);
		ret = -EINVAL;
		goto out;
	}

	pr_info("%s: Setting resend_igmp to %d.\n",
		bond->dev->name, new_value);
	bond->params.resend_igmp = new_value;
out:
	return ret;
}

static DEVICE_ATTR(resend_igmp, S_IRUGO | S_IWUSR,
		   bonding_show_resend_igmp, bonding_store_resend_igmp);

1595 1596 1597 1598 1599 1600 1601 1602 1603 1604 1605 1606 1607 1608 1609 1610 1611 1612 1613 1614 1615 1616 1617 1618 1619 1620 1621 1622 1623 1624 1625 1626 1627 1628 1629 1630 1631 1632

static ssize_t bonding_show_lp_interval(struct device *d,
					struct device_attribute *attr,
					char *buf)
{
	struct bonding *bond = to_bond(d);
	return sprintf(buf, "%d\n", bond->params.lp_interval);
}

static ssize_t bonding_store_lp_interval(struct device *d,
					 struct device_attribute *attr,
					 const char *buf, size_t count)
{
	struct bonding *bond = to_bond(d);
	int new_value, ret = count;

	if (sscanf(buf, "%d", &new_value) != 1) {
		pr_err("%s: no lp interval value specified.\n",
			bond->dev->name);
		ret = -EINVAL;
		goto out;
	}

	if (new_value <= 0) {
		pr_err ("%s: lp_interval must be between 1 and %d\n",
			bond->dev->name, INT_MAX);
		ret = -EINVAL;
		goto out;
	}

	bond->params.lp_interval = new_value;
out:
	return ret;
}

static DEVICE_ATTR(lp_interval, S_IRUGO | S_IWUSR,
		   bonding_show_lp_interval, bonding_store_lp_interval);

1633 1634 1635 1636 1637 1638 1639 1640 1641 1642 1643 1644 1645 1646 1647 1648 1649 1650 1651 1652 1653 1654 1655 1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666 1667 1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679
static ssize_t bonding_show_packets_per_slave(struct device *d,
					      struct device_attribute *attr,
					      char *buf)
{
	struct bonding *bond = to_bond(d);
	int packets_per_slave = bond->params.packets_per_slave;

	if (packets_per_slave > 1)
		packets_per_slave = reciprocal_value(packets_per_slave);

	return sprintf(buf, "%d\n", packets_per_slave);
}

static ssize_t bonding_store_packets_per_slave(struct device *d,
					       struct device_attribute *attr,
					       const char *buf, size_t count)
{
	struct bonding *bond = to_bond(d);
	int new_value, ret = count;

	if (sscanf(buf, "%d", &new_value) != 1) {
		pr_err("%s: no packets_per_slave value specified.\n",
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0 || new_value > USHRT_MAX) {
		pr_err("%s: packets_per_slave must be between 0 and %u\n",
		       bond->dev->name, USHRT_MAX);
		ret = -EINVAL;
		goto out;
	}
	if (bond->params.mode != BOND_MODE_ROUNDROBIN)
		pr_warn("%s: Warning: packets_per_slave has effect only in balance-rr mode\n",
			bond->dev->name);
	if (new_value > 1)
		bond->params.packets_per_slave = reciprocal_value(new_value);
	else
		bond->params.packets_per_slave = new_value;
out:
	return ret;
}

static DEVICE_ATTR(packets_per_slave, S_IRUGO | S_IWUSR,
		   bonding_show_packets_per_slave,
		   bonding_store_packets_per_slave);

1680
static struct attribute *per_bond_attrs[] = {
1681 1682
	&dev_attr_slaves.attr,
	&dev_attr_mode.attr,
1683
	&dev_attr_fail_over_mac.attr,
1684
	&dev_attr_arp_validate.attr,
1685
	&dev_attr_arp_all_targets.attr,
1686 1687 1688 1689 1690
	&dev_attr_arp_interval.attr,
	&dev_attr_arp_ip_target.attr,
	&dev_attr_downdelay.attr,
	&dev_attr_updelay.attr,
	&dev_attr_lacp_rate.attr,
1691
	&dev_attr_ad_select.attr,
1692
	&dev_attr_xmit_hash_policy.attr,
1693 1694
	&dev_attr_num_grat_arp.attr,
	&dev_attr_num_unsol_na.attr,
1695 1696
	&dev_attr_miimon.attr,
	&dev_attr_primary.attr,
1697
	&dev_attr_primary_reselect.attr,
1698 1699 1700 1701 1702 1703 1704 1705
	&dev_attr_use_carrier.attr,
	&dev_attr_active_slave.attr,
	&dev_attr_mii_status.attr,
	&dev_attr_ad_aggregator.attr,
	&dev_attr_ad_num_ports.attr,
	&dev_attr_ad_actor_key.attr,
	&dev_attr_ad_partner_key.attr,
	&dev_attr_ad_partner_mac.attr,
1706
	&dev_attr_queue_id.attr,
1707
	&dev_attr_all_slaves_active.attr,
1708
	&dev_attr_resend_igmp.attr,
1709
	&dev_attr_min_links.attr,
1710
	&dev_attr_lp_interval.attr,
1711
	&dev_attr_packets_per_slave.attr,
1712 1713 1714 1715 1716 1717 1718 1719 1720 1721 1722 1723
	NULL,
};

static struct attribute_group bonding_group = {
	.name = "bonding",
	.attrs = per_bond_attrs,
};

/*
 * Initialize sysfs.  This sets up the bonding_masters file in
 * /sys/class/net.
 */
1724
int bond_create_sysfs(struct bond_net *bn)
1725
{
1726
	int ret;
1727

1728
	bn->class_attr_bonding_masters = class_attr_bonding_masters;
1729
	sysfs_attr_init(&bn->class_attr_bonding_masters.attr);
1730

1731 1732
	ret = netdev_class_create_file_ns(&bn->class_attr_bonding_masters,
					  bn->net);
1733 1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744
	/*
	 * Permit multiple loads of the module by ignoring failures to
	 * create the bonding_masters sysfs file.  Bonding devices
	 * created by second or subsequent loads of the module will
	 * not be listed in, or controllable by, bonding_masters, but
	 * will have the usual "bonding" sysfs directory.
	 *
	 * This is done to preserve backwards compatibility for
	 * initscripts/sysconfig, which load bonding multiple times to
	 * configure multiple bonding devices.
	 */
	if (ret == -EEXIST) {
1745
		/* Is someone being kinky and naming a device bonding_master? */
1746
		if (__dev_get_by_name(bn->net,
1747
				      class_attr_bonding_masters.attr.name))
J
Joe Perches 已提交
1748
			pr_err("network device named %s already exists in sysfs",
1749
			       class_attr_bonding_masters.attr.name);
1750
		ret = 0;
1751
	}
1752 1753 1754 1755 1756 1757 1758 1759

	return ret;

}

/*
 * Remove /sys/class/net/bonding_masters.
 */
1760
void bond_destroy_sysfs(struct bond_net *bn)
1761
{
1762
	netdev_class_remove_file_ns(&bn->class_attr_bonding_masters, bn->net);
1763 1764 1765 1766 1767 1768
}

/*
 * Initialize sysfs for each bond.  This sets up and registers
 * the 'bondctl' directory for each individual bond under /sys/class/net.
 */
1769
void bond_prepare_sysfs_group(struct bonding *bond)
1770
{
1771
	bond->dev->sysfs_groups[0] = &bonding_group;
1772 1773
}