bond_sysfs.c 45.4 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 527 528 529 530 531 532
	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 已提交
533 534
	pr_info("%s: Setting ARP monitoring interval to %d.\n",
		bond->dev->name, new_value);
535
	bond->params.arp_interval = new_value;
536 537 538 539 540 541 542 543 544
	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);
545 546 547 548 549 550 551
	}
	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.
		 */
552
		if (!new_value) {
553 554
			if (bond->params.arp_validate)
				bond->recv_probe = NULL;
555 556
			cancel_delayed_work_sync(&bond->arp_work);
		} else {
557 558 559
			/* arp_validate can be set only in active-backup mode */
			if (bond->params.arp_validate)
				bond->recv_probe = bond_arp_rcv;
560 561 562
			cancel_delayed_work_sync(&bond->mii_work);
			queue_delayed_work(bond->wq, &bond->arp_work, 0);
		}
563 564
	}
out:
565
	rtnl_unlock();
566 567
	return ret;
}
S
Stephen Hemminger 已提交
568 569
static DEVICE_ATTR(arp_interval, S_IRUGO | S_IWUSR,
		   bonding_show_arp_interval, bonding_store_arp_interval);
570 571 572 573

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

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

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

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

605 606 607 608
	targets = bond->params.arp_targets;
	newtarget = in_aton(buf + 1);
	/* look for adds */
	if (buf[0] == '+') {
609
		if ((newtarget == 0) || (newtarget == htonl(INADDR_BROADCAST))) {
J
Joe Perches 已提交
610
			pr_err("%s: invalid ARP target %pI4 specified for addition\n",
H
Harvey Harrison 已提交
611
			       bond->dev->name, &newtarget);
612 613
			goto out;
		}
614 615 616 617 618

		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;
619
		}
620

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

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

643 644 645
		ind = bond_get_targets_ip(targets, newtarget);
		if (ind == -1) {
			pr_err("%s: unable to remove nonexistent ARP target %pI4.\n",
J
Joe Perches 已提交
646
				bond->dev->name, &newtarget);
647 648
			goto out;
		}
649

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

654 655
		pr_info("%s: removing ARP target %pI4.\n", bond->dev->name,
			&newtarget);
656 657

		write_lock_bh(&bond->lock);
658
		bond_for_each_slave(bond, slave, iter) {
659 660 661 662 663 664 665
			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++)
666 667
			targets[i] = targets[i+1];
		targets[i] = 0;
668
		write_unlock_bh(&bond->lock);
S
Stephen Hemminger 已提交
669
	} else {
J
Joe Perches 已提交
670 671
		pr_err("no command found in arp_ip_targets file for bond %s. Use +<addr> or -<addr>.\n",
		       bond->dev->name);
672 673 674 675
		ret = -EPERM;
		goto out;
	}

676
	ret = count;
677
out:
678
	rtnl_unlock();
679 680
	return ret;
}
681
static DEVICE_ATTR(arp_ip_target, S_IRUGO | S_IWUSR , bonding_show_arp_targets, bonding_store_arp_targets);
682 683 684 685 686 687

/*
 * 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.
 */
688 689 690
static ssize_t bonding_show_downdelay(struct device *d,
				      struct device_attribute *attr,
				      char *buf)
691
{
692
	struct bonding *bond = to_bond(d);
693

694
	return sprintf(buf, "%d\n", bond->params.downdelay * bond->params.miimon);
695 696
}

697 698 699
static ssize_t bonding_store_downdelay(struct device *d,
				       struct device_attribute *attr,
				       const char *buf, size_t count)
700 701
{
	int new_value, ret = count;
702
	struct bonding *bond = to_bond(d);
703 704

	if (!(bond->params.miimon)) {
J
Joe Perches 已提交
705
		pr_err("%s: Unable to set down delay as MII monitoring is disabled\n",
706 707 708 709 710 711
		       bond->dev->name);
		ret = -EPERM;
		goto out;
	}

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

	}

out:
	return ret;
}
S
Stephen Hemminger 已提交
739 740
static DEVICE_ATTR(downdelay, S_IRUGO | S_IWUSR,
		   bonding_show_downdelay, bonding_store_downdelay);
741

742 743 744
static ssize_t bonding_show_updelay(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
745
{
746
	struct bonding *bond = to_bond(d);
747

748
	return sprintf(buf, "%d\n", bond->params.updelay * bond->params.miimon);
749 750 751

}

752 753 754
static ssize_t bonding_store_updelay(struct device *d,
				     struct device_attribute *attr,
				     const char *buf, size_t count)
755 756
{
	int new_value, ret = count;
757
	struct bonding *bond = to_bond(d);
758 759

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

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

out:
	return ret;
}
S
Stephen Hemminger 已提交
794 795
static DEVICE_ATTR(updelay, S_IRUGO | S_IWUSR,
		   bonding_show_updelay, bonding_store_updelay);
796 797 798 799 800

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

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

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

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

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

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

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

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

852 853
	return ret;
}
S
Stephen Hemminger 已提交
854 855
static DEVICE_ATTR(lacp_rate, S_IRUGO | S_IWUSR,
		   bonding_show_lacp, bonding_store_lacp);
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 887 888
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);

889 890 891 892 893 894 895 896 897 898 899 900 901 902 903 904 905 906 907 908
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 已提交
909 910
		pr_err("%s: Unable to update ad_select because interface is up.\n",
		       bond->dev->name);
911 912 913 914 915 916 917 918
		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 已提交
919 920 921
		pr_info("%s: Setting ad_select to %s (%d).\n",
			bond->dev->name, ad_select_tbl[new_value].modename,
			new_value);
922
	} else {
J
Joe Perches 已提交
923
		pr_err("%s: Ignoring invalid ad_select value %.*s.\n",
924 925 926 927 928 929
		       bond->dev->name, (int)strlen(buf) - 1, buf);
		ret = -EINVAL;
	}
out:
	return ret;
}
S
Stephen Hemminger 已提交
930 931
static DEVICE_ATTR(ad_select, S_IRUGO | S_IWUSR,
		   bonding_show_ad_select, bonding_store_ad_select);
932

933 934 935 936 937 938 939 940 941 942 943 944 945 946 947 948 949 950 951 952 953 954 955 956
/*
 * 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);

957 958 959 960 961 962
/*
 * 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.
 */
963 964 965
static ssize_t bonding_show_miimon(struct device *d,
				   struct device_attribute *attr,
				   char *buf)
966
{
967
	struct bonding *bond = to_bond(d);
968

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

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

979 980
	if (!rtnl_trylock())
		return restart_syscall();
981
	if (sscanf(buf, "%d", &new_value) != 1) {
J
Joe Perches 已提交
982
		pr_err("%s: no miimon value specified.\n",
983 984 985 986 987
		       bond->dev->name);
		ret = -EINVAL;
		goto out;
	}
	if (new_value < 0) {
J
Joe Perches 已提交
988
		pr_err("%s: Invalid miimon value %d not in range %d-%d; rejected.\n",
989
		       bond->dev->name, new_value, 0, INT_MAX);
990 991
		ret = -EINVAL;
		goto out;
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 1018 1019
	}
	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 {
1020 1021
			cancel_delayed_work_sync(&bond->arp_work);
			queue_delayed_work(bond->wq, &bond->mii_work, 0);
1022 1023 1024
		}
	}
out:
1025
	rtnl_unlock();
1026 1027
	return ret;
}
S
Stephen Hemminger 已提交
1028 1029
static DEVICE_ATTR(miimon, S_IRUGO | S_IWUSR,
		   bonding_show_miimon, bonding_store_miimon);
1030 1031 1032 1033 1034 1035 1036 1037

/*
 * 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.
 */
1038 1039 1040
static ssize_t bonding_show_primary(struct device *d,
				    struct device_attribute *attr,
				    char *buf)
1041 1042
{
	int count = 0;
1043
	struct bonding *bond = to_bond(d);
1044 1045

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

	return count;
}

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

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

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

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

1074 1075 1076 1077 1078
	/* 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;
1079
		memset(bond->params.primary, 0, sizeof(bond->params.primary));
1080 1081 1082 1083
		bond_select_active_slave(bond);
		goto out;
	}

1084
	bond_for_each_slave(bond, slave, iter) {
1085 1086 1087 1088 1089 1090 1091
		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;
1092 1093
		}
	}
1094

1095 1096 1097 1098 1099 1100
	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);
1101
out:
1102 1103
	write_unlock_bh(&bond->curr_slave_lock);
	read_unlock(&bond->lock);
1104
	unblock_netpoll_tx();
1105 1106
	rtnl_unlock();

1107 1108
	return count;
}
S
Stephen Hemminger 已提交
1109 1110
static DEVICE_ATTR(primary, S_IRUGO | S_IWUSR,
		   bonding_show_primary, bonding_store_primary);
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 1136 1137
/*
 * 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 已提交
1138
		pr_err("%s: Ignoring invalid primary_reselect value %.*s.\n",
1139 1140 1141 1142 1143 1144 1145
		       bond->dev->name,
		       (int) strlen(buf) - 1, buf);
		ret = -EINVAL;
		goto out;
	}

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

1150
	block_netpoll_tx();
1151 1152 1153 1154 1155
	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);
1156
	unblock_netpoll_tx();
1157 1158 1159 1160 1161 1162 1163 1164
out:
	rtnl_unlock();
	return ret;
}
static DEVICE_ATTR(primary_reselect, S_IRUGO | S_IWUSR,
		   bonding_show_primary_reselect,
		   bonding_store_primary_reselect);

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

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

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


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


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

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

1223 1224 1225
	return count;
}

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

1235 1236
	if (!rtnl_trylock())
		return restart_syscall();
1237

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

1249 1250 1251
	ret = bond_option_active_slave_set(bond, dev);
	if (!ret)
		ret = count;
1252

1253
 out:
1254 1255
	rtnl_unlock();

1256
	return ret;
1257 1258

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


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

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

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

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

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


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

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

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


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

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

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


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

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

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


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

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

	return count;
}
1382
static DEVICE_ATTR(ad_partner_mac, S_IRUGO, bonding_show_ad_partner_mac, NULL);
1383

1384 1385 1386 1387 1388 1389 1390 1391
/*
 * 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);
1392
	struct list_head *iter;
1393 1394
	struct slave *slave;
	int res = 0;
1395 1396 1397 1398

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

1399
	bond_for_each_slave(bond, slave, iter) {
1400 1401
		if (res > (PAGE_SIZE - IFNAMSIZ - 6)) {
			/* not enough space for another interface_name:queue_id pair */
1402 1403 1404 1405 1406 1407 1408 1409 1410 1411
			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 */
1412

1413
	rtnl_unlock();
1414

1415 1416 1417 1418 1419 1420 1421 1422 1423 1424 1425 1426 1427
	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);
1428
	struct list_head *iter;
1429
	u16 qid;
1430
	int ret = count;
1431 1432 1433 1434 1435 1436 1437 1438 1439 1440 1441 1442 1443 1444 1445 1446 1447 1448 1449 1450 1451 1452
	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) ||
1453
	    qid > bond->dev->real_num_tx_queues)
1454 1455 1456 1457 1458 1459 1460 1461 1462
		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;
1463
	bond_for_each_slave(bond, slave, iter) {
1464 1465 1466 1467 1468 1469 1470
		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) {
1471
			goto err_no_cmd;
1472 1473 1474 1475
		}
	}

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

	/* 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);


1496 1497 1498 1499 1500 1501 1502 1503 1504 1505 1506 1507 1508 1509 1510 1511 1512
/*
 * 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);
1513
	int new_value, ret = count;
1514
	struct list_head *iter;
1515 1516
	struct slave *slave;

1517 1518 1519
	if (!rtnl_trylock())
		return restart_syscall();

1520 1521 1522 1523 1524 1525 1526 1527 1528 1529 1530 1531 1532 1533 1534 1535 1536 1537
	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;
	}
1538

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

1554 1555 1556 1557
/*
 * Show and set the number of IGMP membership reports to send on link failure
 */
static ssize_t bonding_show_resend_igmp(struct device *d,
1558 1559
					struct device_attribute *attr,
					char *buf)
1560 1561 1562 1563 1564 1565 1566
{
	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,
1567 1568
					 struct device_attribute *attr,
					 const char *buf, size_t count)
1569 1570 1571 1572 1573 1574 1575 1576 1577 1578 1579
{
	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;
	}

1580
	if (new_value < 0 || new_value > 255) {
1581 1582 1583 1584 1585 1586 1587 1588 1589 1590 1591 1592 1593 1594 1595 1596
		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);

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 1633 1634

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);

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 1680 1681
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);

1682
static struct attribute *per_bond_attrs[] = {
1683 1684
	&dev_attr_slaves.attr,
	&dev_attr_mode.attr,
1685
	&dev_attr_fail_over_mac.attr,
1686
	&dev_attr_arp_validate.attr,
1687
	&dev_attr_arp_all_targets.attr,
1688 1689 1690 1691 1692
	&dev_attr_arp_interval.attr,
	&dev_attr_arp_ip_target.attr,
	&dev_attr_downdelay.attr,
	&dev_attr_updelay.attr,
	&dev_attr_lacp_rate.attr,
1693
	&dev_attr_ad_select.attr,
1694
	&dev_attr_xmit_hash_policy.attr,
1695 1696
	&dev_attr_num_grat_arp.attr,
	&dev_attr_num_unsol_na.attr,
1697 1698
	&dev_attr_miimon.attr,
	&dev_attr_primary.attr,
1699
	&dev_attr_primary_reselect.attr,
1700 1701 1702 1703 1704 1705 1706 1707
	&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,
1708
	&dev_attr_queue_id.attr,
1709
	&dev_attr_all_slaves_active.attr,
1710
	&dev_attr_resend_igmp.attr,
1711
	&dev_attr_min_links.attr,
1712
	&dev_attr_lp_interval.attr,
1713
	&dev_attr_packets_per_slave.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 1734
	ret = netdev_class_create_file_ns(&bn->class_attr_bonding_masters,
					  bn->net);
1735 1736 1737 1738 1739 1740 1741 1742 1743 1744 1745 1746
	/*
	 * 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) {
1747
		/* Is someone being kinky and naming a device bonding_master? */
1748
		if (__dev_get_by_name(bn->net,
1749
				      class_attr_bonding_masters.attr.name))
J
Joe Perches 已提交
1750
			pr_err("network device named %s already exists in sysfs",
1751
			       class_attr_bonding_masters.attr.name);
1752
		ret = 0;
1753
	}
1754 1755 1756 1757 1758 1759 1760 1761

	return ret;

}

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

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