bond_sysfs.c 45.7 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 44

#include "bonding.h"
45

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

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

62
	rtnl_lock();
63

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

	rtnl_unlock();
78 79 80
	return res;
}

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

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

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

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

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

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

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

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

152 153 154 155 156 157 158 159
static const void *bonding_namespace(struct class *cls,
				     const struct class_attribute *attr)
{
	const struct bond_net *bn =
		container_of(attr, struct bond_net, class_attr_bonding_masters);
	return bn->net;
}

160
/* class attribute for bond_masters file.  This ends up in /sys/class/net */
161 162 163 164 165 166 167 168 169
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,
	.namespace = bonding_namespace,
};
170

S
Stephen Hemminger 已提交
171 172
int bond_create_slave_symlinks(struct net_device *master,
			       struct net_device *slave)
173 174 175 176 177
{
	char linkname[IFNAMSIZ+7];
	int ret = 0;

	/* first, create a link from the slave back to the master */
178
	ret = sysfs_create_link(&(slave->dev.kobj), &(master->dev.kobj),
179 180 181 182
				"master");
	if (ret)
		return ret;
	/* next, create a link from the master to the slave */
S
Stephen Hemminger 已提交
183
	sprintf(linkname, "slave_%s", slave->name);
184
	ret = sysfs_create_link(&(master->dev.kobj), &(slave->dev.kobj),
185
				linkname);
186 187 188 189 190

	/* free the master link created earlier in case of error */
	if (ret)
		sysfs_remove_link(&(slave->dev.kobj), "master");

191 192 193 194
	return ret;

}

S
Stephen Hemminger 已提交
195 196
void bond_destroy_slave_symlinks(struct net_device *master,
				 struct net_device *slave)
197 198 199
{
	char linkname[IFNAMSIZ+7];

200
	sysfs_remove_link(&(slave->dev.kobj), "master");
S
Stephen Hemminger 已提交
201
	sprintf(linkname, "slave_%s", slave->name);
202
	sysfs_remove_link(&(master->dev.kobj), linkname);
203 204 205 206 207 208
}


/*
 * Show the slaves in the current bond.
 */
209 210
static ssize_t bonding_show_slaves(struct device *d,
				   struct device_attribute *attr, char *buf)
211 212 213
{
	struct slave *slave;
	int i, res = 0;
214
	struct bonding *bond = to_bond(d);
215

216
	read_lock(&bond->lock);
217 218 219 220 221
	bond_for_each_slave(bond, slave, i) {
		if (res > (PAGE_SIZE - IFNAMSIZ)) {
			/* not enough space for another interface name */
			if ((PAGE_SIZE - res) > 10)
				res = PAGE_SIZE - 10;
222
			res += sprintf(buf + res, "++more++ ");
223 224 225 226
			break;
		}
		res += sprintf(buf + res, "%s ", slave->dev->name);
	}
227
	read_unlock(&bond->lock);
228 229
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
230 231 232 233
	return res;
}

/*
234
 * Set the slaves in the current bond.
235 236
 * This is supposed to be only thin wrapper for bond_enslave and bond_release.
 * All hard work should be done there.
237
 */
238 239 240
static ssize_t bonding_store_slaves(struct device *d,
				    struct device_attribute *attr,
				    const char *buffer, size_t count)
241 242 243
{
	char command[IFNAMSIZ + 1] = { 0, };
	char *ifname;
244 245
	int res, ret = count;
	struct net_device *dev;
246
	struct bonding *bond = to_bond(d);
247

248 249
	if (!rtnl_trylock())
		return restart_syscall();
250

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

257 258 259 260 261 262 263
	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;
	}
264

265 266 267
	switch (command[0]) {
	case '+':
		pr_info("%s: Adding slave %s.\n", bond->dev->name, dev->name);
268
		res = bond_enslave(bond->dev, dev);
269
		break;
S
Stephen Hemminger 已提交
270

271 272 273 274
	case '-':
		pr_info("%s: Removing slave %s.\n", bond->dev->name, dev->name);
		res = bond_release(bond->dev, dev);
		break;
275

276 277
	default:
		goto err_no_cmd;
278 279
	}

280 281 282 283
	if (res)
		ret = res;
	goto out;

284
err_no_cmd:
J
Joe Perches 已提交
285 286
	pr_err("no command found in slaves file for bond %s. Use +ifname or -ifname.\n",
	       bond->dev->name);
287 288 289
	ret = -EPERM;

out:
290
	rtnl_unlock();
291 292 293
	return ret;
}

S
Stephen Hemminger 已提交
294 295
static DEVICE_ATTR(slaves, S_IRUGO | S_IWUSR, bonding_show_slaves,
		   bonding_store_slaves);
296 297 298 299 300

/*
 * Show and set the bonding mode.  The bond interface must be down to
 * change the mode.
 */
301 302
static ssize_t bonding_show_mode(struct device *d,
				 struct device_attribute *attr, char *buf)
303
{
304
	struct bonding *bond = to_bond(d);
305 306 307

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

311 312 313
static ssize_t bonding_store_mode(struct device *d,
				  struct device_attribute *attr,
				  const char *buf, size_t count)
314 315
{
	int new_value, ret = count;
316
	struct bonding *bond = to_bond(d);
317

318 319 320
	if (!rtnl_trylock())
		return restart_syscall();

321
	if (bond->dev->flags & IFF_UP) {
J
Joe Perches 已提交
322 323
		pr_err("unable to update mode of %s because interface is up.\n",
		       bond->dev->name);
324 325 326 327
		ret = -EPERM;
		goto out;
	}

328 329 330 331 332 333 334
	if (bond->slave_cnt > 0) {
		pr_err("unable to update mode of %s because it has slaves.\n",
			bond->dev->name);
		ret = -EPERM;
		goto out;
	}

J
Jay Vosburgh 已提交
335
	new_value = bond_parse_parm(buf, bond_mode_tbl);
336
	if (new_value < 0)  {
J
Joe Perches 已提交
337 338
		pr_err("%s: Ignoring invalid mode value %.*s.\n",
		       bond->dev->name, (int)strlen(buf) - 1, buf);
339 340
		ret = -EINVAL;
		goto out;
341 342 343 344 345 346 347 348 349
	}
	if ((new_value == BOND_MODE_ALB ||
	     new_value == BOND_MODE_TLB) &&
	    bond->params.arp_interval) {
		pr_err("%s: %s mode is incompatible with arp monitoring.\n",
		       bond->dev->name, bond_mode_tbl[new_value].modename);
		ret = -EINVAL;
		goto out;
	}
350

351 352 353 354 355
	bond->params.mode = new_value;
	bond_set_mode_ops(bond, bond->params.mode);
	pr_info("%s: setting mode to %s (%d).\n",
		bond->dev->name, bond_mode_tbl[new_value].modename,
		new_value);
356
out:
357
	rtnl_unlock();
358 359
	return ret;
}
S
Stephen Hemminger 已提交
360 361
static DEVICE_ATTR(mode, S_IRUGO | S_IWUSR,
		   bonding_show_mode, bonding_store_mode);
362 363

/*
S
Stephen Hemminger 已提交
364
 * Show and set the bonding transmit hash method.
365
 */
366 367 368
static ssize_t bonding_show_xmit_hash(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
369
{
370
	struct bonding *bond = to_bond(d);
371

372 373 374
	return sprintf(buf, "%s %d\n",
		       xmit_hashtype_tbl[bond->params.xmit_policy].modename,
		       bond->params.xmit_policy);
375 376
}

377 378 379
static ssize_t bonding_store_xmit_hash(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
380 381
{
	int new_value, ret = count;
382
	struct bonding *bond = to_bond(d);
383

J
Jay Vosburgh 已提交
384
	new_value = bond_parse_parm(buf, xmit_hashtype_tbl);
385
	if (new_value < 0)  {
J
Joe Perches 已提交
386
		pr_err("%s: Ignoring invalid xmit hash policy value %.*s.\n",
387 388 389 390 391 392
		       bond->dev->name,
		       (int)strlen(buf) - 1, buf);
		ret = -EINVAL;
	} else {
		bond->params.xmit_policy = new_value;
		bond_set_mode_ops(bond, bond->params.mode);
J
Joe Perches 已提交
393
		pr_info("%s: setting xmit hash policy to %s (%d).\n",
S
Stephen Hemminger 已提交
394 395
			bond->dev->name,
			xmit_hashtype_tbl[new_value].modename, new_value);
396
	}
397

398 399
	return ret;
}
S
Stephen Hemminger 已提交
400 401
static DEVICE_ATTR(xmit_hash_policy, S_IRUGO | S_IWUSR,
		   bonding_show_xmit_hash, bonding_store_xmit_hash);
402

403 404 405
/*
 * Show and set arp_validate.
 */
406 407 408
static ssize_t bonding_show_arp_validate(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
409
{
410
	struct bonding *bond = to_bond(d);
411 412 413

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

417 418 419
static ssize_t bonding_store_arp_validate(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
420 421
{
	int new_value;
422
	struct bonding *bond = to_bond(d);
423

J
Jay Vosburgh 已提交
424
	new_value = bond_parse_parm(buf, arp_validate_tbl);
425
	if (new_value < 0) {
J
Joe Perches 已提交
426
		pr_err("%s: Ignoring invalid arp_validate value %s\n",
427 428 429 430
		       bond->dev->name, buf);
		return -EINVAL;
	}
	if (new_value && (bond->params.mode != BOND_MODE_ACTIVEBACKUP)) {
J
Joe Perches 已提交
431
		pr_err("%s: arp_validate only supported in active-backup mode.\n",
432 433 434
		       bond->dev->name);
		return -EINVAL;
	}
J
Joe Perches 已提交
435 436 437
	pr_info("%s: setting arp_validate to %s (%d).\n",
		bond->dev->name, arp_validate_tbl[new_value].modename,
		new_value);
438 439 440 441 442 443

	bond->params.arp_validate = new_value;

	return count;
}

S
Stephen Hemminger 已提交
444 445
static DEVICE_ATTR(arp_validate, S_IRUGO | S_IWUSR, bonding_show_arp_validate,
		   bonding_store_arp_validate);
446 447 448 449 450 451 452 453 454 455 456 457 458 459 460 461 462 463 464 465 466 467 468 469 470 471 472 473 474 475 476 477 478 479 480 481 482 483
/*
 * 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);
484

485 486 487 488
/*
 * Show and store fail_over_mac.  User only allowed to change the
 * value when there are no slaves.
 */
S
Stephen Hemminger 已提交
489 490 491
static ssize_t bonding_show_fail_over_mac(struct device *d,
					  struct device_attribute *attr,
					  char *buf)
492 493 494
{
	struct bonding *bond = to_bond(d);

495 496 497
	return sprintf(buf, "%s %d\n",
		       fail_over_mac_tbl[bond->params.fail_over_mac].modename,
		       bond->params.fail_over_mac);
498 499
}

S
Stephen Hemminger 已提交
500 501 502
static ssize_t bonding_store_fail_over_mac(struct device *d,
					   struct device_attribute *attr,
					   const char *buf, size_t count)
503
{
504
	int new_value, ret = count;
505 506
	struct bonding *bond = to_bond(d);

507 508 509
	if (!rtnl_trylock())
		return restart_syscall();

510
	if (bond->slave_cnt != 0) {
J
Joe Perches 已提交
511
		pr_err("%s: Can't alter fail_over_mac with slaves in bond.\n",
512
		       bond->dev->name);
513 514
		ret = -EPERM;
		goto out;
515 516
	}

517 518
	new_value = bond_parse_parm(buf, fail_over_mac_tbl);
	if (new_value < 0) {
J
Joe Perches 已提交
519
		pr_err("%s: Ignoring invalid fail_over_mac value %s.\n",
520
		       bond->dev->name, buf);
521 522
		ret = -EINVAL;
		goto out;
523 524
	}

525
	bond->params.fail_over_mac = new_value;
J
Joe Perches 已提交
526 527 528
	pr_info("%s: Setting fail_over_mac to %s (%d).\n",
		bond->dev->name, fail_over_mac_tbl[new_value].modename,
		new_value);
529

530 531 532
out:
	rtnl_unlock();
	return ret;
533 534
}

S
Stephen Hemminger 已提交
535 536
static DEVICE_ATTR(fail_over_mac, S_IRUGO | S_IWUSR,
		   bonding_show_fail_over_mac, bonding_store_fail_over_mac);
537

538 539 540 541 542 543
/*
 * 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.
 */
544 545 546
static ssize_t bonding_show_arp_interval(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
547
{
548
	struct bonding *bond = to_bond(d);
549

550
	return sprintf(buf, "%d\n", bond->params.arp_interval);
551 552
}

553 554 555
static ssize_t bonding_store_arp_interval(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
556 557
{
	int new_value, ret = count;
558
	struct bonding *bond = to_bond(d);
559

560 561
	if (!rtnl_trylock())
		return restart_syscall();
562
	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
563
		pr_err("%s: no arp_interval value specified.\n",
564 565 566 567 568
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
569
		pr_err("%s: Invalid arp_interval value %d not in range 0-%d; rejected.\n",
570 571 572 573
		       bond->dev->name, new_value, INT_MAX);
		ret = -EINVAL;
		goto out;
	}
574 575 576 577 578 579 580
	if (bond->params.mode == BOND_MODE_ALB ||
	    bond->params.mode == BOND_MODE_TLB) {
		pr_info("%s: ARP monitoring cannot be used with ALB/TLB. Only MII monitoring is supported on %s.\n",
			bond->dev->name, bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
J
Joe Perches 已提交
581 582
	pr_info("%s: Setting ARP monitoring interval to %d.\n",
		bond->dev->name, new_value);
583
	bond->params.arp_interval = new_value;
584 585 586 587 588 589 590 591 592
	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);
593 594 595 596 597 598 599
	}
	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.
		 */
600 601 602 603 604 605
		if (!new_value) {
			cancel_delayed_work_sync(&bond->arp_work);
		} else {
			cancel_delayed_work_sync(&bond->mii_work);
			queue_delayed_work(bond->wq, &bond->arp_work, 0);
		}
606 607
	}
out:
608
	rtnl_unlock();
609 610
	return ret;
}
S
Stephen Hemminger 已提交
611 612
static DEVICE_ATTR(arp_interval, S_IRUGO | S_IWUSR,
		   bonding_show_arp_interval, bonding_store_arp_interval);
613 614 615 616

/*
 * Show and set the arp targets.
 */
617 618 619
static ssize_t bonding_show_arp_targets(struct device *d,
					struct device_attribute *attr,
					char *buf)
620 621
{
	int i, res = 0;
622
	struct bonding *bond = to_bond(d);
623 624 625

	for (i = 0; i < BOND_MAX_ARP_TARGETS; i++) {
		if (bond->params.arp_targets[i])
H
Harvey Harrison 已提交
626 627
			res += sprintf(buf + res, "%pI4 ",
				       &bond->params.arp_targets[i]);
628
	}
629 630
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
631 632 633
	return res;
}

634 635 636
static ssize_t bonding_store_arp_targets(struct device *d,
					 struct device_attribute *attr,
					 const char *buf, size_t count)
637
{
638
	struct bonding *bond = to_bond(d);
639 640 641 642
	struct slave *slave;
	__be32 newtarget, *targets;
	unsigned long *targets_rx;
	int ind, i, j, ret = -EINVAL;
643 644 645 646 647

	targets = bond->params.arp_targets;
	newtarget = in_aton(buf + 1);
	/* look for adds */
	if (buf[0] == '+') {
648
		if ((newtarget == 0) || (newtarget == htonl(INADDR_BROADCAST))) {
J
Joe Perches 已提交
649
			pr_err("%s: invalid ARP target %pI4 specified for addition\n",
H
Harvey Harrison 已提交
650
			       bond->dev->name, &newtarget);
651 652
			goto out;
		}
653 654 655 656 657

		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;
658
		}
659

660 661
		ind = bond_get_targets_ip(targets, 0); /* first free slot */
		if (ind == -1) {
J
Joe Perches 已提交
662
			pr_err("%s: ARP target table is full!\n",
663 664 665 666
			       bond->dev->name);
			goto out;
		}

667 668
		pr_info("%s: adding ARP target %pI4.\n", bond->dev->name,
			 &newtarget);
669 670 671 672 673 674
		/* not to race with bond_arp_rcv */
		write_lock_bh(&bond->lock);
		bond_for_each_slave(bond, slave, i)
			slave->target_last_arp_rx[ind] = jiffies;
		targets[ind] = newtarget;
		write_unlock_bh(&bond->lock);
S
Stephen Hemminger 已提交
675
	} else if (buf[0] == '-')	{
676
		if ((newtarget == 0) || (newtarget == htonl(INADDR_BROADCAST))) {
J
Joe Perches 已提交
677
			pr_err("%s: invalid ARP target %pI4 specified for removal\n",
H
Harvey Harrison 已提交
678
			       bond->dev->name, &newtarget);
679 680 681
			goto out;
		}

682 683 684
		ind = bond_get_targets_ip(targets, newtarget);
		if (ind == -1) {
			pr_err("%s: unable to remove nonexistent ARP target %pI4.\n",
J
Joe Perches 已提交
685
				bond->dev->name, &newtarget);
686 687
			goto out;
		}
688

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

693 694
		pr_info("%s: removing ARP target %pI4.\n", bond->dev->name,
			&newtarget);
695 696 697 698 699 700 701 702 703 704

		write_lock_bh(&bond->lock);
		bond_for_each_slave(bond, slave, i) {
			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++)
705 706
			targets[i] = targets[i+1];
		targets[i] = 0;
707
		write_unlock_bh(&bond->lock);
S
Stephen Hemminger 已提交
708
	} else {
J
Joe Perches 已提交
709 710
		pr_err("no command found in arp_ip_targets file for bond %s. Use +<addr> or -<addr>.\n",
		       bond->dev->name);
711 712 713 714
		ret = -EPERM;
		goto out;
	}

715
	ret = count;
716 717 718
out:
	return ret;
}
719
static DEVICE_ATTR(arp_ip_target, S_IRUGO | S_IWUSR , bonding_show_arp_targets, bonding_store_arp_targets);
720 721 722 723 724 725

/*
 * 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.
 */
726 727 728
static ssize_t bonding_show_downdelay(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
729
{
730
	struct bonding *bond = to_bond(d);
731

732
	return sprintf(buf, "%d\n", bond->params.downdelay * bond->params.miimon);
733 734
}

735 736 737
static ssize_t bonding_store_downdelay(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
738 739
{
	int new_value, ret = count;
740
	struct bonding *bond = to_bond(d);
741 742

	if (!(bond->params.miimon)) {
J
Joe Perches 已提交
743
		pr_err("%s: Unable to set down delay as MII monitoring is disabled\n",
744 745 746 747 748 749
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
750
		pr_err("%s: no down delay value specified.\n", bond->dev->name);
751 752 753 754
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
J
Joe Perches 已提交
755
		pr_err("%s: Invalid down delay value %d not in range %d-%d; rejected.\n",
756
		       bond->dev->name, new_value, 0, INT_MAX);
757 758 759 760
		ret = -EINVAL;
		goto out;
	} else {
		if ((new_value % bond->params.miimon) != 0) {
J
Joe Perches 已提交
761
			pr_warning("%s: Warning: down delay (%d) is not a multiple of miimon (%d), delay rounded to %d ms\n",
J
Jiri Pirko 已提交
762 763 764 765
				   bond->dev->name, new_value,
				   bond->params.miimon,
				   (new_value / bond->params.miimon) *
				   bond->params.miimon);
766 767
		}
		bond->params.downdelay = new_value / bond->params.miimon;
J
Joe Perches 已提交
768 769 770
		pr_info("%s: Setting down delay to %d.\n",
			bond->dev->name,
			bond->params.downdelay * bond->params.miimon);
771 772 773 774 775 776

	}

out:
	return ret;
}
S
Stephen Hemminger 已提交
777 778
static DEVICE_ATTR(downdelay, S_IRUGO | S_IWUSR,
		   bonding_show_downdelay, bonding_store_downdelay);
779

780 781 782
static ssize_t bonding_show_updelay(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
783
{
784
	struct bonding *bond = to_bond(d);
785

786
	return sprintf(buf, "%d\n", bond->params.updelay * bond->params.miimon);
787 788 789

}

790 791 792
static ssize_t bonding_store_updelay(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
793 794
{
	int new_value, ret = count;
795
	struct bonding *bond = to_bond(d);
796 797

	if (!(bond->params.miimon)) {
J
Joe Perches 已提交
798
		pr_err("%s: Unable to set up delay as MII monitoring is disabled\n",
799 800 801 802 803 804
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
805
		pr_err("%s: no up delay value specified.\n",
806 807 808 809 810
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
811 812
		pr_err("%s: Invalid up delay value %d not in range %d-%d; rejected.\n",
		       bond->dev->name, new_value, 0, INT_MAX);
813 814 815 816
		ret = -EINVAL;
		goto out;
	} else {
		if ((new_value % bond->params.miimon) != 0) {
J
Joe Perches 已提交
817
			pr_warning("%s: Warning: up delay (%d) is not a multiple of miimon (%d), updelay rounded to %d ms\n",
J
Jiri Pirko 已提交
818 819 820 821
				   bond->dev->name, new_value,
				   bond->params.miimon,
				   (new_value / bond->params.miimon) *
				   bond->params.miimon);
822 823
		}
		bond->params.updelay = new_value / bond->params.miimon;
J
Joe Perches 已提交
824 825 826
		pr_info("%s: Setting up delay to %d.\n",
			bond->dev->name,
			bond->params.updelay * bond->params.miimon);
827 828 829 830 831
	}

out:
	return ret;
}
S
Stephen Hemminger 已提交
832 833
static DEVICE_ATTR(updelay, S_IRUGO | S_IWUSR,
		   bonding_show_updelay, bonding_store_updelay);
834 835 836 837 838

/*
 * Show and set the LACP interval.  Interface must be down, and the mode
 * must be set to 802.3ad mode.
 */
839 840 841
static ssize_t bonding_show_lacp(struct device *d,
				 struct device_attribute *attr,
				 char *buf)
842
{
843
	struct bonding *bond = to_bond(d);
844 845 846

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

850 851 852
static ssize_t bonding_store_lacp(struct device *d,
				  struct device_attribute *attr,
				  const char *buf, size_t count)
853 854
{
	int new_value, ret = count;
855
	struct bonding *bond = to_bond(d);
856 857

	if (bond->dev->flags & IFF_UP) {
J
Joe Perches 已提交
858
		pr_err("%s: Unable to update LACP rate because interface is up.\n",
859 860 861 862 863 864
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

	if (bond->params.mode != BOND_MODE_8023AD) {
J
Joe Perches 已提交
865
		pr_err("%s: Unable to update LACP rate because bond is not in 802.3ad mode.\n",
866 867 868 869 870
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

J
Jay Vosburgh 已提交
871
	new_value = bond_parse_parm(buf, bond_lacp_tbl);
872 873 874

	if ((new_value == 1) || (new_value == 0)) {
		bond->params.lacp_fast = new_value;
875
		bond_3ad_update_lacp_rate(bond);
J
Joe Perches 已提交
876
		pr_info("%s: Setting LACP rate to %s (%d).\n",
S
Stephen Hemminger 已提交
877 878
			bond->dev->name, bond_lacp_tbl[new_value].modename,
			new_value);
879
	} else {
J
Joe Perches 已提交
880
		pr_err("%s: Ignoring invalid LACP rate value %.*s.\n",
S
Stephen Hemminger 已提交
881
		       bond->dev->name, (int)strlen(buf) - 1, buf);
882 883 884 885 886
		ret = -EINVAL;
	}
out:
	return ret;
}
S
Stephen Hemminger 已提交
887 888
static DEVICE_ATTR(lacp_rate, S_IRUGO | S_IWUSR,
		   bonding_show_lacp, bonding_store_lacp);
889

890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908 909 910 911 912 913 914 915 916 917 918 919 920 921
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);

922 923 924 925 926 927 928 929 930 931 932 933 934 935 936 937 938 939 940 941
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 已提交
942 943
		pr_err("%s: Unable to update ad_select because interface is up.\n",
		       bond->dev->name);
944 945 946 947 948 949 950 951
		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 已提交
952 953 954
		pr_info("%s: Setting ad_select to %s (%d).\n",
			bond->dev->name, ad_select_tbl[new_value].modename,
			new_value);
955
	} else {
J
Joe Perches 已提交
956
		pr_err("%s: Ignoring invalid ad_select value %.*s.\n",
957 958 959 960 961 962
		       bond->dev->name, (int)strlen(buf) - 1, buf);
		ret = -EINVAL;
	}
out:
	return ret;
}
S
Stephen Hemminger 已提交
963 964
static DEVICE_ATTR(ad_select, S_IRUGO | S_IWUSR,
		   bonding_show_ad_select, bonding_store_ad_select);
965

966 967 968 969 970 971 972 973 974 975 976 977 978 979 980 981 982 983 984 985 986 987 988 989
/*
 * 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);

990 991 992 993 994 995
/*
 * 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.
 */
996 997 998
static ssize_t bonding_show_miimon(struct device *d,
				   struct device_attribute *attr,
				   char *buf)
999
{
1000
	struct bonding *bond = to_bond(d);
1001

1002
	return sprintf(buf, "%d\n", bond->params.miimon);
1003 1004
}

1005 1006 1007
static ssize_t bonding_store_miimon(struct device *d,
				    struct device_attribute *attr,
				    const char *buf, size_t count)
1008 1009
{
	int new_value, ret = count;
1010
	struct bonding *bond = to_bond(d);
1011

1012 1013
	if (!rtnl_trylock())
		return restart_syscall();
1014
	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
1015
		pr_err("%s: no miimon value specified.\n",
1016 1017 1018 1019 1020
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
J
Joe Perches 已提交
1021
		pr_err("%s: Invalid miimon value %d not in range %d-%d; rejected.\n",
1022
		       bond->dev->name, new_value, 0, INT_MAX);
1023 1024
		ret = -EINVAL;
		goto out;
1025 1026 1027 1028 1029 1030 1031 1032 1033 1034 1035 1036 1037 1038 1039 1040 1041 1042 1043 1044 1045 1046 1047 1048 1049 1050 1051 1052
	}
	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 {
1053 1054
			cancel_delayed_work_sync(&bond->arp_work);
			queue_delayed_work(bond->wq, &bond->mii_work, 0);
1055 1056 1057
		}
	}
out:
1058
	rtnl_unlock();
1059 1060
	return ret;
}
S
Stephen Hemminger 已提交
1061 1062
static DEVICE_ATTR(miimon, S_IRUGO | S_IWUSR,
		   bonding_show_miimon, bonding_store_miimon);
1063 1064 1065 1066 1067 1068 1069 1070

/*
 * 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.
 */
1071 1072 1073
static ssize_t bonding_show_primary(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
1074 1075
{
	int count = 0;
1076
	struct bonding *bond = to_bond(d);
1077 1078

	if (bond->primary_slave)
1079
		count = sprintf(buf, "%s\n", bond->primary_slave->dev->name);
1080 1081 1082 1083

	return count;
}

1084 1085 1086
static ssize_t bonding_store_primary(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
1087 1088 1089
{
	int i;
	struct slave *slave;
1090
	struct bonding *bond = to_bond(d);
1091
	char ifname[IFNAMSIZ];
1092

1093 1094
	if (!rtnl_trylock())
		return restart_syscall();
1095
	block_netpoll_tx();
1096 1097 1098
	read_lock(&bond->lock);
	write_lock_bh(&bond->curr_slave_lock);

1099
	if (!USES_PRIMARY(bond->params.mode)) {
J
Joe Perches 已提交
1100 1101
		pr_info("%s: Unable to set primary slave; %s is in mode %d\n",
			bond->dev->name, bond->dev->name, bond->params.mode);
1102 1103
		goto out;
	}
1104

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

1107 1108 1109 1110 1111
	/* 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;
1112
		memset(bond->params.primary, 0, sizeof(bond->params.primary));
1113 1114 1115 1116 1117 1118 1119 1120 1121 1122 1123 1124
		bond_select_active_slave(bond);
		goto out;
	}

	bond_for_each_slave(bond, slave, i) {
		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;
1125 1126
		}
	}
1127

1128 1129 1130 1131 1132 1133
	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);
1134
out:
1135 1136
	write_unlock_bh(&bond->curr_slave_lock);
	read_unlock(&bond->lock);
1137
	unblock_netpoll_tx();
1138 1139
	rtnl_unlock();

1140 1141
	return count;
}
S
Stephen Hemminger 已提交
1142 1143
static DEVICE_ATTR(primary, S_IRUGO | S_IWUSR,
		   bonding_show_primary, bonding_store_primary);
1144

1145 1146 1147 1148 1149 1150 1151 1152 1153 1154 1155 1156 1157 1158 1159 1160 1161 1162 1163 1164 1165 1166 1167 1168 1169 1170
/*
 * 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 已提交
1171
		pr_err("%s: Ignoring invalid primary_reselect value %.*s.\n",
1172 1173 1174 1175 1176 1177 1178
		       bond->dev->name,
		       (int) strlen(buf) - 1, buf);
		ret = -EINVAL;
		goto out;
	}

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

1183
	block_netpoll_tx();
1184 1185 1186 1187 1188
	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);
1189
	unblock_netpoll_tx();
1190 1191 1192 1193 1194 1195 1196 1197
out:
	rtnl_unlock();
	return ret;
}
static DEVICE_ATTR(primary_reselect, S_IRUGO | S_IWUSR,
		   bonding_show_primary_reselect,
		   bonding_store_primary_reselect);

1198 1199 1200
/*
 * Show and set the use_carrier flag.
 */
1201 1202 1203
static ssize_t bonding_show_carrier(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
1204
{
1205
	struct bonding *bond = to_bond(d);
1206

1207
	return sprintf(buf, "%d\n", bond->params.use_carrier);
1208 1209
}

1210 1211 1212
static ssize_t bonding_store_carrier(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
1213 1214
{
	int new_value, ret = count;
1215
	struct bonding *bond = to_bond(d);
1216 1217 1218


	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
1219
		pr_err("%s: no use_carrier value specified.\n",
1220 1221 1222 1223 1224 1225
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if ((new_value == 0) || (new_value == 1)) {
		bond->params.use_carrier = new_value;
J
Joe Perches 已提交
1226 1227
		pr_info("%s: Setting use_carrier to %d.\n",
			bond->dev->name, new_value);
1228
	} else {
J
Joe Perches 已提交
1229 1230
		pr_info("%s: Ignoring invalid use_carrier value %d.\n",
			bond->dev->name, new_value);
1231 1232
	}
out:
1233
	return ret;
1234
}
S
Stephen Hemminger 已提交
1235 1236
static DEVICE_ATTR(use_carrier, S_IRUGO | S_IWUSR,
		   bonding_show_carrier, bonding_store_carrier);
1237 1238 1239 1240 1241


/*
 * Show and set currently active_slave.
 */
1242 1243 1244
static ssize_t bonding_show_active_slave(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
1245 1246
{
	struct slave *curr;
1247
	struct bonding *bond = to_bond(d);
1248
	int count = 0;
1249 1250 1251 1252 1253 1254

	read_lock(&bond->curr_slave_lock);
	curr = bond->curr_active_slave;
	read_unlock(&bond->curr_slave_lock);

	if (USES_PRIMARY(bond->params.mode) && curr)
1255
		count = sprintf(buf, "%s\n", curr->dev->name);
1256 1257 1258
	return count;
}

1259 1260 1261
static ssize_t bonding_store_active_slave(struct device *d,
					  struct device_attribute *attr,
					  const char *buf, size_t count)
1262 1263 1264
{
	int i;
	struct slave *slave;
S
Stephen Hemminger 已提交
1265 1266
	struct slave *old_active = NULL;
	struct slave *new_active = NULL;
1267
	struct bonding *bond = to_bond(d);
1268
	char ifname[IFNAMSIZ];
1269

1270 1271
	if (!rtnl_trylock())
		return restart_syscall();
1272 1273

	block_netpoll_tx();
1274 1275
	read_lock(&bond->lock);
	write_lock_bh(&bond->curr_slave_lock);
1276

1277
	if (!USES_PRIMARY(bond->params.mode)) {
J
Joe Perches 已提交
1278
		pr_info("%s: Unable to change active slave; %s is in mode %d\n",
S
Stephen Hemminger 已提交
1279
			bond->dev->name, bond->dev->name, bond->params.mode);
1280 1281 1282
		goto out;
	}

1283
	sscanf(buf, "%15s", ifname); /* IFNAMSIZ */
1284 1285 1286 1287 1288 1289 1290 1291 1292 1293 1294 1295 1296 1297 1298 1299 1300 1301 1302 1303 1304

	/* check to see if we are clearing active */
	if (!strlen(ifname) || buf[0] == '\n') {
		pr_info("%s: Clearing current active slave.\n",
			bond->dev->name);
		bond->curr_active_slave = NULL;
		bond_select_active_slave(bond);
		goto out;
	}

	bond_for_each_slave(bond, slave, i) {
		if (strncmp(slave->dev->name, ifname, IFNAMSIZ) == 0) {
			old_active = bond->curr_active_slave;
			new_active = slave;
			if (new_active == old_active) {
				/* do nothing */
				pr_info("%s: %s is already the current"
					" active slave.\n",
					bond->dev->name,
					slave->dev->name);
				goto out;
1305
			} else {
1306 1307 1308 1309 1310 1311
				if ((new_active) &&
				    (old_active) &&
				    (new_active->link == BOND_LINK_UP) &&
				    IS_UP(new_active->dev)) {
					pr_info("%s: Setting %s as active"
						" slave.\n",
J
Joe Perches 已提交
1312 1313
						bond->dev->name,
						slave->dev->name);
1314 1315
					bond_change_active_slave(bond,
								 new_active);
1316
				} else {
1317 1318 1319 1320 1321 1322
					pr_info("%s: Could not set %s as"
						" active slave; either %s is"
						" down or the link is down.\n",
						bond->dev->name,
						slave->dev->name,
						slave->dev->name);
1323
				}
1324
				goto out;
1325 1326 1327
			}
		}
	}
1328 1329 1330

	pr_info("%s: Unable to set %.*s as active slave.\n",
		bond->dev->name, (int)strlen(buf) - 1, buf);
S
Stephen Hemminger 已提交
1331
 out:
1332 1333
	write_unlock_bh(&bond->curr_slave_lock);
	read_unlock(&bond->lock);
1334 1335
	unblock_netpoll_tx();

1336 1337
	rtnl_unlock();

1338 1339 1340
	return count;

}
S
Stephen Hemminger 已提交
1341 1342
static DEVICE_ATTR(active_slave, S_IRUGO | S_IWUSR,
		   bonding_show_active_slave, bonding_store_active_slave);
1343 1344 1345 1346 1347


/*
 * Show link status of the bond interface.
 */
1348 1349 1350
static ssize_t bonding_show_mii_status(struct device *d,
				       struct device_attribute *attr,
				       char *buf)
1351 1352
{
	struct slave *curr;
1353
	struct bonding *bond = to_bond(d);
1354 1355 1356 1357 1358

	read_lock(&bond->curr_slave_lock);
	curr = bond->curr_active_slave;
	read_unlock(&bond->curr_slave_lock);

S
Stephen Hemminger 已提交
1359
	return sprintf(buf, "%s\n", curr ? "up" : "down");
1360
}
1361
static DEVICE_ATTR(mii_status, S_IRUGO, bonding_show_mii_status, NULL);
1362 1363 1364 1365

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

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1375
		count = sprintf(buf, "%d\n",
1376
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1377
				?  0 : ad_info.aggregator_id);
1378 1379 1380 1381
	}

	return count;
}
1382
static DEVICE_ATTR(ad_aggregator, S_IRUGO, bonding_show_ad_aggregator, NULL);
1383 1384 1385 1386 1387


/*
 * Show number of active 802.3ad ports.
 */
1388 1389 1390
static ssize_t bonding_show_ad_num_ports(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
1391 1392
{
	int count = 0;
1393
	struct bonding *bond = to_bond(d);
1394 1395 1396

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1397
		count = sprintf(buf, "%d\n",
1398
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1399
				?  0 : ad_info.ports);
1400 1401 1402 1403
	}

	return count;
}
1404
static DEVICE_ATTR(ad_num_ports, S_IRUGO, bonding_show_ad_num_ports, NULL);
1405 1406 1407 1408 1409


/*
 * Show current 802.3ad actor key.
 */
1410 1411 1412
static ssize_t bonding_show_ad_actor_key(struct device *d,
					 struct device_attribute *attr,
					 char *buf)
1413 1414
{
	int count = 0;
1415
	struct bonding *bond = to_bond(d);
1416 1417 1418

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1419
		count = sprintf(buf, "%d\n",
1420
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1421
				?  0 : ad_info.actor_key);
1422 1423 1424 1425
	}

	return count;
}
1426
static DEVICE_ATTR(ad_actor_key, S_IRUGO, bonding_show_ad_actor_key, NULL);
1427 1428 1429 1430 1431


/*
 * Show current 802.3ad partner key.
 */
1432 1433 1434
static ssize_t bonding_show_ad_partner_key(struct device *d,
					   struct device_attribute *attr,
					   char *buf)
1435 1436
{
	int count = 0;
1437
	struct bonding *bond = to_bond(d);
1438 1439 1440

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1441
		count = sprintf(buf, "%d\n",
1442
				bond_3ad_get_active_agg_info(bond, &ad_info)
S
Stephen Hemminger 已提交
1443
				?  0 : ad_info.partner_key);
1444 1445 1446 1447
	}

	return count;
}
1448
static DEVICE_ATTR(ad_partner_key, S_IRUGO, bonding_show_ad_partner_key, NULL);
1449 1450 1451 1452 1453


/*
 * Show current 802.3ad partner mac.
 */
1454 1455 1456
static ssize_t bonding_show_ad_partner_mac(struct device *d,
					   struct device_attribute *attr,
					   char *buf)
1457 1458
{
	int count = 0;
1459
	struct bonding *bond = to_bond(d);
1460 1461 1462

	if (bond->params.mode == BOND_MODE_8023AD) {
		struct ad_info ad_info;
S
Stephen Hemminger 已提交
1463
		if (!bond_3ad_get_active_agg_info(bond, &ad_info))
J
Johannes Berg 已提交
1464
			count = sprintf(buf, "%pM\n", ad_info.partner_system);
1465 1466 1467 1468
	}

	return count;
}
1469
static DEVICE_ATTR(ad_partner_mac, S_IRUGO, bonding_show_ad_partner_mac, NULL);
1470

1471 1472 1473 1474 1475 1476 1477 1478 1479 1480 1481 1482 1483 1484 1485 1486
/*
 * 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 slave *slave;
	int i, res = 0;
	struct bonding *bond = to_bond(d);

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

	read_lock(&bond->lock);
	bond_for_each_slave(bond, slave, i) {
1487 1488
		if (res > (PAGE_SIZE - IFNAMSIZ - 6)) {
			/* not enough space for another interface_name:queue_id pair */
1489 1490 1491 1492 1493 1494 1495 1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512 1513 1514 1515 1516 1517 1518 1519 1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537
			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);
	}
	read_unlock(&bond->lock);
	if (res)
		buf[res-1] = '\n'; /* eat the leftover space */
	rtnl_unlock();
	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);
	u16 qid;
	int i, ret = count;
	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) ||
1538
	    qid > bond->dev->real_num_tx_queues)
1539 1540 1541 1542 1543 1544 1545 1546 1547 1548 1549 1550 1551 1552 1553 1554 1555 1556 1557 1558 1559 1560 1561 1562 1563 1564 1565 1566 1567 1568 1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579 1580 1581 1582 1583 1584 1585
		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;

	read_lock(&bond->lock);

	/* Search for thes slave and check for duplicate qids */
	update_slave = NULL;
	bond_for_each_slave(bond, slave, i) {
		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) {
			goto err_no_cmd_unlock;
		}
	}

	if (!update_slave)
		goto err_no_cmd_unlock;

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

	read_unlock(&bond->lock);
out:
	rtnl_unlock();
	return ret;

err_no_cmd_unlock:
	read_unlock(&bond->lock);
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);


1586 1587 1588 1589 1590 1591 1592 1593 1594 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
/*
 * 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)
{
	int i, new_value, ret = count;
	struct bonding *bond = to_bond(d);
	struct slave *slave;

	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;
	}
1624

1625
	read_lock(&bond->lock);
1626
	bond_for_each_slave(bond, slave, i) {
J
Jiri Pirko 已提交
1627
		if (!bond_is_active_slave(slave)) {
1628
			if (new_value)
1629
				slave->inactive = 0;
1630
			else
1631
				slave->inactive = 1;
1632 1633
		}
	}
1634
	read_unlock(&bond->lock);
1635
out:
1636
	return ret;
1637 1638 1639
}
static DEVICE_ATTR(all_slaves_active, S_IRUGO | S_IWUSR,
		   bonding_show_slaves_active, bonding_store_slaves_active);
1640

1641 1642 1643 1644
/*
 * Show and set the number of IGMP membership reports to send on link failure
 */
static ssize_t bonding_show_resend_igmp(struct device *d,
1645 1646
					struct device_attribute *attr,
					char *buf)
1647 1648 1649 1650 1651 1652 1653
{
	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,
1654 1655
					 struct device_attribute *attr,
					 const char *buf, size_t count)
1656 1657 1658 1659 1660 1661 1662 1663 1664 1665 1666
{
	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;
	}

1667
	if (new_value < 0 || new_value > 255) {
1668 1669 1670 1671 1672 1673 1674 1675 1676 1677 1678 1679 1680 1681 1682 1683
		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);

1684
static struct attribute *per_bond_attrs[] = {
1685 1686
	&dev_attr_slaves.attr,
	&dev_attr_mode.attr,
1687
	&dev_attr_fail_over_mac.attr,
1688
	&dev_attr_arp_validate.attr,
1689
	&dev_attr_arp_all_targets.attr,
1690 1691 1692 1693 1694
	&dev_attr_arp_interval.attr,
	&dev_attr_arp_ip_target.attr,
	&dev_attr_downdelay.attr,
	&dev_attr_updelay.attr,
	&dev_attr_lacp_rate.attr,
1695
	&dev_attr_ad_select.attr,
1696
	&dev_attr_xmit_hash_policy.attr,
1697 1698
	&dev_attr_num_grat_arp.attr,
	&dev_attr_num_unsol_na.attr,
1699 1700
	&dev_attr_miimon.attr,
	&dev_attr_primary.attr,
1701
	&dev_attr_primary_reselect.attr,
1702 1703 1704 1705 1706 1707 1708 1709
	&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,
1710
	&dev_attr_queue_id.attr,
1711
	&dev_attr_all_slaves_active.attr,
1712
	&dev_attr_resend_igmp.attr,
1713
	&dev_attr_min_links.attr,
1714 1715 1716 1717 1718 1719 1720 1721 1722 1723 1724 1725
	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.
 */
1726
int bond_create_sysfs(struct bond_net *bn)
1727
{
1728
	int ret;
1729

1730
	bn->class_attr_bonding_masters = class_attr_bonding_masters;
1731
	sysfs_attr_init(&bn->class_attr_bonding_masters.attr);
1732 1733

	ret = netdev_class_create_file(&bn->class_attr_bonding_masters);
1734 1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745
	/*
	 * 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) {
1746
		/* Is someone being kinky and naming a device bonding_master? */
1747
		if (__dev_get_by_name(bn->net,
1748
				      class_attr_bonding_masters.attr.name))
J
Joe Perches 已提交
1749
			pr_err("network device named %s already exists in sysfs",
1750
			       class_attr_bonding_masters.attr.name);
1751
		ret = 0;
1752
	}
1753 1754 1755 1756 1757 1758 1759 1760

	return ret;

}

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

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