Commit a9925a06 authored by Jens Axboe's avatar Jens Axboe

[BLOCK] CCISS: update for blk softirq completions

Signed-off-by: default avatarJens Axboe <axboe@suse.de>
parent 8672d571
...@@ -2178,16 +2178,48 @@ static inline void resend_cciss_cmd( ctlr_info_t *h, CommandList_struct *c) ...@@ -2178,16 +2178,48 @@ static inline void resend_cciss_cmd( ctlr_info_t *h, CommandList_struct *c)
start_io(h); start_io(h);
} }
static void cciss_softirq_done(struct request *rq)
{
CommandList_struct *cmd = rq->completion_data;
ctlr_info_t *h = hba[cmd->ctlr];
u64bit temp64;
int i, ddir;
if (cmd->Request.Type.Direction == XFER_READ)
ddir = PCI_DMA_FROMDEVICE;
else
ddir = PCI_DMA_TODEVICE;
/* command did not need to be retried */
/* unmap the DMA mapping for all the scatter gather elements */
for(i=0; i<cmd->Header.SGList; i++) {
temp64.val32.lower = cmd->SG[i].Addr.lower;
temp64.val32.upper = cmd->SG[i].Addr.upper;
pci_unmap_page(h->pdev, temp64.val, cmd->SG[i].Len, ddir);
}
complete_buffers(rq->bio, rq->errors);
#ifdef CCISS_DEBUG
printk("Done with %p\n", rq);
#endif /* CCISS_DEBUG */
spin_lock_irq(&h->lock);
end_that_request_last(rq, rq->errors);
cmd_free(h, cmd,1);
spin_unlock_irq(&h->lock);
}
/* checks the status of the job and calls complete buffers to mark all /* checks the status of the job and calls complete buffers to mark all
* buffers for the completed job. * buffers for the completed job. Note that this function does not need
* to hold the hba/queue lock.
*/ */
static inline void complete_command( ctlr_info_t *h, CommandList_struct *cmd, static inline void complete_command( ctlr_info_t *h, CommandList_struct *cmd,
int timeout) int timeout)
{ {
int status = 1; int status = 1;
int i;
int retry_cmd = 0; int retry_cmd = 0;
u64bit temp64;
if (timeout) if (timeout)
status = 0; status = 0;
...@@ -2295,24 +2327,10 @@ static inline void complete_command( ctlr_info_t *h, CommandList_struct *cmd, ...@@ -2295,24 +2327,10 @@ static inline void complete_command( ctlr_info_t *h, CommandList_struct *cmd,
resend_cciss_cmd(h,cmd); resend_cciss_cmd(h,cmd);
return; return;
} }
/* command did not need to be retried */
/* unmap the DMA mapping for all the scatter gather elements */
for(i=0; i<cmd->Header.SGList; i++) {
temp64.val32.lower = cmd->SG[i].Addr.lower;
temp64.val32.upper = cmd->SG[i].Addr.upper;
pci_unmap_page(hba[cmd->ctlr]->pdev,
temp64.val, cmd->SG[i].Len,
(cmd->Request.Type.Direction == XFER_READ) ?
PCI_DMA_FROMDEVICE : PCI_DMA_TODEVICE);
}
complete_buffers(cmd->rq->bio, status);
#ifdef CCISS_DEBUG cmd->rq->completion_data = cmd;
printk("Done with %p\n", cmd->rq); cmd->rq->errors = status;
#endif /* CCISS_DEBUG */ blk_complete_request(cmd->rq);
end_that_request_last(cmd->rq, status ? 1 : -EIO);
cmd_free(h,cmd,1);
} }
/* /*
...@@ -3209,6 +3227,8 @@ static int __devinit cciss_init_one(struct pci_dev *pdev, ...@@ -3209,6 +3227,8 @@ static int __devinit cciss_init_one(struct pci_dev *pdev,
blk_queue_max_sectors(q, 512); blk_queue_max_sectors(q, 512);
blk_queue_softirq_done(q, cciss_softirq_done);
q->queuedata = hba[i]; q->queuedata = hba[i];
sprintf(disk->disk_name, "cciss/c%dd%d", i, j); sprintf(disk->disk_name, "cciss/c%dd%d", i, j);
sprintf(disk->devfs_name, "cciss/host%d/target%d", i, j); sprintf(disk->devfs_name, "cciss/host%d/target%d", i, j);
......
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