Donate to e Foundation | Murena handsets with /e/OS | Own a part of Murena! Learn more

Commit 69c1280b authored by Saeed Mahameed's avatar Saeed Mahameed
Browse files

net/mlx5: Device events, Use async events chain 



Move all the generic async events handling into new specific events
handling file events.c to keep eq.c file clean from concrete event logic
handling.

Use new API to register for NOTIFY_ANY to handle generic events and
dispatch allowed events to mlx5_core consumers (mlx5_ib and mlx5e)

Signed-off-by: default avatarSaeed Mahameed <saeedm@mellanox.com>
parent 2742bc90

drivers/net/ethernet/mellanox/mlx5/core/Makefile

+1 −1
Original line number Diff line number Diff line
@@ -14,7 +14,7 @@ obj-$(CONFIG_MLX5_CORE) += mlx5_core.o 
mlx5_core-y :=	main.o cmd.o debugfs.o fw.o eq.o uar.o pagealloc.o \

		health.o mcg.o cq.o srq.o alloc.o qp.o port.o mr.o pd.o \

		mad.o transobj.o vport.o sriov.o fs_cmd.o fs_core.o \

		fs_counters.o rl.o lag.o dev.o wq.o lib/gid.o  \

		fs_counters.o rl.o lag.o dev.o events.o wq.o lib/gid.o \

		diag/fs_tracepoint.o diag/fw_tracer.o



#

drivers/net/ethernet/mellanox/mlx5/core/en_stats.c

+6 −3
Original line number Diff line number Diff line
@@ -30,6 +30,7 @@ 
 * SOFTWARE.

 */



#include "lib/mlx5.h"

#include "en.h"

#include "en_accel/ipsec.h"

#include "en_accel/tls.h"
@@ -1120,15 +1121,17 @@ static int mlx5e_grp_pme_fill_strings(struct mlx5e_priv *priv, u8 *data, 
static int mlx5e_grp_pme_fill_stats(struct mlx5e_priv *priv, u64 *data,

				    int idx)

{

	struct mlx5_priv *mlx5_priv = &priv->mdev->priv;

	struct mlx5_pme_stats pme_stats;

	int i;



	mlx5_get_pme_stats(priv->mdev, &pme_stats);



	for (i = 0; i < NUM_PME_STATUS_STATS; i++)

		data[idx++] = MLX5E_READ_CTR64_CPU(mlx5_priv->pme_stats.status_counters,

		data[idx++] = MLX5E_READ_CTR64_CPU(pme_stats.status_counters,

						   mlx5e_pme_status_desc, i);



	for (i = 0; i < NUM_PME_ERR_STATS; i++)

		data[idx++] = MLX5E_READ_CTR64_CPU(mlx5_priv->pme_stats.error_counters,

		data[idx++] = MLX5E_READ_CTR64_CPU(pme_stats.error_counters,

						   mlx5e_pme_error_desc, i);



	return idx;

drivers/net/ethernet/mellanox/mlx5/core/eq.c

+0 −157
Original line number Diff line number Diff line
@@ -108,121 +108,6 @@ static int mlx5_cmd_destroy_eq(struct mlx5_core_dev *dev, u8 eqn) 
	return mlx5_cmd_exec(dev, in, sizeof(in), out, sizeof(out));

}



static const char *eqe_type_str(u8 type)

{

	switch (type) {

	case MLX5_EVENT_TYPE_COMP:

		return "MLX5_EVENT_TYPE_COMP";

	case MLX5_EVENT_TYPE_PATH_MIG:

		return "MLX5_EVENT_TYPE_PATH_MIG";

	case MLX5_EVENT_TYPE_COMM_EST:

		return "MLX5_EVENT_TYPE_COMM_EST";

	case MLX5_EVENT_TYPE_SQ_DRAINED:

		return "MLX5_EVENT_TYPE_SQ_DRAINED";

	case MLX5_EVENT_TYPE_SRQ_LAST_WQE:

		return "MLX5_EVENT_TYPE_SRQ_LAST_WQE";

	case MLX5_EVENT_TYPE_SRQ_RQ_LIMIT:

		return "MLX5_EVENT_TYPE_SRQ_RQ_LIMIT";

	case MLX5_EVENT_TYPE_CQ_ERROR:

		return "MLX5_EVENT_TYPE_CQ_ERROR";

	case MLX5_EVENT_TYPE_WQ_CATAS_ERROR:

		return "MLX5_EVENT_TYPE_WQ_CATAS_ERROR";

	case MLX5_EVENT_TYPE_PATH_MIG_FAILED:

		return "MLX5_EVENT_TYPE_PATH_MIG_FAILED";

	case MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR:

		return "MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR";

	case MLX5_EVENT_TYPE_WQ_ACCESS_ERROR:

		return "MLX5_EVENT_TYPE_WQ_ACCESS_ERROR";

	case MLX5_EVENT_TYPE_SRQ_CATAS_ERROR:

		return "MLX5_EVENT_TYPE_SRQ_CATAS_ERROR";

	case MLX5_EVENT_TYPE_INTERNAL_ERROR:

		return "MLX5_EVENT_TYPE_INTERNAL_ERROR";

	case MLX5_EVENT_TYPE_PORT_CHANGE:

		return "MLX5_EVENT_TYPE_PORT_CHANGE";

	case MLX5_EVENT_TYPE_GPIO_EVENT:

		return "MLX5_EVENT_TYPE_GPIO_EVENT";

	case MLX5_EVENT_TYPE_PORT_MODULE_EVENT:

		return "MLX5_EVENT_TYPE_PORT_MODULE_EVENT";

	case MLX5_EVENT_TYPE_TEMP_WARN_EVENT:

		return "MLX5_EVENT_TYPE_TEMP_WARN_EVENT";

	case MLX5_EVENT_TYPE_REMOTE_CONFIG:

		return "MLX5_EVENT_TYPE_REMOTE_CONFIG";

	case MLX5_EVENT_TYPE_DB_BF_CONGESTION:

		return "MLX5_EVENT_TYPE_DB_BF_CONGESTION";

	case MLX5_EVENT_TYPE_STALL_EVENT:

		return "MLX5_EVENT_TYPE_STALL_EVENT";

	case MLX5_EVENT_TYPE_CMD:

		return "MLX5_EVENT_TYPE_CMD";

	case MLX5_EVENT_TYPE_PAGE_REQUEST:

		return "MLX5_EVENT_TYPE_PAGE_REQUEST";

	case MLX5_EVENT_TYPE_PAGE_FAULT:

		return "MLX5_EVENT_TYPE_PAGE_FAULT";

	case MLX5_EVENT_TYPE_PPS_EVENT:

		return "MLX5_EVENT_TYPE_PPS_EVENT";

	case MLX5_EVENT_TYPE_NIC_VPORT_CHANGE:

		return "MLX5_EVENT_TYPE_NIC_VPORT_CHANGE";

	case MLX5_EVENT_TYPE_FPGA_ERROR:

		return "MLX5_EVENT_TYPE_FPGA_ERROR";

	case MLX5_EVENT_TYPE_FPGA_QP_ERROR:

		return "MLX5_EVENT_TYPE_FPGA_QP_ERROR";

	case MLX5_EVENT_TYPE_GENERAL_EVENT:

		return "MLX5_EVENT_TYPE_GENERAL_EVENT";

	case MLX5_EVENT_TYPE_DEVICE_TRACER:

		return "MLX5_EVENT_TYPE_DEVICE_TRACER";

	default:

		return "Unrecognized event";

	}

}



static enum mlx5_dev_event port_subtype_event(u8 subtype)

{

	switch (subtype) {

	case MLX5_PORT_CHANGE_SUBTYPE_DOWN:

		return MLX5_DEV_EVENT_PORT_DOWN;

	case MLX5_PORT_CHANGE_SUBTYPE_ACTIVE:

		return MLX5_DEV_EVENT_PORT_UP;

	case MLX5_PORT_CHANGE_SUBTYPE_INITIALIZED:

		return MLX5_DEV_EVENT_PORT_INITIALIZED;

	case MLX5_PORT_CHANGE_SUBTYPE_LID:

		return MLX5_DEV_EVENT_LID_CHANGE;

	case MLX5_PORT_CHANGE_SUBTYPE_PKEY:

		return MLX5_DEV_EVENT_PKEY_CHANGE;

	case MLX5_PORT_CHANGE_SUBTYPE_GUID:

		return MLX5_DEV_EVENT_GUID_CHANGE;

	case MLX5_PORT_CHANGE_SUBTYPE_CLIENT_REREG:

		return MLX5_DEV_EVENT_CLIENT_REREG;

	}

	return -1;

}



static void general_event_handler(struct mlx5_core_dev *dev,

				  struct mlx5_eqe *eqe)

{

	switch (eqe->sub_type) {

	case MLX5_GENERAL_SUBTYPE_DELAY_DROP_TIMEOUT:

		if (dev->event)

			dev->event(dev, MLX5_DEV_EVENT_DELAY_DROP_TIMEOUT, 0);

		break;

	default:

		mlx5_core_dbg(dev, "General event with unrecognized subtype: sub_type %d\n",

			      eqe->sub_type);

	}

}



static void mlx5_temp_warning_event(struct mlx5_core_dev *dev,

				    struct mlx5_eqe *eqe)

{

	u64 value_lsb;

	u64 value_msb;



	value_lsb = be64_to_cpu(eqe->data.temp_warning.sensor_warning_lsb);

	value_msb = be64_to_cpu(eqe->data.temp_warning.sensor_warning_msb);



	mlx5_core_warn(dev,

		       "High temperature on sensors with bit set %llx %llx",

		       value_msb, value_lsb);

}



/* caller must eventually call mlx5_cq_put on the returned cq */

static struct mlx5_core_cq *mlx5_eq_cq_get(struct mlx5_eq *eq, u32 cqn)

{
@@ -312,7 +197,6 @@ static irqreturn_t mlx5_eq_async_int(int irq, void *eq_ptr) 
	struct mlx5_core_dev *dev;

	struct mlx5_eqe *eqe;

	int set_ci = 0;

	u8 port;



	dev = eq->dev;

	eqt = dev->priv.eq_table;
@@ -324,47 +208,6 @@ static irqreturn_t mlx5_eq_async_int(int irq, void *eq_ptr) 
		 */

		dma_rmb();



		mlx5_core_dbg(eq->dev, "eqn %d, eqe type %s\n",

			      eq->eqn, eqe_type_str(eqe->type));

		switch (eqe->type) {

		case MLX5_EVENT_TYPE_PORT_CHANGE:

			port = (eqe->data.port.port >> 4) & 0xf;

			switch (eqe->sub_type) {

			case MLX5_PORT_CHANGE_SUBTYPE_DOWN:

			case MLX5_PORT_CHANGE_SUBTYPE_ACTIVE:

			case MLX5_PORT_CHANGE_SUBTYPE_LID:

			case MLX5_PORT_CHANGE_SUBTYPE_PKEY:

			case MLX5_PORT_CHANGE_SUBTYPE_GUID:

			case MLX5_PORT_CHANGE_SUBTYPE_CLIENT_REREG:

			case MLX5_PORT_CHANGE_SUBTYPE_INITIALIZED:

				if (dev->event)

					dev->event(dev, port_subtype_event(eqe->sub_type),

						   (unsigned long)port);

				break;

			default:

				mlx5_core_warn(dev, "Port event with unrecognized subtype: port %d, sub_type %d\n",

					       port, eqe->sub_type);

			}

			break;



		case MLX5_EVENT_TYPE_PORT_MODULE_EVENT:

			mlx5_port_module_event(dev, eqe);

			break;



		case MLX5_EVENT_TYPE_TEMP_WARN_EVENT:

			mlx5_temp_warning_event(dev, eqe);

			break;



		case MLX5_EVENT_TYPE_GENERAL_EVENT:

			general_event_handler(dev, eqe);

			break;



		default:

			mlx5_core_warn(dev, "Unhandled event 0x%x on EQ 0x%x\n",

				       eqe->type, eq->eqn);

			break;

		}



		if (likely(eqe->type < MLX5_EVENT_TYPE_MAX))

			atomic_notifier_call_chain(&eqt->nh[eqe->type], eqe->type, eqe);

		else

drivers/net/ethernet/mellanox/mlx5/core/events.c

0 → 100644
+283 −0
Original line number Diff line number Diff line 
// SPDX-License-Identifier: GPL-2.0 OR Linux-OpenIB

// Copyright (c) 2018 Mellanox Technologies



#include <linux/mlx5/driver.h>

#include "mlx5_core.h"

#include "lib/eq.h"

#include "lib/mlx5.h"



struct mlx5_events {

	struct mlx5_nb        nb;

	struct mlx5_core_dev *dev;



	/* port module evetns stats */

	struct mlx5_pme_stats pme_stats;

};



static const char *eqe_type_str(u8 type)

{

	switch (type) {

	case MLX5_EVENT_TYPE_COMP:

		return "MLX5_EVENT_TYPE_COMP";

	case MLX5_EVENT_TYPE_PATH_MIG:

		return "MLX5_EVENT_TYPE_PATH_MIG";

	case MLX5_EVENT_TYPE_COMM_EST:

		return "MLX5_EVENT_TYPE_COMM_EST";

	case MLX5_EVENT_TYPE_SQ_DRAINED:

		return "MLX5_EVENT_TYPE_SQ_DRAINED";

	case MLX5_EVENT_TYPE_SRQ_LAST_WQE:

		return "MLX5_EVENT_TYPE_SRQ_LAST_WQE";

	case MLX5_EVENT_TYPE_SRQ_RQ_LIMIT:

		return "MLX5_EVENT_TYPE_SRQ_RQ_LIMIT";

	case MLX5_EVENT_TYPE_CQ_ERROR:

		return "MLX5_EVENT_TYPE_CQ_ERROR";

	case MLX5_EVENT_TYPE_WQ_CATAS_ERROR:

		return "MLX5_EVENT_TYPE_WQ_CATAS_ERROR";

	case MLX5_EVENT_TYPE_PATH_MIG_FAILED:

		return "MLX5_EVENT_TYPE_PATH_MIG_FAILED";

	case MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR:

		return "MLX5_EVENT_TYPE_WQ_INVAL_REQ_ERROR";

	case MLX5_EVENT_TYPE_WQ_ACCESS_ERROR:

		return "MLX5_EVENT_TYPE_WQ_ACCESS_ERROR";

	case MLX5_EVENT_TYPE_SRQ_CATAS_ERROR:

		return "MLX5_EVENT_TYPE_SRQ_CATAS_ERROR";

	case MLX5_EVENT_TYPE_INTERNAL_ERROR:

		return "MLX5_EVENT_TYPE_INTERNAL_ERROR";

	case MLX5_EVENT_TYPE_PORT_CHANGE:

		return "MLX5_EVENT_TYPE_PORT_CHANGE";

	case MLX5_EVENT_TYPE_GPIO_EVENT:

		return "MLX5_EVENT_TYPE_GPIO_EVENT";

	case MLX5_EVENT_TYPE_PORT_MODULE_EVENT:

		return "MLX5_EVENT_TYPE_PORT_MODULE_EVENT";

	case MLX5_EVENT_TYPE_TEMP_WARN_EVENT:

		return "MLX5_EVENT_TYPE_TEMP_WARN_EVENT";

	case MLX5_EVENT_TYPE_REMOTE_CONFIG:

		return "MLX5_EVENT_TYPE_REMOTE_CONFIG";

	case MLX5_EVENT_TYPE_DB_BF_CONGESTION:

		return "MLX5_EVENT_TYPE_DB_BF_CONGESTION";

	case MLX5_EVENT_TYPE_STALL_EVENT:

		return "MLX5_EVENT_TYPE_STALL_EVENT";

	case MLX5_EVENT_TYPE_CMD:

		return "MLX5_EVENT_TYPE_CMD";

	case MLX5_EVENT_TYPE_PAGE_REQUEST:

		return "MLX5_EVENT_TYPE_PAGE_REQUEST";

	case MLX5_EVENT_TYPE_PAGE_FAULT:

		return "MLX5_EVENT_TYPE_PAGE_FAULT";

	case MLX5_EVENT_TYPE_PPS_EVENT:

		return "MLX5_EVENT_TYPE_PPS_EVENT";

	case MLX5_EVENT_TYPE_NIC_VPORT_CHANGE:

		return "MLX5_EVENT_TYPE_NIC_VPORT_CHANGE";

	case MLX5_EVENT_TYPE_FPGA_ERROR:

		return "MLX5_EVENT_TYPE_FPGA_ERROR";

	case MLX5_EVENT_TYPE_FPGA_QP_ERROR:

		return "MLX5_EVENT_TYPE_FPGA_QP_ERROR";

	case MLX5_EVENT_TYPE_GENERAL_EVENT:

		return "MLX5_EVENT_TYPE_GENERAL_EVENT";

	case MLX5_EVENT_TYPE_DEVICE_TRACER:

		return "MLX5_EVENT_TYPE_DEVICE_TRACER";

	default:

		return "Unrecognized event";

	}

}



static enum mlx5_dev_event port_subtype2dev(u8 subtype)

{

	switch (subtype) {

	case MLX5_PORT_CHANGE_SUBTYPE_DOWN:

		return MLX5_DEV_EVENT_PORT_DOWN;

	case MLX5_PORT_CHANGE_SUBTYPE_ACTIVE:

		return MLX5_DEV_EVENT_PORT_UP;

	case MLX5_PORT_CHANGE_SUBTYPE_INITIALIZED:

		return MLX5_DEV_EVENT_PORT_INITIALIZED;

	case MLX5_PORT_CHANGE_SUBTYPE_LID:

		return MLX5_DEV_EVENT_LID_CHANGE;

	case MLX5_PORT_CHANGE_SUBTYPE_PKEY:

		return MLX5_DEV_EVENT_PKEY_CHANGE;

	case MLX5_PORT_CHANGE_SUBTYPE_GUID:

		return MLX5_DEV_EVENT_GUID_CHANGE;

	case MLX5_PORT_CHANGE_SUBTYPE_CLIENT_REREG:

		return MLX5_DEV_EVENT_CLIENT_REREG;

	}

	return -1;

}



static void temp_warning_event(struct mlx5_core_dev *dev, struct mlx5_eqe *eqe)

{

	u64 value_lsb;

	u64 value_msb;



	value_lsb = be64_to_cpu(eqe->data.temp_warning.sensor_warning_lsb);

	value_msb = be64_to_cpu(eqe->data.temp_warning.sensor_warning_msb);



	mlx5_core_warn(dev,

		       "High temperature on sensors with bit set %llx %llx",

		       value_msb, value_lsb);

}



static const char *mlx5_pme_status[MLX5_MODULE_STATUS_NUM] = {

	"Cable plugged",   /* MLX5_MODULE_STATUS_PLUGGED    = 0x1 */

	"Cable unplugged", /* MLX5_MODULE_STATUS_UNPLUGGED  = 0x2 */

	"Cable error",     /* MLX5_MODULE_STATUS_ERROR      = 0x3 */

};



static const char *mlx5_pme_error[MLX5_MODULE_EVENT_ERROR_NUM] = {

	"Power budget exceeded",

	"Long Range for non MLNX cable",

	"Bus stuck(I2C or data shorted)",

	"No EEPROM/retry timeout",

	"Enforce part number list",

	"Unknown identifier",

	"High Temperature",

	"Bad or shorted cable/module",

	"Unknown status",

};



static void port_module_event(struct mlx5_events *events, struct mlx5_eqe *eqe)

{

	enum port_module_event_status_type module_status;

	enum port_module_event_error_type error_type;

	struct mlx5_eqe_port_module *module_event_eqe;

	struct mlx5_core_dev *dev = events->dev;

	u8 module_num;



	module_event_eqe = &eqe->data.port_module;

	module_num = module_event_eqe->module;

	module_status = module_event_eqe->module_status &

			PORT_MODULE_EVENT_MODULE_STATUS_MASK;

	error_type = module_event_eqe->error_type &

		     PORT_MODULE_EVENT_ERROR_TYPE_MASK;



	if (module_status < MLX5_MODULE_STATUS_ERROR) {

		events->pme_stats.status_counters[module_status - 1]++;

	} else if (module_status == MLX5_MODULE_STATUS_ERROR) {

		if (error_type >= MLX5_MODULE_EVENT_ERROR_UNKNOWN)

			/* Unknown error type */

			error_type = MLX5_MODULE_EVENT_ERROR_UNKNOWN;

		events->pme_stats.error_counters[error_type]++;

	}



	if (!printk_ratelimit())

		return;



	if (module_status < MLX5_MODULE_STATUS_ERROR)

		mlx5_core_info(dev,

			       "Port module event: module %u, %s\n",

			       module_num, mlx5_pme_status[module_status - 1]);



	else if (module_status == MLX5_MODULE_STATUS_ERROR)

		mlx5_core_info(dev,

			       "Port module event[error]: module %u, %s, %s\n",

			       module_num, mlx5_pme_status[module_status - 1],

			       mlx5_pme_error[error_type]);

}



void mlx5_get_pme_stats(struct mlx5_core_dev *dev, struct mlx5_pme_stats *stats)

{

	*stats = dev->priv.events->pme_stats;

}



/* Event handler for the low level mlx5_core driver.

 * This handler will process/filter _some_ events and sometimes dispatch

 * the equivalent mlx5_dev_event to the HCA interfaces (mlx5_ib and mlx5e)

 *

 * Other Major feature specific events such as

 * clock/eswitch/fpga/FW trace and many others, are handled elsewhere, with

 * separate notifiers callbacks, specifically by those mlx5 components.

 */

static int events_notifier(struct notifier_block *nb,

			   unsigned long type, void *data)

{

	bool dev_event_dispatch = false;

	enum mlx5_dev_event dev_event;

	unsigned long dev_event_data;



	struct mlx5_eqe *eqe = data;

	struct mlx5_events *events;

	struct mlx5_core_dev *dev;

	u8 port;



	events = mlx5_nb_cof(nb, struct mlx5_events, nb);

	dev = events->dev;



	mlx5_core_dbg(dev, "Async eqe type %s, subtype (%d)\n",

		      eqe_type_str(eqe->type), eqe->sub_type);

	switch (eqe->type) {

	case MLX5_EVENT_TYPE_PORT_CHANGE:

		port = (eqe->data.port.port >> 4) & 0xf;

		switch (eqe->sub_type) {

		case MLX5_PORT_CHANGE_SUBTYPE_DOWN:

		case MLX5_PORT_CHANGE_SUBTYPE_ACTIVE:

		case MLX5_PORT_CHANGE_SUBTYPE_LID:

		case MLX5_PORT_CHANGE_SUBTYPE_PKEY:

		case MLX5_PORT_CHANGE_SUBTYPE_GUID:

		case MLX5_PORT_CHANGE_SUBTYPE_CLIENT_REREG:

		case MLX5_PORT_CHANGE_SUBTYPE_INITIALIZED:

			dev_event = port_subtype2dev(eqe->sub_type);

			dev_event_data = (unsigned long)port;

			dev_event_dispatch = true;

			break;

		default:

			mlx5_core_warn(dev, "Port event with unrecognized subtype: port %d, sub_type %d\n",

				       port, eqe->sub_type);

		}

		break;

	case MLX5_EVENT_TYPE_GENERAL_EVENT:

		switch (eqe->sub_type) {

		case MLX5_GENERAL_SUBTYPE_DELAY_DROP_TIMEOUT:

			dev_event = MLX5_DEV_EVENT_DELAY_DROP_TIMEOUT;

			dev_event_data = 0;

			dev_event_dispatch = true;

			break;

		default:

			mlx5_core_dbg(dev, "General event with unrecognized subtype: sub_type %d\n",

				      eqe->sub_type);

		}

		break;



	case MLX5_EVENT_TYPE_PORT_MODULE_EVENT:

		port_module_event(events, eqe);

		break;

	case MLX5_EVENT_TYPE_TEMP_WARN_EVENT:

		temp_warning_event(dev, eqe);

		break;

	default:

		return NOTIFY_DONE;

	}



	if (dev->event && dev_event_dispatch)

		dev->event(dev, dev_event, dev_event_data);



	return NOTIFY_OK;

}



int mlx5_events_init(struct mlx5_core_dev *dev)

{

	struct mlx5_events *events = kzalloc(sizeof(*events), GFP_KERNEL);



	if (!events)

		return -ENOMEM;



	events->dev = dev;

	dev->priv.events = events;

	return 0;

}



void mlx5_events_cleanup(struct mlx5_core_dev *dev)

{

	kvfree(dev->priv.events);

}



void mlx5_events_start(struct mlx5_core_dev *dev)

{

	struct mlx5_events *events = dev->priv.events;



	MLX5_NB_INIT(&events->nb, events_notifier, NOTIFY_ANY);

	mlx5_eq_notifier_register(dev, &events->nb);

}



void mlx5_events_stop(struct mlx5_core_dev *dev)

{

	struct mlx5_events *events = dev->priv.events;



	mlx5_eq_notifier_unregister(dev, &events->nb);

}

drivers/net/ethernet/mellanox/mlx5/core/lib/mlx5.h

+34 −0
Original line number Diff line number Diff line
@@ -33,6 +33,8 @@ 
#ifndef __LIB_MLX5_H__

#define __LIB_MLX5_H__



#include "mlx5_core.h"



void mlx5_init_reserved_gids(struct mlx5_core_dev *dev);

void mlx5_cleanup_reserved_gids(struct mlx5_core_dev *dev);

int  mlx5_core_reserve_gids(struct mlx5_core_dev *dev, unsigned int count);
@@ -40,4 +42,36 @@ void mlx5_core_unreserve_gids(struct mlx5_core_dev *dev, unsigned int count); 
int  mlx5_core_reserved_gid_alloc(struct mlx5_core_dev *dev, int *gid_index);

void mlx5_core_reserved_gid_free(struct mlx5_core_dev *dev, int gid_index);



/* TODO move to lib/events.h */



#define PORT_MODULE_EVENT_MODULE_STATUS_MASK 0xF

#define PORT_MODULE_EVENT_ERROR_TYPE_MASK    0xF



enum port_module_event_status_type {

	MLX5_MODULE_STATUS_PLUGGED   = 0x1,

	MLX5_MODULE_STATUS_UNPLUGGED = 0x2,

	MLX5_MODULE_STATUS_ERROR     = 0x3,

	MLX5_MODULE_STATUS_NUM       = 0x3,

};



enum  port_module_event_error_type {

	MLX5_MODULE_EVENT_ERROR_POWER_BUDGET_EXCEEDED,

	MLX5_MODULE_EVENT_ERROR_LONG_RANGE_FOR_NON_MLNX_CABLE_MODULE,

	MLX5_MODULE_EVENT_ERROR_BUS_STUCK,

	MLX5_MODULE_EVENT_ERROR_NO_EEPROM_RETRY_TIMEOUT,

	MLX5_MODULE_EVENT_ERROR_ENFORCE_PART_NUMBER_LIST,

	MLX5_MODULE_EVENT_ERROR_UNKNOWN_IDENTIFIER,

	MLX5_MODULE_EVENT_ERROR_HIGH_TEMPERATURE,

	MLX5_MODULE_EVENT_ERROR_BAD_CABLE,

	MLX5_MODULE_EVENT_ERROR_UNKNOWN,

	MLX5_MODULE_EVENT_ERROR_NUM,

};



struct mlx5_pme_stats {

	u64 status_counters[MLX5_MODULE_STATUS_NUM];

	u64 error_counters[MLX5_MODULE_EVENT_ERROR_NUM];

};



void mlx5_get_pme_stats(struct mlx5_core_dev *dev, struct mlx5_pme_stats *stats);



#endif