Commit 90f1e10d authored by Dan Williams's avatar Dan Williams Committed by James Bottomley

[SCSI] libsas: fix/amend device gone notification in sas_deform_port()

Commit 56dd2c06 "libsas: Don't issue commands to devices that have been
hot-removed" edited Darrick's original patch to remove setting 'gone' in
the sas_deform_port() path because that prevented scsi sync cache
commands from being issued when the driver was unloaded.  However, this
allows true device gone notifications (as signaled port phy events) to
trigger sync cache commands to devices that are known to be unreachable.

Teach libsas which sas_deform_port() invocations are likely device gone
events.
Signed-off-by: default avatarDan Williams <dan.j.williams@intel.com>
Signed-off-by: default avatarJames Bottomley <jbottomley@parallels.com>
parent c95286d8
...@@ -57,7 +57,7 @@ int sas_init_queue(struct sas_ha_struct *sas_ha); ...@@ -57,7 +57,7 @@ int sas_init_queue(struct sas_ha_struct *sas_ha);
int sas_init_events(struct sas_ha_struct *sas_ha); int sas_init_events(struct sas_ha_struct *sas_ha);
void sas_shutdown_queue(struct sas_ha_struct *sas_ha); void sas_shutdown_queue(struct sas_ha_struct *sas_ha);
void sas_deform_port(struct asd_sas_phy *phy); void sas_deform_port(struct asd_sas_phy *phy, int gone);
void sas_porte_bytes_dmaed(struct work_struct *work); void sas_porte_bytes_dmaed(struct work_struct *work);
void sas_porte_broadcast_rcvd(struct work_struct *work); void sas_porte_broadcast_rcvd(struct work_struct *work);
......
...@@ -39,7 +39,7 @@ static void sas_phye_loss_of_signal(struct work_struct *work) ...@@ -39,7 +39,7 @@ static void sas_phye_loss_of_signal(struct work_struct *work)
sas_begin_event(PHYE_LOSS_OF_SIGNAL, &phy->ha->event_lock, sas_begin_event(PHYE_LOSS_OF_SIGNAL, &phy->ha->event_lock,
&phy->phy_events_pending); &phy->phy_events_pending);
phy->error = 0; phy->error = 0;
sas_deform_port(phy); sas_deform_port(phy, 1);
} }
static void sas_phye_oob_done(struct work_struct *work) static void sas_phye_oob_done(struct work_struct *work)
...@@ -66,7 +66,7 @@ static void sas_phye_oob_error(struct work_struct *work) ...@@ -66,7 +66,7 @@ static void sas_phye_oob_error(struct work_struct *work)
sas_begin_event(PHYE_OOB_ERROR, &phy->ha->event_lock, sas_begin_event(PHYE_OOB_ERROR, &phy->ha->event_lock,
&phy->phy_events_pending); &phy->phy_events_pending);
sas_deform_port(phy); sas_deform_port(phy, 1);
if (!port && phy->enabled && i->dft->lldd_control_phy) { if (!port && phy->enabled && i->dft->lldd_control_phy) {
phy->error++; phy->error++;
......
...@@ -57,7 +57,7 @@ static void sas_form_port(struct asd_sas_phy *phy) ...@@ -57,7 +57,7 @@ static void sas_form_port(struct asd_sas_phy *phy)
if (port) { if (port) {
if (!phy_is_wideport_member(port, phy)) if (!phy_is_wideport_member(port, phy))
sas_deform_port(phy); sas_deform_port(phy, 0);
else { else {
SAS_DPRINTK("%s: phy%d belongs to port%d already(%d)!\n", SAS_DPRINTK("%s: phy%d belongs to port%d already(%d)!\n",
__func__, phy->id, phy->port->id, __func__, phy->id, phy->port->id,
...@@ -153,28 +153,31 @@ static void sas_form_port(struct asd_sas_phy *phy) ...@@ -153,28 +153,31 @@ static void sas_form_port(struct asd_sas_phy *phy)
* This is called when the physical link to the other phy has been * This is called when the physical link to the other phy has been
* lost (on this phy), in Event thread context. We cannot delay here. * lost (on this phy), in Event thread context. We cannot delay here.
*/ */
void sas_deform_port(struct asd_sas_phy *phy) void sas_deform_port(struct asd_sas_phy *phy, int gone)
{ {
struct sas_ha_struct *sas_ha = phy->ha; struct sas_ha_struct *sas_ha = phy->ha;
struct asd_sas_port *port = phy->port; struct asd_sas_port *port = phy->port;
struct sas_internal *si = struct sas_internal *si =
to_sas_internal(sas_ha->core.shost->transportt); to_sas_internal(sas_ha->core.shost->transportt);
struct domain_device *dev;
unsigned long flags; unsigned long flags;
if (!port) if (!port)
return; /* done by a phy event */ return; /* done by a phy event */
if (port->port_dev) dev = port->port_dev;
port->port_dev->pathways--; if (dev)
dev->pathways--;
if (port->num_phys == 1) { if (port->num_phys == 1) {
if (dev && gone)
dev->gone = 1;
sas_unregister_domain_devices(port); sas_unregister_domain_devices(port);
sas_port_delete(port->port); sas_port_delete(port->port);
port->port = NULL; port->port = NULL;
} else } else
sas_port_delete_phy(port->port, phy->phy); sas_port_delete_phy(port->port, phy->phy);
if (si->dft->lldd_port_deformed) if (si->dft->lldd_port_deformed)
si->dft->lldd_port_deformed(phy); si->dft->lldd_port_deformed(phy);
...@@ -244,7 +247,7 @@ void sas_porte_link_reset_err(struct work_struct *work) ...@@ -244,7 +247,7 @@ void sas_porte_link_reset_err(struct work_struct *work)
sas_begin_event(PORTE_LINK_RESET_ERR, &phy->ha->event_lock, sas_begin_event(PORTE_LINK_RESET_ERR, &phy->ha->event_lock,
&phy->port_events_pending); &phy->port_events_pending);
sas_deform_port(phy); sas_deform_port(phy, 1);
} }
void sas_porte_timer_event(struct work_struct *work) void sas_porte_timer_event(struct work_struct *work)
...@@ -256,7 +259,7 @@ void sas_porte_timer_event(struct work_struct *work) ...@@ -256,7 +259,7 @@ void sas_porte_timer_event(struct work_struct *work)
sas_begin_event(PORTE_TIMER_EVENT, &phy->ha->event_lock, sas_begin_event(PORTE_TIMER_EVENT, &phy->ha->event_lock,
&phy->port_events_pending); &phy->port_events_pending);
sas_deform_port(phy); sas_deform_port(phy, 1);
} }
void sas_porte_hard_reset(struct work_struct *work) void sas_porte_hard_reset(struct work_struct *work)
...@@ -268,7 +271,7 @@ void sas_porte_hard_reset(struct work_struct *work) ...@@ -268,7 +271,7 @@ void sas_porte_hard_reset(struct work_struct *work)
sas_begin_event(PORTE_HARD_RESET, &phy->ha->event_lock, sas_begin_event(PORTE_HARD_RESET, &phy->ha->event_lock,
&phy->port_events_pending); &phy->port_events_pending);
sas_deform_port(phy); sas_deform_port(phy, 1);
} }
/* ---------- SAS port registration ---------- */ /* ---------- SAS port registration ---------- */
...@@ -306,6 +309,6 @@ void sas_unregister_ports(struct sas_ha_struct *sas_ha) ...@@ -306,6 +309,6 @@ void sas_unregister_ports(struct sas_ha_struct *sas_ha)
for (i = 0; i < sas_ha->num_phys; i++) for (i = 0; i < sas_ha->num_phys; i++)
if (sas_ha->sas_phy[i]->port) if (sas_ha->sas_phy[i]->port)
sas_deform_port(sas_ha->sas_phy[i]); sas_deform_port(sas_ha->sas_phy[i], 0);
} }
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