FEX-Emu/linux
1
0
Fork 0
mirror of https://github.com/FEX-Emu/linux.git synced 2024-12-23 09:56:00 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

[SCSI] libsas: add mutex for SMP task execution

Browse Source 
SAS does not tag SMP requests, and at least one lldd (isci) does not permit
more than one in-flight request at a time.

[jejb: fix sas_init_dev tab issues while we're at it]
Signed-off-by: Jeff Skirvin <jeffrey.d.skirvin@intel.com>
Signed-off-by: Dan Williams <dan.j.williams@intel.com>
Signed-off-by: James Bottomley <JBottomley@Parallels.com>
This commit is contained in:
Jeff Skirvin 2011-11-16 09:44:13 +00:00 committed by James Bottomley
parent 1f4fe89c9c
commit 89d3cf6ac3
3 changed files with 34 additions and 28 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

31
drivers/scsi/libsas/sas_discover.c
View File

@ -37,21 +37,22 @@
void sas_init_dev(struct domain_device *dev) void sas_init_dev(struct domain_device *dev)
{ {
switch (dev->dev_type) { switch (dev->dev_type) {
case SAS_END_DEV: case SAS_END_DEV:
break; break;
case EDGE_DEV: case EDGE_DEV:
case FANOUT_DEV: case FANOUT_DEV:
INIT_LIST_HEAD(&dev->ex_dev.children); INIT_LIST_HEAD(&dev->ex_dev.children);
break; mutex_init(&dev->ex_dev.cmd_mutex);
case SATA_DEV: break;
case SATA_PM: case SATA_DEV:
case SATA_PM_PORT: case SATA_PM:
INIT_LIST_HEAD(&dev->sata_dev.children); case SATA_PM_PORT:
break; INIT_LIST_HEAD(&dev->sata_dev.children);
default: break;
break; default:
} break;
}
} }
/* ---------- Domain device discovery ---------- */ /* ---------- Domain device discovery ---------- */

29
drivers/scsi/libsas/sas_expander.c
View File

@ -72,11 +72,13 @@ static int smp_execute_task(struct domain_device *dev, void *req, int req_size,
struct sas_internal *i = struct sas_internal *i =
to_sas_internal(dev->port->ha->core.shost->transportt); to_sas_internal(dev->port->ha->core.shost->transportt);
mutex_lock(&dev->ex_dev.cmd_mutex);
for (retry = 0; retry < 3; retry++) { for (retry = 0; retry < 3; retry++) {
task = sas_alloc_task(GFP_KERNEL); task = sas_alloc_task(GFP_KERNEL);
if (!task) if (!task) {
return -ENOMEM; res = -ENOMEM;
break;
}
task->dev = dev; task->dev = dev;
task->task_proto = dev->tproto; task->task_proto = dev->tproto;
sg_init_one(&task->smp_task.smp_req, req, req_size); sg_init_one(&task->smp_task.smp_req, req, req_size);
@ -94,7 +96,7 @@ static int smp_execute_task(struct domain_device *dev, void *req, int req_size,
if (res) { if (res) {
del_timer(&task->timer); del_timer(&task->timer);
SAS_DPRINTK("executing SMP task failed:%d\n", res); SAS_DPRINTK("executing SMP task failed:%d\n", res);
goto ex_err; break;
} }
wait_for_completion(&task->completion); wait_for_completion(&task->completion);
@ -104,21 +106,23 @@ static int smp_execute_task(struct domain_device *dev, void *req, int req_size,
i->dft->lldd_abort_task(task); i->dft->lldd_abort_task(task);
if (!(task->task_state_flags & SAS_TASK_STATE_DONE)) { if (!(task->task_state_flags & SAS_TASK_STATE_DONE)) {
SAS_DPRINTK("SMP task aborted and not done\n"); SAS_DPRINTK("SMP task aborted and not done\n");
goto ex_err; break;
} }
} }
if (task->task_status.resp == SAS_TASK_COMPLETE && if (task->task_status.resp == SAS_TASK_COMPLETE &&
task->task_status.stat == SAM_STAT_GOOD) { task->task_status.stat == SAM_STAT_GOOD) {
res = 0; res = 0;
break; break;
} if (task->task_status.resp == SAS_TASK_COMPLETE && }
task->task_status.stat == SAS_DATA_UNDERRUN) { if (task->task_status.resp == SAS_TASK_COMPLETE &&
task->task_status.stat == SAS_DATA_UNDERRUN) {
/* no error, but return the number of bytes of /* no error, but return the number of bytes of
* underrun */ * underrun */
res = task->task_status.residual; res = task->task_status.residual;
break; break;
} if (task->task_status.resp == SAS_TASK_COMPLETE && }
task->task_status.stat == SAS_DATA_OVERRUN) { if (task->task_status.resp == SAS_TASK_COMPLETE &&
task->task_status.stat == SAS_DATA_OVERRUN) {
res = -EMSGSIZE; res = -EMSGSIZE;
break; break;
} else { } else {
@ -131,11 +135,10 @@ static int smp_execute_task(struct domain_device *dev, void *req, int req_size,
task = NULL; task = NULL;
} }
} }
ex_err: mutex_unlock(&dev->ex_dev.cmd_mutex);
BUG_ON(retry == 3 && task != NULL); BUG_ON(retry == 3 && task != NULL);
if (task != NULL) { sas_free_task(task);
sas_free_task(task);
}
return res; return res;
} }

2
include/scsi/libsas.h
View File

@ -153,6 +153,8 @@ struct expander_device {
struct ex_phy *ex_phy; struct ex_phy *ex_phy;
struct sas_port *parent_port; struct sas_port *parent_port;
struct mutex cmd_mutex;
}; };
/* ---------- SATA device ---------- */ /* ---------- SATA device ---------- */