public inbox for linux-scsi@vger.kernel.org
 help / color / mirror / Atom feed
* [patch 0/1] Move helper code from FC drivers to FC transport
@ 2009-10-30 16:59 Christof Schmitt
  2009-10-30 16:59 ` [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh Christof Schmitt
  0 siblings, 1 reply; 4+ messages in thread
From: Christof Schmitt @ 2009-10-30 16:59 UTC (permalink / raw)
  To: James Bottomley; +Cc: linux-scsi

This patch moves duplicated code from three FC drivers to the SCSI FC
transport class. I am working on a follow-on patch for zfcp to apply
the same strategy of holding off SCSI recovery while the remote ports
are blocked. 

The patch applies cleanly to the current scsi-misc tree. I could only
make sure that it compiles on x86, but the code move is fairly
trivial.

--
Christof Schmitt

^ permalink raw reply	[flat|nested] 4+ messages in thread

* [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh
  2009-10-30 16:59 [patch 0/1] Move helper code from FC drivers to FC transport Christof Schmitt
@ 2009-10-30 16:59 ` Christof Schmitt
  2009-11-02 20:11   ` Giridhar Malavali
  2009-11-03 19:38   ` Abhijeet Joglekar (abjoglek)
  0 siblings, 2 replies; 4+ messages in thread
From: Christof Schmitt @ 2009-10-30 16:59 UTC (permalink / raw)
  To: James Bottomley
  Cc: linux-scsi, James Smart, Abhijeet Joglekar, Joe Eykholt,
	Andrew Vasquez, Christof Schmitt

[-- Attachment #1: combine.diff --]
[-- Type: text/plain, Size: 7910 bytes --]

From: Christof Schmitt <christof.schmitt@de.ibm.com>

Move the duplicated code from FC LLDs to SCSI FC transport class.

Acked-by: James Smart <james.smart@emulex.com>
Cc: Abhijeet Joglekar <abjoglek@cisco.com>
Cc: Joe Eykholt <jeykholt@cisco.com>
Cc: Andrew Vasquez <andrew.vasquez@qlogic.com>
Signed-off-by: Christof Schmitt <christof.schmitt@de.ibm.com>
---
 drivers/scsi/fnic/fnic_scsi.c    |   20 ++------------------
 drivers/scsi/lpfc/lpfc_scsi.c    |   30 ++++--------------------------
 drivers/scsi/qla2xxx/qla_os.c    |   25 ++++---------------------
 drivers/scsi/scsi_transport_fc.c |   26 ++++++++++++++++++++++++++
 include/scsi/scsi_transport_fc.h |    1 +
 5 files changed, 37 insertions(+), 65 deletions(-)

--- a/drivers/scsi/scsi_transport_fc.c	2009-10-30 17:47:23.000000000 +0100
+++ b/drivers/scsi/scsi_transport_fc.c	2009-10-30 17:48:50.000000000 +0100
@@ -27,6 +27,7 @@
  */
 #include <linux/module.h>
 #include <linux/init.h>
+#include <linux/delay.h>
 #include <scsi/scsi_device.h>
 #include <scsi/scsi_host.h>
 #include <scsi/scsi_transport.h>
@@ -3144,6 +3145,31 @@ fc_scsi_scan_rport(struct work_struct *w
 	spin_unlock_irqrestore(shost->host_lock, flags);
 }
 
+/**
+ * fc_block_scsi_eh - Block SCSI eh thread for blocked fc_rport
+ * @cmnd: SCSI command that scsi_eh is trying to recover
+ *
+ * This routine can be called from a FC LLD scsi_eh callback. It
+ * blocks the scsi_eh thread until the fc_rport leaves the
+ * FC_PORTSTATE_BLOCKED. This is necessary to avoid the scsi_eh
+ * failing recovery actions for blocked rports which would lead to
+ * offlined SCSI devices.
+ */
+void fc_block_scsi_eh(struct scsi_cmnd *cmnd)
+{
+	struct Scsi_Host *shost = cmnd->device->host;
+	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd->device));
+	unsigned long flags;
+
+	spin_lock_irqsave(shost->host_lock, flags);
+	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
+		spin_unlock_irqrestore(shost->host_lock, flags);
+		msleep(1000);
+		spin_lock_irqsave(shost->host_lock, flags);
+	}
+	spin_unlock_irqrestore(shost->host_lock, flags);
+}
+EXPORT_SYMBOL(fc_block_scsi_eh);
 
 /**
  * fc_vport_setup - allocates and creates a FC virtual port.
--- a/include/scsi/scsi_transport_fc.h	2009-10-30 17:47:25.000000000 +0100
+++ b/include/scsi/scsi_transport_fc.h	2009-10-30 17:48:50.000000000 +0100
@@ -807,5 +807,6 @@ void fc_host_post_vendor_event(struct Sc
 struct fc_vport *fc_vport_create(struct Scsi_Host *shost, int channel,
 		struct fc_vport_identifiers *);
 int fc_vport_terminate(struct fc_vport *vport);
+void fc_block_scsi_eh(struct scsi_cmnd *cmnd);
 
 #endif /* SCSI_TRANSPORT_FC_H */
--- a/drivers/scsi/fnic/fnic_scsi.c	2009-10-30 17:47:23.000000000 +0100
+++ b/drivers/scsi/fnic/fnic_scsi.c	2009-10-30 17:48:50.000000000 +0100
@@ -1225,22 +1225,6 @@ void fnic_terminate_rport_io(struct fc_r
 
 }
 
-static void fnic_block_error_handler(struct scsi_cmnd *sc)
-{
-	struct Scsi_Host *shost = sc->device->host;
-	struct fc_rport *rport = starget_to_rport(scsi_target(sc->device));
-	unsigned long flags;
-
-	spin_lock_irqsave(shost->host_lock, flags);
-	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
-		spin_unlock_irqrestore(shost->host_lock, flags);
-		msleep(1000);
-		spin_lock_irqsave(shost->host_lock, flags);
-	}
-	spin_unlock_irqrestore(shost->host_lock, flags);
-
-}
-
 /*
  * This function is exported to SCSI for sending abort cmnds.
  * A SCSI IO is represented by a io_req in the driver.
@@ -1260,7 +1244,7 @@ int fnic_abort_cmd(struct scsi_cmnd *sc)
 	DECLARE_COMPLETION_ONSTACK(tm_done);
 
 	/* Wait for rport to unblock */
-	fnic_block_error_handler(sc);
+	fc_block_scsi_eh(sc);
 
 	/* Get local-port, check ready and link up */
 	lp = shost_priv(sc->device->host);
@@ -1542,7 +1526,7 @@ int fnic_device_reset(struct scsi_cmnd *
 	DECLARE_COMPLETION_ONSTACK(tm_done);
 
 	/* Wait for rport to unblock */
-	fnic_block_error_handler(sc);
+	fc_block_scsi_eh(sc);
 
 	/* Get local-port, check ready and link up */
 	lp = shost_priv(sc->device->host);
--- a/drivers/scsi/lpfc/lpfc_scsi.c	2009-10-30 17:47:23.000000000 +0100
+++ b/drivers/scsi/lpfc/lpfc_scsi.c	2009-10-30 17:48:50.000000000 +0100
@@ -2917,28 +2917,6 @@ lpfc_queuecommand(struct scsi_cmnd *cmnd
 }
 
 /**
- * lpfc_block_error_handler - Routine to block error  handler
- * @cmnd: Pointer to scsi_cmnd data structure.
- *
- *  This routine blocks execution till fc_rport state is not FC_PORSTAT_BLCOEKD.
- **/
-static void
-lpfc_block_error_handler(struct scsi_cmnd *cmnd)
-{
-	struct Scsi_Host *shost = cmnd->device->host;
-	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd->device));
-
-	spin_lock_irq(shost->host_lock);
-	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
-		spin_unlock_irq(shost->host_lock);
-		msleep(1000);
-		spin_lock_irq(shost->host_lock);
-	}
-	spin_unlock_irq(shost->host_lock);
-	return;
-}
-
-/**
  * lpfc_abort_handler - scsi_host_template eh_abort_handler entry point
  * @cmnd: Pointer to scsi_cmnd data structure.
  *
@@ -2961,7 +2939,7 @@ lpfc_abort_handler(struct scsi_cmnd *cmn
 	int ret = SUCCESS;
 	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(waitq);
 
-	lpfc_block_error_handler(cmnd);
+	fc_block_scsi_eh(cmnd);
 	lpfc_cmd = (struct lpfc_scsi_buf *)cmnd->host_scribble;
 	BUG_ON(!lpfc_cmd);
 
@@ -3259,7 +3237,7 @@ lpfc_device_reset_handler(struct scsi_cm
 	struct lpfc_scsi_event_header scsi_event;
 	int status;
 
-	lpfc_block_error_handler(cmnd);
+	fc_block_scsi_eh(cmnd);
 
 	status = lpfc_chk_tgt_mapped(vport, cmnd);
 	if (status == FAILED) {
@@ -3318,7 +3296,7 @@ lpfc_target_reset_handler(struct scsi_cm
 	struct lpfc_scsi_event_header scsi_event;
 	int status;
 
-	lpfc_block_error_handler(cmnd);
+	fc_block_scsi_eh(cmnd);
 
 	status = lpfc_chk_tgt_mapped(vport, cmnd);
 	if (status == FAILED) {
@@ -3384,7 +3362,7 @@ lpfc_bus_reset_handler(struct scsi_cmnd 
 	fc_host_post_vendor_event(shost, fc_get_event_number(),
 		sizeof(scsi_event), (char *)&scsi_event, LPFC_NL_VENDOR_ID);
 
-	lpfc_block_error_handler(cmnd);
+	fc_block_scsi_eh(cmnd);
 
 	/*
 	 * Since the driver manages a single bus device, reset all
--- a/drivers/scsi/qla2xxx/qla_os.c	2009-10-30 17:47:23.000000000 +0100
+++ b/drivers/scsi/qla2xxx/qla_os.c	2009-10-30 17:48:50.000000000 +0100
@@ -728,23 +728,6 @@ qla2x00_abort_fcport_cmds(fc_port_t *fcp
 	spin_unlock_irqrestore(&ha->hardware_lock, flags);
 }
 
-static void
-qla2x00_block_error_handler(struct scsi_cmnd *cmnd)
-{
-	struct Scsi_Host *shost = cmnd->device->host;
-	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd->device));
-	unsigned long flags;
-
-	spin_lock_irqsave(shost->host_lock, flags);
-	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
-		spin_unlock_irqrestore(shost->host_lock, flags);
-		msleep(1000);
-		spin_lock_irqsave(shost->host_lock, flags);
-	}
-	spin_unlock_irqrestore(shost->host_lock, flags);
-	return;
-}
-
 /**************************************************************************
 * qla2xxx_eh_abort
 *
@@ -774,7 +757,7 @@ qla2xxx_eh_abort(struct scsi_cmnd *cmd)
 	struct req_que *req = vha->req;
 	srb_t *spt;
 
-	qla2x00_block_error_handler(cmd);
+	fc_block_scsi_eh(cmd);
 
 	if (!CMD_SP(cmd))
 		return SUCCESS;
@@ -905,7 +888,7 @@ __qla2xxx_eh_generic_reset(char *name, e
 	fc_port_t *fcport = (struct fc_port *) cmd->device->hostdata;
 	int err;
 
-	qla2x00_block_error_handler(cmd);
+	fc_block_scsi_eh(cmd);
 
 	if (!fcport)
 		return FAILED;
@@ -985,7 +968,7 @@ qla2xxx_eh_bus_reset(struct scsi_cmnd *c
 	unsigned long serial;
 	srb_t *sp = (srb_t *) CMD_SP(cmd);
 
-	qla2x00_block_error_handler(cmd);
+	fc_block_scsi_eh(cmd);
 
 	id = cmd->device->id;
 	lun = cmd->device->lun;
@@ -1048,7 +1031,7 @@ qla2xxx_eh_host_reset(struct scsi_cmnd *
 	srb_t *sp = (srb_t *) CMD_SP(cmd);
 	scsi_qla_host_t *base_vha = pci_get_drvdata(ha->pdev);
 
-	qla2x00_block_error_handler(cmd);
+	fc_block_scsi_eh(cmd);
 
 	id = cmd->device->id;
 	lun = cmd->device->lun;


^ permalink raw reply	[flat|nested] 4+ messages in thread

* Re: [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh
  2009-10-30 16:59 ` [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh Christof Schmitt
@ 2009-11-02 20:11   ` Giridhar Malavali
  2009-11-03 19:38   ` Abhijeet Joglekar (abjoglek)
  1 sibling, 0 replies; 4+ messages in thread
From: Giridhar Malavali @ 2009-11-02 20:11 UTC (permalink / raw)
  To: Christof Schmitt
  Cc: James Bottomley, linux-scsi@vger.kernel.org, James Smart,
	Abhijeet Joglekar, Joe Eykholt, Andrew Vasquez

Thanks Christof.

Acked-by: Giridhar Malavali <giridhar.malavali@qlogic.com>

On Oct 30, 2009, at 9:59 AM, Christof Schmitt wrote:

> From: Christof Schmitt <christof.schmitt@de.ibm.com>
>
> Move the duplicated code from FC LLDs to SCSI FC transport class.
>
> Acked-by: James Smart <james.smart@emulex.com>
> Cc: Abhijeet Joglekar <abjoglek@cisco.com>
> Cc: Joe Eykholt <jeykholt@cisco.com>
> Cc: Andrew Vasquez <andrew.vasquez@qlogic.com>
> Signed-off-by: Christof Schmitt <christof.schmitt@de.ibm.com>
> ---
> drivers/scsi/fnic/fnic_scsi.c    |   20 ++------------------
> drivers/scsi/lpfc/lpfc_scsi.c    |   30 ++++--------------------------
> drivers/scsi/qla2xxx/qla_os.c    |   25 ++++---------------------
> drivers/scsi/scsi_transport_fc.c |   26 ++++++++++++++++++++++++++
> include/scsi/scsi_transport_fc.h |    1 +
> 5 files changed, 37 insertions(+), 65 deletions(-)
>
> --- a/drivers/scsi/scsi_transport_fc.c	2009-10-30 17:47:23.000000000  
> +0100
> +++ b/drivers/scsi/scsi_transport_fc.c	2009-10-30 17:48:50.000000000  
> +0100
> @@ -27,6 +27,7 @@
>  */
> #include <linux/module.h>
> #include <linux/init.h>
> +#include <linux/delay.h>
> #include <scsi/scsi_device.h>
> #include <scsi/scsi_host.h>
> #include <scsi/scsi_transport.h>
> @@ -3144,6 +3145,31 @@ fc_scsi_scan_rport(struct work_struct *w
> 	spin_unlock_irqrestore(shost->host_lock, flags);
> }
>
> +/**
> + * fc_block_scsi_eh - Block SCSI eh thread for blocked fc_rport
> + * @cmnd: SCSI command that scsi_eh is trying to recover
> + *
> + * This routine can be called from a FC LLD scsi_eh callback. It
> + * blocks the scsi_eh thread until the fc_rport leaves the
> + * FC_PORTSTATE_BLOCKED. This is necessary to avoid the scsi_eh
> + * failing recovery actions for blocked rports which would lead to
> + * offlined SCSI devices.
> + */
> +void fc_block_scsi_eh(struct scsi_cmnd *cmnd)
> +{
> +	struct Scsi_Host *shost = cmnd->device->host;
> +	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd- 
> >device));
> +	unsigned long flags;
> +
> +	spin_lock_irqsave(shost->host_lock, flags);
> +	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> +		spin_unlock_irqrestore(shost->host_lock, flags);
> +		msleep(1000);
> +		spin_lock_irqsave(shost->host_lock, flags);
> +	}
> +	spin_unlock_irqrestore(shost->host_lock, flags);
> +}
> +EXPORT_SYMBOL(fc_block_scsi_eh);
>
> /**
>  * fc_vport_setup - allocates and creates a FC virtual port.
> --- a/include/scsi/scsi_transport_fc.h	2009-10-30 17:47:25.000000000  
> +0100
> +++ b/include/scsi/scsi_transport_fc.h	2009-10-30 17:48:50.000000000  
> +0100
> @@ -807,5 +807,6 @@ void fc_host_post_vendor_event(struct Sc
> struct fc_vport *fc_vport_create(struct Scsi_Host *shost, int channel,
> 		struct fc_vport_identifiers *);
> int fc_vport_terminate(struct fc_vport *vport);
> +void fc_block_scsi_eh(struct scsi_cmnd *cmnd);
>
> #endif /* SCSI_TRANSPORT_FC_H */
> --- a/drivers/scsi/fnic/fnic_scsi.c	2009-10-30 17:47:23.000000000  
> +0100
> +++ b/drivers/scsi/fnic/fnic_scsi.c	2009-10-30 17:48:50.000000000  
> +0100
> @@ -1225,22 +1225,6 @@ void fnic_terminate_rport_io(struct fc_r
>
> }
>
> -static void fnic_block_error_handler(struct scsi_cmnd *sc)
> -{
> -	struct Scsi_Host *shost = sc->device->host;
> -	struct fc_rport *rport = starget_to_rport(scsi_target(sc->device));
> -	unsigned long flags;
> -
> -	spin_lock_irqsave(shost->host_lock, flags);
> -	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> -		spin_unlock_irqrestore(shost->host_lock, flags);
> -		msleep(1000);
> -		spin_lock_irqsave(shost->host_lock, flags);
> -	}
> -	spin_unlock_irqrestore(shost->host_lock, flags);
> -
> -}
> -
> /*
>  * This function is exported to SCSI for sending abort cmnds.
>  * A SCSI IO is represented by a io_req in the driver.
> @@ -1260,7 +1244,7 @@ int fnic_abort_cmd(struct scsi_cmnd *sc)
> 	DECLARE_COMPLETION_ONSTACK(tm_done);
>
> 	/* Wait for rport to unblock */
> -	fnic_block_error_handler(sc);
> +	fc_block_scsi_eh(sc);
>
> 	/* Get local-port, check ready and link up */
> 	lp = shost_priv(sc->device->host);
> @@ -1542,7 +1526,7 @@ int fnic_device_reset(struct scsi_cmnd *
> 	DECLARE_COMPLETION_ONSTACK(tm_done);
>
> 	/* Wait for rport to unblock */
> -	fnic_block_error_handler(sc);
> +	fc_block_scsi_eh(sc);
>
> 	/* Get local-port, check ready and link up */
> 	lp = shost_priv(sc->device->host);
> --- a/drivers/scsi/lpfc/lpfc_scsi.c	2009-10-30 17:47:23.000000000  
> +0100
> +++ b/drivers/scsi/lpfc/lpfc_scsi.c	2009-10-30 17:48:50.000000000  
> +0100
> @@ -2917,28 +2917,6 @@ lpfc_queuecommand(struct scsi_cmnd *cmnd
> }
>
> /**
> - * lpfc_block_error_handler - Routine to block error  handler
> - * @cmnd: Pointer to scsi_cmnd data structure.
> - *
> - *  This routine blocks execution till fc_rport state is not  
> FC_PORSTAT_BLCOEKD.
> - **/
> -static void
> -lpfc_block_error_handler(struct scsi_cmnd *cmnd)
> -{
> -	struct Scsi_Host *shost = cmnd->device->host;
> -	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd- 
> >device));
> -
> -	spin_lock_irq(shost->host_lock);
> -	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> -		spin_unlock_irq(shost->host_lock);
> -		msleep(1000);
> -		spin_lock_irq(shost->host_lock);
> -	}
> -	spin_unlock_irq(shost->host_lock);
> -	return;
> -}
> -
> -/**
>  * lpfc_abort_handler - scsi_host_template eh_abort_handler entry  
> point
>  * @cmnd: Pointer to scsi_cmnd data structure.
>  *
> @@ -2961,7 +2939,7 @@ lpfc_abort_handler(struct scsi_cmnd *cmn
> 	int ret = SUCCESS;
> 	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(waitq);
>
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
> 	lpfc_cmd = (struct lpfc_scsi_buf *)cmnd->host_scribble;
> 	BUG_ON(!lpfc_cmd);
>
> @@ -3259,7 +3237,7 @@ lpfc_device_reset_handler(struct scsi_cm
> 	struct lpfc_scsi_event_header scsi_event;
> 	int status;
>
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>
> 	status = lpfc_chk_tgt_mapped(vport, cmnd);
> 	if (status == FAILED) {
> @@ -3318,7 +3296,7 @@ lpfc_target_reset_handler(struct scsi_cm
> 	struct lpfc_scsi_event_header scsi_event;
> 	int status;
>
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>
> 	status = lpfc_chk_tgt_mapped(vport, cmnd);
> 	if (status == FAILED) {
> @@ -3384,7 +3362,7 @@ lpfc_bus_reset_handler(struct scsi_cmnd
> 	fc_host_post_vendor_event(shost, fc_get_event_number(),
> 		sizeof(scsi_event), (char *)&scsi_event, LPFC_NL_VENDOR_ID);
>
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>
> 	/*
> 	 * Since the driver manages a single bus device, reset all
> --- a/drivers/scsi/qla2xxx/qla_os.c	2009-10-30 17:47:23.000000000  
> +0100
> +++ b/drivers/scsi/qla2xxx/qla_os.c	2009-10-30 17:48:50.000000000  
> +0100
> @@ -728,23 +728,6 @@ qla2x00_abort_fcport_cmds(fc_port_t *fcp
> 	spin_unlock_irqrestore(&ha->hardware_lock, flags);
> }
>
> -static void
> -qla2x00_block_error_handler(struct scsi_cmnd *cmnd)
> -{
> -	struct Scsi_Host *shost = cmnd->device->host;
> -	struct fc_rport *rport = starget_to_rport(scsi_target(cmnd- 
> >device));
> -	unsigned long flags;
> -
> -	spin_lock_irqsave(shost->host_lock, flags);
> -	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> -		spin_unlock_irqrestore(shost->host_lock, flags);
> -		msleep(1000);
> -		spin_lock_irqsave(shost->host_lock, flags);
> -	}
> -	spin_unlock_irqrestore(shost->host_lock, flags);
> -	return;
> -}
> -
> / 
> **************************************************************************
> * qla2xxx_eh_abort
> *
> @@ -774,7 +757,7 @@ qla2xxx_eh_abort(struct scsi_cmnd *cmd)
> 	struct req_que *req = vha->req;
> 	srb_t *spt;
>
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>
> 	if (!CMD_SP(cmd))
> 		return SUCCESS;
> @@ -905,7 +888,7 @@ __qla2xxx_eh_generic_reset(char *name, e
> 	fc_port_t *fcport = (struct fc_port *) cmd->device->hostdata;
> 	int err;
>
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>
> 	if (!fcport)
> 		return FAILED;
> @@ -985,7 +968,7 @@ qla2xxx_eh_bus_reset(struct scsi_cmnd *c
> 	unsigned long serial;
> 	srb_t *sp = (srb_t *) CMD_SP(cmd);
>
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>
> 	id = cmd->device->id;
> 	lun = cmd->device->lun;
> @@ -1048,7 +1031,7 @@ qla2xxx_eh_host_reset(struct scsi_cmnd *
> 	srb_t *sp = (srb_t *) CMD_SP(cmd);
> 	scsi_qla_host_t *base_vha = pci_get_drvdata(ha->pdev);
>
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>
> 	id = cmd->device->id;
> 	lun = cmd->device->lun;
>
> --
> To unsubscribe from this list: send the line "unsubscribe linux- 
> scsi" in
> the body of a message to majordomo@vger.kernel.org
> More majordomo info at  http://vger.kernel.org/majordomo-info.html


^ permalink raw reply	[flat|nested] 4+ messages in thread

* RE: [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh
  2009-10-30 16:59 ` [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh Christof Schmitt
  2009-11-02 20:11   ` Giridhar Malavali
@ 2009-11-03 19:38   ` Abhijeet Joglekar (abjoglek)
  1 sibling, 0 replies; 4+ messages in thread
From: Abhijeet Joglekar (abjoglek) @ 2009-11-03 19:38 UTC (permalink / raw)
  To: Christof Schmitt, James Bottomley
  Cc: linux-scsi, James Smart, Joe Eykholt (jeykholt), Andrew Vasquez

Thanks for taking care of this Christof.

Acked-by: Abhijeet Joglekar <abjoglek@cisco.com> 

> -----Original Message-----
> From: Christof Schmitt [mailto:christof.schmitt@de.ibm.com] 
> Sent: Friday, October 30, 2009 9:59 AM
> To: James Bottomley
> Cc: linux-scsi@vger.kernel.org; James Smart; Abhijeet 
> Joglekar (abjoglek); Joe Eykholt (jeykholt); Andrew Vasquez; 
> Christof Schmitt
> Subject: [patch 1/1] scsi_transport_fc: Introduce helper 
> function for blocking scsi_eh
> 
> From: Christof Schmitt <christof.schmitt@de.ibm.com>
> 
> Move the duplicated code from FC LLDs to SCSI FC transport class.
> 
> Acked-by: James Smart <james.smart@emulex.com>
> Cc: Abhijeet Joglekar <abjoglek@cisco.com>
> Cc: Joe Eykholt <jeykholt@cisco.com>
> Cc: Andrew Vasquez <andrew.vasquez@qlogic.com>
> Signed-off-by: Christof Schmitt <christof.schmitt@de.ibm.com>
> ---
>  drivers/scsi/fnic/fnic_scsi.c    |   20 ++------------------
>  drivers/scsi/lpfc/lpfc_scsi.c    |   30 
> ++++--------------------------
>  drivers/scsi/qla2xxx/qla_os.c    |   25 ++++---------------------
>  drivers/scsi/scsi_transport_fc.c |   26 ++++++++++++++++++++++++++
>  include/scsi/scsi_transport_fc.h |    1 +
>  5 files changed, 37 insertions(+), 65 deletions(-)
> 
> --- a/drivers/scsi/scsi_transport_fc.c	2009-10-30 
> 17:47:23.000000000 +0100
> +++ b/drivers/scsi/scsi_transport_fc.c	2009-10-30 
> 17:48:50.000000000 +0100
> @@ -27,6 +27,7 @@
>   */
>  #include <linux/module.h>
>  #include <linux/init.h>
> +#include <linux/delay.h>
>  #include <scsi/scsi_device.h>
>  #include <scsi/scsi_host.h>
>  #include <scsi/scsi_transport.h>
> @@ -3144,6 +3145,31 @@ fc_scsi_scan_rport(struct work_struct *w
>  	spin_unlock_irqrestore(shost->host_lock, flags);  }
>  
> +/**
> + * fc_block_scsi_eh - Block SCSI eh thread for blocked fc_rport
> + * @cmnd: SCSI command that scsi_eh is trying to recover
> + *
> + * This routine can be called from a FC LLD scsi_eh callback. It
> + * blocks the scsi_eh thread until the fc_rport leaves the
> + * FC_PORTSTATE_BLOCKED. This is necessary to avoid the scsi_eh
> + * failing recovery actions for blocked rports which would lead to
> + * offlined SCSI devices.
> + */
> +void fc_block_scsi_eh(struct scsi_cmnd *cmnd) {
> +	struct Scsi_Host *shost = cmnd->device->host;
> +	struct fc_rport *rport = 
> starget_to_rport(scsi_target(cmnd->device));
> +	unsigned long flags;
> +
> +	spin_lock_irqsave(shost->host_lock, flags);
> +	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> +		spin_unlock_irqrestore(shost->host_lock, flags);
> +		msleep(1000);
> +		spin_lock_irqsave(shost->host_lock, flags);
> +	}
> +	spin_unlock_irqrestore(shost->host_lock, flags); } 
> +EXPORT_SYMBOL(fc_block_scsi_eh);
>  
>  /**
>   * fc_vport_setup - allocates and creates a FC virtual port.
> --- a/include/scsi/scsi_transport_fc.h	2009-10-30 
> 17:47:25.000000000 +0100
> +++ b/include/scsi/scsi_transport_fc.h	2009-10-30 
> 17:48:50.000000000 +0100
> @@ -807,5 +807,6 @@ void fc_host_post_vendor_event(struct Sc  
> struct fc_vport *fc_vport_create(struct Scsi_Host *shost, int channel,
>  		struct fc_vport_identifiers *);
>  int fc_vport_terminate(struct fc_vport *vport);
> +void fc_block_scsi_eh(struct scsi_cmnd *cmnd);
>  
>  #endif /* SCSI_TRANSPORT_FC_H */
> --- a/drivers/scsi/fnic/fnic_scsi.c	2009-10-30 
> 17:47:23.000000000 +0100
> +++ b/drivers/scsi/fnic/fnic_scsi.c	2009-10-30 
> 17:48:50.000000000 +0100
> @@ -1225,22 +1225,6 @@ void fnic_terminate_rport_io(struct fc_r
>  
>  }
>  
> -static void fnic_block_error_handler(struct scsi_cmnd *sc) -{
> -	struct Scsi_Host *shost = sc->device->host;
> -	struct fc_rport *rport = 
> starget_to_rport(scsi_target(sc->device));
> -	unsigned long flags;
> -
> -	spin_lock_irqsave(shost->host_lock, flags);
> -	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> -		spin_unlock_irqrestore(shost->host_lock, flags);
> -		msleep(1000);
> -		spin_lock_irqsave(shost->host_lock, flags);
> -	}
> -	spin_unlock_irqrestore(shost->host_lock, flags);
> -
> -}
> -
>  /*
>   * This function is exported to SCSI for sending abort cmnds.
>   * A SCSI IO is represented by a io_req in the driver.
> @@ -1260,7 +1244,7 @@ int fnic_abort_cmd(struct scsi_cmnd *sc)
>  	DECLARE_COMPLETION_ONSTACK(tm_done);
>  
>  	/* Wait for rport to unblock */
> -	fnic_block_error_handler(sc);
> +	fc_block_scsi_eh(sc);
>  
>  	/* Get local-port, check ready and link up */
>  	lp = shost_priv(sc->device->host);
> @@ -1542,7 +1526,7 @@ int fnic_device_reset(struct scsi_cmnd *
>  	DECLARE_COMPLETION_ONSTACK(tm_done);
>  
>  	/* Wait for rport to unblock */
> -	fnic_block_error_handler(sc);
> +	fc_block_scsi_eh(sc);
>  
>  	/* Get local-port, check ready and link up */
>  	lp = shost_priv(sc->device->host);
> --- a/drivers/scsi/lpfc/lpfc_scsi.c	2009-10-30 
> 17:47:23.000000000 +0100
> +++ b/drivers/scsi/lpfc/lpfc_scsi.c	2009-10-30 
> 17:48:50.000000000 +0100
> @@ -2917,28 +2917,6 @@ lpfc_queuecommand(struct scsi_cmnd *cmnd  }
>  
>  /**
> - * lpfc_block_error_handler - Routine to block error  handler
> - * @cmnd: Pointer to scsi_cmnd data structure.
> - *
> - *  This routine blocks execution till fc_rport state is not 
> FC_PORSTAT_BLCOEKD.
> - **/
> -static void
> -lpfc_block_error_handler(struct scsi_cmnd *cmnd) -{
> -	struct Scsi_Host *shost = cmnd->device->host;
> -	struct fc_rport *rport = 
> starget_to_rport(scsi_target(cmnd->device));
> -
> -	spin_lock_irq(shost->host_lock);
> -	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> -		spin_unlock_irq(shost->host_lock);
> -		msleep(1000);
> -		spin_lock_irq(shost->host_lock);
> -	}
> -	spin_unlock_irq(shost->host_lock);
> -	return;
> -}
> -
> -/**
>   * lpfc_abort_handler - scsi_host_template eh_abort_handler 
> entry point
>   * @cmnd: Pointer to scsi_cmnd data structure.
>   *
> @@ -2961,7 +2939,7 @@ lpfc_abort_handler(struct scsi_cmnd *cmn
>  	int ret = SUCCESS;
>  	DECLARE_WAIT_QUEUE_HEAD_ONSTACK(waitq);
>  
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>  	lpfc_cmd = (struct lpfc_scsi_buf *)cmnd->host_scribble;
>  	BUG_ON(!lpfc_cmd);
>  
> @@ -3259,7 +3237,7 @@ lpfc_device_reset_handler(struct scsi_cm
>  	struct lpfc_scsi_event_header scsi_event;
>  	int status;
>  
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>  
>  	status = lpfc_chk_tgt_mapped(vport, cmnd);
>  	if (status == FAILED) {
> @@ -3318,7 +3296,7 @@ lpfc_target_reset_handler(struct scsi_cm
>  	struct lpfc_scsi_event_header scsi_event;
>  	int status;
>  
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>  
>  	status = lpfc_chk_tgt_mapped(vport, cmnd);
>  	if (status == FAILED) {
> @@ -3384,7 +3362,7 @@ lpfc_bus_reset_handler(struct scsi_cmnd 
>  	fc_host_post_vendor_event(shost, fc_get_event_number(),
>  		sizeof(scsi_event), (char *)&scsi_event, 
> LPFC_NL_VENDOR_ID);
>  
> -	lpfc_block_error_handler(cmnd);
> +	fc_block_scsi_eh(cmnd);
>  
>  	/*
>  	 * Since the driver manages a single bus device, reset all
> --- a/drivers/scsi/qla2xxx/qla_os.c	2009-10-30 
> 17:47:23.000000000 +0100
> +++ b/drivers/scsi/qla2xxx/qla_os.c	2009-10-30 
> 17:48:50.000000000 +0100
> @@ -728,23 +728,6 @@ qla2x00_abort_fcport_cmds(fc_port_t *fcp
>  	spin_unlock_irqrestore(&ha->hardware_lock, flags);  }
>  
> -static void
> -qla2x00_block_error_handler(struct scsi_cmnd *cmnd) -{
> -	struct Scsi_Host *shost = cmnd->device->host;
> -	struct fc_rport *rport = 
> starget_to_rport(scsi_target(cmnd->device));
> -	unsigned long flags;
> -
> -	spin_lock_irqsave(shost->host_lock, flags);
> -	while (rport->port_state == FC_PORTSTATE_BLOCKED) {
> -		spin_unlock_irqrestore(shost->host_lock, flags);
> -		msleep(1000);
> -		spin_lock_irqsave(shost->host_lock, flags);
> -	}
> -	spin_unlock_irqrestore(shost->host_lock, flags);
> -	return;
> -}
> -
>  
> /*************************************************************
> *************
>  * qla2xxx_eh_abort
>  *
> @@ -774,7 +757,7 @@ qla2xxx_eh_abort(struct scsi_cmnd *cmd)
>  	struct req_que *req = vha->req;
>  	srb_t *spt;
>  
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>  
>  	if (!CMD_SP(cmd))
>  		return SUCCESS;
> @@ -905,7 +888,7 @@ __qla2xxx_eh_generic_reset(char *name, e
>  	fc_port_t *fcport = (struct fc_port *) cmd->device->hostdata;
>  	int err;
>  
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>  
>  	if (!fcport)
>  		return FAILED;
> @@ -985,7 +968,7 @@ qla2xxx_eh_bus_reset(struct scsi_cmnd *c
>  	unsigned long serial;
>  	srb_t *sp = (srb_t *) CMD_SP(cmd);
>  
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>  
>  	id = cmd->device->id;
>  	lun = cmd->device->lun;
> @@ -1048,7 +1031,7 @@ qla2xxx_eh_host_reset(struct scsi_cmnd *
>  	srb_t *sp = (srb_t *) CMD_SP(cmd);
>  	scsi_qla_host_t *base_vha = pci_get_drvdata(ha->pdev);
>  
> -	qla2x00_block_error_handler(cmd);
> +	fc_block_scsi_eh(cmd);
>  
>  	id = cmd->device->id;
>  	lun = cmd->device->lun;
> 
> 

^ permalink raw reply	[flat|nested] 4+ messages in thread

end of thread, other threads:[~2009-11-03 19:38 UTC | newest]

Thread overview: 4+ messages (download: mbox.gz follow: Atom feed
-- links below jump to the message on this page --
2009-10-30 16:59 [patch 0/1] Move helper code from FC drivers to FC transport Christof Schmitt
2009-10-30 16:59 ` [patch 1/1] scsi_transport_fc: Introduce helper function for blocking scsi_eh Christof Schmitt
2009-11-02 20:11   ` Giridhar Malavali
2009-11-03 19:38   ` Abhijeet Joglekar (abjoglek)

This is a public inbox, see mirroring instructions
for how to clone and mirror all data and code used for this inbox