Commit e2f0cdf7 authored by Sreekanth Reddy's avatar Sreekanth Reddy Committed by Martin K. Petersen

scsi: mpt3sas: Update hba_port's sas_address & phy_mask

Update hba_port's sas_address & phy_mask fields whenever a direct expander
or sas/sata target devices are added or removed.

When any direct attached device is discovered then driver:

 - Gets the hba_port object corresponding to device's PhysicalPort
   number;

 - Updates the hba_port's sas_address field with device's SAS
   Address;

 - Updates the hba_port's phy_mask filed with device's narrow/wide
   port Phy number bits;

 - If a sas/sata end device (not only direct-attached devices) is added
   then corresponding sas_device object's port variable is assigned with
   hba_port object's address whose port_id matches the device's
   PhysicalPort number.

 - If an expander device is added then corresponding sas_expander object's
   port variable is assigned with hba_port object's address whose port_id
   matches the expander device's PhysicalPort number.

When any direct attached device is detached then driver will delete the
hba_port object corresponding to device's PhysicalPort number.

Whenever any HBA phy's link (of direct attached device's port) comes up
then update the phy_mask field of corresponding hba_port object.

Link: https://lore.kernel.org/r/20201027130847.9962-5-sreekanth.reddy@broadcom.comSigned-off-by: default avatarSreekanth Reddy <sreekanth.reddy@broadcom.com>
Signed-off-by: default avatarMartin K. Petersen <martin.petersen@oracle.com>
parent 78ca7003
...@@ -1792,16 +1792,17 @@ extern struct scsi_transport_template *mpt3sas_transport_template; ...@@ -1792,16 +1792,17 @@ extern struct scsi_transport_template *mpt3sas_transport_template;
u8 mpt3sas_transport_done(struct MPT3SAS_ADAPTER *ioc, u16 smid, u8 msix_index, u8 mpt3sas_transport_done(struct MPT3SAS_ADAPTER *ioc, u16 smid, u8 msix_index,
u32 reply); u32 reply);
struct _sas_port *mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, struct _sas_port *mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc,
u16 handle, u64 sas_address); u16 handle, u64 sas_address, struct hba_port *port);
void mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address, void mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address,
u64 sas_address_parent); u64 sas_address_parent, struct hba_port *port);
int mpt3sas_transport_add_host_phy(struct MPT3SAS_ADAPTER *ioc, struct _sas_phy int mpt3sas_transport_add_host_phy(struct MPT3SAS_ADAPTER *ioc, struct _sas_phy
*mpt3sas_phy, Mpi2SasPhyPage0_t phy_pg0, struct device *parent_dev); *mpt3sas_phy, Mpi2SasPhyPage0_t phy_pg0, struct device *parent_dev);
int mpt3sas_transport_add_expander_phy(struct MPT3SAS_ADAPTER *ioc, int mpt3sas_transport_add_expander_phy(struct MPT3SAS_ADAPTER *ioc,
struct _sas_phy *mpt3sas_phy, Mpi2ExpanderPage1_t expander_pg1, struct _sas_phy *mpt3sas_phy, Mpi2ExpanderPage1_t expander_pg1,
struct device *parent_dev); struct device *parent_dev);
void mpt3sas_transport_update_links(struct MPT3SAS_ADAPTER *ioc, void mpt3sas_transport_update_links(struct MPT3SAS_ADAPTER *ioc,
u64 sas_address, u16 handle, u8 phy_number, u8 link_rate); u64 sas_address, u16 handle, u8 phy_number, u8 link_rate,
struct hba_port *port);
extern struct sas_function_template mpt3sas_transport_functions; extern struct sas_function_template mpt3sas_transport_functions;
extern struct scsi_transport_template *mpt3sas_transport_template; extern struct scsi_transport_template *mpt3sas_transport_template;
/* trigger data externs */ /* trigger data externs */
......
This diff is collapsed.
...@@ -594,6 +594,7 @@ _transport_sanity_check(struct MPT3SAS_ADAPTER *ioc, struct _sas_node *sas_node, ...@@ -594,6 +594,7 @@ _transport_sanity_check(struct MPT3SAS_ADAPTER *ioc, struct _sas_node *sas_node,
* @ioc: per adapter object * @ioc: per adapter object
* @handle: handle of attached device * @handle: handle of attached device
* @sas_address: sas address of parent expander or sas host * @sas_address: sas address of parent expander or sas host
* @port: hba port entry
* Context: This function will acquire ioc->sas_node_lock. * Context: This function will acquire ioc->sas_node_lock.
* *
* Adding new port object to the sas_node->sas_port_list. * Adding new port object to the sas_node->sas_port_list.
...@@ -602,7 +603,7 @@ _transport_sanity_check(struct MPT3SAS_ADAPTER *ioc, struct _sas_node *sas_node, ...@@ -602,7 +603,7 @@ _transport_sanity_check(struct MPT3SAS_ADAPTER *ioc, struct _sas_node *sas_node,
*/ */
struct _sas_port * struct _sas_port *
mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
u64 sas_address) u64 sas_address, struct hba_port *hba_port)
{ {
struct _sas_phy *mpt3sas_phy, *next; struct _sas_phy *mpt3sas_phy, *next;
struct _sas_port *mpt3sas_port; struct _sas_port *mpt3sas_port;
...@@ -613,6 +614,12 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, ...@@ -613,6 +614,12 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
int i; int i;
struct sas_port *port; struct sas_port *port;
if (!hba_port) {
ioc_err(ioc, "failure at %s:%d/%s()!\n",
__FILE__, __LINE__, __func__);
return NULL;
}
mpt3sas_port = kzalloc(sizeof(struct _sas_port), mpt3sas_port = kzalloc(sizeof(struct _sas_port),
GFP_KERNEL); GFP_KERNEL);
if (!mpt3sas_port) { if (!mpt3sas_port) {
...@@ -646,6 +653,7 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, ...@@ -646,6 +653,7 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
goto out_fail; goto out_fail;
} }
mpt3sas_port->hba_port = hba_port;
_transport_sanity_check(ioc, sas_node, _transport_sanity_check(ioc, sas_node,
mpt3sas_port->remote_identify.sas_address); mpt3sas_port->remote_identify.sas_address);
...@@ -653,8 +661,12 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, ...@@ -653,8 +661,12 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
if (sas_node->phy[i].remote_identify.sas_address != if (sas_node->phy[i].remote_identify.sas_address !=
mpt3sas_port->remote_identify.sas_address) mpt3sas_port->remote_identify.sas_address)
continue; continue;
if (sas_node->phy[i].port != hba_port)
continue;
list_add_tail(&sas_node->phy[i].port_siblings, list_add_tail(&sas_node->phy[i].port_siblings,
&mpt3sas_port->phy_list); &mpt3sas_port->phy_list);
if (sas_node->handle <= ioc->sas_hba.num_phys)
hba_port->phy_mask |= (1 << i);
mpt3sas_port->num_phys++; mpt3sas_port->num_phys++;
} }
...@@ -686,14 +698,21 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, ...@@ -686,14 +698,21 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
mpt3sas_phy->phy_id); mpt3sas_phy->phy_id);
sas_port_add_phy(port, mpt3sas_phy->phy); sas_port_add_phy(port, mpt3sas_phy->phy);
mpt3sas_phy->phy_belongs_to_port = 1; mpt3sas_phy->phy_belongs_to_port = 1;
mpt3sas_phy->port = hba_port;
} }
mpt3sas_port->port = port; mpt3sas_port->port = port;
if (mpt3sas_port->remote_identify.device_type == SAS_END_DEVICE) if (mpt3sas_port->remote_identify.device_type == SAS_END_DEVICE) {
rphy = sas_end_device_alloc(port); rphy = sas_end_device_alloc(port);
else if (sas_node->handle <= ioc->sas_hba.num_phys)
hba_port->sas_address = sas_device->sas_address;
} else {
rphy = sas_expander_alloc(port, rphy = sas_expander_alloc(port,
mpt3sas_port->remote_identify.device_type); mpt3sas_port->remote_identify.device_type);
if (sas_node->handle <= ioc->sas_hba.num_phys)
hba_port->sas_address =
mpt3sas_port->remote_identify.sas_address;
}
rphy->identify = mpt3sas_port->remote_identify; rphy->identify = mpt3sas_port->remote_identify;
...@@ -751,6 +770,7 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, ...@@ -751,6 +770,7 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
* @ioc: per adapter object * @ioc: per adapter object
* @sas_address: sas address of attached device * @sas_address: sas address of attached device
* @sas_address_parent: sas address of parent expander or sas host * @sas_address_parent: sas address of parent expander or sas host
* @port: hba port entry
* Context: This function will acquire ioc->sas_node_lock. * Context: This function will acquire ioc->sas_node_lock.
* *
* Removing object and freeing associated memory from the * Removing object and freeing associated memory from the
...@@ -758,7 +778,7 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle, ...@@ -758,7 +778,7 @@ mpt3sas_transport_port_add(struct MPT3SAS_ADAPTER *ioc, u16 handle,
*/ */
void void
mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address, mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address,
u64 sas_address_parent) u64 sas_address_parent, struct hba_port *port)
{ {
int i; int i;
unsigned long flags; unsigned long flags;
...@@ -766,6 +786,10 @@ mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address, ...@@ -766,6 +786,10 @@ mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address,
struct _sas_node *sas_node; struct _sas_node *sas_node;
u8 found = 0; u8 found = 0;
struct _sas_phy *mpt3sas_phy, *next_phy; struct _sas_phy *mpt3sas_phy, *next_phy;
struct hba_port *hba_port_next, *hba_port = NULL;
if (!port)
return;
spin_lock_irqsave(&ioc->sas_node_lock, flags); spin_lock_irqsave(&ioc->sas_node_lock, flags);
sas_node = _transport_sas_node_find_by_sas_address(ioc, sas_node = _transport_sas_node_find_by_sas_address(ioc,
...@@ -778,6 +802,8 @@ mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address, ...@@ -778,6 +802,8 @@ mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address,
port_list) { port_list) {
if (mpt3sas_port->remote_identify.sas_address != sas_address) if (mpt3sas_port->remote_identify.sas_address != sas_address)
continue; continue;
if (mpt3sas_port->hba_port != port)
continue;
found = 1; found = 1;
list_del(&mpt3sas_port->port_list); list_del(&mpt3sas_port->port_list);
goto out; goto out;
...@@ -788,6 +814,21 @@ mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address, ...@@ -788,6 +814,21 @@ mpt3sas_transport_port_remove(struct MPT3SAS_ADAPTER *ioc, u64 sas_address,
return; return;
} }
if (sas_node->handle <= ioc->sas_hba.num_phys) {
list_for_each_entry_safe(hba_port, hba_port_next,
&ioc->port_table_list, list) {
if (hba_port != port)
continue;
if (hba_port->sas_address != sas_address)
continue;
ioc_info(ioc,
"remove hba_port entry: %p port: %d from hba_port list\n",
hba_port, hba_port->port_id);
list_del(&hba_port->list);
kfree(hba_port);
}
}
for (i = 0; i < sas_node->num_phys; i++) { for (i = 0; i < sas_node->num_phys; i++) {
if (sas_node->phy[i].remote_identify.sas_address == sas_address) if (sas_node->phy[i].remote_identify.sas_address == sas_address)
memset(&sas_node->phy[i].remote_identify, 0 , memset(&sas_node->phy[i].remote_identify, 0 ,
...@@ -961,14 +1002,19 @@ mpt3sas_transport_add_expander_phy(struct MPT3SAS_ADAPTER *ioc, struct _sas_phy ...@@ -961,14 +1002,19 @@ mpt3sas_transport_add_expander_phy(struct MPT3SAS_ADAPTER *ioc, struct _sas_phy
* @handle: attached device handle * @handle: attached device handle
* @phy_number: phy number * @phy_number: phy number
* @link_rate: new link rate * @link_rate: new link rate
* @port: hba port entry
*
* Return nothing.
*/ */
void void
mpt3sas_transport_update_links(struct MPT3SAS_ADAPTER *ioc, mpt3sas_transport_update_links(struct MPT3SAS_ADAPTER *ioc,
u64 sas_address, u16 handle, u8 phy_number, u8 link_rate) u64 sas_address, u16 handle, u8 phy_number, u8 link_rate,
struct hba_port *port)
{ {
unsigned long flags; unsigned long flags;
struct _sas_node *sas_node; struct _sas_node *sas_node;
struct _sas_phy *mpt3sas_phy; struct _sas_phy *mpt3sas_phy;
struct hba_port *hba_port = NULL;
if (ioc->shost_recovery || ioc->pci_error_recovery) if (ioc->shost_recovery || ioc->pci_error_recovery)
return; return;
...@@ -988,6 +1034,15 @@ mpt3sas_transport_update_links(struct MPT3SAS_ADAPTER *ioc, ...@@ -988,6 +1034,15 @@ mpt3sas_transport_update_links(struct MPT3SAS_ADAPTER *ioc,
&mpt3sas_phy->remote_identify); &mpt3sas_phy->remote_identify);
_transport_add_phy_to_an_existing_port(ioc, sas_node, _transport_add_phy_to_an_existing_port(ioc, sas_node,
mpt3sas_phy, mpt3sas_phy->remote_identify.sas_address); mpt3sas_phy, mpt3sas_phy->remote_identify.sas_address);
if (sas_node->handle <= ioc->sas_hba.num_phys) {
list_for_each_entry(hba_port,
&ioc->port_table_list, list) {
if (hba_port->sas_address == sas_address &&
hba_port == port)
hba_port->phy_mask |=
(1 << mpt3sas_phy->phy_id);
}
}
} else } else
memset(&mpt3sas_phy->remote_identify, 0 , sizeof(struct memset(&mpt3sas_phy->remote_identify, 0 , sizeof(struct
sas_identify)); sas_identify));
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment