[SCSI] allow sleeping in ->eh_abort_handler()

Signed-off-by: James Bottomley <James.Bottomley@SteelEye.com>
This commit is contained in:
Jeff Garzik 2005-05-28 07:54:40 -04:00
Родитель 3471c28803
Коммит 8fa728a268
19 изменённых файлов: 122 добавлений и 49 удалений

Просмотреть файл

@ -936,8 +936,7 @@ Details:
* *
* Returns SUCCESS if command aborted else FAILED * Returns SUCCESS if command aborted else FAILED
* *
* Locks: struct Scsi_Host::host_lock held (with irqsave) on entry * Locks: None held
* and assumed to be held on return.
* *
* Calling context: kernel thread * Calling context: kernel thread
* *

Просмотреть файл

@ -1707,7 +1707,6 @@ mptscsih_abort(struct scsi_cmnd * SCpnt)
MPT_FRAME_HDR *mf; MPT_FRAME_HDR *mf;
u32 ctx2abort; u32 ctx2abort;
int scpnt_idx; int scpnt_idx;
spinlock_t *host_lock = SCpnt->device->host->host_lock;
/* If we can't locate our host adapter structure, return FAILED status. /* If we can't locate our host adapter structure, return FAILED status.
*/ */
@ -1755,7 +1754,6 @@ mptscsih_abort(struct scsi_cmnd * SCpnt)
hd->abortSCpnt = SCpnt; hd->abortSCpnt = SCpnt;
spin_unlock_irq(host_lock);
if (mptscsih_TMHandler(hd, MPI_SCSITASKMGMT_TASKTYPE_ABORT_TASK, if (mptscsih_TMHandler(hd, MPI_SCSITASKMGMT_TASKTYPE_ABORT_TASK,
SCpnt->device->channel, SCpnt->device->id, SCpnt->device->lun, SCpnt->device->channel, SCpnt->device->id, SCpnt->device->lun,
ctx2abort, 2 /* 2 second timeout */) ctx2abort, 2 /* 2 second timeout */)
@ -1772,8 +1770,6 @@ mptscsih_abort(struct scsi_cmnd * SCpnt)
hd->tmPending = 0; hd->tmPending = 0;
hd->tmState = TM_STATE_NONE; hd->tmState = TM_STATE_NONE;
spin_lock_irq(host_lock);
/* Unmap the DMA buffers, if any. */ /* Unmap the DMA buffers, if any. */
if (SCpnt->use_sg) { if (SCpnt->use_sg) {
pci_unmap_sg(ioc->pcidev, (struct scatterlist *) SCpnt->request_buffer, pci_unmap_sg(ioc->pcidev, (struct scatterlist *) SCpnt->request_buffer,
@ -1789,7 +1785,6 @@ mptscsih_abort(struct scsi_cmnd * SCpnt)
mpt_free_msg_frame(ioc, mf); mpt_free_msg_frame(ioc, mf);
return FAILED; return FAILED;
} }
spin_lock_irq(host_lock);
return SUCCESS; return SUCCESS;
} }

Просмотреть файл

@ -433,7 +433,7 @@ zfcp_port_lookup(struct zfcp_adapter *adapter, int channel, scsi_id_t id)
* FAILED - otherwise * FAILED - otherwise
*/ */
int int
zfcp_scsi_eh_abort_handler(struct scsi_cmnd *scpnt) __zfcp_scsi_eh_abort_handler(struct scsi_cmnd *scpnt)
{ {
int retval = SUCCESS; int retval = SUCCESS;
struct zfcp_fsf_req *new_fsf_req, *old_fsf_req; struct zfcp_fsf_req *new_fsf_req, *old_fsf_req;
@ -611,6 +611,17 @@ zfcp_scsi_eh_abort_handler(struct scsi_cmnd *scpnt)
return retval; return retval;
} }
int
zfcp_scsi_eh_abort_handler(struct scsi_cmnd *scpnt)
{
int rc;
struct Scsi_Host *scsi_host = scpnt->device->host;
spin_lock_irq(scsi_host->host_lock);
rc = __zfcp_scsi_eh_abort_handler(scpnt);
spin_unlock_irq(scsi_host->host_lock);
return rc;
}
/* /*
* function: zfcp_scsi_eh_device_reset_handler * function: zfcp_scsi_eh_device_reset_handler
* *

Просмотреть файл

@ -941,7 +941,7 @@ ahd_linux_queue(Scsi_Cmnd * cmd, void (*scsi_done) (Scsi_Cmnd *))
*/ */
cmd->scsi_done = scsi_done; cmd->scsi_done = scsi_done;
ahd_midlayer_entrypoint_lock(ahd, &flags); ahd_lock(ahd, &flags);
/* /*
* Close the race of a command that was in the process of * Close the race of a command that was in the process of
@ -955,7 +955,7 @@ ahd_linux_queue(Scsi_Cmnd * cmd, void (*scsi_done) (Scsi_Cmnd *))
ahd_cmd_set_transaction_status(cmd, CAM_REQUEUE_REQ); ahd_cmd_set_transaction_status(cmd, CAM_REQUEUE_REQ);
ahd_linux_queue_cmd_complete(ahd, cmd); ahd_linux_queue_cmd_complete(ahd, cmd);
ahd_schedule_completeq(ahd); ahd_schedule_completeq(ahd);
ahd_midlayer_entrypoint_unlock(ahd, &flags); ahd_unlock(ahd, &flags);
return (0); return (0);
} }
dev = ahd_linux_get_device(ahd, cmd->device->channel, dev = ahd_linux_get_device(ahd, cmd->device->channel,
@ -965,7 +965,7 @@ ahd_linux_queue(Scsi_Cmnd * cmd, void (*scsi_done) (Scsi_Cmnd *))
ahd_cmd_set_transaction_status(cmd, CAM_RESRC_UNAVAIL); ahd_cmd_set_transaction_status(cmd, CAM_RESRC_UNAVAIL);
ahd_linux_queue_cmd_complete(ahd, cmd); ahd_linux_queue_cmd_complete(ahd, cmd);
ahd_schedule_completeq(ahd); ahd_schedule_completeq(ahd);
ahd_midlayer_entrypoint_unlock(ahd, &flags); ahd_unlock(ahd, &flags);
printf("%s: aic79xx_linux_queue - Unable to allocate device!\n", printf("%s: aic79xx_linux_queue - Unable to allocate device!\n",
ahd_name(ahd)); ahd_name(ahd));
return (0); return (0);
@ -979,7 +979,7 @@ ahd_linux_queue(Scsi_Cmnd * cmd, void (*scsi_done) (Scsi_Cmnd *))
dev->flags |= AHD_DEV_ON_RUN_LIST; dev->flags |= AHD_DEV_ON_RUN_LIST;
ahd_linux_run_device_queues(ahd); ahd_linux_run_device_queues(ahd);
} }
ahd_midlayer_entrypoint_unlock(ahd, &flags); ahd_unlock(ahd, &flags);
return (0); return (0);
} }

Просмотреть файл

@ -2249,6 +2249,8 @@ ahc_linux_queue_recovery_cmd(struct scsi_cmnd *cmd, scb_flag flag)
printf(" 0x%x", cmd->cmnd[cdb_byte]); printf(" 0x%x", cmd->cmnd[cdb_byte]);
printf("\n"); printf("\n");
spin_lock_irq(&ahc->platform_data->spin_lock);
/* /*
* First determine if we currently own this command. * First determine if we currently own this command.
* Start by searching the device queue. If not found * Start by searching the device queue. If not found
@ -2503,6 +2505,8 @@ done:
} }
spin_lock_irq(&ahc->platform_data->spin_lock); spin_lock_irq(&ahc->platform_data->spin_lock);
} }
spin_unlock_irq(&ahc->platform_data->spin_lock);
return (retval); return (retval);
} }

Просмотреть файл

@ -10585,7 +10585,7 @@ aic7xxx_panic_abort(struct aic7xxx_host *p, Scsi_Cmnd *cmd)
* Abort the current SCSI command(s). * Abort the current SCSI command(s).
*-F*************************************************************************/ *-F*************************************************************************/
static int static int
aic7xxx_abort(Scsi_Cmnd *cmd) __aic7xxx_abort(Scsi_Cmnd *cmd)
{ {
struct aic7xxx_scb *scb = NULL; struct aic7xxx_scb *scb = NULL;
struct aic7xxx_host *p; struct aic7xxx_host *p;
@ -10802,6 +10802,19 @@ success:
return SUCCESS; return SUCCESS;
} }
static int
aic7xxx_abort(Scsi_Cmnd *cmd)
{
int rc;
spin_lock_irq(cmd->device->host->host_lock);
rc = __aic7xxx_abort(cmd);
spin_unlock_irq(cmd->device->host->host_lock);
return rc;
}
/*+F************************************************************************* /*+F*************************************************************************
* Function: * Function:
* aic7xxx_reset * aic7xxx_reset

Просмотреть файл

@ -2118,7 +2118,7 @@ static int ibmmca_queuecommand(Scsi_Cmnd * cmd, void (*done) (Scsi_Cmnd *))
return 0; return 0;
} }
static int ibmmca_abort(Scsi_Cmnd * cmd) static int __ibmmca_abort(Scsi_Cmnd * cmd)
{ {
/* Abort does not work, as the adapter never generates an interrupt on /* Abort does not work, as the adapter never generates an interrupt on
* whatever situation is simulated, even when really pending commands * whatever situation is simulated, even when really pending commands
@ -2225,6 +2225,18 @@ static int ibmmca_abort(Scsi_Cmnd * cmd)
} }
} }
static int ibmmca_abort(Scsi_Cmnd * cmd)
{
struct Scsi_Host *shpnt = cmd->device->host;
int rc;
spin_lock_irq(shpnt->host_lock);
rc = __ibmmca_abort(cmd);
spin_unlock_irq(shpnt->host_lock);
return rc;
}
static int ibmmca_host_reset(Scsi_Cmnd * cmd) static int ibmmca_host_reset(Scsi_Cmnd * cmd)
{ {
struct Scsi_Host *shpnt; struct Scsi_Host *shpnt;

Просмотреть файл

@ -874,9 +874,7 @@ static int ibmvscsi_eh_abort_handler(struct scsi_cmnd *cmd)
return FAILED; return FAILED;
} }
spin_unlock_irq(hostdata->host->host_lock);
wait_for_completion(&evt->comp); wait_for_completion(&evt->comp);
spin_lock_irq(hostdata->host->host_lock);
/* make sure we got a good response */ /* make sure we got a good response */
if (unlikely(srp_rsp.srp.generic.type != SRP_RSP_TYPE)) { if (unlikely(srp_rsp.srp.generic.type != SRP_RSP_TYPE)) {

Просмотреть файл

@ -1671,7 +1671,7 @@ static int in2000_bus_reset(Scsi_Cmnd * cmd)
return SUCCESS; return SUCCESS;
} }
static int in2000_abort(Scsi_Cmnd * cmd) static int __in2000_abort(Scsi_Cmnd * cmd)
{ {
struct Scsi_Host *instance; struct Scsi_Host *instance;
struct IN2000_hostdata *hostdata; struct IN2000_hostdata *hostdata;
@ -1792,6 +1792,16 @@ static int in2000_abort(Scsi_Cmnd * cmd)
return SUCCESS; return SUCCESS;
} }
static int in2000_abort(Scsi_Cmnd * cmd)
{
int rc;
spin_lock_irq(cmd->device->host->host_lock);
rc = __in2000_abort(cmd);
spin_unlock_irq(cmd->device->host->host_lock);
return rc;
}
#define MAX_IN2000_HOSTS 3 #define MAX_IN2000_HOSTS 3

Просмотреть файл

@ -3068,6 +3068,12 @@ static int ipr_cancel_op(struct scsi_cmnd * scsi_cmd)
ioa_cfg = (struct ipr_ioa_cfg *)scsi_cmd->device->host->hostdata; ioa_cfg = (struct ipr_ioa_cfg *)scsi_cmd->device->host->hostdata;
res = scsi_cmd->device->hostdata; res = scsi_cmd->device->hostdata;
/* If we are currently going through reset/reload, return failed.
* This will force the mid-layer to call ipr_eh_host_reset,
* which will then go to sleep and wait for the reset to complete
*/
if (ioa_cfg->in_reset_reload || ioa_cfg->ioa_is_dead)
return FAILED;
if (!res || (!ipr_is_gscsi(res) && !ipr_is_vset_device(res))) if (!res || (!ipr_is_gscsi(res) && !ipr_is_vset_device(res)))
return FAILED; return FAILED;
@ -3118,23 +3124,17 @@ static int ipr_cancel_op(struct scsi_cmnd * scsi_cmd)
**/ **/
static int ipr_eh_abort(struct scsi_cmnd * scsi_cmd) static int ipr_eh_abort(struct scsi_cmnd * scsi_cmd)
{ {
struct ipr_ioa_cfg *ioa_cfg; unsigned long flags;
int rc;
ENTER; ENTER;
ioa_cfg = (struct ipr_ioa_cfg *) scsi_cmd->device->host->hostdata;
/* If we are currently going through reset/reload, return failed. This will force the spin_lock_irqsave(scsi_cmd->device->host->host_lock, flags);
mid-layer to call ipr_eh_host_reset, which will then go to sleep and wait for the rc = ipr_cancel_op(scsi_cmd);
reset to complete */ spin_unlock_irqrestore(scsi_cmd->device->host->host_lock, flags);
if (ioa_cfg->in_reset_reload)
return FAILED;
if (ioa_cfg->ioa_is_dead)
return FAILED;
if (!scsi_cmd->device->hostdata)
return FAILED;
LEAVE; LEAVE;
return ipr_cancel_op(scsi_cmd); return rc;
} }
/** /**

Просмотреть файл

@ -819,12 +819,15 @@ ips_eh_abort(Scsi_Cmnd * SC)
ips_ha_t *ha; ips_ha_t *ha;
ips_copp_wait_item_t *item; ips_copp_wait_item_t *item;
int ret; int ret;
unsigned long cpu_flags;
struct Scsi_Host *host;
METHOD_TRACE("ips_eh_abort", 1); METHOD_TRACE("ips_eh_abort", 1);
if (!SC) if (!SC)
return (FAILED); return (FAILED);
host = SC->device->host;
ha = (ips_ha_t *) SC->device->host->hostdata; ha = (ips_ha_t *) SC->device->host->hostdata;
if (!ha) if (!ha)
@ -833,6 +836,8 @@ ips_eh_abort(Scsi_Cmnd * SC)
if (!ha->active) if (!ha->active)
return (FAILED); return (FAILED);
IPS_LOCK_SAVE(host->host_lock, cpu_flags);
/* See if the command is on the copp queue */ /* See if the command is on the copp queue */
item = ha->copp_waitlist.head; item = ha->copp_waitlist.head;
while ((item) && (item->scsi_cmd != SC)) while ((item) && (item->scsi_cmd != SC))
@ -851,6 +856,8 @@ ips_eh_abort(Scsi_Cmnd * SC)
/* command must have already been sent */ /* command must have already been sent */
ret = (FAILED); ret = (FAILED);
} }
IPS_UNLOCK_RESTORE(host->host_lock, cpu_flags);
return ret; return ret;
} }

Просмотреть файл

@ -798,7 +798,7 @@ lpfc_queuecommand(struct scsi_cmnd *cmnd, void (*done) (struct scsi_cmnd *))
} }
static int static int
lpfc_abort_handler(struct scsi_cmnd *cmnd) __lpfc_abort_handler(struct scsi_cmnd *cmnd)
{ {
struct lpfc_hba *phba = struct lpfc_hba *phba =
(struct lpfc_hba *)cmnd->device->host->hostdata[0]; (struct lpfc_hba *)cmnd->device->host->hostdata[0];
@ -917,6 +917,16 @@ lpfc_abort_handler(struct scsi_cmnd *cmnd)
return ret == IOCB_SUCCESS ? SUCCESS : FAILED; return ret == IOCB_SUCCESS ? SUCCESS : FAILED;
} }
static int
lpfc_abort_handler(struct scsi_cmnd *cmnd)
{
int rc;
spin_lock_irq(cmnd->device->host->host_lock);
rc = __lpfc_abort_handler(cmnd);
spin_unlock_irq(cmnd->device->host->host_lock);
return rc;
}
static int static int
lpfc_reset_lun_handler(struct scsi_cmnd *cmnd) lpfc_reset_lun_handler(struct scsi_cmnd *cmnd)
{ {

Просмотреть файл

@ -2566,7 +2566,7 @@ megaraid_mbox_dpc(unsigned long devp)
* aborted. All the commands issued to the F/W must complete. * aborted. All the commands issued to the F/W must complete.
**/ **/
static int static int
megaraid_abort_handler(struct scsi_cmnd *scp) __megaraid_abort_handler(struct scsi_cmnd *scp)
{ {
adapter_t *adapter; adapter_t *adapter;
mraid_device_t *raid_dev; mraid_device_t *raid_dev;
@ -2699,6 +2699,21 @@ megaraid_abort_handler(struct scsi_cmnd *scp)
return FAILED; return FAILED;
} }
static int
megaraid_abort_handler(struct scsi_cmnd *scp)
{
adapter_t *adapter;
int rc;
adapter = SCP2ADAPTER(scp);
spin_lock_irq(adapter->host_lock);
rc = __megaraid_abort_handler(scp);
spin_unlock_irq(adapter->host_lock);
return rc;
}
/** /**
* megaraid_reset_handler - device reset hadler for mailbox based driver * megaraid_reset_handler - device reset hadler for mailbox based driver

Просмотреть файл

@ -1098,7 +1098,13 @@ qla1280_error_action(struct scsi_cmnd *cmd, enum action action)
static int static int
qla1280_eh_abort(struct scsi_cmnd * cmd) qla1280_eh_abort(struct scsi_cmnd * cmd)
{ {
return qla1280_error_action(cmd, ABORT_COMMAND); int rc;
spin_lock_irq(cmd->device->host->host_lock);
rc = qla1280_error_action(cmd, ABORT_COMMAND);
spin_unlock_irq(cmd->device->host->host_lock);
return rc;
} }
/************************************************************************** /**************************************************************************

Просмотреть файл

@ -476,7 +476,6 @@ qla2xxx_eh_abort(struct scsi_cmnd *cmd)
serial = cmd->serial_number; serial = cmd->serial_number;
/* Check active list for command command. */ /* Check active list for command command. */
spin_unlock_irq(ha->host->host_lock);
spin_lock(&ha->hardware_lock); spin_lock(&ha->hardware_lock);
for (i = 1; i < MAX_OUTSTANDING_COMMANDS; i++) { for (i = 1; i < MAX_OUTSTANDING_COMMANDS; i++) {
sp = ha->outstanding_cmds[i]; sp = ha->outstanding_cmds[i];
@ -516,7 +515,6 @@ qla2xxx_eh_abort(struct scsi_cmnd *cmd)
} }
spin_lock(&ha->hardware_lock); spin_lock(&ha->hardware_lock);
} }
spin_lock_irq(ha->host->host_lock);
qla_printk(KERN_INFO, ha, qla_printk(KERN_INFO, ha,
"scsi(%ld:%d:%d): Abort command issued -- %lx %x.\n", ha->host_no, "scsi(%ld:%d:%d): Abort command issued -- %lx %x.\n", ha->host_no,

Просмотреть файл

@ -526,10 +526,8 @@ static int scsi_send_eh_cmnd(struct scsi_cmnd *scmd, int timeout)
* abort a timed out command or not. not sure how * abort a timed out command or not. not sure how
* we should treat them differently anyways. * we should treat them differently anyways.
*/ */
spin_lock_irqsave(shost->host_lock, flags);
if (shost->hostt->eh_abort_handler) if (shost->hostt->eh_abort_handler)
shost->hostt->eh_abort_handler(scmd); shost->hostt->eh_abort_handler(scmd);
spin_unlock_irqrestore(shost->host_lock, flags);
scmd->request->rq_status = RQ_SCSI_DONE; scmd->request->rq_status = RQ_SCSI_DONE;
scmd->owner = SCSI_OWNER_ERROR_HANDLER; scmd->owner = SCSI_OWNER_ERROR_HANDLER;
@ -735,11 +733,8 @@ static int scsi_eh_get_sense(struct list_head *work_q,
**/ **/
static int scsi_try_to_abort_cmd(struct scsi_cmnd *scmd) static int scsi_try_to_abort_cmd(struct scsi_cmnd *scmd)
{ {
unsigned long flags;
int rtn = FAILED;
if (!scmd->device->host->hostt->eh_abort_handler) if (!scmd->device->host->hostt->eh_abort_handler)
return rtn; return FAILED;
/* /*
* scsi_done was called just after the command timed out and before * scsi_done was called just after the command timed out and before
@ -750,11 +745,7 @@ static int scsi_try_to_abort_cmd(struct scsi_cmnd *scmd)
scmd->owner = SCSI_OWNER_LOWLEVEL; scmd->owner = SCSI_OWNER_LOWLEVEL;
spin_lock_irqsave(scmd->device->host->host_lock, flags); return scmd->device->host->hostt->eh_abort_handler(scmd);
rtn = scmd->device->host->hostt->eh_abort_handler(scmd);
spin_unlock_irqrestore(scmd->device->host->host_lock, flags);
return rtn;
} }
/** /**

Просмотреть файл

@ -856,7 +856,13 @@ prepare:
*/ */
static int sym53c8xx_eh_abort_handler(struct scsi_cmnd *cmd) static int sym53c8xx_eh_abort_handler(struct scsi_cmnd *cmd)
{ {
return sym_eh_handler(SYM_EH_ABORT, "ABORT", cmd); int rc;
spin_lock_irq(cmd->device->host->host_lock);
rc = sym_eh_handler(SYM_EH_ABORT, "ABORT", cmd);
spin_unlock_irq(cmd->device->host->host_lock);
return rc;
} }
static int sym53c8xx_eh_device_reset_handler(struct scsi_cmnd *cmd) static int sym53c8xx_eh_device_reset_handler(struct scsi_cmnd *cmd)

Просмотреть файл

@ -879,7 +879,7 @@ static int ultrastor_abort(Scsi_Cmnd *SCpnt)
ogm_addr = (unsigned int)isa_bus_to_virt(inl(port0 + 23)); ogm_addr = (unsigned int)isa_bus_to_virt(inl(port0 + 23));
icm_status = inb(port0 + 27); icm_status = inb(port0 + 27);
icm_addr = (unsigned int)isa_bus_to_virt(inl(port0 + 28)); icm_addr = (unsigned int)isa_bus_to_virt(inl(port0 + 28));
spin_lock_irqsave(host->host_lock, flags); spin_unlock_irqrestore(host->host_lock, flags);
} }
/* First check to see if an interrupt is pending. I suspect the SiS /* First check to see if an interrupt is pending. I suspect the SiS

Просмотреть файл

@ -233,13 +233,11 @@ static int command_abort(struct scsi_cmnd *srb)
set_bit(US_FLIDX_ABORTING, &us->flags); set_bit(US_FLIDX_ABORTING, &us->flags);
usb_stor_stop_transport(us); usb_stor_stop_transport(us);
} }
scsi_unlock(us_to_host(us));
/* Wait for the aborted command to finish */ /* Wait for the aborted command to finish */
wait_for_completion(&us->notify); wait_for_completion(&us->notify);
/* Reacquire the lock and allow USB transfers to resume */ /* Reacquire the lock and allow USB transfers to resume */
scsi_lock(us_to_host(us));
clear_bit(US_FLIDX_ABORTING, &us->flags); clear_bit(US_FLIDX_ABORTING, &us->flags);
clear_bit(US_FLIDX_TIMED_OUT, &us->flags); clear_bit(US_FLIDX_TIMED_OUT, &us->flags);
return SUCCESS; return SUCCESS;