mirror of
https://github.com/torvalds/linux.git
synced 2024-11-19 02:21:47 +00:00
902a45af5c
strtoul returns an 'unsigned long' so there is no reason to check if the value is less than zero. strtoul already checks for the '-' character deep in its bowels. It will return an error if the user has provided a negative value and fcoe_str_to_dev_loss will return that error to its caller. This patch fixes the following Coverity reported warning: CID 703581 - NO_EFFECT Unsigned compared against 0 - This less-than-zero comparison of an unsigned value is never true. "*val < 0UL". drivers/scsi/fcoe/fcoe_sysfs.c:105 Signed-off-by: Robert Love <robert.w.love@intel.com> Signed-off-by: James Bottomley <JBottomley@Parallels.com>
833 lines
23 KiB
C
833 lines
23 KiB
C
/*
|
|
* Copyright(c) 2011 - 2012 Intel Corporation. All rights reserved.
|
|
*
|
|
* This program is free software; you can redistribute it and/or modify it
|
|
* under the terms and conditions of the GNU General Public License,
|
|
* version 2, as published by the Free Software Foundation.
|
|
*
|
|
* This program is distributed in the hope 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.,
|
|
* 51 Franklin St - Fifth Floor, Boston, MA 02110-1301 USA.
|
|
*
|
|
* Maintained at www.Open-FCoE.org
|
|
*/
|
|
|
|
#include <linux/module.h>
|
|
#include <linux/types.h>
|
|
#include <linux/kernel.h>
|
|
#include <linux/etherdevice.h>
|
|
|
|
#include <scsi/fcoe_sysfs.h>
|
|
|
|
static atomic_t ctlr_num;
|
|
static atomic_t fcf_num;
|
|
|
|
/*
|
|
* fcoe_fcf_dev_loss_tmo: the default number of seconds that fcoe sysfs
|
|
* should insulate the loss of a fcf.
|
|
*/
|
|
static unsigned int fcoe_fcf_dev_loss_tmo = 1800; /* seconds */
|
|
|
|
module_param_named(fcf_dev_loss_tmo, fcoe_fcf_dev_loss_tmo,
|
|
uint, S_IRUGO|S_IWUSR);
|
|
MODULE_PARM_DESC(fcf_dev_loss_tmo,
|
|
"Maximum number of seconds that libfcoe should"
|
|
" insulate the loss of a fcf. Once this value is"
|
|
" exceeded, the fcf is removed.");
|
|
|
|
/*
|
|
* These are used by the fcoe_*_show_function routines, they
|
|
* are intentionally placed in the .c file as they're not intended
|
|
* for use throughout the code.
|
|
*/
|
|
#define fcoe_ctlr_id(x) \
|
|
((x)->id)
|
|
#define fcoe_ctlr_work_q_name(x) \
|
|
((x)->work_q_name)
|
|
#define fcoe_ctlr_work_q(x) \
|
|
((x)->work_q)
|
|
#define fcoe_ctlr_devloss_work_q_name(x) \
|
|
((x)->devloss_work_q_name)
|
|
#define fcoe_ctlr_devloss_work_q(x) \
|
|
((x)->devloss_work_q)
|
|
#define fcoe_ctlr_mode(x) \
|
|
((x)->mode)
|
|
#define fcoe_ctlr_fcf_dev_loss_tmo(x) \
|
|
((x)->fcf_dev_loss_tmo)
|
|
#define fcoe_ctlr_link_fail(x) \
|
|
((x)->lesb.lesb_link_fail)
|
|
#define fcoe_ctlr_vlink_fail(x) \
|
|
((x)->lesb.lesb_vlink_fail)
|
|
#define fcoe_ctlr_miss_fka(x) \
|
|
((x)->lesb.lesb_miss_fka)
|
|
#define fcoe_ctlr_symb_err(x) \
|
|
((x)->lesb.lesb_symb_err)
|
|
#define fcoe_ctlr_err_block(x) \
|
|
((x)->lesb.lesb_err_block)
|
|
#define fcoe_ctlr_fcs_error(x) \
|
|
((x)->lesb.lesb_fcs_error)
|
|
#define fcoe_fcf_state(x) \
|
|
((x)->state)
|
|
#define fcoe_fcf_fabric_name(x) \
|
|
((x)->fabric_name)
|
|
#define fcoe_fcf_switch_name(x) \
|
|
((x)->switch_name)
|
|
#define fcoe_fcf_fc_map(x) \
|
|
((x)->fc_map)
|
|
#define fcoe_fcf_vfid(x) \
|
|
((x)->vfid)
|
|
#define fcoe_fcf_mac(x) \
|
|
((x)->mac)
|
|
#define fcoe_fcf_priority(x) \
|
|
((x)->priority)
|
|
#define fcoe_fcf_fka_period(x) \
|
|
((x)->fka_period)
|
|
#define fcoe_fcf_dev_loss_tmo(x) \
|
|
((x)->dev_loss_tmo)
|
|
#define fcoe_fcf_selected(x) \
|
|
((x)->selected)
|
|
#define fcoe_fcf_vlan_id(x) \
|
|
((x)->vlan_id)
|
|
|
|
/*
|
|
* dev_loss_tmo attribute
|
|
*/
|
|
static int fcoe_str_to_dev_loss(const char *buf, unsigned long *val)
|
|
{
|
|
int ret;
|
|
|
|
ret = kstrtoul(buf, 0, val);
|
|
if (ret)
|
|
return -EINVAL;
|
|
/*
|
|
* Check for overflow; dev_loss_tmo is u32
|
|
*/
|
|
if (*val > UINT_MAX)
|
|
return -EINVAL;
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int fcoe_fcf_set_dev_loss_tmo(struct fcoe_fcf_device *fcf,
|
|
unsigned long val)
|
|
{
|
|
if ((fcf->state == FCOE_FCF_STATE_UNKNOWN) ||
|
|
(fcf->state == FCOE_FCF_STATE_DISCONNECTED) ||
|
|
(fcf->state == FCOE_FCF_STATE_DELETED))
|
|
return -EBUSY;
|
|
/*
|
|
* Check for overflow; dev_loss_tmo is u32
|
|
*/
|
|
if (val > UINT_MAX)
|
|
return -EINVAL;
|
|
|
|
fcoe_fcf_dev_loss_tmo(fcf) = val;
|
|
return 0;
|
|
}
|
|
|
|
#define FCOE_DEVICE_ATTR(_prefix, _name, _mode, _show, _store) \
|
|
struct device_attribute device_attr_fcoe_##_prefix##_##_name = \
|
|
__ATTR(_name, _mode, _show, _store)
|
|
|
|
#define fcoe_ctlr_show_function(field, format_string, sz, cast) \
|
|
static ssize_t show_fcoe_ctlr_device_##field(struct device *dev, \
|
|
struct device_attribute *attr, \
|
|
char *buf) \
|
|
{ \
|
|
struct fcoe_ctlr_device *ctlr = dev_to_ctlr(dev); \
|
|
if (ctlr->f->get_fcoe_ctlr_##field) \
|
|
ctlr->f->get_fcoe_ctlr_##field(ctlr); \
|
|
return snprintf(buf, sz, format_string, \
|
|
cast fcoe_ctlr_##field(ctlr)); \
|
|
}
|
|
|
|
#define fcoe_fcf_show_function(field, format_string, sz, cast) \
|
|
static ssize_t show_fcoe_fcf_device_##field(struct device *dev, \
|
|
struct device_attribute *attr, \
|
|
char *buf) \
|
|
{ \
|
|
struct fcoe_fcf_device *fcf = dev_to_fcf(dev); \
|
|
struct fcoe_ctlr_device *ctlr = fcoe_fcf_dev_to_ctlr_dev(fcf); \
|
|
if (ctlr->f->get_fcoe_fcf_##field) \
|
|
ctlr->f->get_fcoe_fcf_##field(fcf); \
|
|
return snprintf(buf, sz, format_string, \
|
|
cast fcoe_fcf_##field(fcf)); \
|
|
}
|
|
|
|
#define fcoe_ctlr_private_show_function(field, format_string, sz, cast) \
|
|
static ssize_t show_fcoe_ctlr_device_##field(struct device *dev, \
|
|
struct device_attribute *attr, \
|
|
char *buf) \
|
|
{ \
|
|
struct fcoe_ctlr_device *ctlr = dev_to_ctlr(dev); \
|
|
return snprintf(buf, sz, format_string, cast fcoe_ctlr_##field(ctlr)); \
|
|
}
|
|
|
|
#define fcoe_fcf_private_show_function(field, format_string, sz, cast) \
|
|
static ssize_t show_fcoe_fcf_device_##field(struct device *dev, \
|
|
struct device_attribute *attr, \
|
|
char *buf) \
|
|
{ \
|
|
struct fcoe_fcf_device *fcf = dev_to_fcf(dev); \
|
|
return snprintf(buf, sz, format_string, cast fcoe_fcf_##field(fcf)); \
|
|
}
|
|
|
|
#define fcoe_ctlr_private_rd_attr(field, format_string, sz) \
|
|
fcoe_ctlr_private_show_function(field, format_string, sz, ) \
|
|
static FCOE_DEVICE_ATTR(ctlr, field, S_IRUGO, \
|
|
show_fcoe_ctlr_device_##field, NULL)
|
|
|
|
#define fcoe_ctlr_rd_attr(field, format_string, sz) \
|
|
fcoe_ctlr_show_function(field, format_string, sz, ) \
|
|
static FCOE_DEVICE_ATTR(ctlr, field, S_IRUGO, \
|
|
show_fcoe_ctlr_device_##field, NULL)
|
|
|
|
#define fcoe_fcf_rd_attr(field, format_string, sz) \
|
|
fcoe_fcf_show_function(field, format_string, sz, ) \
|
|
static FCOE_DEVICE_ATTR(fcf, field, S_IRUGO, \
|
|
show_fcoe_fcf_device_##field, NULL)
|
|
|
|
#define fcoe_fcf_private_rd_attr(field, format_string, sz) \
|
|
fcoe_fcf_private_show_function(field, format_string, sz, ) \
|
|
static FCOE_DEVICE_ATTR(fcf, field, S_IRUGO, \
|
|
show_fcoe_fcf_device_##field, NULL)
|
|
|
|
#define fcoe_ctlr_private_rd_attr_cast(field, format_string, sz, cast) \
|
|
fcoe_ctlr_private_show_function(field, format_string, sz, (cast)) \
|
|
static FCOE_DEVICE_ATTR(ctlr, field, S_IRUGO, \
|
|
show_fcoe_ctlr_device_##field, NULL)
|
|
|
|
#define fcoe_fcf_private_rd_attr_cast(field, format_string, sz, cast) \
|
|
fcoe_fcf_private_show_function(field, format_string, sz, (cast)) \
|
|
static FCOE_DEVICE_ATTR(fcf, field, S_IRUGO, \
|
|
show_fcoe_fcf_device_##field, NULL)
|
|
|
|
#define fcoe_enum_name_search(title, table_type, table) \
|
|
static const char *get_fcoe_##title##_name(enum table_type table_key) \
|
|
{ \
|
|
int i; \
|
|
char *name = NULL; \
|
|
\
|
|
for (i = 0; i < ARRAY_SIZE(table); i++) { \
|
|
if (table[i].value == table_key) { \
|
|
name = table[i].name; \
|
|
break; \
|
|
} \
|
|
} \
|
|
return name; \
|
|
}
|
|
|
|
static struct {
|
|
enum fcf_state value;
|
|
char *name;
|
|
} fcf_state_names[] = {
|
|
{ FCOE_FCF_STATE_UNKNOWN, "Unknown" },
|
|
{ FCOE_FCF_STATE_DISCONNECTED, "Disconnected" },
|
|
{ FCOE_FCF_STATE_CONNECTED, "Connected" },
|
|
};
|
|
fcoe_enum_name_search(fcf_state, fcf_state, fcf_state_names)
|
|
#define FCOE_FCF_STATE_MAX_NAMELEN 50
|
|
|
|
static ssize_t show_fcf_state(struct device *dev,
|
|
struct device_attribute *attr,
|
|
char *buf)
|
|
{
|
|
struct fcoe_fcf_device *fcf = dev_to_fcf(dev);
|
|
const char *name;
|
|
name = get_fcoe_fcf_state_name(fcf->state);
|
|
if (!name)
|
|
return -EINVAL;
|
|
return snprintf(buf, FCOE_FCF_STATE_MAX_NAMELEN, "%s\n", name);
|
|
}
|
|
static FCOE_DEVICE_ATTR(fcf, state, S_IRUGO, show_fcf_state, NULL);
|
|
|
|
static struct {
|
|
enum fip_conn_type value;
|
|
char *name;
|
|
} fip_conn_type_names[] = {
|
|
{ FIP_CONN_TYPE_UNKNOWN, "Unknown" },
|
|
{ FIP_CONN_TYPE_FABRIC, "Fabric" },
|
|
{ FIP_CONN_TYPE_VN2VN, "VN2VN" },
|
|
};
|
|
fcoe_enum_name_search(ctlr_mode, fip_conn_type, fip_conn_type_names)
|
|
#define FCOE_CTLR_MODE_MAX_NAMELEN 50
|
|
|
|
static ssize_t show_ctlr_mode(struct device *dev,
|
|
struct device_attribute *attr,
|
|
char *buf)
|
|
{
|
|
struct fcoe_ctlr_device *ctlr = dev_to_ctlr(dev);
|
|
const char *name;
|
|
|
|
if (ctlr->f->get_fcoe_ctlr_mode)
|
|
ctlr->f->get_fcoe_ctlr_mode(ctlr);
|
|
|
|
name = get_fcoe_ctlr_mode_name(ctlr->mode);
|
|
if (!name)
|
|
return -EINVAL;
|
|
return snprintf(buf, FCOE_CTLR_MODE_MAX_NAMELEN,
|
|
"%s\n", name);
|
|
}
|
|
static FCOE_DEVICE_ATTR(ctlr, mode, S_IRUGO,
|
|
show_ctlr_mode, NULL);
|
|
|
|
static ssize_t
|
|
store_private_fcoe_ctlr_fcf_dev_loss_tmo(struct device *dev,
|
|
struct device_attribute *attr,
|
|
const char *buf, size_t count)
|
|
{
|
|
struct fcoe_ctlr_device *ctlr = dev_to_ctlr(dev);
|
|
struct fcoe_fcf_device *fcf;
|
|
unsigned long val;
|
|
int rc;
|
|
|
|
rc = fcoe_str_to_dev_loss(buf, &val);
|
|
if (rc)
|
|
return rc;
|
|
|
|
fcoe_ctlr_fcf_dev_loss_tmo(ctlr) = val;
|
|
mutex_lock(&ctlr->lock);
|
|
list_for_each_entry(fcf, &ctlr->fcfs, peers)
|
|
fcoe_fcf_set_dev_loss_tmo(fcf, val);
|
|
mutex_unlock(&ctlr->lock);
|
|
return count;
|
|
}
|
|
fcoe_ctlr_private_show_function(fcf_dev_loss_tmo, "%d\n", 20, );
|
|
static FCOE_DEVICE_ATTR(ctlr, fcf_dev_loss_tmo, S_IRUGO | S_IWUSR,
|
|
show_fcoe_ctlr_device_fcf_dev_loss_tmo,
|
|
store_private_fcoe_ctlr_fcf_dev_loss_tmo);
|
|
|
|
/* Link Error Status Block (LESB) */
|
|
fcoe_ctlr_rd_attr(link_fail, "%u\n", 20);
|
|
fcoe_ctlr_rd_attr(vlink_fail, "%u\n", 20);
|
|
fcoe_ctlr_rd_attr(miss_fka, "%u\n", 20);
|
|
fcoe_ctlr_rd_attr(symb_err, "%u\n", 20);
|
|
fcoe_ctlr_rd_attr(err_block, "%u\n", 20);
|
|
fcoe_ctlr_rd_attr(fcs_error, "%u\n", 20);
|
|
|
|
fcoe_fcf_private_rd_attr_cast(fabric_name, "0x%llx\n", 20, unsigned long long);
|
|
fcoe_fcf_private_rd_attr_cast(switch_name, "0x%llx\n", 20, unsigned long long);
|
|
fcoe_fcf_private_rd_attr(priority, "%u\n", 20);
|
|
fcoe_fcf_private_rd_attr(fc_map, "0x%x\n", 20);
|
|
fcoe_fcf_private_rd_attr(vfid, "%u\n", 20);
|
|
fcoe_fcf_private_rd_attr(mac, "%pM\n", 20);
|
|
fcoe_fcf_private_rd_attr(fka_period, "%u\n", 20);
|
|
fcoe_fcf_rd_attr(selected, "%u\n", 20);
|
|
fcoe_fcf_rd_attr(vlan_id, "%u\n", 20);
|
|
|
|
fcoe_fcf_private_show_function(dev_loss_tmo, "%d\n", 20, )
|
|
static ssize_t
|
|
store_fcoe_fcf_dev_loss_tmo(struct device *dev, struct device_attribute *attr,
|
|
const char *buf, size_t count)
|
|
{
|
|
struct fcoe_fcf_device *fcf = dev_to_fcf(dev);
|
|
unsigned long val;
|
|
int rc;
|
|
|
|
rc = fcoe_str_to_dev_loss(buf, &val);
|
|
if (rc)
|
|
return rc;
|
|
|
|
rc = fcoe_fcf_set_dev_loss_tmo(fcf, val);
|
|
if (rc)
|
|
return rc;
|
|
return count;
|
|
}
|
|
static FCOE_DEVICE_ATTR(fcf, dev_loss_tmo, S_IRUGO | S_IWUSR,
|
|
show_fcoe_fcf_device_dev_loss_tmo,
|
|
store_fcoe_fcf_dev_loss_tmo);
|
|
|
|
static struct attribute *fcoe_ctlr_lesb_attrs[] = {
|
|
&device_attr_fcoe_ctlr_link_fail.attr,
|
|
&device_attr_fcoe_ctlr_vlink_fail.attr,
|
|
&device_attr_fcoe_ctlr_miss_fka.attr,
|
|
&device_attr_fcoe_ctlr_symb_err.attr,
|
|
&device_attr_fcoe_ctlr_err_block.attr,
|
|
&device_attr_fcoe_ctlr_fcs_error.attr,
|
|
NULL,
|
|
};
|
|
|
|
static struct attribute_group fcoe_ctlr_lesb_attr_group = {
|
|
.name = "lesb",
|
|
.attrs = fcoe_ctlr_lesb_attrs,
|
|
};
|
|
|
|
static struct attribute *fcoe_ctlr_attrs[] = {
|
|
&device_attr_fcoe_ctlr_fcf_dev_loss_tmo.attr,
|
|
&device_attr_fcoe_ctlr_mode.attr,
|
|
NULL,
|
|
};
|
|
|
|
static struct attribute_group fcoe_ctlr_attr_group = {
|
|
.attrs = fcoe_ctlr_attrs,
|
|
};
|
|
|
|
static const struct attribute_group *fcoe_ctlr_attr_groups[] = {
|
|
&fcoe_ctlr_attr_group,
|
|
&fcoe_ctlr_lesb_attr_group,
|
|
NULL,
|
|
};
|
|
|
|
static struct attribute *fcoe_fcf_attrs[] = {
|
|
&device_attr_fcoe_fcf_fabric_name.attr,
|
|
&device_attr_fcoe_fcf_switch_name.attr,
|
|
&device_attr_fcoe_fcf_dev_loss_tmo.attr,
|
|
&device_attr_fcoe_fcf_fc_map.attr,
|
|
&device_attr_fcoe_fcf_vfid.attr,
|
|
&device_attr_fcoe_fcf_mac.attr,
|
|
&device_attr_fcoe_fcf_priority.attr,
|
|
&device_attr_fcoe_fcf_fka_period.attr,
|
|
&device_attr_fcoe_fcf_state.attr,
|
|
&device_attr_fcoe_fcf_selected.attr,
|
|
&device_attr_fcoe_fcf_vlan_id.attr,
|
|
NULL
|
|
};
|
|
|
|
static struct attribute_group fcoe_fcf_attr_group = {
|
|
.attrs = fcoe_fcf_attrs,
|
|
};
|
|
|
|
static const struct attribute_group *fcoe_fcf_attr_groups[] = {
|
|
&fcoe_fcf_attr_group,
|
|
NULL,
|
|
};
|
|
|
|
struct bus_type fcoe_bus_type;
|
|
|
|
static int fcoe_bus_match(struct device *dev,
|
|
struct device_driver *drv)
|
|
{
|
|
if (dev->bus == &fcoe_bus_type)
|
|
return 1;
|
|
return 0;
|
|
}
|
|
|
|
/**
|
|
* fcoe_ctlr_device_release() - Release the FIP ctlr memory
|
|
* @dev: Pointer to the FIP ctlr's embedded device
|
|
*
|
|
* Called when the last FIP ctlr reference is released.
|
|
*/
|
|
static void fcoe_ctlr_device_release(struct device *dev)
|
|
{
|
|
struct fcoe_ctlr_device *ctlr = dev_to_ctlr(dev);
|
|
kfree(ctlr);
|
|
}
|
|
|
|
/**
|
|
* fcoe_fcf_device_release() - Release the FIP fcf memory
|
|
* @dev: Pointer to the fcf's embedded device
|
|
*
|
|
* Called when the last FIP fcf reference is released.
|
|
*/
|
|
static void fcoe_fcf_device_release(struct device *dev)
|
|
{
|
|
struct fcoe_fcf_device *fcf = dev_to_fcf(dev);
|
|
kfree(fcf);
|
|
}
|
|
|
|
struct device_type fcoe_ctlr_device_type = {
|
|
.name = "fcoe_ctlr",
|
|
.groups = fcoe_ctlr_attr_groups,
|
|
.release = fcoe_ctlr_device_release,
|
|
};
|
|
|
|
struct device_type fcoe_fcf_device_type = {
|
|
.name = "fcoe_fcf",
|
|
.groups = fcoe_fcf_attr_groups,
|
|
.release = fcoe_fcf_device_release,
|
|
};
|
|
|
|
struct bus_type fcoe_bus_type = {
|
|
.name = "fcoe",
|
|
.match = &fcoe_bus_match,
|
|
};
|
|
|
|
/**
|
|
* fcoe_ctlr_device_flush_work() - Flush a FIP ctlr's workqueue
|
|
* @ctlr: Pointer to the FIP ctlr whose workqueue is to be flushed
|
|
*/
|
|
void fcoe_ctlr_device_flush_work(struct fcoe_ctlr_device *ctlr)
|
|
{
|
|
if (!fcoe_ctlr_work_q(ctlr)) {
|
|
printk(KERN_ERR
|
|
"ERROR: FIP Ctlr '%d' attempted to flush work, "
|
|
"when no workqueue created.\n", ctlr->id);
|
|
dump_stack();
|
|
return;
|
|
}
|
|
|
|
flush_workqueue(fcoe_ctlr_work_q(ctlr));
|
|
}
|
|
|
|
/**
|
|
* fcoe_ctlr_device_queue_work() - Schedule work for a FIP ctlr's workqueue
|
|
* @ctlr: Pointer to the FIP ctlr who owns the devloss workqueue
|
|
* @work: Work to queue for execution
|
|
*
|
|
* Return value:
|
|
* 1 on success / 0 already queued / < 0 for error
|
|
*/
|
|
int fcoe_ctlr_device_queue_work(struct fcoe_ctlr_device *ctlr,
|
|
struct work_struct *work)
|
|
{
|
|
if (unlikely(!fcoe_ctlr_work_q(ctlr))) {
|
|
printk(KERN_ERR
|
|
"ERROR: FIP Ctlr '%d' attempted to queue work, "
|
|
"when no workqueue created.\n", ctlr->id);
|
|
dump_stack();
|
|
|
|
return -EINVAL;
|
|
}
|
|
|
|
return queue_work(fcoe_ctlr_work_q(ctlr), work);
|
|
}
|
|
|
|
/**
|
|
* fcoe_ctlr_device_flush_devloss() - Flush a FIP ctlr's devloss workqueue
|
|
* @ctlr: Pointer to FIP ctlr whose workqueue is to be flushed
|
|
*/
|
|
void fcoe_ctlr_device_flush_devloss(struct fcoe_ctlr_device *ctlr)
|
|
{
|
|
if (!fcoe_ctlr_devloss_work_q(ctlr)) {
|
|
printk(KERN_ERR
|
|
"ERROR: FIP Ctlr '%d' attempted to flush work, "
|
|
"when no workqueue created.\n", ctlr->id);
|
|
dump_stack();
|
|
return;
|
|
}
|
|
|
|
flush_workqueue(fcoe_ctlr_devloss_work_q(ctlr));
|
|
}
|
|
|
|
/**
|
|
* fcoe_ctlr_device_queue_devloss_work() - Schedule work for a FIP ctlr's devloss workqueue
|
|
* @ctlr: Pointer to the FIP ctlr who owns the devloss workqueue
|
|
* @work: Work to queue for execution
|
|
* @delay: jiffies to delay the work queuing
|
|
*
|
|
* Return value:
|
|
* 1 on success / 0 already queued / < 0 for error
|
|
*/
|
|
int fcoe_ctlr_device_queue_devloss_work(struct fcoe_ctlr_device *ctlr,
|
|
struct delayed_work *work,
|
|
unsigned long delay)
|
|
{
|
|
if (unlikely(!fcoe_ctlr_devloss_work_q(ctlr))) {
|
|
printk(KERN_ERR
|
|
"ERROR: FIP Ctlr '%d' attempted to queue work, "
|
|
"when no workqueue created.\n", ctlr->id);
|
|
dump_stack();
|
|
|
|
return -EINVAL;
|
|
}
|
|
|
|
return queue_delayed_work(fcoe_ctlr_devloss_work_q(ctlr), work, delay);
|
|
}
|
|
|
|
static int fcoe_fcf_device_match(struct fcoe_fcf_device *new,
|
|
struct fcoe_fcf_device *old)
|
|
{
|
|
if (new->switch_name == old->switch_name &&
|
|
new->fabric_name == old->fabric_name &&
|
|
new->fc_map == old->fc_map &&
|
|
compare_ether_addr(new->mac, old->mac) == 0)
|
|
return 1;
|
|
return 0;
|
|
}
|
|
|
|
/**
|
|
* fcoe_ctlr_device_add() - Add a FIP ctlr to sysfs
|
|
* @parent: The parent device to which the fcoe_ctlr instance
|
|
* should be attached
|
|
* @f: The LLD's FCoE sysfs function template pointer
|
|
* @priv_size: Size to be allocated with the fcoe_ctlr_device for the LLD
|
|
*
|
|
* This routine allocates a FIP ctlr object with some additional memory
|
|
* for the LLD. The FIP ctlr is initialized, added to sysfs and then
|
|
* attributes are added to it.
|
|
*/
|
|
struct fcoe_ctlr_device *fcoe_ctlr_device_add(struct device *parent,
|
|
struct fcoe_sysfs_function_template *f,
|
|
int priv_size)
|
|
{
|
|
struct fcoe_ctlr_device *ctlr;
|
|
int error = 0;
|
|
|
|
ctlr = kzalloc(sizeof(struct fcoe_ctlr_device) + priv_size,
|
|
GFP_KERNEL);
|
|
if (!ctlr)
|
|
goto out;
|
|
|
|
ctlr->id = atomic_inc_return(&ctlr_num) - 1;
|
|
ctlr->f = f;
|
|
INIT_LIST_HEAD(&ctlr->fcfs);
|
|
mutex_init(&ctlr->lock);
|
|
ctlr->dev.parent = parent;
|
|
ctlr->dev.bus = &fcoe_bus_type;
|
|
ctlr->dev.type = &fcoe_ctlr_device_type;
|
|
|
|
ctlr->fcf_dev_loss_tmo = fcoe_fcf_dev_loss_tmo;
|
|
|
|
snprintf(ctlr->work_q_name, sizeof(ctlr->work_q_name),
|
|
"ctlr_wq_%d", ctlr->id);
|
|
ctlr->work_q = create_singlethread_workqueue(
|
|
ctlr->work_q_name);
|
|
if (!ctlr->work_q)
|
|
goto out_del;
|
|
|
|
snprintf(ctlr->devloss_work_q_name,
|
|
sizeof(ctlr->devloss_work_q_name),
|
|
"ctlr_dl_wq_%d", ctlr->id);
|
|
ctlr->devloss_work_q = create_singlethread_workqueue(
|
|
ctlr->devloss_work_q_name);
|
|
if (!ctlr->devloss_work_q)
|
|
goto out_del_q;
|
|
|
|
dev_set_name(&ctlr->dev, "ctlr_%d", ctlr->id);
|
|
error = device_register(&ctlr->dev);
|
|
if (error)
|
|
goto out_del_q2;
|
|
|
|
return ctlr;
|
|
|
|
out_del_q2:
|
|
destroy_workqueue(ctlr->devloss_work_q);
|
|
ctlr->devloss_work_q = NULL;
|
|
out_del_q:
|
|
destroy_workqueue(ctlr->work_q);
|
|
ctlr->work_q = NULL;
|
|
out_del:
|
|
kfree(ctlr);
|
|
out:
|
|
return NULL;
|
|
}
|
|
EXPORT_SYMBOL_GPL(fcoe_ctlr_device_add);
|
|
|
|
/**
|
|
* fcoe_ctlr_device_delete() - Delete a FIP ctlr and its subtree from sysfs
|
|
* @ctlr: A pointer to the ctlr to be deleted
|
|
*
|
|
* Deletes a FIP ctlr and any fcfs attached
|
|
* to it. Deleting fcfs will cause their childen
|
|
* to be deleted as well.
|
|
*
|
|
* The ctlr is detached from sysfs and it's resources
|
|
* are freed (work q), but the memory is not freed
|
|
* until its last reference is released.
|
|
*
|
|
* This routine expects no locks to be held before
|
|
* calling.
|
|
*
|
|
* TODO: Currently there are no callbacks to clean up LLD data
|
|
* for a fcoe_fcf_device. LLDs must keep this in mind as they need
|
|
* to clean up each of their LLD data for all fcoe_fcf_device before
|
|
* calling fcoe_ctlr_device_delete.
|
|
*/
|
|
void fcoe_ctlr_device_delete(struct fcoe_ctlr_device *ctlr)
|
|
{
|
|
struct fcoe_fcf_device *fcf, *next;
|
|
/* Remove any attached fcfs */
|
|
mutex_lock(&ctlr->lock);
|
|
list_for_each_entry_safe(fcf, next,
|
|
&ctlr->fcfs, peers) {
|
|
list_del(&fcf->peers);
|
|
fcf->state = FCOE_FCF_STATE_DELETED;
|
|
fcoe_ctlr_device_queue_work(ctlr, &fcf->delete_work);
|
|
}
|
|
mutex_unlock(&ctlr->lock);
|
|
|
|
fcoe_ctlr_device_flush_work(ctlr);
|
|
|
|
destroy_workqueue(ctlr->devloss_work_q);
|
|
ctlr->devloss_work_q = NULL;
|
|
destroy_workqueue(ctlr->work_q);
|
|
ctlr->work_q = NULL;
|
|
|
|
device_unregister(&ctlr->dev);
|
|
}
|
|
EXPORT_SYMBOL_GPL(fcoe_ctlr_device_delete);
|
|
|
|
/**
|
|
* fcoe_fcf_device_final_delete() - Final delete routine
|
|
* @work: The FIP fcf's embedded work struct
|
|
*
|
|
* It is expected that the fcf has been removed from
|
|
* the FIP ctlr's list before calling this routine.
|
|
*/
|
|
static void fcoe_fcf_device_final_delete(struct work_struct *work)
|
|
{
|
|
struct fcoe_fcf_device *fcf =
|
|
container_of(work, struct fcoe_fcf_device, delete_work);
|
|
struct fcoe_ctlr_device *ctlr = fcoe_fcf_dev_to_ctlr_dev(fcf);
|
|
|
|
/*
|
|
* Cancel any outstanding timers. These should really exist
|
|
* only when rmmod'ing the LLDD and we're asking for
|
|
* immediate termination of the rports
|
|
*/
|
|
if (!cancel_delayed_work(&fcf->dev_loss_work))
|
|
fcoe_ctlr_device_flush_devloss(ctlr);
|
|
|
|
device_unregister(&fcf->dev);
|
|
}
|
|
|
|
/**
|
|
* fip_timeout_deleted_fcf() - Delete a fcf when the devloss timer fires
|
|
* @work: The FIP fcf's embedded work struct
|
|
*
|
|
* Removes the fcf from the FIP ctlr's list of fcfs and
|
|
* queues the final deletion.
|
|
*/
|
|
static void fip_timeout_deleted_fcf(struct work_struct *work)
|
|
{
|
|
struct fcoe_fcf_device *fcf =
|
|
container_of(work, struct fcoe_fcf_device, dev_loss_work.work);
|
|
struct fcoe_ctlr_device *ctlr = fcoe_fcf_dev_to_ctlr_dev(fcf);
|
|
|
|
mutex_lock(&ctlr->lock);
|
|
|
|
/*
|
|
* If the fcf is deleted or reconnected before the timer
|
|
* fires the devloss queue will be flushed, but the state will
|
|
* either be CONNECTED or DELETED. If that is the case we
|
|
* cancel deleting the fcf.
|
|
*/
|
|
if (fcf->state != FCOE_FCF_STATE_DISCONNECTED)
|
|
goto out;
|
|
|
|
dev_printk(KERN_ERR, &fcf->dev,
|
|
"FIP fcf connection time out: removing fcf\n");
|
|
|
|
list_del(&fcf->peers);
|
|
fcf->state = FCOE_FCF_STATE_DELETED;
|
|
fcoe_ctlr_device_queue_work(ctlr, &fcf->delete_work);
|
|
|
|
out:
|
|
mutex_unlock(&ctlr->lock);
|
|
}
|
|
|
|
/**
|
|
* fcoe_fcf_device_delete() - Delete a FIP fcf
|
|
* @fcf: Pointer to the fcf which is to be deleted
|
|
*
|
|
* Queues the FIP fcf on the devloss workqueue
|
|
*
|
|
* Expects the ctlr_attrs mutex to be held for fcf
|
|
* state change.
|
|
*/
|
|
void fcoe_fcf_device_delete(struct fcoe_fcf_device *fcf)
|
|
{
|
|
struct fcoe_ctlr_device *ctlr = fcoe_fcf_dev_to_ctlr_dev(fcf);
|
|
int timeout = fcf->dev_loss_tmo;
|
|
|
|
if (fcf->state != FCOE_FCF_STATE_CONNECTED)
|
|
return;
|
|
|
|
fcf->state = FCOE_FCF_STATE_DISCONNECTED;
|
|
|
|
/*
|
|
* FCF will only be re-connected by the LLD calling
|
|
* fcoe_fcf_device_add, and it should be setting up
|
|
* priv then.
|
|
*/
|
|
fcf->priv = NULL;
|
|
|
|
fcoe_ctlr_device_queue_devloss_work(ctlr, &fcf->dev_loss_work,
|
|
timeout * HZ);
|
|
}
|
|
EXPORT_SYMBOL_GPL(fcoe_fcf_device_delete);
|
|
|
|
/**
|
|
* fcoe_fcf_device_add() - Add a FCoE sysfs fcoe_fcf_device to the system
|
|
* @ctlr: The fcoe_ctlr_device that will be the fcoe_fcf_device parent
|
|
* @new_fcf: A temporary FCF used for lookups on the current list of fcfs
|
|
*
|
|
* Expects to be called with the ctlr->lock held
|
|
*/
|
|
struct fcoe_fcf_device *fcoe_fcf_device_add(struct fcoe_ctlr_device *ctlr,
|
|
struct fcoe_fcf_device *new_fcf)
|
|
{
|
|
struct fcoe_fcf_device *fcf;
|
|
int error = 0;
|
|
|
|
list_for_each_entry(fcf, &ctlr->fcfs, peers) {
|
|
if (fcoe_fcf_device_match(new_fcf, fcf)) {
|
|
if (fcf->state == FCOE_FCF_STATE_CONNECTED)
|
|
return fcf;
|
|
|
|
fcf->state = FCOE_FCF_STATE_CONNECTED;
|
|
|
|
if (!cancel_delayed_work(&fcf->dev_loss_work))
|
|
fcoe_ctlr_device_flush_devloss(ctlr);
|
|
|
|
return fcf;
|
|
}
|
|
}
|
|
|
|
fcf = kzalloc(sizeof(struct fcoe_fcf_device), GFP_ATOMIC);
|
|
if (unlikely(!fcf))
|
|
goto out;
|
|
|
|
INIT_WORK(&fcf->delete_work, fcoe_fcf_device_final_delete);
|
|
INIT_DELAYED_WORK(&fcf->dev_loss_work, fip_timeout_deleted_fcf);
|
|
|
|
fcf->dev.parent = &ctlr->dev;
|
|
fcf->dev.bus = &fcoe_bus_type;
|
|
fcf->dev.type = &fcoe_fcf_device_type;
|
|
fcf->id = atomic_inc_return(&fcf_num) - 1;
|
|
fcf->state = FCOE_FCF_STATE_UNKNOWN;
|
|
|
|
fcf->dev_loss_tmo = ctlr->fcf_dev_loss_tmo;
|
|
|
|
dev_set_name(&fcf->dev, "fcf_%d", fcf->id);
|
|
|
|
fcf->fabric_name = new_fcf->fabric_name;
|
|
fcf->switch_name = new_fcf->switch_name;
|
|
fcf->fc_map = new_fcf->fc_map;
|
|
fcf->vfid = new_fcf->vfid;
|
|
memcpy(fcf->mac, new_fcf->mac, ETH_ALEN);
|
|
fcf->priority = new_fcf->priority;
|
|
fcf->fka_period = new_fcf->fka_period;
|
|
fcf->selected = new_fcf->selected;
|
|
|
|
error = device_register(&fcf->dev);
|
|
if (error)
|
|
goto out_del;
|
|
|
|
fcf->state = FCOE_FCF_STATE_CONNECTED;
|
|
list_add_tail(&fcf->peers, &ctlr->fcfs);
|
|
|
|
return fcf;
|
|
|
|
out_del:
|
|
kfree(fcf);
|
|
out:
|
|
return NULL;
|
|
}
|
|
EXPORT_SYMBOL_GPL(fcoe_fcf_device_add);
|
|
|
|
int __init fcoe_sysfs_setup(void)
|
|
{
|
|
int error;
|
|
|
|
atomic_set(&ctlr_num, 0);
|
|
atomic_set(&fcf_num, 0);
|
|
|
|
error = bus_register(&fcoe_bus_type);
|
|
if (error)
|
|
return error;
|
|
|
|
return 0;
|
|
}
|
|
|
|
void __exit fcoe_sysfs_teardown(void)
|
|
{
|
|
bus_unregister(&fcoe_bus_type);
|
|
}
|