From patchwork Fri Jan 8 07:41:50 2016 Content-Type: text/plain; charset="utf-8" MIME-Version: 1.0 Content-Transfer-Encoding: 7bit X-Patchwork-Submitter: Zhu Yanjun X-Patchwork-Id: 564640 X-Patchwork-Delegate: davem@davemloft.net Return-Path: X-Original-To: patchwork-incoming@ozlabs.org Delivered-To: patchwork-incoming@ozlabs.org Received: from vger.kernel.org (vger.kernel.org [209.132.180.67]) by ozlabs.org (Postfix) with ESMTP id 0CB281402A8 for ; Fri, 8 Jan 2016 18:41:26 +1100 (AEDT) Received: (majordomo@vger.kernel.org) by vger.kernel.org via listexpand id S1752154AbcAHHlV (ORCPT ); Fri, 8 Jan 2016 02:41:21 -0500 Received: from mail.windriver.com ([147.11.1.11]:54166 "EHLO mail.windriver.com" rhost-flags-OK-OK-OK-OK) by vger.kernel.org with ESMTP id S1751681AbcAHHlT (ORCPT ); Fri, 8 Jan 2016 02:41:19 -0500 Received: from ALA-HCA.corp.ad.wrs.com (ala-hca.corp.ad.wrs.com [147.11.189.40]) by mail.windriver.com (8.15.2/8.15.1) with ESMTPS id u087fBFi008569 (version=TLSv1 cipher=AES128-SHA bits=128 verify=FAIL); Thu, 7 Jan 2016 23:41:11 -0800 (PST) Received: from sustaining-2.corp.ad.wrs.com (128.224.162.248) by ALA-HCA.corp.ad.wrs.com (147.11.189.50) with Microsoft SMTP Server id 14.3.248.2; Thu, 7 Jan 2016 23:41:10 -0800 From: To: CC: , , , , , Subject: [PATCH 1/1] bonding: utilize notifier callbacks to detect slave link state changes Date: Fri, 8 Jan 2016 15:41:50 +0800 Message-ID: <1452238910-13277-2-git-send-email-zyjzyj2000@gmail.com> X-Mailer: git-send-email 1.7.9.5 In-Reply-To: <1452238910-13277-1-git-send-email-zyjzyj2000@gmail.com> References: <30904.1452233570@famine> <1452238910-13277-1-git-send-email-zyjzyj2000@gmail.com> MIME-Version: 1.0 Sender: netdev-owner@vger.kernel.org Precedence: bulk List-ID: X-Mailing-List: netdev@vger.kernel.org From: Zhu Yanjun This patch modifies bonding to utilize notifier callbacks to detect slave link state changes. It is intended to be used with miimon set to zero, and does not support the updelay or downdelay options to bonding. It's not as complicated as it looks; most of the change set is to break out the inner loop of bond_miimon_inspect into its own function. Signed-off-by: Zhu Yanjun --- drivers/net/bonding/bond_main.c | 154 ++++++++++++++++++++------------------- 1 file changed, 78 insertions(+), 76 deletions(-) diff --git a/drivers/net/bonding/bond_main.c b/drivers/net/bonding/bond_main.c index 9e0f8a7..9a0e69e 100644 --- a/drivers/net/bonding/bond_main.c +++ b/drivers/net/bonding/bond_main.c @@ -1977,101 +1977,100 @@ static int bond_slave_info_query(struct net_device *bond_dev, struct ifslave *in /*-------------------------------- Monitoring -------------------------------*/ /* called with rcu_read_lock() */ -static int bond_miimon_inspect(struct bonding *bond) +static int bond_miimon_inspect_slave(struct bonding *bond, struct slave *slave) { - int link_state, commit = 0; - struct list_head *iter; - struct slave *slave; + int link_state; bool ignore_updelay; ignore_updelay = !rcu_dereference(bond->curr_active_slave); - bond_for_each_slave_rcu(bond, slave, iter) { - slave->new_link = BOND_LINK_NOCHANGE; - - link_state = bond_check_dev_link(bond, slave->dev, 0); + slave->new_link = BOND_LINK_NOCHANGE; - switch (slave->link) { - case BOND_LINK_UP: - if (link_state) - continue; + link_state = bond_check_dev_link(bond, slave->dev, 0); - bond_set_slave_link_state(slave, BOND_LINK_FAIL); - slave->delay = bond->params.downdelay; - if (slave->delay) { - netdev_info(bond->dev, "link status down for %sinterface %s, disabling it in %d ms\n", - (BOND_MODE(bond) == - BOND_MODE_ACTIVEBACKUP) ? - (bond_is_active_slave(slave) ? - "active " : "backup ") : "", - slave->dev->name, - bond->params.downdelay * bond->params.miimon); - } - /*FALLTHRU*/ - case BOND_LINK_FAIL: - if (link_state) { - /* recovered before downdelay expired */ - bond_set_slave_link_state(slave, BOND_LINK_UP); - slave->last_link_up = jiffies; - netdev_info(bond->dev, "link status up again after %d ms for interface %s\n", - (bond->params.downdelay - slave->delay) * - bond->params.miimon, - slave->dev->name); - continue; - } + switch (slave->link) { + case BOND_LINK_UP: + if (link_state) + return 0; - if (slave->delay <= 0) { - slave->new_link = BOND_LINK_DOWN; - commit++; - continue; - } + bond_set_slave_link_state(slave, BOND_LINK_FAIL); + slave->delay = bond->params.downdelay; + if (slave->delay) { + netdev_info(bond->dev, "link status down for %sinterface %s, disabling it in %d ms\n", + (BOND_MODE(bond) == BOND_MODE_ACTIVEBACKUP) ? + (bond_is_active_slave(slave) ? + "active " : "backup ") : "", + slave->dev->name, + bond->params.downdelay * bond->params.miimon); + } + /*FALLTHRU*/ + case BOND_LINK_FAIL: + if (link_state) { + /* recovered before downdelay expired */ + bond_set_slave_link_state(slave, BOND_LINK_UP); + slave->last_link_up = jiffies; + netdev_info(bond->dev, "link status up again after %d ms for interface %s\n", + (bond->params.downdelay - slave->delay) * + bond->params.miimon, slave->dev->name); + return 0; + } - slave->delay--; - break; + if (slave->delay <= 0) { + slave->new_link = BOND_LINK_DOWN; + return 1; + } - case BOND_LINK_DOWN: - if (!link_state) - continue; + slave->delay--; + break; - bond_set_slave_link_state(slave, BOND_LINK_BACK); - slave->delay = bond->params.updelay; + case BOND_LINK_DOWN: + if (!link_state) + return 0; - if (slave->delay) { - netdev_info(bond->dev, "link status up for interface %s, enabling it in %d ms\n", - slave->dev->name, - ignore_updelay ? 0 : - bond->params.updelay * - bond->params.miimon); - } - /*FALLTHRU*/ - case BOND_LINK_BACK: - if (!link_state) { - bond_set_slave_link_state(slave, - BOND_LINK_DOWN); - netdev_info(bond->dev, "link status down again after %d ms for interface %s\n", - (bond->params.updelay - slave->delay) * - bond->params.miimon, - slave->dev->name); + bond_set_slave_link_state(slave, BOND_LINK_BACK); + slave->delay = bond->params.updelay; - continue; - } + if (slave->delay) { + netdev_info(bond->dev, "link status up for interface %s, enabling it in %d ms\n", + slave->dev->name, ignore_updelay ? 0 : + bond->params.updelay * bond->params.miimon); + } + /*FALLTHRU*/ + case BOND_LINK_BACK: + if (!link_state) { + bond_set_slave_link_state(slave, BOND_LINK_DOWN); + netdev_info(bond->dev, "link status down again after %d ms for interface %s\n", + (bond->params.updelay - slave->delay) * + bond->params.miimon, slave->dev->name); - if (ignore_updelay) - slave->delay = 0; + return 0; + } - if (slave->delay <= 0) { - slave->new_link = BOND_LINK_UP; - commit++; - ignore_updelay = false; - continue; - } + if (ignore_updelay) + slave->delay = 0; - slave->delay--; - break; + if (slave->delay <= 0) { + slave->new_link = BOND_LINK_UP; + return 1; } + + slave->delay--; + break; } - return commit; + return 0; +} + +static int bond_miimon_inspect(struct bonding *bond) +{ + struct list_head *iter; + struct slave *slave; + int commit = 0; + + bond_for_each_slave_rcu(bond, slave, iter) + commit += bond_miimon_inspect_slave(bond, slave); + + return commit; } static void bond_miimon_commit(struct bonding *bond) @@ -2969,6 +2968,9 @@ static int bond_slave_netdev_event(unsigned long event, bond_3ad_adapter_speed_duplex_changed(slave); /* Fallthrough */ case NETDEV_DOWN: + if (bond_miimon_inspect_slave(bond, slave)) + bond_miimon_commit(bond); + /* Refresh slave-array if applicable! * If the setup does not use miimon or arpmon (mode-specific!), * then these events will not cause the slave-array to be