1 /*
2 * Copyright 2014 Cisco Systems, Inc. All rights reserved.
3 *
4 * This program is free software; you may redistribute it and/or modify
5 * it under the terms of the GNU General Public License as published by
6 * the Free Software Foundation; version 2 of the License.
7 *
8 * THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND,
9 * EXPRESS OR IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF
10 * MERCHANTABILITY, FITNESS FOR A PARTICULAR PURPOSE AND
11 * NONINFRINGEMENT. IN NO EVENT SHALL THE AUTHORS OR COPYRIGHT HOLDERS
12 * BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER LIABILITY, WHETHER IN AN
13 * ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING FROM, OUT OF OR IN
14 * CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS IN THE
15 * SOFTWARE.
16 */
17
18 #include <linux/mempool.h>
19 #include <linux/errno.h>
20 #include <linux/init.h>
21 #include <linux/workqueue.h>
22 #include <linux/pci.h>
23 #include <linux/spinlock.h>
24 #include <linux/delay.h>
25 #include <linux/gfp.h>
26 #include <scsi/scsi.h>
27 #include <scsi/scsi_host.h>
28 #include <scsi/scsi_device.h>
29 #include <scsi/scsi_cmnd.h>
30 #include <scsi/scsi_tcq.h>
31 #include <scsi/scsi_dbg.h>
32
33 #include "snic_io.h"
34 #include "snic.h"
35
36 #define snic_cmd_tag(sc) (((struct scsi_cmnd *) sc)->request->tag)
37
38 const char *snic_state_str[] = {
39 [SNIC_INIT] = "SNIC_INIT",
40 [SNIC_ERROR] = "SNIC_ERROR",
41 [SNIC_ONLINE] = "SNIC_ONLINE",
42 [SNIC_OFFLINE] = "SNIC_OFFLINE",
43 [SNIC_FWRESET] = "SNIC_FWRESET",
44 };
45
46 static const char * const snic_req_state_str[] = {
47 [SNIC_IOREQ_NOT_INITED] = "SNIC_IOREQ_NOT_INITED",
48 [SNIC_IOREQ_PENDING] = "SNIC_IOREQ_PENDING",
49 [SNIC_IOREQ_ABTS_PENDING] = "SNIC_IOREQ_ABTS_PENDING",
50 [SNIC_IOREQ_ABTS_COMPLETE] = "SNIC_IOREQ_ABTS_COMPLETE",
51 [SNIC_IOREQ_LR_PENDING] = "SNIC_IOREQ_LR_PENDING",
52 [SNIC_IOREQ_LR_COMPLETE] = "SNIC_IOREQ_LR_COMPLETE",
53 [SNIC_IOREQ_COMPLETE] = "SNIC_IOREQ_CMD_COMPLETE",
54 };
55
56 /* snic cmd status strings */
57 static const char * const snic_io_status_str[] = {
58 [SNIC_STAT_IO_SUCCESS] = "SNIC_STAT_IO_SUCCESS", /* 0x0 */
59 [SNIC_STAT_INVALID_HDR] = "SNIC_STAT_INVALID_HDR",
60 [SNIC_STAT_OUT_OF_RES] = "SNIC_STAT_OUT_OF_RES",
61 [SNIC_STAT_INVALID_PARM] = "SNIC_STAT_INVALID_PARM",
62 [SNIC_STAT_REQ_NOT_SUP] = "SNIC_STAT_REQ_NOT_SUP",
63 [SNIC_STAT_IO_NOT_FOUND] = "SNIC_STAT_IO_NOT_FOUND",
64 [SNIC_STAT_ABORTED] = "SNIC_STAT_ABORTED",
65 [SNIC_STAT_TIMEOUT] = "SNIC_STAT_TIMEOUT",
66 [SNIC_STAT_SGL_INVALID] = "SNIC_STAT_SGL_INVALID",
67 [SNIC_STAT_DATA_CNT_MISMATCH] = "SNIC_STAT_DATA_CNT_MISMATCH",
68 [SNIC_STAT_FW_ERR] = "SNIC_STAT_FW_ERR",
69 [SNIC_STAT_ITMF_REJECT] = "SNIC_STAT_ITMF_REJECT",
70 [SNIC_STAT_ITMF_FAIL] = "SNIC_STAT_ITMF_FAIL",
71 [SNIC_STAT_ITMF_INCORRECT_LUN] = "SNIC_STAT_ITMF_INCORRECT_LUN",
72 [SNIC_STAT_CMND_REJECT] = "SNIC_STAT_CMND_REJECT",
73 [SNIC_STAT_DEV_OFFLINE] = "SNIC_STAT_DEV_OFFLINE",
74 [SNIC_STAT_NO_BOOTLUN] = "SNIC_STAT_NO_BOOTLUN",
75 [SNIC_STAT_SCSI_ERR] = "SNIC_STAT_SCSI_ERR",
76 [SNIC_STAT_NOT_READY] = "SNIC_STAT_NOT_READY",
77 [SNIC_STAT_FATAL_ERROR] = "SNIC_STAT_FATAL_ERROR",
78 };
79
80 static void snic_scsi_cleanup(struct snic *, int);
81
82 const char *
snic_state_to_str(unsigned int state)83 snic_state_to_str(unsigned int state)
84 {
85 if (state >= ARRAY_SIZE(snic_state_str) || !snic_state_str[state])
86 return "Unknown";
87
88 return snic_state_str[state];
89 }
90
91 static const char *
snic_io_status_to_str(unsigned int state)92 snic_io_status_to_str(unsigned int state)
93 {
94 if ((state >= ARRAY_SIZE(snic_io_status_str)) ||
95 (!snic_io_status_str[state]))
96 return "Unknown";
97
98 return snic_io_status_str[state];
99 }
100
101 static const char *
snic_ioreq_state_to_str(unsigned int state)102 snic_ioreq_state_to_str(unsigned int state)
103 {
104 if (state >= ARRAY_SIZE(snic_req_state_str) ||
105 !snic_req_state_str[state])
106 return "Unknown";
107
108 return snic_req_state_str[state];
109 }
110
111 static inline spinlock_t *
snic_io_lock_hash(struct snic * snic,struct scsi_cmnd * sc)112 snic_io_lock_hash(struct snic *snic, struct scsi_cmnd *sc)
113 {
114 u32 hash = snic_cmd_tag(sc) & (SNIC_IO_LOCKS - 1);
115
116 return &snic->io_req_lock[hash];
117 }
118
119 static inline spinlock_t *
snic_io_lock_tag(struct snic * snic,int tag)120 snic_io_lock_tag(struct snic *snic, int tag)
121 {
122 return &snic->io_req_lock[tag & (SNIC_IO_LOCKS - 1)];
123 }
124
125 /* snic_release_req_buf : Releases snic_req_info */
126 static void
snic_release_req_buf(struct snic * snic,struct snic_req_info * rqi,struct scsi_cmnd * sc)127 snic_release_req_buf(struct snic *snic,
128 struct snic_req_info *rqi,
129 struct scsi_cmnd *sc)
130 {
131 struct snic_host_req *req = rqi_to_req(rqi);
132
133 /* Freeing cmd without marking completion, not okay */
134 SNIC_BUG_ON(!((CMD_STATE(sc) == SNIC_IOREQ_COMPLETE) ||
135 (CMD_STATE(sc) == SNIC_IOREQ_ABTS_COMPLETE) ||
136 (CMD_FLAGS(sc) & SNIC_DEV_RST_NOTSUP) ||
137 (CMD_FLAGS(sc) & SNIC_IO_INTERNAL_TERM_ISSUED) ||
138 (CMD_FLAGS(sc) & SNIC_DEV_RST_TERM_ISSUED) ||
139 (CMD_FLAGS(sc) & SNIC_SCSI_CLEANUP) ||
140 (CMD_STATE(sc) == SNIC_IOREQ_LR_COMPLETE)));
141
142 SNIC_SCSI_DBG(snic->shost,
143 "Rel_req:sc %p:tag %x:rqi %p:ioreq %p:abt %p:dr %p: state %s:flags 0x%llx\n",
144 sc, snic_cmd_tag(sc), rqi, rqi->req, rqi->abort_req,
145 rqi->dr_req, snic_ioreq_state_to_str(CMD_STATE(sc)),
146 CMD_FLAGS(sc));
147
148 if (req->u.icmnd.sense_addr)
149 dma_unmap_single(&snic->pdev->dev,
150 le64_to_cpu(req->u.icmnd.sense_addr),
151 SCSI_SENSE_BUFFERSIZE,
152 DMA_FROM_DEVICE);
153
154 scsi_dma_unmap(sc);
155
156 snic_req_free(snic, rqi);
157 } /* end of snic_release_req_buf */
158
159 /*
160 * snic_queue_icmnd_req : Queues snic_icmnd request
161 */
162 static int
snic_queue_icmnd_req(struct snic * snic,struct snic_req_info * rqi,struct scsi_cmnd * sc,int sg_cnt)163 snic_queue_icmnd_req(struct snic *snic,
164 struct snic_req_info *rqi,
165 struct scsi_cmnd *sc,
166 int sg_cnt)
167 {
168 struct scatterlist *sg;
169 struct snic_sg_desc *sgd;
170 dma_addr_t pa = 0;
171 struct scsi_lun lun;
172 u16 flags = 0;
173 int ret = 0;
174 unsigned int i;
175
176 if (sg_cnt) {
177 flags = SNIC_ICMND_ESGL;
178 sgd = (struct snic_sg_desc *) req_to_sgl(rqi->req);
179
180 for_each_sg(scsi_sglist(sc), sg, sg_cnt, i) {
181 sgd->addr = cpu_to_le64(sg_dma_address(sg));
182 sgd->len = cpu_to_le32(sg_dma_len(sg));
183 sgd->_resvd = 0;
184 sgd++;
185 }
186 }
187
188 pa = dma_map_single(&snic->pdev->dev,
189 sc->sense_buffer,
190 SCSI_SENSE_BUFFERSIZE,
191 DMA_FROM_DEVICE);
192 if (dma_mapping_error(&snic->pdev->dev, pa)) {
193 SNIC_HOST_ERR(snic->shost,
194 "QIcmnd:PCI Map Failed for sns buf %p tag %x\n",
195 sc->sense_buffer, snic_cmd_tag(sc));
196 ret = -ENOMEM;
197
198 return ret;
199 }
200
201 int_to_scsilun(sc->device->lun, &lun);
202 if (sc->sc_data_direction == DMA_FROM_DEVICE)
203 flags |= SNIC_ICMND_RD;
204 if (sc->sc_data_direction == DMA_TO_DEVICE)
205 flags |= SNIC_ICMND_WR;
206
207 /* Initialize icmnd */
208 snic_icmnd_init(rqi->req,
209 snic_cmd_tag(sc),
210 snic->config.hid, /* hid */
211 (ulong) rqi,
212 flags, /* command flags */
213 rqi->tgt_id,
214 lun.scsi_lun,
215 sc->cmnd,
216 sc->cmd_len,
217 scsi_bufflen(sc),
218 sg_cnt,
219 (ulong) req_to_sgl(rqi->req),
220 pa, /* sense buffer pa */
221 SCSI_SENSE_BUFFERSIZE);
222
223 atomic64_inc(&snic->s_stats.io.active);
224 ret = snic_queue_wq_desc(snic, rqi->req, rqi->req_len);
225 if (ret) {
226 atomic64_dec(&snic->s_stats.io.active);
227 SNIC_HOST_ERR(snic->shost,
228 "QIcmnd: Queuing Icmnd Failed. ret = %d\n",
229 ret);
230 } else
231 snic_stats_update_active_ios(&snic->s_stats);
232
233 return ret;
234 } /* end of snic_queue_icmnd_req */
235
236 /*
237 * snic_issue_scsi_req : Prepares IO request and Issues to FW.
238 */
239 static int
snic_issue_scsi_req(struct snic * snic,struct snic_tgt * tgt,struct scsi_cmnd * sc)240 snic_issue_scsi_req(struct snic *snic,
241 struct snic_tgt *tgt,
242 struct scsi_cmnd *sc)
243 {
244 struct snic_req_info *rqi = NULL;
245 int sg_cnt = 0;
246 int ret = 0;
247 u32 tag = snic_cmd_tag(sc);
248 u64 cmd_trc = 0, cmd_st_flags = 0;
249 spinlock_t *io_lock = NULL;
250 unsigned long flags;
251
252 CMD_STATE(sc) = SNIC_IOREQ_NOT_INITED;
253 CMD_FLAGS(sc) = SNIC_NO_FLAGS;
254 sg_cnt = scsi_dma_map(sc);
255 if (sg_cnt < 0) {
256 SNIC_TRC((u16)snic->shost->host_no, tag, (ulong) sc, 0,
257 sc->cmnd[0], sg_cnt, CMD_STATE(sc));
258
259 SNIC_HOST_ERR(snic->shost, "issue_sc:Failed to map SG List.\n");
260 ret = -ENOMEM;
261
262 goto issue_sc_end;
263 }
264
265 rqi = snic_req_init(snic, sg_cnt);
266 if (!rqi) {
267 scsi_dma_unmap(sc);
268 ret = -ENOMEM;
269
270 goto issue_sc_end;
271 }
272
273 rqi->tgt_id = tgt->id;
274 rqi->sc = sc;
275
276 CMD_STATE(sc) = SNIC_IOREQ_PENDING;
277 CMD_SP(sc) = (char *) rqi;
278 cmd_trc = SNIC_TRC_CMD(sc);
279 CMD_FLAGS(sc) |= (SNIC_IO_INITIALIZED | SNIC_IO_ISSUED);
280 cmd_st_flags = SNIC_TRC_CMD_STATE_FLAGS(sc);
281 io_lock = snic_io_lock_hash(snic, sc);
282
283 /* create wq desc and enqueue it */
284 ret = snic_queue_icmnd_req(snic, rqi, sc, sg_cnt);
285 if (ret) {
286 SNIC_HOST_ERR(snic->shost,
287 "issue_sc: icmnd qing Failed for sc %p, err %d\n",
288 sc, ret);
289
290 spin_lock_irqsave(io_lock, flags);
291 rqi = (struct snic_req_info *) CMD_SP(sc);
292 CMD_SP(sc) = NULL;
293 CMD_STATE(sc) = SNIC_IOREQ_COMPLETE;
294 CMD_FLAGS(sc) &= ~SNIC_IO_ISSUED; /* turn off the flag */
295 spin_unlock_irqrestore(io_lock, flags);
296
297 if (rqi)
298 snic_release_req_buf(snic, rqi, sc);
299
300 SNIC_TRC(snic->shost->host_no, tag, (ulong) sc, 0, 0, 0,
301 SNIC_TRC_CMD_STATE_FLAGS(sc));
302 } else {
303 u32 io_sz = scsi_bufflen(sc) >> 9;
304 u32 qtime = jiffies - rqi->start_time;
305 struct snic_io_stats *iostats = &snic->s_stats.io;
306
307 if (io_sz > atomic64_read(&iostats->max_io_sz))
308 atomic64_set(&iostats->max_io_sz, io_sz);
309
310 if (qtime > atomic64_read(&iostats->max_qtime))
311 atomic64_set(&iostats->max_qtime, qtime);
312
313 SNIC_SCSI_DBG(snic->shost,
314 "issue_sc:sc %p, tag %d queued to WQ.\n",
315 sc, tag);
316
317 SNIC_TRC(snic->shost->host_no, tag, (ulong) sc, (ulong) rqi,
318 sg_cnt, cmd_trc, cmd_st_flags);
319 }
320
321 issue_sc_end:
322
323 return ret;
324 } /* end of snic_issue_scsi_req */
325
326
327 /*
328 * snic_queuecommand
329 * Routine to send a scsi cdb to LLD
330 * Called with host_lock held and interrupts disabled
331 */
332 int
snic_queuecommand(struct Scsi_Host * shost,struct scsi_cmnd * sc)333 snic_queuecommand(struct Scsi_Host *shost, struct scsi_cmnd *sc)
334 {
335 struct snic_tgt *tgt = NULL;
336 struct snic *snic = shost_priv(shost);
337 int ret;
338
339 tgt = starget_to_tgt(scsi_target(sc->device));
340 ret = snic_tgt_chkready(tgt);
341 if (ret) {
342 SNIC_HOST_ERR(shost, "Tgt %p id %d Not Ready.\n", tgt, tgt->id);
343 atomic64_inc(&snic->s_stats.misc.tgt_not_rdy);
344 sc->result = ret;
345 sc->scsi_done(sc);
346
347 return 0;
348 }
349
350 if (snic_get_state(snic) != SNIC_ONLINE) {
351 SNIC_HOST_ERR(shost, "snic state is %s\n",
352 snic_state_str[snic_get_state(snic)]);
353
354 return SCSI_MLQUEUE_HOST_BUSY;
355 }
356 atomic_inc(&snic->ios_inflight);
357
358 SNIC_SCSI_DBG(shost, "sc %p Tag %d (sc %0x) lun %lld in snic_qcmd\n",
359 sc, snic_cmd_tag(sc), sc->cmnd[0], sc->device->lun);
360
361 ret = snic_issue_scsi_req(snic, tgt, sc);
362 if (ret) {
363 SNIC_HOST_ERR(shost, "Failed to Q, Scsi Req w/ err %d.\n", ret);
364 ret = SCSI_MLQUEUE_HOST_BUSY;
365 }
366
367 atomic_dec(&snic->ios_inflight);
368
369 return ret;
370 } /* end of snic_queuecommand */
371
372 /*
373 * snic_process_abts_pending_state:
374 * caller should hold IO lock
375 */
376 static void
snic_proc_tmreq_pending_state(struct snic * snic,struct scsi_cmnd * sc,u8 cmpl_status)377 snic_proc_tmreq_pending_state(struct snic *snic,
378 struct scsi_cmnd *sc,
379 u8 cmpl_status)
380 {
381 int state = CMD_STATE(sc);
382
383 if (state == SNIC_IOREQ_ABTS_PENDING)
384 CMD_FLAGS(sc) |= SNIC_IO_ABTS_PENDING;
385 else if (state == SNIC_IOREQ_LR_PENDING)
386 CMD_FLAGS(sc) |= SNIC_DEV_RST_PENDING;
387 else
388 SNIC_BUG_ON(1);
389
390 switch (cmpl_status) {
391 case SNIC_STAT_IO_SUCCESS:
392 CMD_FLAGS(sc) |= SNIC_IO_DONE;
393 break;
394
395 case SNIC_STAT_ABORTED:
396 CMD_FLAGS(sc) |= SNIC_IO_ABORTED;
397 break;
398
399 default:
400 SNIC_BUG_ON(1);
401 }
402 }
403
404 /*
405 * snic_process_io_failed_state:
406 * Processes IO's error states
407 */
408 static void
snic_process_io_failed_state(struct snic * snic,struct snic_icmnd_cmpl * icmnd_cmpl,struct scsi_cmnd * sc,u8 cmpl_stat)409 snic_process_io_failed_state(struct snic *snic,
410 struct snic_icmnd_cmpl *icmnd_cmpl,
411 struct scsi_cmnd *sc,
412 u8 cmpl_stat)
413 {
414 int res = 0;
415
416 switch (cmpl_stat) {
417 case SNIC_STAT_TIMEOUT: /* Req was timedout */
418 atomic64_inc(&snic->s_stats.misc.io_tmo);
419 res = DID_TIME_OUT;
420 break;
421
422 case SNIC_STAT_ABORTED: /* Req was aborted */
423 atomic64_inc(&snic->s_stats.misc.io_aborted);
424 res = DID_ABORT;
425 break;
426
427 case SNIC_STAT_DATA_CNT_MISMATCH:/* Recv/Sent more/less data than exp */
428 atomic64_inc(&snic->s_stats.misc.data_cnt_mismat);
429 scsi_set_resid(sc, le32_to_cpu(icmnd_cmpl->resid));
430 res = DID_ERROR;
431 break;
432
433 case SNIC_STAT_OUT_OF_RES: /* Out of resources to complete request */
434 atomic64_inc(&snic->s_stats.fw.out_of_res);
435 res = DID_REQUEUE;
436 break;
437
438 case SNIC_STAT_IO_NOT_FOUND: /* Requested I/O was not found */
439 atomic64_inc(&snic->s_stats.io.io_not_found);
440 res = DID_ERROR;
441 break;
442
443 case SNIC_STAT_SGL_INVALID: /* Req was aborted to due to sgl error*/
444 atomic64_inc(&snic->s_stats.misc.sgl_inval);
445 res = DID_ERROR;
446 break;
447
448 case SNIC_STAT_FW_ERR: /* Req terminated due to FW Error */
449 atomic64_inc(&snic->s_stats.fw.io_errs);
450 res = DID_ERROR;
451 break;
452
453 case SNIC_STAT_SCSI_ERR: /* FW hits SCSI Error */
454 atomic64_inc(&snic->s_stats.fw.scsi_errs);
455 break;
456
457 case SNIC_STAT_NOT_READY: /* XPT yet to initialize */
458 case SNIC_STAT_DEV_OFFLINE: /* Device offline */
459 res = DID_NO_CONNECT;
460 break;
461
462 case SNIC_STAT_INVALID_HDR: /* Hdr contains invalid data */
463 case SNIC_STAT_INVALID_PARM: /* Some param in req is invalid */
464 case SNIC_STAT_REQ_NOT_SUP: /* Req type is not supported */
465 case SNIC_STAT_CMND_REJECT: /* Req rejected */
466 case SNIC_STAT_FATAL_ERROR: /* XPT Error */
467 default:
468 SNIC_SCSI_DBG(snic->shost,
469 "Invalid Hdr/Param or Req Not Supported or Cmnd Rejected or Device Offline. or Unknown\n");
470 res = DID_ERROR;
471 break;
472 }
473
474 SNIC_HOST_ERR(snic->shost, "fw returns failed status %s flags 0x%llx\n",
475 snic_io_status_to_str(cmpl_stat), CMD_FLAGS(sc));
476
477 /* Set sc->result */
478 sc->result = (res << 16) | icmnd_cmpl->scsi_status;
479 } /* end of snic_process_io_failed_state */
480
481 /*
482 * snic_tmreq_pending : is task management in progress.
483 */
484 static int
snic_tmreq_pending(struct scsi_cmnd * sc)485 snic_tmreq_pending(struct scsi_cmnd *sc)
486 {
487 int state = CMD_STATE(sc);
488
489 return ((state == SNIC_IOREQ_ABTS_PENDING) ||
490 (state == SNIC_IOREQ_LR_PENDING));
491 }
492
493 /*
494 * snic_process_icmnd_cmpl_status:
495 * Caller should hold io_lock
496 */
497 static int
snic_process_icmnd_cmpl_status(struct snic * snic,struct snic_icmnd_cmpl * icmnd_cmpl,u8 cmpl_stat,struct scsi_cmnd * sc)498 snic_process_icmnd_cmpl_status(struct snic *snic,
499 struct snic_icmnd_cmpl *icmnd_cmpl,
500 u8 cmpl_stat,
501 struct scsi_cmnd *sc)
502 {
503 u8 scsi_stat = icmnd_cmpl->scsi_status;
504 u64 xfer_len = 0;
505 int ret = 0;
506
507 /* Mark the IO as complete */
508 CMD_STATE(sc) = SNIC_IOREQ_COMPLETE;
509
510 if (likely(cmpl_stat == SNIC_STAT_IO_SUCCESS)) {
511 sc->result = (DID_OK << 16) | scsi_stat;
512
513 xfer_len = scsi_bufflen(sc);
514
515 /* Update SCSI Cmd with resid value */
516 scsi_set_resid(sc, le32_to_cpu(icmnd_cmpl->resid));
517
518 if (icmnd_cmpl->flags & SNIC_ICMND_CMPL_UNDR_RUN) {
519 xfer_len -= le32_to_cpu(icmnd_cmpl->resid);
520 atomic64_inc(&snic->s_stats.misc.io_under_run);
521 }
522
523 if (icmnd_cmpl->scsi_status == SAM_STAT_TASK_SET_FULL)
524 atomic64_inc(&snic->s_stats.misc.qfull);
525
526 ret = 0;
527 } else {
528 snic_process_io_failed_state(snic, icmnd_cmpl, sc, cmpl_stat);
529 atomic64_inc(&snic->s_stats.io.fail);
530 SNIC_HOST_ERR(snic->shost,
531 "icmnd_cmpl: IO Failed : Hdr Status %s flags 0x%llx\n",
532 snic_io_status_to_str(cmpl_stat), CMD_FLAGS(sc));
533 ret = 1;
534 }
535
536 return ret;
537 } /* end of snic_process_icmnd_cmpl_status */
538
539
540 /*
541 * snic_icmnd_cmpl_handler
542 * Routine to handle icmnd completions
543 */
544 static void
snic_icmnd_cmpl_handler(struct snic * snic,struct snic_fw_req * fwreq)545 snic_icmnd_cmpl_handler(struct snic *snic, struct snic_fw_req *fwreq)
546 {
547 u8 typ, hdr_stat;
548 u32 cmnd_id, hid;
549 ulong ctx;
550 struct scsi_cmnd *sc = NULL;
551 struct snic_icmnd_cmpl *icmnd_cmpl = NULL;
552 struct snic_host_req *req = NULL;
553 struct snic_req_info *rqi = NULL;
554 unsigned long flags, start_time;
555 spinlock_t *io_lock;
556 u8 sc_stat = 0;
557
558 snic_io_hdr_dec(&fwreq->hdr, &typ, &hdr_stat, &cmnd_id, &hid, &ctx);
559 icmnd_cmpl = &fwreq->u.icmnd_cmpl;
560 sc_stat = icmnd_cmpl->scsi_status;
561
562 SNIC_SCSI_DBG(snic->shost,
563 "Icmnd_cmpl: type = %x, hdr_stat = %x, cmnd_id = %x, hid = %x,i ctx = %lx\n",
564 typ, hdr_stat, cmnd_id, hid, ctx);
565
566 if (cmnd_id >= snic->max_tag_id) {
567 SNIC_HOST_ERR(snic->shost,
568 "Icmnd_cmpl:Tag Error:Out of Range Tag %d, hdr status = %s\n",
569 cmnd_id, snic_io_status_to_str(hdr_stat));
570 return;
571 }
572
573 sc = scsi_host_find_tag(snic->shost, cmnd_id);
574 WARN_ON_ONCE(!sc);
575
576 if (!sc) {
577 atomic64_inc(&snic->s_stats.io.sc_null);
578 SNIC_HOST_ERR(snic->shost,
579 "Icmnd_cmpl: Scsi Cmnd Not found, sc = NULL Hdr Status = %s tag = 0x%x fwreq = 0x%p\n",
580 snic_io_status_to_str(hdr_stat),
581 cmnd_id,
582 fwreq);
583
584 SNIC_TRC(snic->shost->host_no, cmnd_id, 0,
585 ((u64)hdr_stat << 16 |
586 (u64)sc_stat << 8 | (u64)icmnd_cmpl->flags),
587 (ulong) fwreq, le32_to_cpu(icmnd_cmpl->resid), ctx);
588
589 return;
590 }
591
592 io_lock = snic_io_lock_hash(snic, sc);
593
594 spin_lock_irqsave(io_lock, flags);
595 rqi = (struct snic_req_info *) CMD_SP(sc);
596 SNIC_SCSI_DBG(snic->shost,
597 "Icmnd_cmpl:lun %lld sc %p cmd %xtag %d flags 0x%llx rqi %p\n",
598 sc->device->lun, sc, sc->cmnd[0], snic_cmd_tag(sc),
599 CMD_FLAGS(sc), rqi);
600
601 if (CMD_FLAGS(sc) & SNIC_HOST_RESET_CMD_TERM) {
602 spin_unlock_irqrestore(io_lock, flags);
603
604 return;
605 }
606
607 SNIC_BUG_ON(rqi != (struct snic_req_info *)ctx);
608 WARN_ON_ONCE(req);
609 if (!rqi) {
610 atomic64_inc(&snic->s_stats.io.req_null);
611 CMD_FLAGS(sc) |= SNIC_IO_REQ_NULL;
612 spin_unlock_irqrestore(io_lock, flags);
613
614 SNIC_HOST_ERR(snic->shost,
615 "Icmnd_cmpl:Host Req Not Found(null), Hdr Status %s, Tag 0x%x, sc 0x%p flags 0x%llx\n",
616 snic_io_status_to_str(hdr_stat),
617 cmnd_id, sc, CMD_FLAGS(sc));
618 return;
619 }
620
621 rqi = (struct snic_req_info *) ctx;
622 start_time = rqi->start_time;
623
624 /* firmware completed the io */
625 rqi->io_cmpl = 1;
626
627 /*
628 * if SCSI-ML has already issued abort on this command,
629 * ignore completion of the IO. The abts path will clean it up
630 */
631 if (unlikely(snic_tmreq_pending(sc))) {
632 snic_proc_tmreq_pending_state(snic, sc, hdr_stat);
633 spin_unlock_irqrestore(io_lock, flags);
634
635 snic_stats_update_io_cmpl(&snic->s_stats);
636
637 /* Expected value is SNIC_STAT_ABORTED */
638 if (likely(hdr_stat == SNIC_STAT_ABORTED))
639 return;
640
641 SNIC_SCSI_DBG(snic->shost,
642 "icmnd_cmpl:TM Req Pending(%s), Hdr Status %s sc 0x%p scsi status %x resid %d flags 0x%llx\n",
643 snic_ioreq_state_to_str(CMD_STATE(sc)),
644 snic_io_status_to_str(hdr_stat),
645 sc, sc_stat, le32_to_cpu(icmnd_cmpl->resid),
646 CMD_FLAGS(sc));
647
648 SNIC_TRC(snic->shost->host_no, cmnd_id, (ulong) sc,
649 jiffies_to_msecs(jiffies - start_time), (ulong) fwreq,
650 SNIC_TRC_CMD(sc), SNIC_TRC_CMD_STATE_FLAGS(sc));
651
652 return;
653 }
654
655 if (snic_process_icmnd_cmpl_status(snic, icmnd_cmpl, hdr_stat, sc)) {
656 scsi_print_command(sc);
657 SNIC_HOST_ERR(snic->shost,
658 "icmnd_cmpl:IO Failed, sc 0x%p Tag %d Cmd %x Hdr Status %s flags 0x%llx\n",
659 sc, sc->cmnd[0], cmnd_id,
660 snic_io_status_to_str(hdr_stat), CMD_FLAGS(sc));
661 }
662
663 /* Break link with the SCSI Command */
664 CMD_SP(sc) = NULL;
665 CMD_FLAGS(sc) |= SNIC_IO_DONE;
666
667 spin_unlock_irqrestore(io_lock, flags);
668
669 /* For now, consider only successful IO. */
670 snic_calc_io_process_time(snic, rqi);
671
672 snic_release_req_buf(snic, rqi, sc);
673
674 SNIC_TRC(snic->shost->host_no, cmnd_id, (ulong) sc,
675 jiffies_to_msecs(jiffies - start_time), (ulong) fwreq,
676 SNIC_TRC_CMD(sc), SNIC_TRC_CMD_STATE_FLAGS(sc));
677
678
679 if (sc->scsi_done)
680 sc->scsi_done(sc);
681
682 snic_stats_update_io_cmpl(&snic->s_stats);
683 } /* end of snic_icmnd_cmpl_handler */
684
685 static void
snic_proc_dr_cmpl_locked(struct snic * snic,struct snic_fw_req * fwreq,u8 cmpl_stat,u32 cmnd_id,struct scsi_cmnd * sc)686 snic_proc_dr_cmpl_locked(struct snic *snic,
687 struct snic_fw_req *fwreq,
688 u8 cmpl_stat,
689 u32 cmnd_id,
690 struct scsi_cmnd *sc)
691 {
692 struct snic_req_info *rqi = (struct snic_req_info *) CMD_SP(sc);
693 u32 start_time = rqi->start_time;
694
695 CMD_LR_STATUS(sc) = cmpl_stat;
696
697 SNIC_SCSI_DBG(snic->shost, "itmf_cmpl: Cmd State = %s\n",
698 snic_ioreq_state_to_str(CMD_STATE(sc)));
699
700 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING) {
701 CMD_FLAGS(sc) |= SNIC_DEV_RST_ABTS_PENDING;
702
703 SNIC_TRC(snic->shost->host_no, cmnd_id, (ulong) sc,
704 jiffies_to_msecs(jiffies - start_time),
705 (ulong) fwreq, 0, SNIC_TRC_CMD_STATE_FLAGS(sc));
706
707 SNIC_SCSI_DBG(snic->shost,
708 "itmf_cmpl: Terminate Pending Dev Reset Cmpl Recvd.id %x, status %s flags 0x%llx\n",
709 (int)(cmnd_id & SNIC_TAG_MASK),
710 snic_io_status_to_str(cmpl_stat),
711 CMD_FLAGS(sc));
712
713 return;
714 }
715
716
717 if (CMD_FLAGS(sc) & SNIC_DEV_RST_TIMEDOUT) {
718 SNIC_TRC(snic->shost->host_no, cmnd_id, (ulong) sc,
719 jiffies_to_msecs(jiffies - start_time),
720 (ulong) fwreq, 0, SNIC_TRC_CMD_STATE_FLAGS(sc));
721
722 SNIC_SCSI_DBG(snic->shost,
723 "itmf_cmpl:Dev Reset Completion Received after timeout. id %d cmpl status %s flags 0x%llx\n",
724 (int)(cmnd_id & SNIC_TAG_MASK),
725 snic_io_status_to_str(cmpl_stat),
726 CMD_FLAGS(sc));
727
728 return;
729 }
730
731 CMD_STATE(sc) = SNIC_IOREQ_LR_COMPLETE;
732 CMD_FLAGS(sc) |= SNIC_DEV_RST_DONE;
733
734 SNIC_SCSI_DBG(snic->shost,
735 "itmf_cmpl:Dev Reset Cmpl Recvd id %d cmpl status %s flags 0x%llx\n",
736 (int)(cmnd_id & SNIC_TAG_MASK),
737 snic_io_status_to_str(cmpl_stat),
738 CMD_FLAGS(sc));
739
740 if (rqi->dr_done)
741 complete(rqi->dr_done);
742 } /* end of snic_proc_dr_cmpl_locked */
743
744 /*
745 * snic_update_abort_stats : Updates abort stats based on completion status.
746 */
747 static void
snic_update_abort_stats(struct snic * snic,u8 cmpl_stat)748 snic_update_abort_stats(struct snic *snic, u8 cmpl_stat)
749 {
750 struct snic_abort_stats *abt_stats = &snic->s_stats.abts;
751
752 SNIC_SCSI_DBG(snic->shost, "Updating Abort stats.\n");
753
754 switch (cmpl_stat) {
755 case SNIC_STAT_IO_SUCCESS:
756 break;
757
758 case SNIC_STAT_TIMEOUT:
759 atomic64_inc(&abt_stats->fw_tmo);
760 break;
761
762 case SNIC_STAT_IO_NOT_FOUND:
763 atomic64_inc(&abt_stats->io_not_found);
764 break;
765
766 default:
767 atomic64_inc(&abt_stats->fail);
768 break;
769 }
770 }
771
772 static int
snic_process_itmf_cmpl(struct snic * snic,struct snic_fw_req * fwreq,u32 cmnd_id,u8 cmpl_stat,struct scsi_cmnd * sc)773 snic_process_itmf_cmpl(struct snic *snic,
774 struct snic_fw_req *fwreq,
775 u32 cmnd_id,
776 u8 cmpl_stat,
777 struct scsi_cmnd *sc)
778 {
779 struct snic_req_info *rqi = NULL;
780 u32 tm_tags = 0;
781 spinlock_t *io_lock = NULL;
782 unsigned long flags;
783 u32 start_time = 0;
784 int ret = 0;
785
786 io_lock = snic_io_lock_hash(snic, sc);
787 spin_lock_irqsave(io_lock, flags);
788 if (CMD_FLAGS(sc) & SNIC_HOST_RESET_CMD_TERM) {
789 spin_unlock_irqrestore(io_lock, flags);
790
791 return ret;
792 }
793 rqi = (struct snic_req_info *) CMD_SP(sc);
794 WARN_ON_ONCE(!rqi);
795
796 if (!rqi) {
797 atomic64_inc(&snic->s_stats.io.req_null);
798 spin_unlock_irqrestore(io_lock, flags);
799 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TERM_REQ_NULL;
800 SNIC_HOST_ERR(snic->shost,
801 "itmf_cmpl: rqi is null,Hdr stat = %s Tag = 0x%x sc = 0x%p flags 0x%llx\n",
802 snic_io_status_to_str(cmpl_stat), cmnd_id, sc,
803 CMD_FLAGS(sc));
804
805 return ret;
806 }
807
808 /* Extract task management flags */
809 tm_tags = cmnd_id & ~(SNIC_TAG_MASK);
810
811 start_time = rqi->start_time;
812 cmnd_id &= (SNIC_TAG_MASK);
813
814 switch (tm_tags) {
815 case SNIC_TAG_ABORT:
816 /* Abort only issued on cmd */
817 snic_update_abort_stats(snic, cmpl_stat);
818
819 if (CMD_STATE(sc) != SNIC_IOREQ_ABTS_PENDING) {
820 /* This is a late completion. Ignore it. */
821 ret = -1;
822 spin_unlock_irqrestore(io_lock, flags);
823 break;
824 }
825
826 CMD_STATE(sc) = SNIC_IOREQ_ABTS_COMPLETE;
827 CMD_ABTS_STATUS(sc) = cmpl_stat;
828 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TERM_DONE;
829
830 SNIC_SCSI_DBG(snic->shost,
831 "itmf_cmpl:Abort Cmpl Recvd.Tag 0x%x Status %s flags 0x%llx\n",
832 cmnd_id,
833 snic_io_status_to_str(cmpl_stat),
834 CMD_FLAGS(sc));
835
836 /*
837 * If scsi_eh thread is blocked waiting for abts complete,
838 * signal completion to it. IO will be cleaned in the thread,
839 * else clean it in this context.
840 */
841 if (rqi->abts_done) {
842 complete(rqi->abts_done);
843 spin_unlock_irqrestore(io_lock, flags);
844
845 break; /* jump out */
846 }
847
848 CMD_SP(sc) = NULL;
849 sc->result = (DID_ERROR << 16);
850 SNIC_SCSI_DBG(snic->shost,
851 "itmf_cmpl: Completing IO. sc %p flags 0x%llx\n",
852 sc, CMD_FLAGS(sc));
853
854 spin_unlock_irqrestore(io_lock, flags);
855
856 snic_release_req_buf(snic, rqi, sc);
857
858 if (sc->scsi_done) {
859 SNIC_TRC(snic->shost->host_no, cmnd_id, (ulong) sc,
860 jiffies_to_msecs(jiffies - start_time),
861 (ulong) fwreq, SNIC_TRC_CMD(sc),
862 SNIC_TRC_CMD_STATE_FLAGS(sc));
863
864 sc->scsi_done(sc);
865 }
866
867 break;
868
869 case SNIC_TAG_DEV_RST:
870 case SNIC_TAG_DEV_RST | SNIC_TAG_IOCTL_DEV_RST:
871 snic_proc_dr_cmpl_locked(snic, fwreq, cmpl_stat, cmnd_id, sc);
872 spin_unlock_irqrestore(io_lock, flags);
873 ret = 0;
874
875 break;
876
877 case SNIC_TAG_ABORT | SNIC_TAG_DEV_RST:
878 /* Abort and terminate completion of device reset req */
879
880 CMD_STATE(sc) = SNIC_IOREQ_ABTS_COMPLETE;
881 CMD_ABTS_STATUS(sc) = cmpl_stat;
882 CMD_FLAGS(sc) |= SNIC_DEV_RST_DONE;
883
884 SNIC_SCSI_DBG(snic->shost,
885 "itmf_cmpl:dev reset abts cmpl recvd. id %d status %s flags 0x%llx\n",
886 cmnd_id, snic_io_status_to_str(cmpl_stat),
887 CMD_FLAGS(sc));
888
889 if (rqi->abts_done)
890 complete(rqi->abts_done);
891
892 spin_unlock_irqrestore(io_lock, flags);
893
894 break;
895
896 default:
897 spin_unlock_irqrestore(io_lock, flags);
898 SNIC_HOST_ERR(snic->shost,
899 "itmf_cmpl: Unknown TM tag bit 0x%x\n", tm_tags);
900
901 SNIC_HOST_ERR(snic->shost,
902 "itmf_cmpl:Unexpected itmf io stat %s Tag = 0x%x flags 0x%llx\n",
903 snic_ioreq_state_to_str(CMD_STATE(sc)),
904 cmnd_id,
905 CMD_FLAGS(sc));
906 ret = -1;
907 SNIC_BUG_ON(1);
908
909 break;
910 }
911
912 return ret;
913 } /* end of snic_process_itmf_cmpl_status */
914
915 /*
916 * snic_itmf_cmpl_handler.
917 * Routine to handle itmf completions.
918 */
919 static void
snic_itmf_cmpl_handler(struct snic * snic,struct snic_fw_req * fwreq)920 snic_itmf_cmpl_handler(struct snic *snic, struct snic_fw_req *fwreq)
921 {
922 struct scsi_cmnd *sc = NULL;
923 struct snic_req_info *rqi = NULL;
924 struct snic_itmf_cmpl *itmf_cmpl = NULL;
925 ulong ctx;
926 u32 cmnd_id;
927 u32 hid;
928 u8 typ;
929 u8 hdr_stat;
930
931 snic_io_hdr_dec(&fwreq->hdr, &typ, &hdr_stat, &cmnd_id, &hid, &ctx);
932 SNIC_SCSI_DBG(snic->shost,
933 "Itmf_cmpl: %s: type = %x, hdr_stat = %x, cmnd_id = %x, hid = %x,ctx = %lx\n",
934 __func__, typ, hdr_stat, cmnd_id, hid, ctx);
935
936 itmf_cmpl = &fwreq->u.itmf_cmpl;
937 SNIC_SCSI_DBG(snic->shost,
938 "Itmf_cmpl: nterm %u , flags 0x%x\n",
939 le32_to_cpu(itmf_cmpl->nterminated), itmf_cmpl->flags);
940
941 /* spl case, dev reset issued through ioctl */
942 if (cmnd_id & SNIC_TAG_IOCTL_DEV_RST) {
943 rqi = (struct snic_req_info *) ctx;
944 sc = rqi->sc;
945
946 goto ioctl_dev_rst;
947 }
948
949 if ((cmnd_id & SNIC_TAG_MASK) >= snic->max_tag_id) {
950 SNIC_HOST_ERR(snic->shost,
951 "Itmf_cmpl: Tag 0x%x out of Range,HdrStat %s\n",
952 cmnd_id, snic_io_status_to_str(hdr_stat));
953 SNIC_BUG_ON(1);
954
955 return;
956 }
957
958 sc = scsi_host_find_tag(snic->shost, cmnd_id & SNIC_TAG_MASK);
959 WARN_ON_ONCE(!sc);
960
961 ioctl_dev_rst:
962 if (!sc) {
963 atomic64_inc(&snic->s_stats.io.sc_null);
964 SNIC_HOST_ERR(snic->shost,
965 "Itmf_cmpl: sc is NULL - Hdr Stat %s Tag 0x%x\n",
966 snic_io_status_to_str(hdr_stat), cmnd_id);
967
968 return;
969 }
970
971 snic_process_itmf_cmpl(snic, fwreq, cmnd_id, hdr_stat, sc);
972 } /* end of snic_itmf_cmpl_handler */
973
974
975
976 static void
snic_hba_reset_scsi_cleanup(struct snic * snic,struct scsi_cmnd * sc)977 snic_hba_reset_scsi_cleanup(struct snic *snic, struct scsi_cmnd *sc)
978 {
979 struct snic_stats *st = &snic->s_stats;
980 long act_ios = 0, act_fwreqs = 0;
981
982 SNIC_SCSI_DBG(snic->shost, "HBA Reset scsi cleanup.\n");
983 snic_scsi_cleanup(snic, snic_cmd_tag(sc));
984
985 /* Update stats on pending IOs */
986 act_ios = atomic64_read(&st->io.active);
987 atomic64_add(act_ios, &st->io.compl);
988 atomic64_sub(act_ios, &st->io.active);
989
990 act_fwreqs = atomic64_read(&st->fw.actv_reqs);
991 atomic64_sub(act_fwreqs, &st->fw.actv_reqs);
992 }
993
994 /*
995 * snic_hba_reset_cmpl_handler :
996 *
997 * Notes :
998 * 1. Cleanup all the scsi cmds, release all snic specific cmds
999 * 2. Issue Report Targets in case of SAN targets
1000 */
1001 static int
snic_hba_reset_cmpl_handler(struct snic * snic,struct snic_fw_req * fwreq)1002 snic_hba_reset_cmpl_handler(struct snic *snic, struct snic_fw_req *fwreq)
1003 {
1004 ulong ctx;
1005 u32 cmnd_id;
1006 u32 hid;
1007 u8 typ;
1008 u8 hdr_stat;
1009 struct scsi_cmnd *sc = NULL;
1010 struct snic_req_info *rqi = NULL;
1011 spinlock_t *io_lock = NULL;
1012 unsigned long flags, gflags;
1013 int ret = 0;
1014
1015 snic_io_hdr_dec(&fwreq->hdr, &typ, &hdr_stat, &cmnd_id, &hid, &ctx);
1016 SNIC_HOST_INFO(snic->shost,
1017 "reset_cmpl:Tag %d ctx %lx cmpl status %s HBA Reset Completion received.\n",
1018 cmnd_id, ctx, snic_io_status_to_str(hdr_stat));
1019
1020 SNIC_SCSI_DBG(snic->shost,
1021 "reset_cmpl: type = %x, hdr_stat = %x, cmnd_id = %x, hid = %x, ctx = %lx\n",
1022 typ, hdr_stat, cmnd_id, hid, ctx);
1023
1024 /* spl case, host reset issued through ioctl */
1025 if (cmnd_id == SCSI_NO_TAG) {
1026 rqi = (struct snic_req_info *) ctx;
1027 SNIC_HOST_INFO(snic->shost,
1028 "reset_cmpl:Tag %d ctx %lx cmpl stat %s\n",
1029 cmnd_id, ctx, snic_io_status_to_str(hdr_stat));
1030 sc = rqi->sc;
1031
1032 goto ioctl_hba_rst;
1033 }
1034
1035 if (cmnd_id >= snic->max_tag_id) {
1036 SNIC_HOST_ERR(snic->shost,
1037 "reset_cmpl: Tag 0x%x out of Range,HdrStat %s\n",
1038 cmnd_id, snic_io_status_to_str(hdr_stat));
1039 SNIC_BUG_ON(1);
1040
1041 return 1;
1042 }
1043
1044 sc = scsi_host_find_tag(snic->shost, cmnd_id);
1045 ioctl_hba_rst:
1046 if (!sc) {
1047 atomic64_inc(&snic->s_stats.io.sc_null);
1048 SNIC_HOST_ERR(snic->shost,
1049 "reset_cmpl: sc is NULL - Hdr Stat %s Tag 0x%x\n",
1050 snic_io_status_to_str(hdr_stat), cmnd_id);
1051 ret = 1;
1052
1053 return ret;
1054 }
1055
1056 SNIC_HOST_INFO(snic->shost,
1057 "reset_cmpl: sc %p rqi %p Tag %d flags 0x%llx\n",
1058 sc, rqi, cmnd_id, CMD_FLAGS(sc));
1059
1060 io_lock = snic_io_lock_hash(snic, sc);
1061 spin_lock_irqsave(io_lock, flags);
1062
1063 if (!snic->remove_wait) {
1064 spin_unlock_irqrestore(io_lock, flags);
1065 SNIC_HOST_ERR(snic->shost,
1066 "reset_cmpl:host reset completed after timeout\n");
1067 ret = 1;
1068
1069 return ret;
1070 }
1071
1072 rqi = (struct snic_req_info *) CMD_SP(sc);
1073 WARN_ON_ONCE(!rqi);
1074
1075 if (!rqi) {
1076 atomic64_inc(&snic->s_stats.io.req_null);
1077 spin_unlock_irqrestore(io_lock, flags);
1078 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TERM_REQ_NULL;
1079 SNIC_HOST_ERR(snic->shost,
1080 "reset_cmpl: rqi is null,Hdr stat %s Tag 0x%x sc 0x%p flags 0x%llx\n",
1081 snic_io_status_to_str(hdr_stat), cmnd_id, sc,
1082 CMD_FLAGS(sc));
1083
1084 ret = 1;
1085
1086 return ret;
1087 }
1088 /* stats */
1089 spin_unlock_irqrestore(io_lock, flags);
1090
1091 /* scsi cleanup */
1092 snic_hba_reset_scsi_cleanup(snic, sc);
1093
1094 SNIC_BUG_ON(snic_get_state(snic) != SNIC_OFFLINE &&
1095 snic_get_state(snic) != SNIC_FWRESET);
1096
1097 /* Careful locking between snic_lock and io lock */
1098 spin_lock_irqsave(io_lock, flags);
1099 spin_lock_irqsave(&snic->snic_lock, gflags);
1100 if (snic_get_state(snic) == SNIC_FWRESET)
1101 snic_set_state(snic, SNIC_ONLINE);
1102 spin_unlock_irqrestore(&snic->snic_lock, gflags);
1103
1104 if (snic->remove_wait)
1105 complete(snic->remove_wait);
1106
1107 spin_unlock_irqrestore(io_lock, flags);
1108 atomic64_inc(&snic->s_stats.reset.hba_reset_cmpl);
1109
1110 ret = 0;
1111 /* Rediscovery is for SAN */
1112 if (snic->config.xpt_type == SNIC_DAS)
1113 return ret;
1114
1115 SNIC_SCSI_DBG(snic->shost, "reset_cmpl: Queuing discovery work.\n");
1116 queue_work(snic_glob->event_q, &snic->disc_work);
1117
1118 return ret;
1119 }
1120
1121 static void
snic_msg_ack_handler(struct snic * snic,struct snic_fw_req * fwreq)1122 snic_msg_ack_handler(struct snic *snic, struct snic_fw_req *fwreq)
1123 {
1124 SNIC_HOST_INFO(snic->shost, "Message Ack Received.\n");
1125
1126 SNIC_ASSERT_NOT_IMPL(1);
1127 }
1128
1129 static void
snic_aen_handler(struct snic * snic,struct snic_fw_req * fwreq)1130 snic_aen_handler(struct snic *snic, struct snic_fw_req *fwreq)
1131 {
1132 u8 typ, hdr_stat;
1133 u32 cmnd_id, hid;
1134 ulong ctx;
1135 struct snic_async_evnotify *aen = &fwreq->u.async_ev;
1136 u32 event_id = 0;
1137
1138 snic_io_hdr_dec(&fwreq->hdr, &typ, &hdr_stat, &cmnd_id, &hid, &ctx);
1139 SNIC_SCSI_DBG(snic->shost,
1140 "aen: type = %x, hdr_stat = %x, cmnd_id = %x, hid = %x, ctx = %lx\n",
1141 typ, hdr_stat, cmnd_id, hid, ctx);
1142
1143 event_id = le32_to_cpu(aen->ev_id);
1144
1145 switch (event_id) {
1146 case SNIC_EV_TGT_OFFLINE:
1147 SNIC_HOST_INFO(snic->shost, "aen:TGT_OFFLINE Event Recvd.\n");
1148 break;
1149
1150 case SNIC_EV_TGT_ONLINE:
1151 SNIC_HOST_INFO(snic->shost, "aen:TGT_ONLINE Event Recvd.\n");
1152 break;
1153
1154 case SNIC_EV_LUN_OFFLINE:
1155 SNIC_HOST_INFO(snic->shost, "aen:LUN_OFFLINE Event Recvd.\n");
1156 break;
1157
1158 case SNIC_EV_LUN_ONLINE:
1159 SNIC_HOST_INFO(snic->shost, "aen:LUN_ONLINE Event Recvd.\n");
1160 break;
1161
1162 case SNIC_EV_CONF_CHG:
1163 SNIC_HOST_INFO(snic->shost, "aen:Config Change Event Recvd.\n");
1164 break;
1165
1166 case SNIC_EV_TGT_ADDED:
1167 SNIC_HOST_INFO(snic->shost, "aen:TGT_ADD Event Recvd.\n");
1168 break;
1169
1170 case SNIC_EV_TGT_DELTD:
1171 SNIC_HOST_INFO(snic->shost, "aen:TGT_DEL Event Recvd.\n");
1172 break;
1173
1174 case SNIC_EV_LUN_ADDED:
1175 SNIC_HOST_INFO(snic->shost, "aen:LUN_ADD Event Recvd.\n");
1176 break;
1177
1178 case SNIC_EV_LUN_DELTD:
1179 SNIC_HOST_INFO(snic->shost, "aen:LUN_DEL Event Recvd.\n");
1180 break;
1181
1182 case SNIC_EV_DISC_CMPL:
1183 SNIC_HOST_INFO(snic->shost, "aen:DISC_CMPL Event Recvd.\n");
1184 break;
1185
1186 default:
1187 SNIC_HOST_INFO(snic->shost, "aen:Unknown Event Recvd.\n");
1188 SNIC_BUG_ON(1);
1189 break;
1190 }
1191
1192 SNIC_ASSERT_NOT_IMPL(1);
1193 } /* end of snic_aen_handler */
1194
1195 /*
1196 * snic_io_cmpl_handler
1197 * Routine to process CQ entries(IO Completions) posted by fw.
1198 */
1199 static int
snic_io_cmpl_handler(struct vnic_dev * vdev,unsigned int cq_idx,struct snic_fw_req * fwreq)1200 snic_io_cmpl_handler(struct vnic_dev *vdev,
1201 unsigned int cq_idx,
1202 struct snic_fw_req *fwreq)
1203 {
1204 struct snic *snic = svnic_dev_priv(vdev);
1205 u64 start = jiffies, cmpl_time;
1206
1207 snic_print_desc(__func__, (char *)fwreq, sizeof(*fwreq));
1208
1209 /* Update FW Stats */
1210 if ((fwreq->hdr.type >= SNIC_RSP_REPORT_TGTS_CMPL) &&
1211 (fwreq->hdr.type <= SNIC_RSP_BOOT_LUNS_CMPL))
1212 atomic64_dec(&snic->s_stats.fw.actv_reqs);
1213
1214 SNIC_BUG_ON((fwreq->hdr.type > SNIC_RSP_BOOT_LUNS_CMPL) &&
1215 (fwreq->hdr.type < SNIC_MSG_ASYNC_EVNOTIFY));
1216
1217 /* Check for snic subsys errors */
1218 switch (fwreq->hdr.status) {
1219 case SNIC_STAT_NOT_READY: /* XPT yet to initialize */
1220 SNIC_HOST_ERR(snic->shost,
1221 "sNIC SubSystem is NOT Ready.\n");
1222 break;
1223
1224 case SNIC_STAT_FATAL_ERROR: /* XPT Error */
1225 SNIC_HOST_ERR(snic->shost,
1226 "sNIC SubSystem in Unrecoverable State.\n");
1227 break;
1228 }
1229
1230 switch (fwreq->hdr.type) {
1231 case SNIC_RSP_EXCH_VER_CMPL:
1232 snic_io_exch_ver_cmpl_handler(snic, fwreq);
1233 break;
1234
1235 case SNIC_RSP_REPORT_TGTS_CMPL:
1236 snic_report_tgt_cmpl_handler(snic, fwreq);
1237 break;
1238
1239 case SNIC_RSP_ICMND_CMPL:
1240 snic_icmnd_cmpl_handler(snic, fwreq);
1241 break;
1242
1243 case SNIC_RSP_ITMF_CMPL:
1244 snic_itmf_cmpl_handler(snic, fwreq);
1245 break;
1246
1247 case SNIC_RSP_HBA_RESET_CMPL:
1248 snic_hba_reset_cmpl_handler(snic, fwreq);
1249 break;
1250
1251 case SNIC_MSG_ACK:
1252 snic_msg_ack_handler(snic, fwreq);
1253 break;
1254
1255 case SNIC_MSG_ASYNC_EVNOTIFY:
1256 snic_aen_handler(snic, fwreq);
1257 break;
1258
1259 default:
1260 SNIC_BUG_ON(1);
1261 SNIC_SCSI_DBG(snic->shost,
1262 "Unknown Firmware completion request type %d\n",
1263 fwreq->hdr.type);
1264 break;
1265 }
1266
1267 /* Update Stats */
1268 cmpl_time = jiffies - start;
1269 if (cmpl_time > atomic64_read(&snic->s_stats.io.max_cmpl_time))
1270 atomic64_set(&snic->s_stats.io.max_cmpl_time, cmpl_time);
1271
1272 return 0;
1273 } /* end of snic_io_cmpl_handler */
1274
1275 /*
1276 * snic_fwcq_cmpl_handler
1277 * Routine to process fwCQ
1278 * This CQ is independent, and not associated with wq/rq/wq_copy queues
1279 */
1280 int
snic_fwcq_cmpl_handler(struct snic * snic,int io_cmpl_work)1281 snic_fwcq_cmpl_handler(struct snic *snic, int io_cmpl_work)
1282 {
1283 unsigned int num_ent = 0; /* number cq entries processed */
1284 unsigned int cq_idx;
1285 unsigned int nent_per_cq;
1286 struct snic_misc_stats *misc_stats = &snic->s_stats.misc;
1287
1288 for (cq_idx = snic->wq_count; cq_idx < snic->cq_count; cq_idx++) {
1289 nent_per_cq = vnic_cq_fw_service(&snic->cq[cq_idx],
1290 snic_io_cmpl_handler,
1291 io_cmpl_work);
1292 num_ent += nent_per_cq;
1293
1294 if (nent_per_cq > atomic64_read(&misc_stats->max_cq_ents))
1295 atomic64_set(&misc_stats->max_cq_ents, nent_per_cq);
1296 }
1297
1298 return num_ent;
1299 } /* end of snic_fwcq_cmpl_handler */
1300
1301 /*
1302 * snic_queue_itmf_req: Common API to queue Task Management requests.
1303 * Use rqi->tm_tag for passing special tags.
1304 * @req_id : aborted request's tag, -1 for lun reset.
1305 */
1306 static int
snic_queue_itmf_req(struct snic * snic,struct snic_host_req * tmreq,struct scsi_cmnd * sc,u32 tmf,u32 req_id)1307 snic_queue_itmf_req(struct snic *snic,
1308 struct snic_host_req *tmreq,
1309 struct scsi_cmnd *sc,
1310 u32 tmf,
1311 u32 req_id)
1312 {
1313 struct snic_req_info *rqi = req_to_rqi(tmreq);
1314 struct scsi_lun lun;
1315 int tm_tag = snic_cmd_tag(sc) | rqi->tm_tag;
1316 int ret = 0;
1317
1318 SNIC_BUG_ON(!rqi);
1319 SNIC_BUG_ON(!rqi->tm_tag);
1320
1321 /* fill in lun info */
1322 int_to_scsilun(sc->device->lun, &lun);
1323
1324 /* Initialize snic_host_req: itmf */
1325 snic_itmf_init(tmreq,
1326 tm_tag,
1327 snic->config.hid,
1328 (ulong) rqi,
1329 0 /* flags */,
1330 req_id, /* Command to be aborted. */
1331 rqi->tgt_id,
1332 lun.scsi_lun,
1333 tmf);
1334
1335 /*
1336 * In case of multiple aborts on same cmd,
1337 * use try_wait_for_completion and completion_done() to check
1338 * whether it queues aborts even after completion of abort issued
1339 * prior.SNIC_BUG_ON(completion_done(&rqi->done));
1340 */
1341
1342 ret = snic_queue_wq_desc(snic, tmreq, sizeof(*tmreq));
1343 if (ret)
1344 SNIC_HOST_ERR(snic->shost,
1345 "qitmf:Queuing ITMF(%d) Req sc %p, rqi %p, req_id %d tag %d Failed, ret = %d\n",
1346 tmf, sc, rqi, req_id, snic_cmd_tag(sc), ret);
1347 else
1348 SNIC_SCSI_DBG(snic->shost,
1349 "qitmf:Queuing ITMF(%d) Req sc %p, rqi %p, req_id %d, tag %d (req_id)- Success.",
1350 tmf, sc, rqi, req_id, snic_cmd_tag(sc));
1351
1352 return ret;
1353 } /* end of snic_queue_itmf_req */
1354
1355 static int
snic_issue_tm_req(struct snic * snic,struct snic_req_info * rqi,struct scsi_cmnd * sc,int tmf)1356 snic_issue_tm_req(struct snic *snic,
1357 struct snic_req_info *rqi,
1358 struct scsi_cmnd *sc,
1359 int tmf)
1360 {
1361 struct snic_host_req *tmreq = NULL;
1362 int req_id = 0, tag = snic_cmd_tag(sc);
1363 int ret = 0;
1364
1365 if (snic_get_state(snic) == SNIC_FWRESET)
1366 return -EBUSY;
1367
1368 atomic_inc(&snic->ios_inflight);
1369
1370 SNIC_SCSI_DBG(snic->shost,
1371 "issu_tmreq: Task mgmt req %d. rqi %p w/ tag %x\n",
1372 tmf, rqi, tag);
1373
1374
1375 if (tmf == SNIC_ITMF_LUN_RESET) {
1376 tmreq = snic_dr_req_init(snic, rqi);
1377 req_id = SCSI_NO_TAG;
1378 } else {
1379 tmreq = snic_abort_req_init(snic, rqi);
1380 req_id = tag;
1381 }
1382
1383 if (!tmreq) {
1384 ret = -ENOMEM;
1385
1386 goto tmreq_err;
1387 }
1388
1389 ret = snic_queue_itmf_req(snic, tmreq, sc, tmf, req_id);
1390 if (ret)
1391 goto tmreq_err;
1392
1393 ret = 0;
1394
1395 tmreq_err:
1396 if (ret) {
1397 SNIC_HOST_ERR(snic->shost,
1398 "issu_tmreq: Queing ITMF(%d) Req, sc %p rqi %p req_id %d tag %x fails err = %d\n",
1399 tmf, sc, rqi, req_id, tag, ret);
1400 } else {
1401 SNIC_SCSI_DBG(snic->shost,
1402 "issu_tmreq: Queuing ITMF(%d) Req, sc %p, rqi %p, req_id %d tag %x - Success.\n",
1403 tmf, sc, rqi, req_id, tag);
1404 }
1405
1406 atomic_dec(&snic->ios_inflight);
1407
1408 return ret;
1409 }
1410
1411 /*
1412 * snic_queue_abort_req : Queues abort req to WQ
1413 */
1414 static int
snic_queue_abort_req(struct snic * snic,struct snic_req_info * rqi,struct scsi_cmnd * sc,int tmf)1415 snic_queue_abort_req(struct snic *snic,
1416 struct snic_req_info *rqi,
1417 struct scsi_cmnd *sc,
1418 int tmf)
1419 {
1420 SNIC_SCSI_DBG(snic->shost, "q_abtreq: sc %p, rqi %p, tag %x, tmf %d\n",
1421 sc, rqi, snic_cmd_tag(sc), tmf);
1422
1423 /* Add special tag for abort */
1424 rqi->tm_tag |= SNIC_TAG_ABORT;
1425
1426 return snic_issue_tm_req(snic, rqi, sc, tmf);
1427 }
1428
1429 /*
1430 * snic_abort_finish : called by snic_abort_cmd on queuing abort successfully.
1431 */
1432 static int
snic_abort_finish(struct snic * snic,struct scsi_cmnd * sc)1433 snic_abort_finish(struct snic *snic, struct scsi_cmnd *sc)
1434 {
1435 struct snic_req_info *rqi = NULL;
1436 spinlock_t *io_lock = NULL;
1437 unsigned long flags;
1438 int ret = 0, tag = snic_cmd_tag(sc);
1439
1440 io_lock = snic_io_lock_hash(snic, sc);
1441 spin_lock_irqsave(io_lock, flags);
1442 rqi = (struct snic_req_info *) CMD_SP(sc);
1443 if (!rqi) {
1444 atomic64_inc(&snic->s_stats.io.req_null);
1445 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TERM_REQ_NULL;
1446
1447 SNIC_SCSI_DBG(snic->shost,
1448 "abt_fini:req info is null tag 0x%x, sc 0x%p flags 0x%llx\n",
1449 tag, sc, CMD_FLAGS(sc));
1450 ret = FAILED;
1451
1452 goto abort_fail;
1453 }
1454
1455 rqi->abts_done = NULL;
1456
1457 ret = FAILED;
1458
1459 /* Check the abort status. */
1460 switch (CMD_ABTS_STATUS(sc)) {
1461 case SNIC_INVALID_CODE:
1462 /* Firmware didn't complete abort req, timedout */
1463 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TIMEDOUT;
1464 atomic64_inc(&snic->s_stats.abts.drv_tmo);
1465 SNIC_SCSI_DBG(snic->shost,
1466 "abt_fini:sc %p Tag %x Driver Timeout.flags 0x%llx\n",
1467 sc, snic_cmd_tag(sc), CMD_FLAGS(sc));
1468 /* do not release snic request in timedout case */
1469 rqi = NULL;
1470
1471 goto abort_fail;
1472
1473 case SNIC_STAT_IO_SUCCESS:
1474 case SNIC_STAT_IO_NOT_FOUND:
1475 ret = SUCCESS;
1476 /*
1477 * If abort path doesn't call scsi_done(),
1478 * the # IO timeouts == 2, will cause the LUN offline.
1479 * Call scsi_done to complete the IO.
1480 */
1481 sc->result = (DID_ERROR << 16);
1482 sc->scsi_done(sc);
1483 break;
1484
1485 default:
1486 /* Firmware completed abort with error */
1487 ret = FAILED;
1488 rqi = NULL;
1489 break;
1490 }
1491
1492 CMD_SP(sc) = NULL;
1493 SNIC_HOST_INFO(snic->shost,
1494 "abt_fini: Tag %x, Cmpl Status %s flags 0x%llx\n",
1495 tag, snic_io_status_to_str(CMD_ABTS_STATUS(sc)),
1496 CMD_FLAGS(sc));
1497
1498 abort_fail:
1499 spin_unlock_irqrestore(io_lock, flags);
1500 if (rqi)
1501 snic_release_req_buf(snic, rqi, sc);
1502
1503 return ret;
1504 } /* end of snic_abort_finish */
1505
1506 /*
1507 * snic_send_abort_and_wait : Issues Abort, and Waits
1508 */
1509 static int
snic_send_abort_and_wait(struct snic * snic,struct scsi_cmnd * sc)1510 snic_send_abort_and_wait(struct snic *snic, struct scsi_cmnd *sc)
1511 {
1512 struct snic_req_info *rqi = NULL;
1513 enum snic_ioreq_state sv_state;
1514 struct snic_tgt *tgt = NULL;
1515 spinlock_t *io_lock = NULL;
1516 DECLARE_COMPLETION_ONSTACK(tm_done);
1517 unsigned long flags;
1518 int ret = 0, tmf = 0, tag = snic_cmd_tag(sc);
1519
1520 tgt = starget_to_tgt(scsi_target(sc->device));
1521 if ((snic_tgt_chkready(tgt) != 0) && (tgt->tdata.typ == SNIC_TGT_SAN))
1522 tmf = SNIC_ITMF_ABTS_TASK_TERM;
1523 else
1524 tmf = SNIC_ITMF_ABTS_TASK;
1525
1526 /* stats */
1527
1528 io_lock = snic_io_lock_hash(snic, sc);
1529
1530 /*
1531 * Avoid a race between SCSI issuing the abort and the device
1532 * completing the command.
1533 *
1534 * If the command is already completed by fw_cmpl code,
1535 * we just return SUCCESS from here. This means that the abort
1536 * succeeded. In the SCSI ML, since the timeout for command has
1537 * happend, the completion wont actually complete the command
1538 * and it will be considered as an aborted command
1539 *
1540 * The CMD_SP will not be cleared except while holding io_lock
1541 */
1542 spin_lock_irqsave(io_lock, flags);
1543 rqi = (struct snic_req_info *) CMD_SP(sc);
1544 if (!rqi) {
1545 spin_unlock_irqrestore(io_lock, flags);
1546
1547 SNIC_HOST_ERR(snic->shost,
1548 "abt_cmd: rqi is null. Tag %d flags 0x%llx\n",
1549 tag, CMD_FLAGS(sc));
1550
1551 ret = SUCCESS;
1552
1553 goto send_abts_end;
1554 }
1555
1556 rqi->abts_done = &tm_done;
1557 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING) {
1558 spin_unlock_irqrestore(io_lock, flags);
1559
1560 ret = 0;
1561 goto abts_pending;
1562 }
1563 SNIC_BUG_ON(!rqi->abts_done);
1564
1565 /* Save Command State, should be restored on failed to Queue. */
1566 sv_state = CMD_STATE(sc);
1567
1568 /*
1569 * Command is still pending, need to abort it
1570 * If the fw completes the command after this point,
1571 * the completion won't be done till mid-layer, since abot
1572 * has already started.
1573 */
1574 CMD_STATE(sc) = SNIC_IOREQ_ABTS_PENDING;
1575 CMD_ABTS_STATUS(sc) = SNIC_INVALID_CODE;
1576
1577 SNIC_SCSI_DBG(snic->shost, "send_abt_cmd: TAG 0x%x\n", tag);
1578
1579 spin_unlock_irqrestore(io_lock, flags);
1580
1581 /* Now Queue the abort command to firmware */
1582 ret = snic_queue_abort_req(snic, rqi, sc, tmf);
1583 if (ret) {
1584 atomic64_inc(&snic->s_stats.abts.q_fail);
1585 SNIC_HOST_ERR(snic->shost,
1586 "send_abt_cmd: IO w/ Tag 0x%x fail w/ err %d flags 0x%llx\n",
1587 tag, ret, CMD_FLAGS(sc));
1588
1589 spin_lock_irqsave(io_lock, flags);
1590 /* Restore Command's previous state */
1591 CMD_STATE(sc) = sv_state;
1592 rqi = (struct snic_req_info *) CMD_SP(sc);
1593 if (rqi)
1594 rqi->abts_done = NULL;
1595 spin_unlock_irqrestore(io_lock, flags);
1596 ret = FAILED;
1597
1598 goto send_abts_end;
1599 }
1600
1601 spin_lock_irqsave(io_lock, flags);
1602 if (tmf == SNIC_ITMF_ABTS_TASK) {
1603 CMD_FLAGS(sc) |= SNIC_IO_ABTS_ISSUED;
1604 atomic64_inc(&snic->s_stats.abts.num);
1605 } else {
1606 /* term stats */
1607 CMD_FLAGS(sc) |= SNIC_IO_TERM_ISSUED;
1608 }
1609 spin_unlock_irqrestore(io_lock, flags);
1610
1611 SNIC_SCSI_DBG(snic->shost,
1612 "send_abt_cmd: sc %p Tag %x flags 0x%llx\n",
1613 sc, tag, CMD_FLAGS(sc));
1614
1615
1616 ret = 0;
1617
1618 abts_pending:
1619 /*
1620 * Queued an abort IO, wait for its completion.
1621 * Once the fw completes the abort command, it will
1622 * wakeup this thread.
1623 */
1624 wait_for_completion_timeout(&tm_done, SNIC_ABTS_TIMEOUT);
1625
1626 send_abts_end:
1627 return ret;
1628 } /* end of snic_send_abort_and_wait */
1629
1630 /*
1631 * This function is exported to SCSI for sending abort cmnds.
1632 * A SCSI IO is represent by snic_ioreq in the driver.
1633 * The snic_ioreq is linked to the SCSI Cmd, thus a link with the ULP'S IO
1634 */
1635 int
snic_abort_cmd(struct scsi_cmnd * sc)1636 snic_abort_cmd(struct scsi_cmnd *sc)
1637 {
1638 struct snic *snic = shost_priv(sc->device->host);
1639 int ret = SUCCESS, tag = snic_cmd_tag(sc);
1640 u32 start_time = jiffies;
1641
1642 SNIC_SCSI_DBG(snic->shost, "abt_cmd:sc %p :0x%x :req = %p :tag = %d\n",
1643 sc, sc->cmnd[0], sc->request, tag);
1644
1645 if (unlikely(snic_get_state(snic) != SNIC_ONLINE)) {
1646 SNIC_HOST_ERR(snic->shost,
1647 "abt_cmd: tag %x Parent Devs are not rdy\n",
1648 tag);
1649 ret = FAST_IO_FAIL;
1650
1651 goto abort_end;
1652 }
1653
1654
1655 ret = snic_send_abort_and_wait(snic, sc);
1656 if (ret)
1657 goto abort_end;
1658
1659 ret = snic_abort_finish(snic, sc);
1660
1661 abort_end:
1662 SNIC_TRC(snic->shost->host_no, tag, (ulong) sc,
1663 jiffies_to_msecs(jiffies - start_time), 0,
1664 SNIC_TRC_CMD(sc), SNIC_TRC_CMD_STATE_FLAGS(sc));
1665
1666 SNIC_SCSI_DBG(snic->shost,
1667 "abts: Abort Req Status = %s\n",
1668 (ret == SUCCESS) ? "SUCCESS" :
1669 ((ret == FAST_IO_FAIL) ? "FAST_IO_FAIL" : "FAILED"));
1670
1671 return ret;
1672 }
1673
1674
1675
1676 static int
snic_is_abts_pending(struct snic * snic,struct scsi_cmnd * lr_sc)1677 snic_is_abts_pending(struct snic *snic, struct scsi_cmnd *lr_sc)
1678 {
1679 struct snic_req_info *rqi = NULL;
1680 struct scsi_cmnd *sc = NULL;
1681 struct scsi_device *lr_sdev = NULL;
1682 spinlock_t *io_lock = NULL;
1683 u32 tag;
1684 unsigned long flags;
1685
1686 if (lr_sc)
1687 lr_sdev = lr_sc->device;
1688
1689 /* walk through the tag map, an dcheck if IOs are still pending in fw*/
1690 for (tag = 0; tag < snic->max_tag_id; tag++) {
1691 io_lock = snic_io_lock_tag(snic, tag);
1692
1693 spin_lock_irqsave(io_lock, flags);
1694 sc = scsi_host_find_tag(snic->shost, tag);
1695
1696 if (!sc || (lr_sc && (sc->device != lr_sdev || sc == lr_sc))) {
1697 spin_unlock_irqrestore(io_lock, flags);
1698
1699 continue;
1700 }
1701
1702 rqi = (struct snic_req_info *) CMD_SP(sc);
1703 if (!rqi) {
1704 spin_unlock_irqrestore(io_lock, flags);
1705
1706 continue;
1707 }
1708
1709 /*
1710 * Found IO that is still pending w/ firmware and belongs to
1711 * the LUN that is under reset, if lr_sc != NULL
1712 */
1713 SNIC_SCSI_DBG(snic->shost, "Found IO in %s on LUN\n",
1714 snic_ioreq_state_to_str(CMD_STATE(sc)));
1715
1716 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING) {
1717 spin_unlock_irqrestore(io_lock, flags);
1718
1719 return 1;
1720 }
1721
1722 spin_unlock_irqrestore(io_lock, flags);
1723 }
1724
1725 return 0;
1726 } /* end of snic_is_abts_pending */
1727
1728 static int
snic_dr_clean_single_req(struct snic * snic,u32 tag,struct scsi_device * lr_sdev)1729 snic_dr_clean_single_req(struct snic *snic,
1730 u32 tag,
1731 struct scsi_device *lr_sdev)
1732 {
1733 struct snic_req_info *rqi = NULL;
1734 struct snic_tgt *tgt = NULL;
1735 struct scsi_cmnd *sc = NULL;
1736 spinlock_t *io_lock = NULL;
1737 u32 sv_state = 0, tmf = 0;
1738 DECLARE_COMPLETION_ONSTACK(tm_done);
1739 unsigned long flags;
1740 int ret = 0;
1741
1742 io_lock = snic_io_lock_tag(snic, tag);
1743 spin_lock_irqsave(io_lock, flags);
1744 sc = scsi_host_find_tag(snic->shost, tag);
1745
1746 /* Ignore Cmd that don't belong to Lun Reset device */
1747 if (!sc || sc->device != lr_sdev)
1748 goto skip_clean;
1749
1750 rqi = (struct snic_req_info *) CMD_SP(sc);
1751
1752 if (!rqi)
1753 goto skip_clean;
1754
1755
1756 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING)
1757 goto skip_clean;
1758
1759
1760 if ((CMD_FLAGS(sc) & SNIC_DEVICE_RESET) &&
1761 (!(CMD_FLAGS(sc) & SNIC_DEV_RST_ISSUED))) {
1762
1763 SNIC_SCSI_DBG(snic->shost,
1764 "clean_single_req: devrst is not pending sc 0x%p\n",
1765 sc);
1766
1767 goto skip_clean;
1768 }
1769
1770 SNIC_SCSI_DBG(snic->shost,
1771 "clean_single_req: Found IO in %s on lun\n",
1772 snic_ioreq_state_to_str(CMD_STATE(sc)));
1773
1774 /* Save Command State */
1775 sv_state = CMD_STATE(sc);
1776
1777 /*
1778 * Any pending IO issued prior to reset is expected to be
1779 * in abts pending state, if not we need to set SNIC_IOREQ_ABTS_PENDING
1780 * to indicate the IO is abort pending.
1781 * When IO is completed, the IO will be handed over and handled
1782 * in this function.
1783 */
1784
1785 CMD_STATE(sc) = SNIC_IOREQ_ABTS_PENDING;
1786 SNIC_BUG_ON(rqi->abts_done);
1787
1788 if (CMD_FLAGS(sc) & SNIC_DEVICE_RESET) {
1789 rqi->tm_tag = SNIC_TAG_DEV_RST;
1790
1791 SNIC_SCSI_DBG(snic->shost,
1792 "clean_single_req:devrst sc 0x%p\n", sc);
1793 }
1794
1795 CMD_ABTS_STATUS(sc) = SNIC_INVALID_CODE;
1796 rqi->abts_done = &tm_done;
1797 spin_unlock_irqrestore(io_lock, flags);
1798
1799 tgt = starget_to_tgt(scsi_target(sc->device));
1800 if ((snic_tgt_chkready(tgt) != 0) && (tgt->tdata.typ == SNIC_TGT_SAN))
1801 tmf = SNIC_ITMF_ABTS_TASK_TERM;
1802 else
1803 tmf = SNIC_ITMF_ABTS_TASK;
1804
1805 /* Now queue the abort command to firmware */
1806 ret = snic_queue_abort_req(snic, rqi, sc, tmf);
1807 if (ret) {
1808 SNIC_HOST_ERR(snic->shost,
1809 "clean_single_req_err:sc %p, tag %d abt failed. tm_tag %d flags 0x%llx\n",
1810 sc, tag, rqi->tm_tag, CMD_FLAGS(sc));
1811
1812 spin_lock_irqsave(io_lock, flags);
1813 rqi = (struct snic_req_info *) CMD_SP(sc);
1814 if (rqi)
1815 rqi->abts_done = NULL;
1816
1817 /* Restore Command State */
1818 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING)
1819 CMD_STATE(sc) = sv_state;
1820
1821 ret = 1;
1822 goto skip_clean;
1823 }
1824
1825 spin_lock_irqsave(io_lock, flags);
1826 if (CMD_FLAGS(sc) & SNIC_DEVICE_RESET)
1827 CMD_FLAGS(sc) |= SNIC_DEV_RST_TERM_ISSUED;
1828
1829 CMD_FLAGS(sc) |= SNIC_IO_INTERNAL_TERM_ISSUED;
1830 spin_unlock_irqrestore(io_lock, flags);
1831
1832 wait_for_completion_timeout(&tm_done, SNIC_ABTS_TIMEOUT);
1833
1834 /* Recheck cmd state to check if it now aborted. */
1835 spin_lock_irqsave(io_lock, flags);
1836 rqi = (struct snic_req_info *) CMD_SP(sc);
1837 if (!rqi) {
1838 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TERM_REQ_NULL;
1839 goto skip_clean;
1840 }
1841 rqi->abts_done = NULL;
1842
1843 /* if abort is still pending w/ fw, fail */
1844 if (CMD_ABTS_STATUS(sc) == SNIC_INVALID_CODE) {
1845 SNIC_HOST_ERR(snic->shost,
1846 "clean_single_req_err:sc %p tag %d abt still pending w/ fw, tm_tag %d flags 0x%llx\n",
1847 sc, tag, rqi->tm_tag, CMD_FLAGS(sc));
1848
1849 CMD_FLAGS(sc) |= SNIC_IO_ABTS_TERM_DONE;
1850 ret = 1;
1851
1852 goto skip_clean;
1853 }
1854
1855 CMD_STATE(sc) = SNIC_IOREQ_ABTS_COMPLETE;
1856 CMD_SP(sc) = NULL;
1857 spin_unlock_irqrestore(io_lock, flags);
1858
1859 snic_release_req_buf(snic, rqi, sc);
1860
1861 sc->result = (DID_ERROR << 16);
1862 sc->scsi_done(sc);
1863
1864 ret = 0;
1865
1866 return ret;
1867
1868 skip_clean:
1869 spin_unlock_irqrestore(io_lock, flags);
1870
1871 return ret;
1872 } /* end of snic_dr_clean_single_req */
1873
1874 static int
snic_dr_clean_pending_req(struct snic * snic,struct scsi_cmnd * lr_sc)1875 snic_dr_clean_pending_req(struct snic *snic, struct scsi_cmnd *lr_sc)
1876 {
1877 struct scsi_device *lr_sdev = lr_sc->device;
1878 u32 tag = 0;
1879 int ret = FAILED;
1880
1881 for (tag = 0; tag < snic->max_tag_id; tag++) {
1882 if (tag == snic_cmd_tag(lr_sc))
1883 continue;
1884
1885 ret = snic_dr_clean_single_req(snic, tag, lr_sdev);
1886 if (ret) {
1887 SNIC_HOST_ERR(snic->shost, "clean_err:tag = %d\n", tag);
1888
1889 goto clean_err;
1890 }
1891 }
1892
1893 schedule_timeout(msecs_to_jiffies(100));
1894
1895 /* Walk through all the cmds and check abts status. */
1896 if (snic_is_abts_pending(snic, lr_sc)) {
1897 ret = FAILED;
1898
1899 goto clean_err;
1900 }
1901
1902 ret = 0;
1903 SNIC_SCSI_DBG(snic->shost, "clean_pending_req: Success.\n");
1904
1905 return ret;
1906
1907 clean_err:
1908 ret = FAILED;
1909 SNIC_HOST_ERR(snic->shost,
1910 "Failed to Clean Pending IOs on %s device.\n",
1911 dev_name(&lr_sdev->sdev_gendev));
1912
1913 return ret;
1914
1915 } /* end of snic_dr_clean_pending_req */
1916
1917 /*
1918 * snic_dr_finish : Called by snic_device_reset
1919 */
1920 static int
snic_dr_finish(struct snic * snic,struct scsi_cmnd * sc)1921 snic_dr_finish(struct snic *snic, struct scsi_cmnd *sc)
1922 {
1923 struct snic_req_info *rqi = NULL;
1924 spinlock_t *io_lock = NULL;
1925 unsigned long flags;
1926 int lr_res = 0;
1927 int ret = FAILED;
1928
1929 io_lock = snic_io_lock_hash(snic, sc);
1930 spin_lock_irqsave(io_lock, flags);
1931 rqi = (struct snic_req_info *) CMD_SP(sc);
1932 if (!rqi) {
1933 spin_unlock_irqrestore(io_lock, flags);
1934 SNIC_SCSI_DBG(snic->shost,
1935 "dr_fini: rqi is null tag 0x%x sc 0x%p flags 0x%llx\n",
1936 snic_cmd_tag(sc), sc, CMD_FLAGS(sc));
1937
1938 ret = FAILED;
1939 goto dr_fini_end;
1940 }
1941
1942 rqi->dr_done = NULL;
1943
1944 lr_res = CMD_LR_STATUS(sc);
1945
1946 switch (lr_res) {
1947 case SNIC_INVALID_CODE:
1948 /* stats */
1949 SNIC_SCSI_DBG(snic->shost,
1950 "dr_fini: Tag %x Dev Reset Timedout. flags 0x%llx\n",
1951 snic_cmd_tag(sc), CMD_FLAGS(sc));
1952
1953 CMD_FLAGS(sc) |= SNIC_DEV_RST_TIMEDOUT;
1954 ret = FAILED;
1955
1956 goto dr_failed;
1957
1958 case SNIC_STAT_IO_SUCCESS:
1959 SNIC_SCSI_DBG(snic->shost,
1960 "dr_fini: Tag %x Dev Reset cmpl\n",
1961 snic_cmd_tag(sc));
1962 ret = 0;
1963 break;
1964
1965 default:
1966 SNIC_HOST_ERR(snic->shost,
1967 "dr_fini:Device Reset completed& failed.Tag = %x lr_status %s flags 0x%llx\n",
1968 snic_cmd_tag(sc),
1969 snic_io_status_to_str(lr_res), CMD_FLAGS(sc));
1970 ret = FAILED;
1971 goto dr_failed;
1972 }
1973 spin_unlock_irqrestore(io_lock, flags);
1974
1975 /*
1976 * Cleanup any IOs on this LUN that have still not completed.
1977 * If any of these fail, then LUN Reset fails.
1978 * Cleanup cleans all commands on this LUN except
1979 * the lun reset command. If all cmds get cleaned, the LUN Reset
1980 * succeeds.
1981 */
1982
1983 ret = snic_dr_clean_pending_req(snic, sc);
1984 if (ret) {
1985 spin_lock_irqsave(io_lock, flags);
1986 SNIC_SCSI_DBG(snic->shost,
1987 "dr_fini: Device Reset Failed since could not abort all IOs. Tag = %x.\n",
1988 snic_cmd_tag(sc));
1989 rqi = (struct snic_req_info *) CMD_SP(sc);
1990
1991 goto dr_failed;
1992 } else {
1993 /* Cleanup LUN Reset Command */
1994 spin_lock_irqsave(io_lock, flags);
1995 rqi = (struct snic_req_info *) CMD_SP(sc);
1996 if (rqi)
1997 ret = SUCCESS; /* Completed Successfully */
1998 else
1999 ret = FAILED;
2000 }
2001
2002 dr_failed:
2003 lockdep_assert_held(io_lock);
2004 if (rqi)
2005 CMD_SP(sc) = NULL;
2006 spin_unlock_irqrestore(io_lock, flags);
2007
2008 if (rqi)
2009 snic_release_req_buf(snic, rqi, sc);
2010
2011 dr_fini_end:
2012 return ret;
2013 } /* end of snic_dr_finish */
2014
2015 static int
snic_queue_dr_req(struct snic * snic,struct snic_req_info * rqi,struct scsi_cmnd * sc)2016 snic_queue_dr_req(struct snic *snic,
2017 struct snic_req_info *rqi,
2018 struct scsi_cmnd *sc)
2019 {
2020 /* Add special tag for device reset */
2021 rqi->tm_tag |= SNIC_TAG_DEV_RST;
2022
2023 return snic_issue_tm_req(snic, rqi, sc, SNIC_ITMF_LUN_RESET);
2024 }
2025
2026 static int
snic_send_dr_and_wait(struct snic * snic,struct scsi_cmnd * sc)2027 snic_send_dr_and_wait(struct snic *snic, struct scsi_cmnd *sc)
2028 {
2029 struct snic_req_info *rqi = NULL;
2030 enum snic_ioreq_state sv_state;
2031 spinlock_t *io_lock = NULL;
2032 unsigned long flags;
2033 DECLARE_COMPLETION_ONSTACK(tm_done);
2034 int ret = FAILED, tag = snic_cmd_tag(sc);
2035
2036 io_lock = snic_io_lock_hash(snic, sc);
2037 spin_lock_irqsave(io_lock, flags);
2038 CMD_FLAGS(sc) |= SNIC_DEVICE_RESET;
2039 rqi = (struct snic_req_info *) CMD_SP(sc);
2040 if (!rqi) {
2041 SNIC_HOST_ERR(snic->shost,
2042 "send_dr: rqi is null, Tag 0x%x flags 0x%llx\n",
2043 tag, CMD_FLAGS(sc));
2044 spin_unlock_irqrestore(io_lock, flags);
2045
2046 ret = FAILED;
2047 goto send_dr_end;
2048 }
2049
2050 /* Save Command state to restore in case Queuing failed. */
2051 sv_state = CMD_STATE(sc);
2052
2053 CMD_STATE(sc) = SNIC_IOREQ_LR_PENDING;
2054 CMD_LR_STATUS(sc) = SNIC_INVALID_CODE;
2055
2056 SNIC_SCSI_DBG(snic->shost, "dr: TAG = %x\n", tag);
2057
2058 rqi->dr_done = &tm_done;
2059 SNIC_BUG_ON(!rqi->dr_done);
2060
2061 spin_unlock_irqrestore(io_lock, flags);
2062 /*
2063 * The Command state is changed to IOREQ_PENDING,
2064 * in this case, if the command is completed, the icmnd_cmpl will
2065 * mark the cmd as completed.
2066 * This logic still makes LUN Reset is inevitable.
2067 */
2068
2069 ret = snic_queue_dr_req(snic, rqi, sc);
2070 if (ret) {
2071 SNIC_HOST_ERR(snic->shost,
2072 "send_dr: IO w/ Tag 0x%x Failed err = %d. flags 0x%llx\n",
2073 tag, ret, CMD_FLAGS(sc));
2074
2075 spin_lock_irqsave(io_lock, flags);
2076 /* Restore State */
2077 CMD_STATE(sc) = sv_state;
2078 rqi = (struct snic_req_info *) CMD_SP(sc);
2079 if (rqi)
2080 rqi->dr_done = NULL;
2081 /* rqi is freed in caller. */
2082 spin_unlock_irqrestore(io_lock, flags);
2083 ret = FAILED;
2084
2085 goto send_dr_end;
2086 }
2087
2088 spin_lock_irqsave(io_lock, flags);
2089 CMD_FLAGS(sc) |= SNIC_DEV_RST_ISSUED;
2090 spin_unlock_irqrestore(io_lock, flags);
2091
2092 ret = 0;
2093
2094 wait_for_completion_timeout(&tm_done, SNIC_LUN_RESET_TIMEOUT);
2095
2096 send_dr_end:
2097 return ret;
2098 }
2099
2100 /*
2101 * auxillary funciton to check lun reset op is supported or not
2102 * Not supported if returns 0
2103 */
2104 static int
snic_dev_reset_supported(struct scsi_device * sdev)2105 snic_dev_reset_supported(struct scsi_device *sdev)
2106 {
2107 struct snic_tgt *tgt = starget_to_tgt(scsi_target(sdev));
2108
2109 if (tgt->tdata.typ == SNIC_TGT_DAS)
2110 return 0;
2111
2112 return 1;
2113 }
2114
2115 static void
snic_unlink_and_release_req(struct snic * snic,struct scsi_cmnd * sc,int flag)2116 snic_unlink_and_release_req(struct snic *snic, struct scsi_cmnd *sc, int flag)
2117 {
2118 struct snic_req_info *rqi = NULL;
2119 spinlock_t *io_lock = NULL;
2120 unsigned long flags;
2121 u32 start_time = jiffies;
2122
2123 io_lock = snic_io_lock_hash(snic, sc);
2124 spin_lock_irqsave(io_lock, flags);
2125 rqi = (struct snic_req_info *) CMD_SP(sc);
2126 if (rqi) {
2127 start_time = rqi->start_time;
2128 CMD_SP(sc) = NULL;
2129 }
2130
2131 CMD_FLAGS(sc) |= flag;
2132 spin_unlock_irqrestore(io_lock, flags);
2133
2134 if (rqi)
2135 snic_release_req_buf(snic, rqi, sc);
2136
2137 SNIC_TRC(snic->shost->host_no, snic_cmd_tag(sc), (ulong) sc,
2138 jiffies_to_msecs(jiffies - start_time), (ulong) rqi,
2139 SNIC_TRC_CMD(sc), SNIC_TRC_CMD_STATE_FLAGS(sc));
2140 }
2141
2142 /*
2143 * SCSI Eh thread issues a LUN Reset when one or more commands on a LUN
2144 * fail to get aborted. It calls driver's eh_device_reset with a SCSI
2145 * command on the LUN.
2146 */
2147 int
snic_device_reset(struct scsi_cmnd * sc)2148 snic_device_reset(struct scsi_cmnd *sc)
2149 {
2150 struct Scsi_Host *shost = sc->device->host;
2151 struct snic *snic = shost_priv(shost);
2152 struct snic_req_info *rqi = NULL;
2153 int tag = snic_cmd_tag(sc);
2154 int start_time = jiffies;
2155 int ret = FAILED;
2156 int dr_supp = 0;
2157
2158 SNIC_SCSI_DBG(shost, "dev_reset:sc %p :0x%x :req = %p :tag = %d\n",
2159 sc, sc->cmnd[0], sc->request,
2160 snic_cmd_tag(sc));
2161 dr_supp = snic_dev_reset_supported(sc->device);
2162 if (!dr_supp) {
2163 /* device reset op is not supported */
2164 SNIC_HOST_INFO(shost, "LUN Reset Op not supported.\n");
2165 snic_unlink_and_release_req(snic, sc, SNIC_DEV_RST_NOTSUP);
2166
2167 goto dev_rst_end;
2168 }
2169
2170 if (unlikely(snic_get_state(snic) != SNIC_ONLINE)) {
2171 snic_unlink_and_release_req(snic, sc, 0);
2172 SNIC_HOST_ERR(shost, "Devrst: Parent Devs are not online.\n");
2173
2174 goto dev_rst_end;
2175 }
2176
2177 /* There is no tag when lun reset is issue through ioctl. */
2178 if (unlikely(tag <= SNIC_NO_TAG)) {
2179 SNIC_HOST_INFO(snic->shost,
2180 "Devrst: LUN Reset Recvd thru IOCTL.\n");
2181
2182 rqi = snic_req_init(snic, 0);
2183 if (!rqi)
2184 goto dev_rst_end;
2185
2186 memset(scsi_cmd_priv(sc), 0,
2187 sizeof(struct snic_internal_io_state));
2188 CMD_SP(sc) = (char *)rqi;
2189 CMD_FLAGS(sc) = SNIC_NO_FLAGS;
2190
2191 /* Add special tag for dr coming from user spc */
2192 rqi->tm_tag = SNIC_TAG_IOCTL_DEV_RST;
2193 rqi->sc = sc;
2194 }
2195
2196 ret = snic_send_dr_and_wait(snic, sc);
2197 if (ret) {
2198 SNIC_HOST_ERR(snic->shost,
2199 "Devrst: IO w/ Tag %x Failed w/ err = %d\n",
2200 tag, ret);
2201
2202 snic_unlink_and_release_req(snic, sc, 0);
2203
2204 goto dev_rst_end;
2205 }
2206
2207 ret = snic_dr_finish(snic, sc);
2208
2209 dev_rst_end:
2210 SNIC_TRC(snic->shost->host_no, tag, (ulong) sc,
2211 jiffies_to_msecs(jiffies - start_time),
2212 0, SNIC_TRC_CMD(sc), SNIC_TRC_CMD_STATE_FLAGS(sc));
2213
2214 SNIC_SCSI_DBG(snic->shost,
2215 "Devrst: Returning from Device Reset : %s\n",
2216 (ret == SUCCESS) ? "SUCCESS" : "FAILED");
2217
2218 return ret;
2219 } /* end of snic_device_reset */
2220
2221 /*
2222 * SCSI Error handling calls driver's eh_host_reset if all prior
2223 * error handling levels return FAILED.
2224 *
2225 * Host Reset is the highest level of error recovery. If this fails, then
2226 * host is offlined by SCSI.
2227 */
2228 /*
2229 * snic_issue_hba_reset : Queues FW Reset Request.
2230 */
2231 static int
snic_issue_hba_reset(struct snic * snic,struct scsi_cmnd * sc)2232 snic_issue_hba_reset(struct snic *snic, struct scsi_cmnd *sc)
2233 {
2234 struct snic_req_info *rqi = NULL;
2235 struct snic_host_req *req = NULL;
2236 spinlock_t *io_lock = NULL;
2237 DECLARE_COMPLETION_ONSTACK(wait);
2238 unsigned long flags;
2239 int ret = -ENOMEM;
2240
2241 rqi = snic_req_init(snic, 0);
2242 if (!rqi) {
2243 ret = -ENOMEM;
2244
2245 goto hba_rst_end;
2246 }
2247
2248 if (snic_cmd_tag(sc) == SCSI_NO_TAG) {
2249 memset(scsi_cmd_priv(sc), 0,
2250 sizeof(struct snic_internal_io_state));
2251 SNIC_HOST_INFO(snic->shost, "issu_hr:Host reset thru ioctl.\n");
2252 rqi->sc = sc;
2253 }
2254
2255 req = rqi_to_req(rqi);
2256
2257 io_lock = snic_io_lock_hash(snic, sc);
2258 spin_lock_irqsave(io_lock, flags);
2259 SNIC_BUG_ON(CMD_SP(sc) != NULL);
2260 CMD_STATE(sc) = SNIC_IOREQ_PENDING;
2261 CMD_SP(sc) = (char *) rqi;
2262 CMD_FLAGS(sc) |= SNIC_IO_INITIALIZED;
2263 snic->remove_wait = &wait;
2264 spin_unlock_irqrestore(io_lock, flags);
2265
2266 /* Initialize Request */
2267 snic_io_hdr_enc(&req->hdr, SNIC_REQ_HBA_RESET, 0, snic_cmd_tag(sc),
2268 snic->config.hid, 0, (ulong) rqi);
2269
2270 req->u.reset.flags = 0;
2271
2272 ret = snic_queue_wq_desc(snic, req, sizeof(*req));
2273 if (ret) {
2274 SNIC_HOST_ERR(snic->shost,
2275 "issu_hr:Queuing HBA Reset Failed. w err %d\n",
2276 ret);
2277
2278 goto hba_rst_err;
2279 }
2280
2281 spin_lock_irqsave(io_lock, flags);
2282 CMD_FLAGS(sc) |= SNIC_HOST_RESET_ISSUED;
2283 spin_unlock_irqrestore(io_lock, flags);
2284 atomic64_inc(&snic->s_stats.reset.hba_resets);
2285 SNIC_HOST_INFO(snic->shost, "Queued HBA Reset Successfully.\n");
2286
2287 wait_for_completion_timeout(snic->remove_wait,
2288 SNIC_HOST_RESET_TIMEOUT);
2289
2290 if (snic_get_state(snic) == SNIC_FWRESET) {
2291 SNIC_HOST_ERR(snic->shost, "reset_cmpl: Reset Timedout.\n");
2292 ret = -ETIMEDOUT;
2293
2294 goto hba_rst_err;
2295 }
2296
2297 spin_lock_irqsave(io_lock, flags);
2298 snic->remove_wait = NULL;
2299 rqi = (struct snic_req_info *) CMD_SP(sc);
2300 CMD_SP(sc) = NULL;
2301 spin_unlock_irqrestore(io_lock, flags);
2302
2303 if (rqi)
2304 snic_req_free(snic, rqi);
2305
2306 ret = 0;
2307
2308 return ret;
2309
2310 hba_rst_err:
2311 spin_lock_irqsave(io_lock, flags);
2312 snic->remove_wait = NULL;
2313 rqi = (struct snic_req_info *) CMD_SP(sc);
2314 CMD_SP(sc) = NULL;
2315 spin_unlock_irqrestore(io_lock, flags);
2316
2317 if (rqi)
2318 snic_req_free(snic, rqi);
2319
2320 hba_rst_end:
2321 SNIC_HOST_ERR(snic->shost,
2322 "reset:HBA Reset Failed w/ err = %d.\n",
2323 ret);
2324
2325 return ret;
2326 } /* end of snic_issue_hba_reset */
2327
2328 int
snic_reset(struct Scsi_Host * shost,struct scsi_cmnd * sc)2329 snic_reset(struct Scsi_Host *shost, struct scsi_cmnd *sc)
2330 {
2331 struct snic *snic = shost_priv(shost);
2332 enum snic_state sv_state;
2333 unsigned long flags;
2334 int ret = FAILED;
2335
2336 /* Set snic state as SNIC_FWRESET*/
2337 sv_state = snic_get_state(snic);
2338
2339 spin_lock_irqsave(&snic->snic_lock, flags);
2340 if (snic_get_state(snic) == SNIC_FWRESET) {
2341 spin_unlock_irqrestore(&snic->snic_lock, flags);
2342 SNIC_HOST_INFO(shost, "reset:prev reset is in progres\n");
2343
2344 msleep(SNIC_HOST_RESET_TIMEOUT);
2345 ret = SUCCESS;
2346
2347 goto reset_end;
2348 }
2349
2350 snic_set_state(snic, SNIC_FWRESET);
2351 spin_unlock_irqrestore(&snic->snic_lock, flags);
2352
2353
2354 /* Wait for all the IOs that are entered in Qcmd */
2355 while (atomic_read(&snic->ios_inflight))
2356 schedule_timeout(msecs_to_jiffies(1));
2357
2358 ret = snic_issue_hba_reset(snic, sc);
2359 if (ret) {
2360 SNIC_HOST_ERR(shost,
2361 "reset:Host Reset Failed w/ err %d.\n",
2362 ret);
2363 spin_lock_irqsave(&snic->snic_lock, flags);
2364 snic_set_state(snic, sv_state);
2365 spin_unlock_irqrestore(&snic->snic_lock, flags);
2366 atomic64_inc(&snic->s_stats.reset.hba_reset_fail);
2367 ret = FAILED;
2368
2369 goto reset_end;
2370 }
2371
2372 ret = SUCCESS;
2373
2374 reset_end:
2375 return ret;
2376 } /* end of snic_reset */
2377
2378 /*
2379 * SCSI Error handling calls driver's eh_host_reset if all prior
2380 * error handling levels return FAILED.
2381 *
2382 * Host Reset is the highest level of error recovery. If this fails, then
2383 * host is offlined by SCSI.
2384 */
2385 int
snic_host_reset(struct scsi_cmnd * sc)2386 snic_host_reset(struct scsi_cmnd *sc)
2387 {
2388 struct Scsi_Host *shost = sc->device->host;
2389 u32 start_time = jiffies;
2390 int ret = FAILED;
2391
2392 SNIC_SCSI_DBG(shost,
2393 "host reset:sc %p sc_cmd 0x%x req %p tag %d flags 0x%llx\n",
2394 sc, sc->cmnd[0], sc->request,
2395 snic_cmd_tag(sc), CMD_FLAGS(sc));
2396
2397 ret = snic_reset(shost, sc);
2398
2399 SNIC_TRC(shost->host_no, snic_cmd_tag(sc), (ulong) sc,
2400 jiffies_to_msecs(jiffies - start_time),
2401 0, SNIC_TRC_CMD(sc), SNIC_TRC_CMD_STATE_FLAGS(sc));
2402
2403 return ret;
2404 } /* end of snic_host_reset */
2405
2406 /*
2407 * snic_cmpl_pending_tmreq : Caller should hold io_lock
2408 */
2409 static void
snic_cmpl_pending_tmreq(struct snic * snic,struct scsi_cmnd * sc)2410 snic_cmpl_pending_tmreq(struct snic *snic, struct scsi_cmnd *sc)
2411 {
2412 struct snic_req_info *rqi = NULL;
2413
2414 SNIC_SCSI_DBG(snic->shost,
2415 "Completing Pending TM Req sc %p, state %s flags 0x%llx\n",
2416 sc, snic_io_status_to_str(CMD_STATE(sc)), CMD_FLAGS(sc));
2417
2418 /*
2419 * CASE : FW didn't post itmf completion due to PCIe Errors.
2420 * Marking the abort status as Success to call scsi completion
2421 * in snic_abort_finish()
2422 */
2423 CMD_ABTS_STATUS(sc) = SNIC_STAT_IO_SUCCESS;
2424
2425 rqi = (struct snic_req_info *) CMD_SP(sc);
2426 if (!rqi)
2427 return;
2428
2429 if (rqi->dr_done)
2430 complete(rqi->dr_done);
2431 else if (rqi->abts_done)
2432 complete(rqi->abts_done);
2433 }
2434
2435 /*
2436 * snic_scsi_cleanup: Walks through tag map and releases the reqs
2437 */
2438 static void
snic_scsi_cleanup(struct snic * snic,int ex_tag)2439 snic_scsi_cleanup(struct snic *snic, int ex_tag)
2440 {
2441 struct snic_req_info *rqi = NULL;
2442 struct scsi_cmnd *sc = NULL;
2443 spinlock_t *io_lock = NULL;
2444 unsigned long flags;
2445 int tag;
2446 u64 st_time = 0;
2447
2448 SNIC_SCSI_DBG(snic->shost, "sc_clean: scsi cleanup.\n");
2449
2450 for (tag = 0; tag < snic->max_tag_id; tag++) {
2451 /* Skip ex_tag */
2452 if (tag == ex_tag)
2453 continue;
2454
2455 io_lock = snic_io_lock_tag(snic, tag);
2456 spin_lock_irqsave(io_lock, flags);
2457 sc = scsi_host_find_tag(snic->shost, tag);
2458 if (!sc) {
2459 spin_unlock_irqrestore(io_lock, flags);
2460
2461 continue;
2462 }
2463
2464 if (unlikely(snic_tmreq_pending(sc))) {
2465 /*
2466 * When FW Completes reset w/o sending completions
2467 * for outstanding ios.
2468 */
2469 snic_cmpl_pending_tmreq(snic, sc);
2470 spin_unlock_irqrestore(io_lock, flags);
2471
2472 continue;
2473 }
2474
2475 rqi = (struct snic_req_info *) CMD_SP(sc);
2476 if (!rqi) {
2477 spin_unlock_irqrestore(io_lock, flags);
2478
2479 goto cleanup;
2480 }
2481
2482 SNIC_SCSI_DBG(snic->shost,
2483 "sc_clean: sc %p, rqi %p, tag %d flags 0x%llx\n",
2484 sc, rqi, tag, CMD_FLAGS(sc));
2485
2486 CMD_SP(sc) = NULL;
2487 CMD_FLAGS(sc) |= SNIC_SCSI_CLEANUP;
2488 spin_unlock_irqrestore(io_lock, flags);
2489 st_time = rqi->start_time;
2490
2491 SNIC_HOST_INFO(snic->shost,
2492 "sc_clean: Releasing rqi %p : flags 0x%llx\n",
2493 rqi, CMD_FLAGS(sc));
2494
2495 snic_release_req_buf(snic, rqi, sc);
2496
2497 cleanup:
2498 sc->result = DID_TRANSPORT_DISRUPTED << 16;
2499 SNIC_HOST_INFO(snic->shost,
2500 "sc_clean: DID_TRANSPORT_DISRUPTED for sc %p, Tag %d flags 0x%llx rqi %p duration %u msecs\n",
2501 sc, sc->request->tag, CMD_FLAGS(sc), rqi,
2502 jiffies_to_msecs(jiffies - st_time));
2503
2504 /* Update IO stats */
2505 snic_stats_update_io_cmpl(&snic->s_stats);
2506
2507 if (sc->scsi_done) {
2508 SNIC_TRC(snic->shost->host_no, tag, (ulong) sc,
2509 jiffies_to_msecs(jiffies - st_time), 0,
2510 SNIC_TRC_CMD(sc),
2511 SNIC_TRC_CMD_STATE_FLAGS(sc));
2512
2513 sc->scsi_done(sc);
2514 }
2515 }
2516 } /* end of snic_scsi_cleanup */
2517
2518 void
snic_shutdown_scsi_cleanup(struct snic * snic)2519 snic_shutdown_scsi_cleanup(struct snic *snic)
2520 {
2521 SNIC_HOST_INFO(snic->shost, "Shutdown time SCSI Cleanup.\n");
2522
2523 snic_scsi_cleanup(snic, SCSI_NO_TAG);
2524 } /* end of snic_shutdown_scsi_cleanup */
2525
2526 /*
2527 * snic_internal_abort_io
2528 * called by : snic_tgt_scsi_abort_io
2529 */
2530 static int
snic_internal_abort_io(struct snic * snic,struct scsi_cmnd * sc,int tmf)2531 snic_internal_abort_io(struct snic *snic, struct scsi_cmnd *sc, int tmf)
2532 {
2533 struct snic_req_info *rqi = NULL;
2534 spinlock_t *io_lock = NULL;
2535 unsigned long flags;
2536 u32 sv_state = 0;
2537 int ret = 0;
2538
2539 io_lock = snic_io_lock_hash(snic, sc);
2540 spin_lock_irqsave(io_lock, flags);
2541 rqi = (struct snic_req_info *) CMD_SP(sc);
2542 if (!rqi)
2543 goto skip_internal_abts;
2544
2545 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING)
2546 goto skip_internal_abts;
2547
2548 if ((CMD_FLAGS(sc) & SNIC_DEVICE_RESET) &&
2549 (!(CMD_FLAGS(sc) & SNIC_DEV_RST_ISSUED))) {
2550
2551 SNIC_SCSI_DBG(snic->shost,
2552 "internal_abts: dev rst not pending sc 0x%p\n",
2553 sc);
2554
2555 goto skip_internal_abts;
2556 }
2557
2558
2559 if (!(CMD_FLAGS(sc) & SNIC_IO_ISSUED)) {
2560 SNIC_SCSI_DBG(snic->shost,
2561 "internal_abts: IO not yet issued sc 0x%p tag 0x%x flags 0x%llx state %d\n",
2562 sc, snic_cmd_tag(sc), CMD_FLAGS(sc), CMD_STATE(sc));
2563
2564 goto skip_internal_abts;
2565 }
2566
2567 sv_state = CMD_STATE(sc);
2568 CMD_STATE(sc) = SNIC_IOREQ_ABTS_PENDING;
2569 CMD_ABTS_STATUS(sc) = SNIC_INVALID_CODE;
2570 CMD_FLAGS(sc) |= SNIC_IO_INTERNAL_TERM_PENDING;
2571
2572 if (CMD_FLAGS(sc) & SNIC_DEVICE_RESET) {
2573 /* stats */
2574 rqi->tm_tag = SNIC_TAG_DEV_RST;
2575 SNIC_SCSI_DBG(snic->shost, "internal_abts:dev rst sc %p\n", sc);
2576 }
2577
2578 SNIC_SCSI_DBG(snic->shost, "internal_abts: Issuing abts tag %x\n",
2579 snic_cmd_tag(sc));
2580 SNIC_BUG_ON(rqi->abts_done);
2581 spin_unlock_irqrestore(io_lock, flags);
2582
2583 ret = snic_queue_abort_req(snic, rqi, sc, tmf);
2584 if (ret) {
2585 SNIC_HOST_ERR(snic->shost,
2586 "internal_abts: Tag = %x , Failed w/ err = %d\n",
2587 snic_cmd_tag(sc), ret);
2588
2589 spin_lock_irqsave(io_lock, flags);
2590
2591 if (CMD_STATE(sc) == SNIC_IOREQ_ABTS_PENDING)
2592 CMD_STATE(sc) = sv_state;
2593
2594 goto skip_internal_abts;
2595 }
2596
2597 spin_lock_irqsave(io_lock, flags);
2598 if (CMD_FLAGS(sc) & SNIC_DEVICE_RESET)
2599 CMD_FLAGS(sc) |= SNIC_DEV_RST_TERM_ISSUED;
2600 else
2601 CMD_FLAGS(sc) |= SNIC_IO_INTERNAL_TERM_ISSUED;
2602
2603 ret = SUCCESS;
2604
2605 skip_internal_abts:
2606 lockdep_assert_held(io_lock);
2607 spin_unlock_irqrestore(io_lock, flags);
2608
2609 return ret;
2610 } /* end of snic_internal_abort_io */
2611
2612 /*
2613 * snic_tgt_scsi_abort_io : called by snic_tgt_del
2614 */
2615 int
snic_tgt_scsi_abort_io(struct snic_tgt * tgt)2616 snic_tgt_scsi_abort_io(struct snic_tgt *tgt)
2617 {
2618 struct snic *snic = NULL;
2619 struct scsi_cmnd *sc = NULL;
2620 struct snic_tgt *sc_tgt = NULL;
2621 spinlock_t *io_lock = NULL;
2622 unsigned long flags;
2623 int ret = 0, tag, abt_cnt = 0, tmf = 0;
2624
2625 if (!tgt)
2626 return -1;
2627
2628 snic = shost_priv(snic_tgt_to_shost(tgt));
2629 SNIC_SCSI_DBG(snic->shost, "tgt_abt_io: Cleaning Pending IOs.\n");
2630
2631 if (tgt->tdata.typ == SNIC_TGT_DAS)
2632 tmf = SNIC_ITMF_ABTS_TASK;
2633 else
2634 tmf = SNIC_ITMF_ABTS_TASK_TERM;
2635
2636 for (tag = 0; tag < snic->max_tag_id; tag++) {
2637 io_lock = snic_io_lock_tag(snic, tag);
2638
2639 spin_lock_irqsave(io_lock, flags);
2640 sc = scsi_host_find_tag(snic->shost, tag);
2641 if (!sc) {
2642 spin_unlock_irqrestore(io_lock, flags);
2643
2644 continue;
2645 }
2646
2647 sc_tgt = starget_to_tgt(scsi_target(sc->device));
2648 if (sc_tgt != tgt) {
2649 spin_unlock_irqrestore(io_lock, flags);
2650
2651 continue;
2652 }
2653 spin_unlock_irqrestore(io_lock, flags);
2654
2655 ret = snic_internal_abort_io(snic, sc, tmf);
2656 if (ret < 0) {
2657 SNIC_HOST_ERR(snic->shost,
2658 "tgt_abt_io: Tag %x, Failed w err = %d\n",
2659 tag, ret);
2660
2661 continue;
2662 }
2663
2664 if (ret == SUCCESS)
2665 abt_cnt++;
2666 }
2667
2668 SNIC_SCSI_DBG(snic->shost, "tgt_abt_io: abt_cnt = %d\n", abt_cnt);
2669
2670 return 0;
2671 } /* end of snic_tgt_scsi_abort_io */
2672