mirror of
https://mirrors.bfsu.edu.cn/git/linux.git
synced 2024-12-13 22:14:20 +08:00
e4c275f776
Fix the following KASAN warning produced when booting a 64-bit kernel:
[ 13.334750] BUG: KASAN: stack-out-of-bounds in find_first_bit+0x19/0x70
[ 13.342166] Read of size 8 at addr ffff880235067178 by task kworker/2:1/42
[ 13.342176] CPU: 2 PID: 42 Comm: kworker/2:1 Not tainted 4.20.0-rc1+ #106
[ 13.342179] Hardware name: Mellanox Technologies Ltd. MSN2740/Mellanox x86 SFF board, BIOS 5.6.5 06/07/2016
[ 13.342190] Workqueue: events deferred_probe_work_func
[ 13.342194] Call Trace:
[ 13.342206] dump_stack+0xc7/0x15b
[ 13.342214] ? show_regs_print_info+0x5/0x5
[ 13.342220] ? kmsg_dump_rewind_nolock+0x59/0x59
[ 13.342234] ? _raw_write_lock_irqsave+0x100/0x100
[ 13.351593] print_address_description+0x73/0x260
[ 13.351603] kasan_report+0x260/0x380
[ 13.351611] ? find_first_bit+0x19/0x70
[ 13.351619] find_first_bit+0x19/0x70
[ 13.351630] mlxreg_hotplug_work_handler+0x73c/0x920 [mlxreg_hotplug]
[ 13.351639] ? __lock_text_start+0x8/0x8
[ 13.351646] ? _raw_write_lock_irqsave+0x80/0x100
[ 13.351656] ? mlxreg_hotplug_remove+0x1e0/0x1e0 [mlxreg_hotplug]
[ 13.351663] ? regmap_volatile+0x40/0xb0
[ 13.351668] ? regcache_write+0x4c/0x90
[ 13.351676] ? mlxplat_mlxcpld_reg_write+0x24/0x30 [mlx_platform]
[ 13.351681] ? _regmap_write+0xea/0x220
[ 13.351688] ? __mutex_lock_slowpath+0x10/0x10
[ 13.351696] ? devm_add_action+0x70/0x70
[ 13.351701] ? mutex_unlock+0x1d/0x40
[ 13.351710] mlxreg_hotplug_probe+0x82e/0x989 [mlxreg_hotplug]
[ 13.351723] ? mlxreg_hotplug_work_handler+0x920/0x920 [mlxreg_hotplug]
[ 13.351731] ? sysfs_do_create_link_sd.isra.2+0xf4/0x190
[ 13.351737] ? sysfs_rename_link_ns+0xf0/0xf0
[ 13.351743] ? devres_close_group+0x2b0/0x2b0
[ 13.351749] ? pinctrl_put+0x20/0x20
[ 13.351755] ? acpi_dev_pm_attach+0x2c/0xd0
[ 13.351763] platform_drv_probe+0x70/0xd0
[ 13.351771] really_probe+0x480/0x6e0
[ 13.351778] ? device_attach+0x10/0x10
[ 13.351784] ? __lock_text_start+0x8/0x8
[ 13.351790] ? _raw_write_lock_irqsave+0x80/0x100
[ 13.351797] ? _raw_write_lock_irqsave+0x80/0x100
[ 13.351806] ? __driver_attach+0x190/0x190
[ 13.351812] driver_probe_device+0x17d/0x1a0
[ 13.351819] ? __driver_attach+0x190/0x190
[ 13.351825] bus_for_each_drv+0xd6/0x130
[ 13.351831] ? bus_rescan_devices+0x20/0x20
[ 13.351837] ? __mutex_lock_slowpath+0x10/0x10
[ 13.351845] __device_attach+0x18c/0x230
[ 13.351852] ? device_bind_driver+0x70/0x70
[ 13.351859] ? __mutex_lock_slowpath+0x10/0x10
[ 13.351866] bus_probe_device+0xea/0x110
[ 13.351874] deferred_probe_work_func+0x1c9/0x290
[ 13.351882] ? driver_deferred_probe_add+0x1d0/0x1d0
[ 13.351889] ? preempt_notifier_dec+0x20/0x20
[ 13.351897] ? read_word_at_a_time+0xe/0x20
[ 13.351904] ? strscpy+0x151/0x290
[ 13.351912] ? set_work_pool_and_clear_pending+0x9c/0xf0
[ 13.351918] ? __switch_to_asm+0x34/0x70
[ 13.351924] ? __switch_to_asm+0x40/0x70
[ 13.351929] ? __switch_to_asm+0x34/0x70
[ 13.351935] ? __switch_to_asm+0x40/0x70
[ 13.351942] process_one_work+0x5cc/0xa00
[ 13.351952] ? pwq_dec_nr_in_flight+0x1e0/0x1e0
[ 13.351960] ? pci_mmcfg_check_reserved+0x80/0xb8
[ 13.351967] ? run_rebalance_domains+0x250/0x250
[ 13.351980] ? stack_access_ok+0x35/0x80
[ 13.351986] ? deref_stack_reg+0xa1/0xe0
[ 13.351994] ? schedule+0xcd/0x250
[ 13.352000] ? worker_enter_idle+0x2d6/0x330
[ 13.352006] ? __schedule+0xeb0/0xeb0
[ 13.352014] ? fork_usermode_blob+0x130/0x130
[ 13.352019] ? mutex_lock+0xa7/0x100
[ 13.352026] ? _raw_spin_lock_irq+0x98/0xf0
[ 13.352032] ? _raw_read_unlock_irqrestore+0x30/0x30
[ 13.352037] i2c i2c-2: Added multiplexed i2c bus 11
[ 13.352043] worker_thread+0x181/0xa80
[ 13.352052] ? __switch_to_asm+0x34/0x70
[ 13.352058] ? __switch_to_asm+0x40/0x70
[ 13.352064] ? process_one_work+0xa00/0xa00
[ 13.352070] ? __switch_to_asm+0x34/0x70
[ 13.352076] ? __switch_to_asm+0x40/0x70
[ 13.352081] ? __switch_to_asm+0x34/0x70
[ 13.352086] ? __switch_to_asm+0x40/0x70
[ 13.352092] ? __switch_to_asm+0x34/0x70
[ 13.352097] ? __switch_to_asm+0x40/0x70
[ 13.352105] ? __schedule+0x3d6/0xeb0
[ 13.352112] ? migrate_swap_stop+0x470/0x470
[ 13.352119] ? save_stack+0x89/0xb0
[ 13.352127] ? kmem_cache_alloc_trace+0xe5/0x570
[ 13.352132] ? kthread+0x59/0x1d0
[ 13.352138] ? ret_from_fork+0x35/0x40
[ 13.352154] ? __schedule+0xeb0/0xeb0
[ 13.352161] ? remove_wait_queue+0x150/0x150
[ 13.352169] ? _raw_write_lock_irqsave+0x80/0x100
[ 13.352175] ? __lock_text_start+0x8/0x8
[ 13.352183] ? process_one_work+0xa00/0xa00
[ 13.352188] kthread+0x1a4/0x1d0
[ 13.352195] ? kthread_create_worker_on_cpu+0xc0/0xc0
[ 13.352202] ret_from_fork+0x35/0x40
[ 13.353879] The buggy address belongs to the page:
[ 13.353885] page:ffffea0008d419c0 count:0 mapcount:0 mapping:0000000000000000 index:0x0
[ 13.353890] flags: 0x2ffff8000000000()
[ 13.353897] raw: 02ffff8000000000 ffffea0008d419c8 ffffea0008d419c8 0000000000000000
[ 13.353903] raw: 0000000000000000 0000000000000000 00000000ffffffff 0000000000000000
[ 13.353905] page dumped because: kasan: bad access detected
[ 13.353908] Memory state around the buggy address:
[ 13.353912] ffff880235067000: 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00
[ 13.353917] ffff880235067080: 00 00 00 00 00 00 00 00 00 00 00 f1 f1 f1 f1 04
[ 13.353921] >ffff880235067100: f2 f2 f2 f2 f2 f2 f2 04 f2 f2 f2 f2 f2 f2 f2 04
[ 13.353923] ^
[ 13.353927] ffff880235067180: f2 f2 f2 f2 f2 f2 f2 04 f2 f2 f2 00 00 00 00 00
[ 13.353931] ffff880235067200: 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00 00
[ 13.353933] ==================================================================
The warning is caused by the below loop:
for_each_set_bit(bit, (unsigned long *)&asserted, 8) {
while "asserted" is declared as 'unsigned'.
The casting of 32-bit unsigned integer pointer to a 64-bit unsigned long
pointer. There are two problems here.
It causes the access of four extra byte, which can corrupt memory
The 32-bit pointer address may not be 64-bit aligned.
The fix changes variable "asserted" to "unsigned long".
Fixes: 1f976f6978
("platform/x86: Move Mellanox platform hotplug driver to platform/mellanox")
Signed-off-by: Vadim Pasternak <vadimp@mellanox.com>
Signed-off-by: Darren Hart (VMware) <dvhart@infradead.org>
715 lines
20 KiB
C
715 lines
20 KiB
C
/*
|
|
* Copyright (c) 2016-2018 Mellanox Technologies. All rights reserved.
|
|
* Copyright (c) 2016-2018 Vadim Pasternak <vadimp@mellanox.com>
|
|
*
|
|
* Redistribution and use in source and binary forms, with or without
|
|
* modification, are permitted provided that the following conditions are met:
|
|
*
|
|
* 1. Redistributions of source code must retain the above copyright
|
|
* notice, this list of conditions and the following disclaimer.
|
|
* 2. Redistributions in binary form must reproduce the above copyright
|
|
* notice, this list of conditions and the following disclaimer in the
|
|
* documentation and/or other materials provided with the distribution.
|
|
* 3. Neither the names of the copyright holders nor the names of its
|
|
* contributors may be used to endorse or promote products derived from
|
|
* this software without specific prior written permission.
|
|
*
|
|
* Alternatively, this software may be distributed under the terms of the
|
|
* GNU General Public License ("GPL") version 2 as published by the Free
|
|
* Software Foundation.
|
|
*
|
|
* THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS "AS IS"
|
|
* AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE
|
|
* IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR PURPOSE
|
|
* ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT OWNER OR CONTRIBUTORS BE
|
|
* LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR
|
|
* CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF
|
|
* SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR PROFITS; OR BUSINESS
|
|
* INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY OF LIABILITY, WHETHER IN
|
|
* CONTRACT, STRICT LIABILITY, OR TORT (INCLUDING NEGLIGENCE OR OTHERWISE)
|
|
* ARISING IN ANY WAY OUT OF THE USE OF THIS SOFTWARE, EVEN IF ADVISED OF THE
|
|
* POSSIBILITY OF SUCH DAMAGE.
|
|
*/
|
|
|
|
#include <linux/bitops.h>
|
|
#include <linux/device.h>
|
|
#include <linux/hwmon.h>
|
|
#include <linux/hwmon-sysfs.h>
|
|
#include <linux/i2c.h>
|
|
#include <linux/interrupt.h>
|
|
#include <linux/module.h>
|
|
#include <linux/of_device.h>
|
|
#include <linux/platform_data/mlxreg.h>
|
|
#include <linux/platform_device.h>
|
|
#include <linux/spinlock.h>
|
|
#include <linux/regmap.h>
|
|
#include <linux/workqueue.h>
|
|
|
|
/* Offset of event and mask registers from status register. */
|
|
#define MLXREG_HOTPLUG_EVENT_OFF 1
|
|
#define MLXREG_HOTPLUG_MASK_OFF 2
|
|
#define MLXREG_HOTPLUG_AGGR_MASK_OFF 1
|
|
|
|
/* ASIC good health mask. */
|
|
#define MLXREG_HOTPLUG_GOOD_HEALTH_MASK 0x02
|
|
|
|
#define MLXREG_HOTPLUG_ATTRS_MAX 24
|
|
#define MLXREG_HOTPLUG_NOT_ASSERT 3
|
|
|
|
/**
|
|
* struct mlxreg_hotplug_priv_data - platform private data:
|
|
* @irq: platform device interrupt number;
|
|
* @dev: basic device;
|
|
* @pdev: platform device;
|
|
* @plat: platform data;
|
|
* @regmap: register map handle;
|
|
* @dwork_irq: delayed work template;
|
|
* @lock: spin lock;
|
|
* @hwmon: hwmon device;
|
|
* @mlxreg_hotplug_attr: sysfs attributes array;
|
|
* @mlxreg_hotplug_dev_attr: sysfs sensor device attribute array;
|
|
* @group: sysfs attribute group;
|
|
* @groups: list of sysfs attribute group for hwmon registration;
|
|
* @cell: location of top aggregation interrupt register;
|
|
* @mask: top aggregation interrupt common mask;
|
|
* @aggr_cache: last value of aggregation register status;
|
|
* @after_probe: flag indication probing completion;
|
|
* @not_asserted: number of entries in workqueue with no signal assertion;
|
|
*/
|
|
struct mlxreg_hotplug_priv_data {
|
|
int irq;
|
|
struct device *dev;
|
|
struct platform_device *pdev;
|
|
struct mlxreg_hotplug_platform_data *plat;
|
|
struct regmap *regmap;
|
|
struct delayed_work dwork_irq;
|
|
spinlock_t lock; /* sync with interrupt */
|
|
struct device *hwmon;
|
|
struct attribute *mlxreg_hotplug_attr[MLXREG_HOTPLUG_ATTRS_MAX + 1];
|
|
struct sensor_device_attribute_2
|
|
mlxreg_hotplug_dev_attr[MLXREG_HOTPLUG_ATTRS_MAX];
|
|
struct attribute_group group;
|
|
const struct attribute_group *groups[2];
|
|
u32 cell;
|
|
u32 mask;
|
|
u32 aggr_cache;
|
|
bool after_probe;
|
|
u8 not_asserted;
|
|
};
|
|
|
|
static int mlxreg_hotplug_device_create(struct mlxreg_hotplug_priv_data *priv,
|
|
struct mlxreg_core_data *data)
|
|
{
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
|
|
/* Notify user by sending hwmon uevent. */
|
|
kobject_uevent(&priv->hwmon->kobj, KOBJ_CHANGE);
|
|
|
|
/*
|
|
* Return if adapter number is negative. It could be in case hotplug
|
|
* event is not associated with hotplug device.
|
|
*/
|
|
if (data->hpdev.nr < 0)
|
|
return 0;
|
|
|
|
pdata = dev_get_platdata(&priv->pdev->dev);
|
|
data->hpdev.adapter = i2c_get_adapter(data->hpdev.nr +
|
|
pdata->shift_nr);
|
|
if (!data->hpdev.adapter) {
|
|
dev_err(priv->dev, "Failed to get adapter for bus %d\n",
|
|
data->hpdev.nr + pdata->shift_nr);
|
|
return -EFAULT;
|
|
}
|
|
|
|
data->hpdev.client = i2c_new_device(data->hpdev.adapter,
|
|
data->hpdev.brdinfo);
|
|
if (!data->hpdev.client) {
|
|
dev_err(priv->dev, "Failed to create client %s at bus %d at addr 0x%02x\n",
|
|
data->hpdev.brdinfo->type, data->hpdev.nr +
|
|
pdata->shift_nr, data->hpdev.brdinfo->addr);
|
|
|
|
i2c_put_adapter(data->hpdev.adapter);
|
|
data->hpdev.adapter = NULL;
|
|
return -EFAULT;
|
|
}
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void
|
|
mlxreg_hotplug_device_destroy(struct mlxreg_hotplug_priv_data *priv,
|
|
struct mlxreg_core_data *data)
|
|
{
|
|
/* Notify user by sending hwmon uevent. */
|
|
kobject_uevent(&priv->hwmon->kobj, KOBJ_CHANGE);
|
|
|
|
if (data->hpdev.client) {
|
|
i2c_unregister_device(data->hpdev.client);
|
|
data->hpdev.client = NULL;
|
|
}
|
|
|
|
if (data->hpdev.adapter) {
|
|
i2c_put_adapter(data->hpdev.adapter);
|
|
data->hpdev.adapter = NULL;
|
|
}
|
|
}
|
|
|
|
static ssize_t mlxreg_hotplug_attr_show(struct device *dev,
|
|
struct device_attribute *attr,
|
|
char *buf)
|
|
{
|
|
struct mlxreg_hotplug_priv_data *priv = dev_get_drvdata(dev);
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
int index = to_sensor_dev_attr_2(attr)->index;
|
|
int nr = to_sensor_dev_attr_2(attr)->nr;
|
|
struct mlxreg_core_item *item;
|
|
struct mlxreg_core_data *data;
|
|
u32 regval;
|
|
int ret;
|
|
|
|
pdata = dev_get_platdata(&priv->pdev->dev);
|
|
item = pdata->items + nr;
|
|
data = item->data + index;
|
|
|
|
ret = regmap_read(priv->regmap, data->reg, ®val);
|
|
if (ret)
|
|
return ret;
|
|
|
|
if (item->health) {
|
|
regval &= data->mask;
|
|
} else {
|
|
/* Bit = 0 : functional if item->inversed is true. */
|
|
if (item->inversed)
|
|
regval = !(regval & data->mask);
|
|
else
|
|
regval = !!(regval & data->mask);
|
|
}
|
|
|
|
return sprintf(buf, "%u\n", regval);
|
|
}
|
|
|
|
#define PRIV_ATTR(i) priv->mlxreg_hotplug_attr[i]
|
|
#define PRIV_DEV_ATTR(i) priv->mlxreg_hotplug_dev_attr[i]
|
|
|
|
static int mlxreg_hotplug_attr_init(struct mlxreg_hotplug_priv_data *priv)
|
|
{
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
struct mlxreg_core_item *item;
|
|
struct mlxreg_core_data *data;
|
|
int num_attrs = 0, id = 0, i, j;
|
|
|
|
pdata = dev_get_platdata(&priv->pdev->dev);
|
|
item = pdata->items;
|
|
|
|
/* Go over all kinds of items - psu, pwr, fan. */
|
|
for (i = 0; i < pdata->counter; i++, item++) {
|
|
num_attrs += item->count;
|
|
data = item->data;
|
|
/* Go over all units within the item. */
|
|
for (j = 0; j < item->count; j++, data++, id++) {
|
|
PRIV_ATTR(id) = &PRIV_DEV_ATTR(id).dev_attr.attr;
|
|
PRIV_ATTR(id)->name = devm_kasprintf(&priv->pdev->dev,
|
|
GFP_KERNEL,
|
|
data->label);
|
|
|
|
if (!PRIV_ATTR(id)->name) {
|
|
dev_err(priv->dev, "Memory allocation failed for attr %d.\n",
|
|
id);
|
|
return -ENOMEM;
|
|
}
|
|
|
|
PRIV_DEV_ATTR(id).dev_attr.attr.name =
|
|
PRIV_ATTR(id)->name;
|
|
PRIV_DEV_ATTR(id).dev_attr.attr.mode = 0444;
|
|
PRIV_DEV_ATTR(id).dev_attr.show =
|
|
mlxreg_hotplug_attr_show;
|
|
PRIV_DEV_ATTR(id).nr = i;
|
|
PRIV_DEV_ATTR(id).index = j;
|
|
sysfs_attr_init(&PRIV_DEV_ATTR(id).dev_attr.attr);
|
|
}
|
|
}
|
|
|
|
priv->group.attrs = devm_kcalloc(&priv->pdev->dev,
|
|
num_attrs,
|
|
sizeof(struct attribute *),
|
|
GFP_KERNEL);
|
|
if (!priv->group.attrs)
|
|
return -ENOMEM;
|
|
|
|
priv->group.attrs = priv->mlxreg_hotplug_attr;
|
|
priv->groups[0] = &priv->group;
|
|
priv->groups[1] = NULL;
|
|
|
|
return 0;
|
|
}
|
|
|
|
static void
|
|
mlxreg_hotplug_work_helper(struct mlxreg_hotplug_priv_data *priv,
|
|
struct mlxreg_core_item *item)
|
|
{
|
|
struct mlxreg_core_data *data;
|
|
unsigned long asserted;
|
|
u32 regval, bit;
|
|
int ret;
|
|
|
|
/*
|
|
* Validate if item related to received signal type is valid.
|
|
* It should never happen, excepted the situation when some
|
|
* piece of hardware is broken. In such situation just produce
|
|
* error message and return. Caller must continue to handle the
|
|
* signals from other devices if any.
|
|
*/
|
|
if (unlikely(!item)) {
|
|
dev_err(priv->dev, "False signal: at offset:mask 0x%02x:0x%02x.\n",
|
|
item->reg, item->mask);
|
|
|
|
return;
|
|
}
|
|
|
|
/* Mask event. */
|
|
ret = regmap_write(priv->regmap, item->reg + MLXREG_HOTPLUG_MASK_OFF,
|
|
0);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/* Read status. */
|
|
ret = regmap_read(priv->regmap, item->reg, ®val);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/* Set asserted bits and save last status. */
|
|
regval &= item->mask;
|
|
asserted = item->cache ^ regval;
|
|
item->cache = regval;
|
|
|
|
for_each_set_bit(bit, &asserted, 8) {
|
|
data = item->data + bit;
|
|
if (regval & BIT(bit)) {
|
|
if (item->inversed)
|
|
mlxreg_hotplug_device_destroy(priv, data);
|
|
else
|
|
mlxreg_hotplug_device_create(priv, data);
|
|
} else {
|
|
if (item->inversed)
|
|
mlxreg_hotplug_device_create(priv, data);
|
|
else
|
|
mlxreg_hotplug_device_destroy(priv, data);
|
|
}
|
|
}
|
|
|
|
/* Acknowledge event. */
|
|
ret = regmap_write(priv->regmap, item->reg + MLXREG_HOTPLUG_EVENT_OFF,
|
|
0);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/* Unmask event. */
|
|
ret = regmap_write(priv->regmap, item->reg + MLXREG_HOTPLUG_MASK_OFF,
|
|
item->mask);
|
|
|
|
out:
|
|
if (ret)
|
|
dev_err(priv->dev, "Failed to complete workqueue.\n");
|
|
}
|
|
|
|
static void
|
|
mlxreg_hotplug_health_work_helper(struct mlxreg_hotplug_priv_data *priv,
|
|
struct mlxreg_core_item *item)
|
|
{
|
|
struct mlxreg_core_data *data = item->data;
|
|
u32 regval;
|
|
int i, ret = 0;
|
|
|
|
for (i = 0; i < item->count; i++, data++) {
|
|
/* Mask event. */
|
|
ret = regmap_write(priv->regmap, data->reg +
|
|
MLXREG_HOTPLUG_MASK_OFF, 0);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/* Read status. */
|
|
ret = regmap_read(priv->regmap, data->reg, ®val);
|
|
if (ret)
|
|
goto out;
|
|
|
|
regval &= data->mask;
|
|
|
|
if (item->cache == regval)
|
|
goto ack_event;
|
|
|
|
/*
|
|
* ASIC health indication is provided through two bits. Bits
|
|
* value 0x2 indicates that ASIC reached the good health, value
|
|
* 0x0 indicates ASIC the bad health or dormant state and value
|
|
* 0x3 indicates the booting state. During ASIC reset it should
|
|
* pass the following states: dormant -> booting -> good.
|
|
*/
|
|
if (regval == MLXREG_HOTPLUG_GOOD_HEALTH_MASK) {
|
|
if (!data->attached) {
|
|
/*
|
|
* ASIC is in steady state. Connect associated
|
|
* device, if configured.
|
|
*/
|
|
mlxreg_hotplug_device_create(priv, data);
|
|
data->attached = true;
|
|
}
|
|
} else {
|
|
if (data->attached) {
|
|
/*
|
|
* ASIC health is failed after ASIC has been
|
|
* in steady state. Disconnect associated
|
|
* device, if it has been connected.
|
|
*/
|
|
mlxreg_hotplug_device_destroy(priv, data);
|
|
data->attached = false;
|
|
data->health_cntr = 0;
|
|
}
|
|
}
|
|
item->cache = regval;
|
|
ack_event:
|
|
/* Acknowledge event. */
|
|
ret = regmap_write(priv->regmap, data->reg +
|
|
MLXREG_HOTPLUG_EVENT_OFF, 0);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/* Unmask event. */
|
|
ret = regmap_write(priv->regmap, data->reg +
|
|
MLXREG_HOTPLUG_MASK_OFF, data->mask);
|
|
if (ret)
|
|
goto out;
|
|
}
|
|
|
|
out:
|
|
if (ret)
|
|
dev_err(priv->dev, "Failed to complete workqueue.\n");
|
|
}
|
|
|
|
/*
|
|
* mlxreg_hotplug_work_handler - performs traversing of device interrupt
|
|
* registers according to the below hierarchy schema:
|
|
*
|
|
* Aggregation registers (status/mask)
|
|
* PSU registers: *---*
|
|
* *-----------------* | |
|
|
* |status/event/mask|-----> | * |
|
|
* *-----------------* | |
|
|
* Power registers: | |
|
|
* *-----------------* | |
|
|
* |status/event/mask|-----> | * |
|
|
* *-----------------* | |
|
|
* FAN registers: | |--> CPU
|
|
* *-----------------* | |
|
|
* |status/event/mask|-----> | * |
|
|
* *-----------------* | |
|
|
* ASIC registers: | |
|
|
* *-----------------* | |
|
|
* |status/event/mask|-----> | * |
|
|
* *-----------------* | |
|
|
* *---*
|
|
*
|
|
* In case some system changed are detected: FAN in/out, PSU in/out, power
|
|
* cable attached/detached, ASIC health good/bad, relevant device is created
|
|
* or destroyed.
|
|
*/
|
|
static void mlxreg_hotplug_work_handler(struct work_struct *work)
|
|
{
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
struct mlxreg_hotplug_priv_data *priv;
|
|
struct mlxreg_core_item *item;
|
|
u32 regval, aggr_asserted;
|
|
unsigned long flags;
|
|
int i, ret;
|
|
|
|
priv = container_of(work, struct mlxreg_hotplug_priv_data,
|
|
dwork_irq.work);
|
|
pdata = dev_get_platdata(&priv->pdev->dev);
|
|
item = pdata->items;
|
|
|
|
/* Mask aggregation event. */
|
|
ret = regmap_write(priv->regmap, pdata->cell +
|
|
MLXREG_HOTPLUG_AGGR_MASK_OFF, 0);
|
|
if (ret < 0)
|
|
goto out;
|
|
|
|
/* Read aggregation status. */
|
|
ret = regmap_read(priv->regmap, pdata->cell, ®val);
|
|
if (ret)
|
|
goto out;
|
|
|
|
regval &= pdata->mask;
|
|
aggr_asserted = priv->aggr_cache ^ regval;
|
|
priv->aggr_cache = regval;
|
|
|
|
/*
|
|
* Handler is invoked, but no assertion is detected at top aggregation
|
|
* status level. Set aggr_asserted to mask value to allow handler extra
|
|
* run over all relevant signals to recover any missed signal.
|
|
*/
|
|
if (priv->not_asserted == MLXREG_HOTPLUG_NOT_ASSERT) {
|
|
priv->not_asserted = 0;
|
|
aggr_asserted = pdata->mask;
|
|
}
|
|
if (!aggr_asserted)
|
|
goto unmask_event;
|
|
|
|
/* Handle topology and health configuration changes. */
|
|
for (i = 0; i < pdata->counter; i++, item++) {
|
|
if (aggr_asserted & item->aggr_mask) {
|
|
if (item->health)
|
|
mlxreg_hotplug_health_work_helper(priv, item);
|
|
else
|
|
mlxreg_hotplug_work_helper(priv, item);
|
|
}
|
|
}
|
|
|
|
spin_lock_irqsave(&priv->lock, flags);
|
|
|
|
/*
|
|
* It is possible, that some signals have been inserted, while
|
|
* interrupt has been masked by mlxreg_hotplug_work_handler. In this
|
|
* case such signals will be missed. In order to handle these signals
|
|
* delayed work is canceled and work task re-scheduled for immediate
|
|
* execution. It allows to handle missed signals, if any. In other case
|
|
* work handler just validates that no new signals have been received
|
|
* during masking.
|
|
*/
|
|
cancel_delayed_work(&priv->dwork_irq);
|
|
schedule_delayed_work(&priv->dwork_irq, 0);
|
|
|
|
spin_unlock_irqrestore(&priv->lock, flags);
|
|
|
|
return;
|
|
|
|
unmask_event:
|
|
priv->not_asserted++;
|
|
/* Unmask aggregation event (no need acknowledge). */
|
|
ret = regmap_write(priv->regmap, pdata->cell +
|
|
MLXREG_HOTPLUG_AGGR_MASK_OFF, pdata->mask);
|
|
|
|
out:
|
|
if (ret)
|
|
dev_err(priv->dev, "Failed to complete workqueue.\n");
|
|
}
|
|
|
|
static int mlxreg_hotplug_set_irq(struct mlxreg_hotplug_priv_data *priv)
|
|
{
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
struct mlxreg_core_item *item;
|
|
struct mlxreg_core_data *data;
|
|
u32 regval;
|
|
int i, j, ret;
|
|
|
|
pdata = dev_get_platdata(&priv->pdev->dev);
|
|
item = pdata->items;
|
|
|
|
for (i = 0; i < pdata->counter; i++, item++) {
|
|
/* Clear group presense event. */
|
|
ret = regmap_write(priv->regmap, item->reg +
|
|
MLXREG_HOTPLUG_EVENT_OFF, 0);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/*
|
|
* Verify if hardware configuration requires to disable
|
|
* interrupt capability for some of components.
|
|
*/
|
|
data = item->data;
|
|
for (j = 0; j < item->count; j++, data++) {
|
|
/* Verify if the attribute has capability register. */
|
|
if (data->capability) {
|
|
/* Read capability register. */
|
|
ret = regmap_read(priv->regmap,
|
|
data->capability, ®val);
|
|
if (ret)
|
|
goto out;
|
|
|
|
if (!(regval & data->bit))
|
|
item->mask &= ~BIT(j);
|
|
}
|
|
}
|
|
|
|
/* Set group initial status as mask and unmask group event. */
|
|
if (item->inversed) {
|
|
item->cache = item->mask;
|
|
ret = regmap_write(priv->regmap, item->reg +
|
|
MLXREG_HOTPLUG_MASK_OFF,
|
|
item->mask);
|
|
if (ret)
|
|
goto out;
|
|
}
|
|
}
|
|
|
|
/* Keep aggregation initial status as zero and unmask events. */
|
|
ret = regmap_write(priv->regmap, pdata->cell +
|
|
MLXREG_HOTPLUG_AGGR_MASK_OFF, pdata->mask);
|
|
if (ret)
|
|
goto out;
|
|
|
|
/* Keep low aggregation initial status as zero and unmask events. */
|
|
if (pdata->cell_low) {
|
|
ret = regmap_write(priv->regmap, pdata->cell_low +
|
|
MLXREG_HOTPLUG_AGGR_MASK_OFF,
|
|
pdata->mask_low);
|
|
if (ret)
|
|
goto out;
|
|
}
|
|
|
|
/* Invoke work handler for initializing hot plug devices setting. */
|
|
mlxreg_hotplug_work_handler(&priv->dwork_irq.work);
|
|
|
|
out:
|
|
if (ret)
|
|
dev_err(priv->dev, "Failed to set interrupts.\n");
|
|
enable_irq(priv->irq);
|
|
return ret;
|
|
}
|
|
|
|
static void mlxreg_hotplug_unset_irq(struct mlxreg_hotplug_priv_data *priv)
|
|
{
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
struct mlxreg_core_item *item;
|
|
struct mlxreg_core_data *data;
|
|
int count, i, j;
|
|
|
|
pdata = dev_get_platdata(&priv->pdev->dev);
|
|
item = pdata->items;
|
|
disable_irq(priv->irq);
|
|
cancel_delayed_work_sync(&priv->dwork_irq);
|
|
|
|
/* Mask low aggregation event, if defined. */
|
|
if (pdata->cell_low)
|
|
regmap_write(priv->regmap, pdata->cell_low +
|
|
MLXREG_HOTPLUG_AGGR_MASK_OFF, 0);
|
|
|
|
/* Mask aggregation event. */
|
|
regmap_write(priv->regmap, pdata->cell + MLXREG_HOTPLUG_AGGR_MASK_OFF,
|
|
0);
|
|
|
|
/* Clear topology configurations. */
|
|
for (i = 0; i < pdata->counter; i++, item++) {
|
|
data = item->data;
|
|
/* Mask group presense event. */
|
|
regmap_write(priv->regmap, data->reg + MLXREG_HOTPLUG_MASK_OFF,
|
|
0);
|
|
/* Clear group presense event. */
|
|
regmap_write(priv->regmap, data->reg +
|
|
MLXREG_HOTPLUG_EVENT_OFF, 0);
|
|
|
|
/* Remove all the attached devices in group. */
|
|
count = item->count;
|
|
for (j = 0; j < count; j++, data++)
|
|
mlxreg_hotplug_device_destroy(priv, data);
|
|
}
|
|
}
|
|
|
|
static irqreturn_t mlxreg_hotplug_irq_handler(int irq, void *dev)
|
|
{
|
|
struct mlxreg_hotplug_priv_data *priv;
|
|
|
|
priv = (struct mlxreg_hotplug_priv_data *)dev;
|
|
|
|
/* Schedule work task for immediate execution.*/
|
|
schedule_delayed_work(&priv->dwork_irq, 0);
|
|
|
|
return IRQ_HANDLED;
|
|
}
|
|
|
|
static int mlxreg_hotplug_probe(struct platform_device *pdev)
|
|
{
|
|
struct mlxreg_core_hotplug_platform_data *pdata;
|
|
struct mlxreg_hotplug_priv_data *priv;
|
|
struct i2c_adapter *deferred_adap;
|
|
int err;
|
|
|
|
pdata = dev_get_platdata(&pdev->dev);
|
|
if (!pdata) {
|
|
dev_err(&pdev->dev, "Failed to get platform data.\n");
|
|
return -EINVAL;
|
|
}
|
|
|
|
/* Defer probing if the necessary adapter is not configured yet. */
|
|
deferred_adap = i2c_get_adapter(pdata->deferred_nr);
|
|
if (!deferred_adap)
|
|
return -EPROBE_DEFER;
|
|
i2c_put_adapter(deferred_adap);
|
|
|
|
priv = devm_kzalloc(&pdev->dev, sizeof(*priv), GFP_KERNEL);
|
|
if (!priv)
|
|
return -ENOMEM;
|
|
|
|
if (pdata->irq) {
|
|
priv->irq = pdata->irq;
|
|
} else {
|
|
priv->irq = platform_get_irq(pdev, 0);
|
|
if (priv->irq < 0) {
|
|
dev_err(&pdev->dev, "Failed to get platform irq: %d\n",
|
|
priv->irq);
|
|
return priv->irq;
|
|
}
|
|
}
|
|
|
|
priv->regmap = pdata->regmap;
|
|
priv->dev = pdev->dev.parent;
|
|
priv->pdev = pdev;
|
|
|
|
err = devm_request_irq(&pdev->dev, priv->irq,
|
|
mlxreg_hotplug_irq_handler, IRQF_TRIGGER_FALLING
|
|
| IRQF_SHARED, "mlxreg-hotplug", priv);
|
|
if (err) {
|
|
dev_err(&pdev->dev, "Failed to request irq: %d\n", err);
|
|
return err;
|
|
}
|
|
|
|
disable_irq(priv->irq);
|
|
spin_lock_init(&priv->lock);
|
|
INIT_DELAYED_WORK(&priv->dwork_irq, mlxreg_hotplug_work_handler);
|
|
dev_set_drvdata(&pdev->dev, priv);
|
|
|
|
err = mlxreg_hotplug_attr_init(priv);
|
|
if (err) {
|
|
dev_err(&pdev->dev, "Failed to allocate attributes: %d\n",
|
|
err);
|
|
return err;
|
|
}
|
|
|
|
priv->hwmon = devm_hwmon_device_register_with_groups(&pdev->dev,
|
|
"mlxreg_hotplug", priv, priv->groups);
|
|
if (IS_ERR(priv->hwmon)) {
|
|
dev_err(&pdev->dev, "Failed to register hwmon device %ld\n",
|
|
PTR_ERR(priv->hwmon));
|
|
return PTR_ERR(priv->hwmon);
|
|
}
|
|
|
|
/* Perform initial interrupts setup. */
|
|
mlxreg_hotplug_set_irq(priv);
|
|
priv->after_probe = true;
|
|
|
|
return 0;
|
|
}
|
|
|
|
static int mlxreg_hotplug_remove(struct platform_device *pdev)
|
|
{
|
|
struct mlxreg_hotplug_priv_data *priv = dev_get_drvdata(&pdev->dev);
|
|
|
|
/* Clean interrupts setup. */
|
|
mlxreg_hotplug_unset_irq(priv);
|
|
|
|
return 0;
|
|
}
|
|
|
|
static struct platform_driver mlxreg_hotplug_driver = {
|
|
.driver = {
|
|
.name = "mlxreg-hotplug",
|
|
},
|
|
.probe = mlxreg_hotplug_probe,
|
|
.remove = mlxreg_hotplug_remove,
|
|
};
|
|
|
|
module_platform_driver(mlxreg_hotplug_driver);
|
|
|
|
MODULE_AUTHOR("Vadim Pasternak <vadimp@mellanox.com>");
|
|
MODULE_DESCRIPTION("Mellanox regmap hotplug platform driver");
|
|
MODULE_LICENSE("Dual BSD/GPL");
|
|
MODULE_ALIAS("platform:mlxreg-hotplug");
|