1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17#include <linux/module.h>
18#include <linux/sched.h>
19#include <linux/gfp.h>
20#include <linux/timer.h>
21#include <linux/string.h>
22#include <linux/kernel.h>
23#include <linux/freezer.h>
24#include <linux/kthread.h>
25#include <linux/interrupt.h>
26#include <linux/blkdev.h>
27#include <linux/delay.h>
28
29#include <scsi/scsi.h>
30#include <scsi/scsi_cmnd.h>
31#include <scsi/scsi_dbg.h>
32#include <scsi/scsi_device.h>
33#include <scsi/scsi_driver.h>
34#include <scsi/scsi_eh.h>
35#include <scsi/scsi_transport.h>
36#include <scsi/scsi_host.h>
37#include <scsi/scsi_ioctl.h>
38
39#include "scsi_priv.h"
40#include "scsi_logging.h"
41#include "scsi_transport_api.h"
42
43#include <trace/events/scsi.h>
44
45static void scsi_eh_done(struct scsi_cmnd *scmd);
46
47#define SENSE_TIMEOUT (10*HZ)
48
49
50
51
52
53#define BUS_RESET_SETTLE_TIME (10)
54#define HOST_RESET_SETTLE_TIME (10)
55
56static int scsi_eh_try_stu(struct scsi_cmnd *scmd);
57
58
59void scsi_eh_wakeup(struct Scsi_Host *shost)
60{
61 if (shost->host_busy == shost->host_failed) {
62 trace_scsi_eh_wakeup(shost);
63 wake_up_process(shost->ehandler);
64 SCSI_LOG_ERROR_RECOVERY(5,
65 printk("Waking error handler thread\n"));
66 }
67}
68
69
70
71
72
73
74
75void scsi_schedule_eh(struct Scsi_Host *shost)
76{
77 unsigned long flags;
78
79 spin_lock_irqsave(shost->host_lock, flags);
80
81 if (scsi_host_set_state(shost, SHOST_RECOVERY) == 0 ||
82 scsi_host_set_state(shost, SHOST_CANCEL_RECOVERY) == 0) {
83 shost->host_eh_scheduled++;
84 scsi_eh_wakeup(shost);
85 }
86
87 spin_unlock_irqrestore(shost->host_lock, flags);
88}
89EXPORT_SYMBOL_GPL(scsi_schedule_eh);
90
91
92
93
94
95
96
97
98
99int scsi_eh_scmd_add(struct scsi_cmnd *scmd, int eh_flag)
100{
101 struct Scsi_Host *shost = scmd->device->host;
102 unsigned long flags;
103 int ret = 0;
104
105 if (!shost->ehandler)
106 return 0;
107
108 spin_lock_irqsave(shost->host_lock, flags);
109 if (scsi_host_set_state(shost, SHOST_RECOVERY))
110 if (scsi_host_set_state(shost, SHOST_CANCEL_RECOVERY))
111 goto out_unlock;
112
113 ret = 1;
114 scmd->eh_eflags |= eh_flag;
115 list_add_tail(&scmd->eh_entry, &shost->eh_cmd_q);
116 shost->host_failed++;
117 scsi_eh_wakeup(shost);
118 out_unlock:
119 spin_unlock_irqrestore(shost->host_lock, flags);
120 return ret;
121}
122
123
124
125
126
127
128
129
130
131
132
133enum blk_eh_timer_return scsi_times_out(struct request *req)
134{
135 struct scsi_cmnd *scmd = req->special;
136 enum blk_eh_timer_return rtn = BLK_EH_NOT_HANDLED;
137 struct Scsi_Host *host = scmd->device->host;
138
139 trace_scsi_dispatch_cmd_timeout(scmd);
140 scsi_log_completion(scmd, TIMEOUT_ERROR);
141
142 if (host->transportt->eh_timed_out)
143 rtn = host->transportt->eh_timed_out(scmd);
144 else if (host->hostt->eh_timed_out)
145 rtn = host->hostt->eh_timed_out(scmd);
146
147 scmd->result |= DID_TIME_OUT << 16;
148
149 if (unlikely(rtn == BLK_EH_NOT_HANDLED &&
150 !scsi_eh_scmd_add(scmd, SCSI_EH_CANCEL_CMD)))
151 rtn = BLK_EH_HANDLED;
152
153 return rtn;
154}
155
156
157
158
159
160
161
162
163
164
165
166
167int scsi_block_when_processing_errors(struct scsi_device *sdev)
168{
169 int online;
170
171 wait_event(sdev->host->host_wait, !scsi_host_in_recovery(sdev->host));
172
173 online = scsi_device_online(sdev);
174
175 SCSI_LOG_ERROR_RECOVERY(5, printk("%s: rtn: %d\n", __func__,
176 online));
177
178 return online;
179}
180EXPORT_SYMBOL(scsi_block_when_processing_errors);
181
182#ifdef CONFIG_SCSI_LOGGING
183
184
185
186
187
188static inline void scsi_eh_prt_fail_stats(struct Scsi_Host *shost,
189 struct list_head *work_q)
190{
191 struct scsi_cmnd *scmd;
192 struct scsi_device *sdev;
193 int total_failures = 0;
194 int cmd_failed = 0;
195 int cmd_cancel = 0;
196 int devices_failed = 0;
197
198 shost_for_each_device(sdev, shost) {
199 list_for_each_entry(scmd, work_q, eh_entry) {
200 if (scmd->device == sdev) {
201 ++total_failures;
202 if (scmd->eh_eflags & SCSI_EH_CANCEL_CMD)
203 ++cmd_cancel;
204 else
205 ++cmd_failed;
206 }
207 }
208
209 if (cmd_cancel || cmd_failed) {
210 SCSI_LOG_ERROR_RECOVERY(3,
211 sdev_printk(KERN_INFO, sdev,
212 "%s: cmds failed: %d, cancel: %d\n",
213 __func__, cmd_failed,
214 cmd_cancel));
215 cmd_cancel = 0;
216 cmd_failed = 0;
217 ++devices_failed;
218 }
219 }
220
221 SCSI_LOG_ERROR_RECOVERY(2, printk("Total of %d commands on %d"
222 " devices require eh work\n",
223 total_failures, devices_failed));
224}
225#endif
226
227
228
229
230
231
232
233
234
235
236
237
238static int scsi_check_sense(struct scsi_cmnd *scmd)
239{
240 struct scsi_device *sdev = scmd->device;
241 struct scsi_sense_hdr sshdr;
242
243 if (! scsi_command_normalize_sense(scmd, &sshdr))
244 return FAILED;
245
246 if (scmd->cmnd[0] == TEST_UNIT_READY && scmd->scsi_done != scsi_eh_done)
247
248
249
250
251
252 return SUCCESS;
253
254 if (scsi_sense_is_deferred(&sshdr))
255 return NEEDS_RETRY;
256
257 if (sdev->scsi_dh_data && sdev->scsi_dh_data->scsi_dh &&
258 sdev->scsi_dh_data->scsi_dh->check_sense) {
259 int rc;
260
261 rc = sdev->scsi_dh_data->scsi_dh->check_sense(sdev, &sshdr);
262 if (rc != SCSI_RETURN_NOT_HANDLED)
263 return rc;
264
265 }
266
267
268
269
270
271 if (sshdr.response_code == 0x70) {
272
273 if (scmd->sense_buffer[2] & 0xe0)
274 return SUCCESS;
275 } else {
276
277
278
279
280
281 if ((sshdr.additional_length > 3) &&
282 (scmd->sense_buffer[8] == 0x4) &&
283 (scmd->sense_buffer[11] & 0xe0))
284 return SUCCESS;
285 }
286
287 switch (sshdr.sense_key) {
288 case NO_SENSE:
289 return SUCCESS;
290 case RECOVERED_ERROR:
291 return SUCCESS;
292
293 case ABORTED_COMMAND:
294 if (sshdr.asc == 0x10)
295 return SUCCESS;
296
297 return NEEDS_RETRY;
298 case NOT_READY:
299 case UNIT_ATTENTION:
300
301
302
303
304
305
306 if (scmd->device->expecting_cc_ua) {
307
308
309
310
311
312
313 if (sshdr.asc != 0x28 || sshdr.ascq != 0x00) {
314 scmd->device->expecting_cc_ua = 0;
315 return NEEDS_RETRY;
316 }
317 }
318
319
320
321
322 if ((sshdr.asc == 0x04) && (sshdr.ascq == 0x01))
323 return NEEDS_RETRY;
324
325
326
327
328 if (scmd->device->allow_restart &&
329 (sshdr.asc == 0x04) && (sshdr.ascq == 0x02))
330 return FAILED;
331
332 if (sshdr.asc == 0x3f && sshdr.ascq == 0x0e)
333 scmd_printk(KERN_WARNING, scmd,
334 "Warning! Received an indication that the "
335 "LUN assignments on this target have "
336 "changed. The Linux SCSI layer does not "
337 "automatically remap LUN assignments.\n");
338 else if (sshdr.asc == 0x3f)
339 scmd_printk(KERN_WARNING, scmd,
340 "Warning! Received an indication that the "
341 "operating parameters on this target have "
342 "changed. The Linux SCSI layer does not "
343 "automatically adjust these parameters.\n");
344
345 if (sshdr.asc == 0x38 && sshdr.ascq == 0x07)
346 scmd_printk(KERN_WARNING, scmd,
347 "Warning! Received an indication that the "
348 "LUN reached a thin provisioning soft "
349 "threshold.\n");
350
351
352
353
354
355 return SUCCESS;
356
357
358 case COPY_ABORTED:
359 case VOLUME_OVERFLOW:
360 case MISCOMPARE:
361 case BLANK_CHECK:
362 case DATA_PROTECT:
363 return TARGET_ERROR;
364
365 case MEDIUM_ERROR:
366 if (sshdr.asc == 0x11 ||
367 sshdr.asc == 0x13 ||
368 sshdr.asc == 0x14) {
369 return TARGET_ERROR;
370 }
371 return NEEDS_RETRY;
372
373 case HARDWARE_ERROR:
374 if (scmd->device->retry_hwerror)
375 return ADD_TO_MLQUEUE;
376 else
377 return TARGET_ERROR;
378
379 case ILLEGAL_REQUEST:
380 if (sshdr.asc == 0x20 ||
381 sshdr.asc == 0x21 ||
382 sshdr.asc == 0x24 ||
383 sshdr.asc == 0x26) {
384 return TARGET_ERROR;
385 }
386 return SUCCESS;
387
388 default:
389 return SUCCESS;
390 }
391}
392
393static void scsi_handle_queue_ramp_up(struct scsi_device *sdev)
394{
395 struct scsi_host_template *sht = sdev->host->hostt;
396 struct scsi_device *tmp_sdev;
397
398 if (!sht->change_queue_depth ||
399 sdev->queue_depth >= sdev->max_queue_depth)
400 return;
401
402 if (time_before(jiffies,
403 sdev->last_queue_ramp_up + sdev->queue_ramp_up_period))
404 return;
405
406 if (time_before(jiffies,
407 sdev->last_queue_full_time + sdev->queue_ramp_up_period))
408 return;
409
410
411
412
413
414 shost_for_each_device(tmp_sdev, sdev->host) {
415 if (tmp_sdev->channel != sdev->channel ||
416 tmp_sdev->id != sdev->id ||
417 tmp_sdev->queue_depth == sdev->max_queue_depth)
418 continue;
419
420
421
422
423 sht->change_queue_depth(tmp_sdev, tmp_sdev->queue_depth + 1,
424 SCSI_QDEPTH_RAMP_UP);
425 sdev->last_queue_ramp_up = jiffies;
426 }
427}
428
429static void scsi_handle_queue_full(struct scsi_device *sdev)
430{
431 struct scsi_host_template *sht = sdev->host->hostt;
432 struct scsi_device *tmp_sdev;
433
434 if (!sht->change_queue_depth)
435 return;
436
437 shost_for_each_device(tmp_sdev, sdev->host) {
438 if (tmp_sdev->channel != sdev->channel ||
439 tmp_sdev->id != sdev->id)
440 continue;
441
442
443
444
445
446 sht->change_queue_depth(tmp_sdev, tmp_sdev->queue_depth - 1,
447 SCSI_QDEPTH_QFULL);
448 }
449}
450
451
452
453
454
455
456
457
458
459
460
461static int scsi_eh_completed_normally(struct scsi_cmnd *scmd)
462{
463
464
465
466
467 if (host_byte(scmd->result) == DID_RESET) {
468
469
470
471
472
473
474 return scsi_check_sense(scmd);
475 }
476 if (host_byte(scmd->result) != DID_OK)
477 return FAILED;
478
479
480
481
482 if (msg_byte(scmd->result) != COMMAND_COMPLETE)
483 return FAILED;
484
485
486
487
488
489 switch (status_byte(scmd->result)) {
490 case GOOD:
491 scsi_handle_queue_ramp_up(scmd->device);
492 case COMMAND_TERMINATED:
493 return SUCCESS;
494 case CHECK_CONDITION:
495 return scsi_check_sense(scmd);
496 case CONDITION_GOOD:
497 case INTERMEDIATE_GOOD:
498 case INTERMEDIATE_C_GOOD:
499
500
501
502 return SUCCESS;
503 case RESERVATION_CONFLICT:
504 if (scmd->cmnd[0] == TEST_UNIT_READY)
505
506
507 return SUCCESS;
508
509 return FAILED;
510 case QUEUE_FULL:
511 scsi_handle_queue_full(scmd->device);
512
513 case BUSY:
514 return NEEDS_RETRY;
515 default:
516 return FAILED;
517 }
518 return FAILED;
519}
520
521
522
523
524
525static void scsi_eh_done(struct scsi_cmnd *scmd)
526{
527 struct completion *eh_action;
528
529 SCSI_LOG_ERROR_RECOVERY(3,
530 printk("%s scmd: %p result: %x\n",
531 __func__, scmd, scmd->result));
532
533 eh_action = scmd->device->host->eh_action;
534 if (eh_action)
535 complete(eh_action);
536}
537
538
539
540
541
542static int scsi_try_host_reset(struct scsi_cmnd *scmd)
543{
544 unsigned long flags;
545 int rtn;
546 struct Scsi_Host *host = scmd->device->host;
547 struct scsi_host_template *hostt = host->hostt;
548
549 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Snd Host RST\n",
550 __func__));
551
552 if (!hostt->eh_host_reset_handler)
553 return FAILED;
554
555 rtn = hostt->eh_host_reset_handler(scmd);
556
557 if (rtn == SUCCESS) {
558 if (!hostt->skip_settle_delay)
559 ssleep(HOST_RESET_SETTLE_TIME);
560 spin_lock_irqsave(host->host_lock, flags);
561 scsi_report_bus_reset(host, scmd_channel(scmd));
562 spin_unlock_irqrestore(host->host_lock, flags);
563 }
564
565 return rtn;
566}
567
568
569
570
571
572static int scsi_try_bus_reset(struct scsi_cmnd *scmd)
573{
574 unsigned long flags;
575 int rtn;
576 struct Scsi_Host *host = scmd->device->host;
577 struct scsi_host_template *hostt = host->hostt;
578
579 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Snd Bus RST\n",
580 __func__));
581
582 if (!hostt->eh_bus_reset_handler)
583 return FAILED;
584
585 rtn = hostt->eh_bus_reset_handler(scmd);
586
587 if (rtn == SUCCESS) {
588 if (!hostt->skip_settle_delay)
589 ssleep(BUS_RESET_SETTLE_TIME);
590 spin_lock_irqsave(host->host_lock, flags);
591 scsi_report_bus_reset(host, scmd_channel(scmd));
592 spin_unlock_irqrestore(host->host_lock, flags);
593 }
594
595 return rtn;
596}
597
598static void __scsi_report_device_reset(struct scsi_device *sdev, void *data)
599{
600 sdev->was_reset = 1;
601 sdev->expecting_cc_ua = 1;
602}
603
604
605
606
607
608
609
610
611
612
613
614static int scsi_try_target_reset(struct scsi_cmnd *scmd)
615{
616 unsigned long flags;
617 int rtn;
618 struct Scsi_Host *host = scmd->device->host;
619 struct scsi_host_template *hostt = host->hostt;
620
621 if (!hostt->eh_target_reset_handler)
622 return FAILED;
623
624 rtn = hostt->eh_target_reset_handler(scmd);
625 if (rtn == SUCCESS) {
626 spin_lock_irqsave(host->host_lock, flags);
627 __starget_for_each_device(scsi_target(scmd->device), NULL,
628 __scsi_report_device_reset);
629 spin_unlock_irqrestore(host->host_lock, flags);
630 }
631
632 return rtn;
633}
634
635
636
637
638
639
640
641
642
643
644
645static int scsi_try_bus_device_reset(struct scsi_cmnd *scmd)
646{
647 int rtn;
648 struct scsi_host_template *hostt = scmd->device->host->hostt;
649
650 if (!hostt->eh_device_reset_handler)
651 return FAILED;
652
653 rtn = hostt->eh_device_reset_handler(scmd);
654 if (rtn == SUCCESS)
655 __scsi_report_device_reset(scmd->device, NULL);
656 return rtn;
657}
658
659static int scsi_try_to_abort_cmd(struct scsi_host_template *hostt, struct scsi_cmnd *scmd)
660{
661 if (!hostt->eh_abort_handler)
662 return FAILED;
663
664 return hostt->eh_abort_handler(scmd);
665}
666
667static void scsi_abort_eh_cmnd(struct scsi_cmnd *scmd)
668{
669 if (scsi_try_to_abort_cmd(scmd->device->host->hostt, scmd) != SUCCESS)
670 if (scsi_try_bus_device_reset(scmd) != SUCCESS)
671 if (scsi_try_target_reset(scmd) != SUCCESS)
672 if (scsi_try_bus_reset(scmd) != SUCCESS)
673 scsi_try_host_reset(scmd);
674}
675
676
677
678
679
680
681
682
683
684
685
686
687
688
689
690void scsi_eh_prep_cmnd(struct scsi_cmnd *scmd, struct scsi_eh_save *ses,
691 unsigned char *cmnd, int cmnd_size, unsigned sense_bytes)
692{
693 struct scsi_device *sdev = scmd->device;
694
695
696
697
698
699
700
701
702 ses->cmd_len = scmd->cmd_len;
703 ses->cmnd = scmd->cmnd;
704 ses->data_direction = scmd->sc_data_direction;
705 ses->sdb = scmd->sdb;
706 ses->next_rq = scmd->request->next_rq;
707 ses->result = scmd->result;
708 ses->underflow = scmd->underflow;
709 ses->prot_op = scmd->prot_op;
710
711 scmd->prot_op = SCSI_PROT_NORMAL;
712 scmd->cmnd = ses->eh_cmnd;
713 memset(scmd->cmnd, 0, BLK_MAX_CDB);
714 memset(&scmd->sdb, 0, sizeof(scmd->sdb));
715 scmd->request->next_rq = NULL;
716
717 if (sense_bytes) {
718 scmd->sdb.length = min_t(unsigned, SCSI_SENSE_BUFFERSIZE,
719 sense_bytes);
720 sg_init_one(&ses->sense_sgl, scmd->sense_buffer,
721 scmd->sdb.length);
722 scmd->sdb.table.sgl = &ses->sense_sgl;
723 scmd->sc_data_direction = DMA_FROM_DEVICE;
724 scmd->sdb.table.nents = 1;
725 scmd->cmnd[0] = REQUEST_SENSE;
726 scmd->cmnd[4] = scmd->sdb.length;
727 scmd->cmd_len = COMMAND_SIZE(scmd->cmnd[0]);
728 } else {
729 scmd->sc_data_direction = DMA_NONE;
730 if (cmnd) {
731 BUG_ON(cmnd_size > BLK_MAX_CDB);
732 memcpy(scmd->cmnd, cmnd, cmnd_size);
733 scmd->cmd_len = COMMAND_SIZE(scmd->cmnd[0]);
734 }
735 }
736
737 scmd->underflow = 0;
738
739 if (sdev->scsi_level <= SCSI_2 && sdev->scsi_level != SCSI_UNKNOWN)
740 scmd->cmnd[1] = (scmd->cmnd[1] & 0x1f) |
741 (sdev->lun << 5 & 0xe0);
742
743
744
745
746
747 memset(scmd->sense_buffer, 0, SCSI_SENSE_BUFFERSIZE);
748}
749EXPORT_SYMBOL(scsi_eh_prep_cmnd);
750
751
752
753
754
755
756
757
758void scsi_eh_restore_cmnd(struct scsi_cmnd* scmd, struct scsi_eh_save *ses)
759{
760
761
762
763 scmd->cmd_len = ses->cmd_len;
764 scmd->cmnd = ses->cmnd;
765 scmd->sc_data_direction = ses->data_direction;
766 scmd->sdb = ses->sdb;
767 scmd->request->next_rq = ses->next_rq;
768 scmd->result = ses->result;
769 scmd->underflow = ses->underflow;
770 scmd->prot_op = ses->prot_op;
771}
772EXPORT_SYMBOL(scsi_eh_restore_cmnd);
773
774
775
776
777
778
779
780
781
782
783
784
785
786
787
788static int scsi_send_eh_cmnd(struct scsi_cmnd *scmd, unsigned char *cmnd,
789 int cmnd_size, int timeout, unsigned sense_bytes)
790{
791 struct scsi_device *sdev = scmd->device;
792 struct scsi_driver *sdrv = scsi_cmd_to_driver(scmd);
793 struct Scsi_Host *shost = sdev->host;
794 DECLARE_COMPLETION_ONSTACK(done);
795 unsigned long timeleft;
796 struct scsi_eh_save ses;
797 int rtn;
798
799 scsi_eh_prep_cmnd(scmd, &ses, cmnd, cmnd_size, sense_bytes);
800 shost->eh_action = &done;
801
802 scsi_log_send(scmd);
803 scmd->scsi_done = scsi_eh_done;
804 shost->hostt->queuecommand(shost, scmd);
805
806 timeleft = wait_for_completion_timeout(&done, timeout);
807
808 shost->eh_action = NULL;
809
810 scsi_log_completion(scmd, SUCCESS);
811
812 SCSI_LOG_ERROR_RECOVERY(3,
813 printk("%s: scmd: %p, timeleft: %ld\n",
814 __func__, scmd, timeleft));
815
816
817
818
819
820
821
822 if (timeleft) {
823 rtn = scsi_eh_completed_normally(scmd);
824 SCSI_LOG_ERROR_RECOVERY(3,
825 printk("%s: scsi_eh_completed_normally %x\n",
826 __func__, rtn));
827
828 switch (rtn) {
829 case SUCCESS:
830 case NEEDS_RETRY:
831 case FAILED:
832 case TARGET_ERROR:
833 break;
834 case ADD_TO_MLQUEUE:
835 rtn = NEEDS_RETRY;
836 break;
837 default:
838 rtn = FAILED;
839 break;
840 }
841 } else {
842 scsi_abort_eh_cmnd(scmd);
843 rtn = FAILED;
844 }
845
846 scsi_eh_restore_cmnd(scmd, &ses);
847
848 if (sdrv && sdrv->eh_action)
849 rtn = sdrv->eh_action(scmd, cmnd, cmnd_size, rtn);
850
851 return rtn;
852}
853
854
855
856
857
858
859
860
861
862
863static int scsi_request_sense(struct scsi_cmnd *scmd)
864{
865 return scsi_send_eh_cmnd(scmd, NULL, 0, SENSE_TIMEOUT, ~0);
866}
867
868
869
870
871
872
873
874
875
876
877
878
879
880void scsi_eh_finish_cmd(struct scsi_cmnd *scmd, struct list_head *done_q)
881{
882 scmd->device->host->host_failed--;
883 scmd->eh_eflags = 0;
884 list_move_tail(&scmd->eh_entry, done_q);
885}
886EXPORT_SYMBOL(scsi_eh_finish_cmd);
887
888
889
890
891
892
893
894
895
896
897
898
899
900
901
902
903
904
905
906
907
908int scsi_eh_get_sense(struct list_head *work_q,
909 struct list_head *done_q)
910{
911 struct scsi_cmnd *scmd, *next;
912 int rtn;
913
914 list_for_each_entry_safe(scmd, next, work_q, eh_entry) {
915 if ((scmd->eh_eflags & SCSI_EH_CANCEL_CMD) ||
916 SCSI_SENSE_VALID(scmd))
917 continue;
918
919 SCSI_LOG_ERROR_RECOVERY(2, scmd_printk(KERN_INFO, scmd,
920 "%s: requesting sense\n",
921 current->comm));
922 rtn = scsi_request_sense(scmd);
923 if (rtn != SUCCESS)
924 continue;
925
926 SCSI_LOG_ERROR_RECOVERY(3, printk("sense requested for %p"
927 " result %x\n", scmd,
928 scmd->result));
929 SCSI_LOG_ERROR_RECOVERY(3, scsi_print_sense("bh", scmd));
930
931 rtn = scsi_decide_disposition(scmd);
932
933
934
935
936
937 if (rtn == SUCCESS)
938
939
940
941
942 scmd->retries = scmd->allowed;
943 else if (rtn != NEEDS_RETRY)
944 continue;
945
946 scsi_eh_finish_cmd(scmd, done_q);
947 }
948
949 return list_empty(work_q);
950}
951EXPORT_SYMBOL_GPL(scsi_eh_get_sense);
952
953
954
955
956
957
958
959
960static int scsi_eh_tur(struct scsi_cmnd *scmd)
961{
962 static unsigned char tur_command[6] = {TEST_UNIT_READY, 0, 0, 0, 0, 0};
963 int retry_cnt = 1, rtn;
964
965retry_tur:
966 rtn = scsi_send_eh_cmnd(scmd, tur_command, 6, SENSE_TIMEOUT, 0);
967
968 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: scmd %p rtn %x\n",
969 __func__, scmd, rtn));
970
971 switch (rtn) {
972 case NEEDS_RETRY:
973 if (retry_cnt--)
974 goto retry_tur;
975
976 case SUCCESS:
977 return 0;
978 default:
979 return 1;
980 }
981}
982
983
984
985
986
987
988
989
990
991
992
993
994
995
996static int scsi_eh_test_devices(struct list_head *cmd_list,
997 struct list_head *work_q,
998 struct list_head *done_q, int try_stu)
999{
1000 struct scsi_cmnd *scmd, *next;
1001 struct scsi_device *sdev;
1002 int finish_cmds;
1003
1004 while (!list_empty(cmd_list)) {
1005 scmd = list_entry(cmd_list->next, struct scsi_cmnd, eh_entry);
1006 sdev = scmd->device;
1007
1008 finish_cmds = !scsi_device_online(scmd->device) ||
1009 (try_stu && !scsi_eh_try_stu(scmd) &&
1010 !scsi_eh_tur(scmd)) ||
1011 !scsi_eh_tur(scmd);
1012
1013 list_for_each_entry_safe(scmd, next, cmd_list, eh_entry)
1014 if (scmd->device == sdev) {
1015 if (finish_cmds)
1016 scsi_eh_finish_cmd(scmd, done_q);
1017 else
1018 list_move_tail(&scmd->eh_entry, work_q);
1019 }
1020 }
1021 return list_empty(work_q);
1022}
1023
1024
1025
1026
1027
1028
1029
1030
1031
1032
1033
1034
1035
1036
1037static int scsi_eh_abort_cmds(struct list_head *work_q,
1038 struct list_head *done_q)
1039{
1040 struct scsi_cmnd *scmd, *next;
1041 LIST_HEAD(check_list);
1042 int rtn;
1043
1044 list_for_each_entry_safe(scmd, next, work_q, eh_entry) {
1045 if (!(scmd->eh_eflags & SCSI_EH_CANCEL_CMD))
1046 continue;
1047 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: aborting cmd:"
1048 "0x%p\n", current->comm,
1049 scmd));
1050 rtn = scsi_try_to_abort_cmd(scmd->device->host->hostt, scmd);
1051 if (rtn == SUCCESS || rtn == FAST_IO_FAIL) {
1052 scmd->eh_eflags &= ~SCSI_EH_CANCEL_CMD;
1053 if (rtn == FAST_IO_FAIL)
1054 scsi_eh_finish_cmd(scmd, done_q);
1055 else
1056 list_move_tail(&scmd->eh_entry, &check_list);
1057 } else
1058 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: aborting"
1059 " cmd failed:"
1060 "0x%p\n",
1061 current->comm,
1062 scmd));
1063 }
1064
1065 return scsi_eh_test_devices(&check_list, work_q, done_q, 0);
1066}
1067
1068
1069
1070
1071
1072
1073
1074
1075static int scsi_eh_try_stu(struct scsi_cmnd *scmd)
1076{
1077 static unsigned char stu_command[6] = {START_STOP, 0, 0, 0, 1, 0};
1078
1079 if (scmd->device->allow_restart) {
1080 int i, rtn = NEEDS_RETRY;
1081
1082 for (i = 0; rtn == NEEDS_RETRY && i < 2; i++)
1083 rtn = scsi_send_eh_cmnd(scmd, stu_command, 6, scmd->device->request_queue->rq_timeout, 0);
1084
1085 if (rtn == SUCCESS)
1086 return 0;
1087 }
1088
1089 return 1;
1090}
1091
1092
1093
1094
1095
1096
1097
1098
1099
1100
1101
1102static int scsi_eh_stu(struct Scsi_Host *shost,
1103 struct list_head *work_q,
1104 struct list_head *done_q)
1105{
1106 struct scsi_cmnd *scmd, *stu_scmd, *next;
1107 struct scsi_device *sdev;
1108
1109 shost_for_each_device(sdev, shost) {
1110 stu_scmd = NULL;
1111 list_for_each_entry(scmd, work_q, eh_entry)
1112 if (scmd->device == sdev && SCSI_SENSE_VALID(scmd) &&
1113 scsi_check_sense(scmd) == FAILED ) {
1114 stu_scmd = scmd;
1115 break;
1116 }
1117
1118 if (!stu_scmd)
1119 continue;
1120
1121 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Sending START_UNIT to sdev:"
1122 " 0x%p\n", current->comm, sdev));
1123
1124 if (!scsi_eh_try_stu(stu_scmd)) {
1125 if (!scsi_device_online(sdev) ||
1126 !scsi_eh_tur(stu_scmd)) {
1127 list_for_each_entry_safe(scmd, next,
1128 work_q, eh_entry) {
1129 if (scmd->device == sdev)
1130 scsi_eh_finish_cmd(scmd, done_q);
1131 }
1132 }
1133 } else {
1134 SCSI_LOG_ERROR_RECOVERY(3,
1135 printk("%s: START_UNIT failed to sdev:"
1136 " 0x%p\n", current->comm, sdev));
1137 }
1138 }
1139
1140 return list_empty(work_q);
1141}
1142
1143
1144
1145
1146
1147
1148
1149
1150
1151
1152
1153
1154
1155
1156static int scsi_eh_bus_device_reset(struct Scsi_Host *shost,
1157 struct list_head *work_q,
1158 struct list_head *done_q)
1159{
1160 struct scsi_cmnd *scmd, *bdr_scmd, *next;
1161 struct scsi_device *sdev;
1162 int rtn;
1163
1164 shost_for_each_device(sdev, shost) {
1165 bdr_scmd = NULL;
1166 list_for_each_entry(scmd, work_q, eh_entry)
1167 if (scmd->device == sdev) {
1168 bdr_scmd = scmd;
1169 break;
1170 }
1171
1172 if (!bdr_scmd)
1173 continue;
1174
1175 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Sending BDR sdev:"
1176 " 0x%p\n", current->comm,
1177 sdev));
1178 rtn = scsi_try_bus_device_reset(bdr_scmd);
1179 if (rtn == SUCCESS || rtn == FAST_IO_FAIL) {
1180 if (!scsi_device_online(sdev) ||
1181 rtn == FAST_IO_FAIL ||
1182 !scsi_eh_tur(bdr_scmd)) {
1183 list_for_each_entry_safe(scmd, next,
1184 work_q, eh_entry) {
1185 if (scmd->device == sdev)
1186 scsi_eh_finish_cmd(scmd,
1187 done_q);
1188 }
1189 }
1190 } else {
1191 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: BDR"
1192 " failed sdev:"
1193 "0x%p\n",
1194 current->comm,
1195 sdev));
1196 }
1197 }
1198
1199 return list_empty(work_q);
1200}
1201
1202
1203
1204
1205
1206
1207
1208
1209
1210
1211static int scsi_eh_target_reset(struct Scsi_Host *shost,
1212 struct list_head *work_q,
1213 struct list_head *done_q)
1214{
1215 LIST_HEAD(tmp_list);
1216 LIST_HEAD(check_list);
1217
1218 list_splice_init(work_q, &tmp_list);
1219
1220 while (!list_empty(&tmp_list)) {
1221 struct scsi_cmnd *next, *scmd;
1222 int rtn;
1223 unsigned int id;
1224
1225 scmd = list_entry(tmp_list.next, struct scsi_cmnd, eh_entry);
1226 id = scmd_id(scmd);
1227
1228 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Sending target reset "
1229 "to target %d\n",
1230 current->comm, id));
1231 rtn = scsi_try_target_reset(scmd);
1232 if (rtn != SUCCESS && rtn != FAST_IO_FAIL)
1233 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Target reset"
1234 " failed target: "
1235 "%d\n",
1236 current->comm, id));
1237 list_for_each_entry_safe(scmd, next, &tmp_list, eh_entry) {
1238 if (scmd_id(scmd) != id)
1239 continue;
1240
1241 if (rtn == SUCCESS)
1242 list_move_tail(&scmd->eh_entry, &check_list);
1243 else if (rtn == FAST_IO_FAIL)
1244 scsi_eh_finish_cmd(scmd, done_q);
1245 else
1246
1247 list_move(&scmd->eh_entry, work_q);
1248 }
1249 }
1250
1251 return scsi_eh_test_devices(&check_list, work_q, done_q, 0);
1252}
1253
1254
1255
1256
1257
1258
1259
1260static int scsi_eh_bus_reset(struct Scsi_Host *shost,
1261 struct list_head *work_q,
1262 struct list_head *done_q)
1263{
1264 struct scsi_cmnd *scmd, *chan_scmd, *next;
1265 LIST_HEAD(check_list);
1266 unsigned int channel;
1267 int rtn;
1268
1269
1270
1271
1272
1273
1274
1275
1276 for (channel = 0; channel <= shost->max_channel; channel++) {
1277 chan_scmd = NULL;
1278 list_for_each_entry(scmd, work_q, eh_entry) {
1279 if (channel == scmd_channel(scmd)) {
1280 chan_scmd = scmd;
1281 break;
1282
1283
1284
1285
1286 }
1287 }
1288
1289 if (!chan_scmd)
1290 continue;
1291 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Sending BRST chan:"
1292 " %d\n", current->comm,
1293 channel));
1294 rtn = scsi_try_bus_reset(chan_scmd);
1295 if (rtn == SUCCESS || rtn == FAST_IO_FAIL) {
1296 list_for_each_entry_safe(scmd, next, work_q, eh_entry) {
1297 if (channel == scmd_channel(scmd)) {
1298 if (rtn == FAST_IO_FAIL)
1299 scsi_eh_finish_cmd(scmd,
1300 done_q);
1301 else
1302 list_move_tail(&scmd->eh_entry,
1303 &check_list);
1304 }
1305 }
1306 } else {
1307 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: BRST"
1308 " failed chan: %d\n",
1309 current->comm,
1310 channel));
1311 }
1312 }
1313 return scsi_eh_test_devices(&check_list, work_q, done_q, 0);
1314}
1315
1316
1317
1318
1319
1320
1321static int scsi_eh_host_reset(struct list_head *work_q,
1322 struct list_head *done_q)
1323{
1324 struct scsi_cmnd *scmd, *next;
1325 LIST_HEAD(check_list);
1326 int rtn;
1327
1328 if (!list_empty(work_q)) {
1329 scmd = list_entry(work_q->next,
1330 struct scsi_cmnd, eh_entry);
1331
1332 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: Sending HRST\n"
1333 , current->comm));
1334
1335 rtn = scsi_try_host_reset(scmd);
1336 if (rtn == SUCCESS) {
1337 list_splice_init(work_q, &check_list);
1338 } else if (rtn == FAST_IO_FAIL) {
1339 list_for_each_entry_safe(scmd, next, work_q, eh_entry) {
1340 scsi_eh_finish_cmd(scmd, done_q);
1341 }
1342 } else {
1343 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: HRST"
1344 " failed\n",
1345 current->comm));
1346 }
1347 }
1348 return scsi_eh_test_devices(&check_list, work_q, done_q, 1);
1349}
1350
1351
1352
1353
1354
1355
1356static void scsi_eh_offline_sdevs(struct list_head *work_q,
1357 struct list_head *done_q)
1358{
1359 struct scsi_cmnd *scmd, *next;
1360
1361 list_for_each_entry_safe(scmd, next, work_q, eh_entry) {
1362 sdev_printk(KERN_INFO, scmd->device, "Device offlined - "
1363 "not ready after error recovery\n");
1364 scsi_device_set_state(scmd->device, SDEV_OFFLINE);
1365 if (scmd->eh_eflags & SCSI_EH_CANCEL_CMD) {
1366
1367
1368
1369 }
1370 scsi_eh_finish_cmd(scmd, done_q);
1371 }
1372 return;
1373}
1374
1375
1376
1377
1378
1379int scsi_noretry_cmd(struct scsi_cmnd *scmd)
1380{
1381 switch (host_byte(scmd->result)) {
1382 case DID_OK:
1383 break;
1384 case DID_BUS_BUSY:
1385 return (scmd->request->cmd_flags & REQ_FAILFAST_TRANSPORT);
1386 case DID_PARITY:
1387 return (scmd->request->cmd_flags & REQ_FAILFAST_DEV);
1388 case DID_ERROR:
1389 if (msg_byte(scmd->result) == COMMAND_COMPLETE &&
1390 status_byte(scmd->result) == RESERVATION_CONFLICT)
1391 return 0;
1392
1393 case DID_SOFT_ERROR:
1394 return (scmd->request->cmd_flags & REQ_FAILFAST_DRIVER);
1395 }
1396
1397 switch (status_byte(scmd->result)) {
1398 case CHECK_CONDITION:
1399
1400
1401
1402
1403 if (scmd->request->cmd_flags & REQ_FAILFAST_DEV ||
1404 scmd->request->cmd_type == REQ_TYPE_BLOCK_PC)
1405 return 1;
1406 }
1407
1408 return 0;
1409}
1410
1411
1412
1413
1414
1415
1416
1417
1418
1419
1420
1421
1422
1423
1424
1425int scsi_decide_disposition(struct scsi_cmnd *scmd)
1426{
1427 int rtn;
1428
1429
1430
1431
1432
1433 if (!scsi_device_online(scmd->device)) {
1434 SCSI_LOG_ERROR_RECOVERY(5, printk("%s: device offline - report"
1435 " as SUCCESS\n",
1436 __func__));
1437 return SUCCESS;
1438 }
1439
1440
1441
1442
1443
1444 switch (host_byte(scmd->result)) {
1445 case DID_PASSTHROUGH:
1446
1447
1448
1449
1450
1451 scmd->result &= 0xff00ffff;
1452 return SUCCESS;
1453 case DID_OK:
1454
1455
1456
1457 break;
1458 case DID_NO_CONNECT:
1459 case DID_BAD_TARGET:
1460 case DID_ABORT:
1461
1462
1463
1464
1465
1466 return SUCCESS;
1467
1468
1469
1470
1471
1472
1473
1474
1475
1476 case DID_SOFT_ERROR:
1477 goto maybe_retry;
1478 case DID_IMM_RETRY:
1479 return NEEDS_RETRY;
1480
1481 case DID_REQUEUE:
1482 return ADD_TO_MLQUEUE;
1483 case DID_TRANSPORT_DISRUPTED:
1484
1485
1486
1487
1488
1489
1490
1491 goto maybe_retry;
1492 case DID_TRANSPORT_FAILFAST:
1493
1494
1495
1496
1497 return SUCCESS;
1498 case DID_ERROR:
1499 if (msg_byte(scmd->result) == COMMAND_COMPLETE &&
1500 status_byte(scmd->result) == RESERVATION_CONFLICT)
1501
1502
1503
1504
1505 break;
1506
1507 case DID_BUS_BUSY:
1508 case DID_PARITY:
1509 goto maybe_retry;
1510 case DID_TIME_OUT:
1511
1512
1513
1514
1515
1516 if ((scmd->cmnd[0] == TEST_UNIT_READY ||
1517 scmd->cmnd[0] == INQUIRY)) {
1518 return SUCCESS;
1519 } else {
1520 return FAILED;
1521 }
1522 case DID_RESET:
1523 return SUCCESS;
1524 default:
1525 return FAILED;
1526 }
1527
1528
1529
1530
1531 if (msg_byte(scmd->result) != COMMAND_COMPLETE)
1532 return FAILED;
1533
1534
1535
1536
1537 switch (status_byte(scmd->result)) {
1538 case QUEUE_FULL:
1539 scsi_handle_queue_full(scmd->device);
1540
1541
1542
1543
1544 case BUSY:
1545
1546
1547
1548
1549
1550
1551 return ADD_TO_MLQUEUE;
1552 case GOOD:
1553 scsi_handle_queue_ramp_up(scmd->device);
1554 case COMMAND_TERMINATED:
1555 return SUCCESS;
1556 case TASK_ABORTED:
1557 goto maybe_retry;
1558 case CHECK_CONDITION:
1559 rtn = scsi_check_sense(scmd);
1560 if (rtn == NEEDS_RETRY)
1561 goto maybe_retry;
1562 else if (rtn == TARGET_ERROR) {
1563
1564
1565
1566
1567 set_host_byte(scmd, DID_TARGET_FAILURE);
1568 rtn = SUCCESS;
1569 }
1570
1571
1572
1573
1574 return rtn;
1575 case CONDITION_GOOD:
1576 case INTERMEDIATE_GOOD:
1577 case INTERMEDIATE_C_GOOD:
1578 case ACA_ACTIVE:
1579
1580
1581
1582 return SUCCESS;
1583
1584 case RESERVATION_CONFLICT:
1585 sdev_printk(KERN_INFO, scmd->device,
1586 "reservation conflict\n");
1587 set_host_byte(scmd, DID_NEXUS_FAILURE);
1588 return SUCCESS;
1589 default:
1590 return FAILED;
1591 }
1592 return FAILED;
1593
1594 maybe_retry:
1595
1596
1597
1598
1599
1600 if ((++scmd->retries) <= scmd->allowed
1601 && !scsi_noretry_cmd(scmd)) {
1602 return NEEDS_RETRY;
1603 } else {
1604
1605
1606
1607 return SUCCESS;
1608 }
1609}
1610
1611static void eh_lock_door_done(struct request *req, int uptodate)
1612{
1613 __blk_put_request(req->q, req);
1614}
1615
1616
1617
1618
1619
1620
1621
1622
1623
1624
1625
1626
1627static void scsi_eh_lock_door(struct scsi_device *sdev)
1628{
1629 struct request *req;
1630
1631
1632
1633
1634
1635 req = blk_get_request(sdev->request_queue, READ, GFP_KERNEL);
1636
1637 req->cmd[0] = ALLOW_MEDIUM_REMOVAL;
1638 req->cmd[1] = 0;
1639 req->cmd[2] = 0;
1640 req->cmd[3] = 0;
1641 req->cmd[4] = SCSI_REMOVAL_PREVENT;
1642 req->cmd[5] = 0;
1643
1644 req->cmd_len = COMMAND_SIZE(req->cmd[0]);
1645
1646 req->cmd_type = REQ_TYPE_BLOCK_PC;
1647 req->cmd_flags |= REQ_QUIET;
1648 req->timeout = 10 * HZ;
1649 req->retries = 5;
1650
1651 blk_execute_rq_nowait(req->q, NULL, req, 1, eh_lock_door_done);
1652}
1653
1654
1655
1656
1657
1658
1659
1660
1661
1662static void scsi_restart_operations(struct Scsi_Host *shost)
1663{
1664 struct scsi_device *sdev;
1665 unsigned long flags;
1666
1667
1668
1669
1670
1671
1672 shost_for_each_device(sdev, shost) {
1673 if (scsi_device_online(sdev) && sdev->locked)
1674 scsi_eh_lock_door(sdev);
1675 }
1676
1677
1678
1679
1680
1681
1682 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: waking up host to restart\n",
1683 __func__));
1684
1685 spin_lock_irqsave(shost->host_lock, flags);
1686 if (scsi_host_set_state(shost, SHOST_RUNNING))
1687 if (scsi_host_set_state(shost, SHOST_CANCEL))
1688 BUG_ON(scsi_host_set_state(shost, SHOST_DEL));
1689 spin_unlock_irqrestore(shost->host_lock, flags);
1690
1691 wake_up(&shost->host_wait);
1692
1693
1694
1695
1696
1697
1698
1699 scsi_run_host_queues(shost);
1700
1701
1702
1703
1704
1705
1706
1707
1708
1709 spin_lock_irqsave(shost->host_lock, flags);
1710 if (shost->host_eh_scheduled)
1711 if (scsi_host_set_state(shost, SHOST_RECOVERY))
1712 WARN_ON(scsi_host_set_state(shost, SHOST_CANCEL_RECOVERY));
1713 spin_unlock_irqrestore(shost->host_lock, flags);
1714}
1715
1716
1717
1718
1719
1720
1721
1722void scsi_eh_ready_devs(struct Scsi_Host *shost,
1723 struct list_head *work_q,
1724 struct list_head *done_q)
1725{
1726 if (!scsi_eh_stu(shost, work_q, done_q))
1727 if (!scsi_eh_bus_device_reset(shost, work_q, done_q))
1728 if (!scsi_eh_target_reset(shost, work_q, done_q))
1729 if (!scsi_eh_bus_reset(shost, work_q, done_q))
1730 if (!scsi_eh_host_reset(work_q, done_q))
1731 scsi_eh_offline_sdevs(work_q,
1732 done_q);
1733}
1734EXPORT_SYMBOL_GPL(scsi_eh_ready_devs);
1735
1736
1737
1738
1739
1740void scsi_eh_flush_done_q(struct list_head *done_q)
1741{
1742 struct scsi_cmnd *scmd, *next;
1743
1744 list_for_each_entry_safe(scmd, next, done_q, eh_entry) {
1745 list_del_init(&scmd->eh_entry);
1746 if (scsi_device_online(scmd->device) &&
1747 !scsi_noretry_cmd(scmd) &&
1748 (++scmd->retries <= scmd->allowed)) {
1749 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: flush"
1750 " retry cmd: %p\n",
1751 current->comm,
1752 scmd));
1753 scsi_queue_insert(scmd, SCSI_MLQUEUE_EH_RETRY);
1754 } else {
1755
1756
1757
1758
1759
1760 if (!scmd->result)
1761 scmd->result |= (DRIVER_TIMEOUT << 24);
1762 SCSI_LOG_ERROR_RECOVERY(3, printk("%s: flush finish"
1763 " cmd: %p\n",
1764 current->comm, scmd));
1765 scsi_finish_command(scmd);
1766 }
1767 }
1768}
1769EXPORT_SYMBOL(scsi_eh_flush_done_q);
1770
1771
1772
1773
1774
1775
1776
1777
1778
1779
1780
1781
1782
1783
1784
1785
1786
1787
1788
1789
1790
1791
1792
1793
1794static void scsi_unjam_host(struct Scsi_Host *shost)
1795{
1796 unsigned long flags;
1797 LIST_HEAD(eh_work_q);
1798 LIST_HEAD(eh_done_q);
1799
1800 spin_lock_irqsave(shost->host_lock, flags);
1801 list_splice_init(&shost->eh_cmd_q, &eh_work_q);
1802 spin_unlock_irqrestore(shost->host_lock, flags);
1803
1804 SCSI_LOG_ERROR_RECOVERY(1, scsi_eh_prt_fail_stats(shost, &eh_work_q));
1805
1806 if (!scsi_eh_get_sense(&eh_work_q, &eh_done_q))
1807 if (!scsi_eh_abort_cmds(&eh_work_q, &eh_done_q))
1808 scsi_eh_ready_devs(shost, &eh_work_q, &eh_done_q);
1809
1810 scsi_eh_flush_done_q(&eh_done_q);
1811}
1812
1813
1814
1815
1816
1817
1818
1819
1820
1821int scsi_error_handler(void *data)
1822{
1823 struct Scsi_Host *shost = data;
1824
1825
1826
1827
1828
1829
1830
1831 while (!kthread_should_stop()) {
1832 set_current_state(TASK_INTERRUPTIBLE);
1833 if ((shost->host_failed == 0 && shost->host_eh_scheduled == 0) ||
1834 shost->host_failed != shost->host_busy) {
1835 SCSI_LOG_ERROR_RECOVERY(1,
1836 printk("Error handler scsi_eh_%d sleeping\n",
1837 shost->host_no));
1838 schedule();
1839 continue;
1840 }
1841
1842 __set_current_state(TASK_RUNNING);
1843 SCSI_LOG_ERROR_RECOVERY(1,
1844 printk("Error handler scsi_eh_%d waking up\n",
1845 shost->host_no));
1846
1847
1848
1849
1850
1851
1852 if (!shost->eh_noresume && scsi_autopm_get_host(shost) != 0) {
1853 SCSI_LOG_ERROR_RECOVERY(1,
1854 printk(KERN_ERR "Error handler scsi_eh_%d "
1855 "unable to autoresume\n",
1856 shost->host_no));
1857 continue;
1858 }
1859
1860 if (shost->transportt->eh_strategy_handler)
1861 shost->transportt->eh_strategy_handler(shost);
1862 else
1863 scsi_unjam_host(shost);
1864
1865
1866
1867
1868
1869
1870
1871
1872 scsi_restart_operations(shost);
1873 if (!shost->eh_noresume)
1874 scsi_autopm_put_host(shost);
1875 }
1876 __set_current_state(TASK_RUNNING);
1877
1878 SCSI_LOG_ERROR_RECOVERY(1,
1879 printk("Error handler scsi_eh_%d exiting\n", shost->host_no));
1880 shost->ehandler = NULL;
1881 return 0;
1882}
1883
1884
1885
1886
1887
1888
1889
1890
1891
1892
1893
1894
1895
1896
1897
1898
1899
1900
1901
1902
1903
1904
1905void scsi_report_bus_reset(struct Scsi_Host *shost, int channel)
1906{
1907 struct scsi_device *sdev;
1908
1909 __shost_for_each_device(sdev, shost) {
1910 if (channel == sdev_channel(sdev))
1911 __scsi_report_device_reset(sdev, NULL);
1912 }
1913}
1914EXPORT_SYMBOL(scsi_report_bus_reset);
1915
1916
1917
1918
1919
1920
1921
1922
1923
1924
1925
1926
1927
1928
1929
1930
1931
1932
1933
1934
1935
1936
1937
1938void scsi_report_device_reset(struct Scsi_Host *shost, int channel, int target)
1939{
1940 struct scsi_device *sdev;
1941
1942 __shost_for_each_device(sdev, shost) {
1943 if (channel == sdev_channel(sdev) &&
1944 target == sdev_id(sdev))
1945 __scsi_report_device_reset(sdev, NULL);
1946 }
1947}
1948EXPORT_SYMBOL(scsi_report_device_reset);
1949
1950static void
1951scsi_reset_provider_done_command(struct scsi_cmnd *scmd)
1952{
1953}
1954
1955
1956
1957
1958
1959
1960
1961
1962
1963
1964
1965
1966
1967
1968int
1969scsi_reset_provider(struct scsi_device *dev, int flag)
1970{
1971 struct scsi_cmnd *scmd;
1972 struct Scsi_Host *shost = dev->host;
1973 struct request req;
1974 unsigned long flags;
1975 int rtn;
1976
1977 if (scsi_autopm_get_host(shost) < 0)
1978 return FAILED;
1979
1980 scmd = scsi_get_command(dev, GFP_KERNEL);
1981 blk_rq_init(NULL, &req);
1982 scmd->request = &req;
1983
1984 scmd->cmnd = req.cmd;
1985
1986 scmd->scsi_done = scsi_reset_provider_done_command;
1987 memset(&scmd->sdb, 0, sizeof(scmd->sdb));
1988
1989 scmd->cmd_len = 0;
1990
1991 scmd->sc_data_direction = DMA_BIDIRECTIONAL;
1992
1993 spin_lock_irqsave(shost->host_lock, flags);
1994 shost->tmf_in_progress = 1;
1995 spin_unlock_irqrestore(shost->host_lock, flags);
1996
1997 switch (flag) {
1998 case SCSI_TRY_RESET_DEVICE:
1999 rtn = scsi_try_bus_device_reset(scmd);
2000 if (rtn == SUCCESS)
2001 break;
2002
2003 case SCSI_TRY_RESET_TARGET:
2004 rtn = scsi_try_target_reset(scmd);
2005 if (rtn == SUCCESS)
2006 break;
2007
2008 case SCSI_TRY_RESET_BUS:
2009 rtn = scsi_try_bus_reset(scmd);
2010 if (rtn == SUCCESS)
2011 break;
2012
2013 case SCSI_TRY_RESET_HOST:
2014 rtn = scsi_try_host_reset(scmd);
2015 break;
2016 default:
2017 rtn = FAILED;
2018 }
2019
2020 spin_lock_irqsave(shost->host_lock, flags);
2021 shost->tmf_in_progress = 0;
2022 spin_unlock_irqrestore(shost->host_lock, flags);
2023
2024
2025
2026
2027
2028 SCSI_LOG_ERROR_RECOVERY(3,
2029 printk("%s: waking up host to restart after TMF\n",
2030 __func__));
2031
2032 wake_up(&shost->host_wait);
2033
2034 scsi_run_host_queues(shost);
2035
2036 scsi_next_command(scmd);
2037 scsi_autopm_put_host(shost);
2038 return rtn;
2039}
2040EXPORT_SYMBOL(scsi_reset_provider);
2041
2042
2043
2044
2045
2046
2047
2048
2049
2050
2051
2052
2053
2054
2055
2056
2057
2058
2059
2060
2061int scsi_normalize_sense(const u8 *sense_buffer, int sb_len,
2062 struct scsi_sense_hdr *sshdr)
2063{
2064 if (!sense_buffer || !sb_len)
2065 return 0;
2066
2067 memset(sshdr, 0, sizeof(struct scsi_sense_hdr));
2068
2069 sshdr->response_code = (sense_buffer[0] & 0x7f);
2070
2071 if (!scsi_sense_valid(sshdr))
2072 return 0;
2073
2074 if (sshdr->response_code >= 0x72) {
2075
2076
2077
2078 if (sb_len > 1)
2079 sshdr->sense_key = (sense_buffer[1] & 0xf);
2080 if (sb_len > 2)
2081 sshdr->asc = sense_buffer[2];
2082 if (sb_len > 3)
2083 sshdr->ascq = sense_buffer[3];
2084 if (sb_len > 7)
2085 sshdr->additional_length = sense_buffer[7];
2086 } else {
2087
2088
2089
2090 if (sb_len > 2)
2091 sshdr->sense_key = (sense_buffer[2] & 0xf);
2092 if (sb_len > 7) {
2093 sb_len = (sb_len < (sense_buffer[7] + 8)) ?
2094 sb_len : (sense_buffer[7] + 8);
2095 if (sb_len > 12)
2096 sshdr->asc = sense_buffer[12];
2097 if (sb_len > 13)
2098 sshdr->ascq = sense_buffer[13];
2099 }
2100 }
2101
2102 return 1;
2103}
2104EXPORT_SYMBOL(scsi_normalize_sense);
2105
2106int scsi_command_normalize_sense(struct scsi_cmnd *cmd,
2107 struct scsi_sense_hdr *sshdr)
2108{
2109 return scsi_normalize_sense(cmd->sense_buffer,
2110 SCSI_SENSE_BUFFERSIZE, sshdr);
2111}
2112EXPORT_SYMBOL(scsi_command_normalize_sense);
2113
2114
2115
2116
2117
2118
2119
2120
2121
2122
2123
2124
2125
2126
2127const u8 * scsi_sense_desc_find(const u8 * sense_buffer, int sb_len,
2128 int desc_type)
2129{
2130 int add_sen_len, add_len, desc_len, k;
2131 const u8 * descp;
2132
2133 if ((sb_len < 8) || (0 == (add_sen_len = sense_buffer[7])))
2134 return NULL;
2135 if ((sense_buffer[0] < 0x72) || (sense_buffer[0] > 0x73))
2136 return NULL;
2137 add_sen_len = (add_sen_len < (sb_len - 8)) ?
2138 add_sen_len : (sb_len - 8);
2139 descp = &sense_buffer[8];
2140 for (desc_len = 0, k = 0; k < add_sen_len; k += desc_len) {
2141 descp += desc_len;
2142 add_len = (k < (add_sen_len - 1)) ? descp[1]: -1;
2143 desc_len = add_len + 2;
2144 if (descp[0] == desc_type)
2145 return descp;
2146 if (add_len < 0)
2147 break;
2148 }
2149 return NULL;
2150}
2151EXPORT_SYMBOL(scsi_sense_desc_find);
2152
2153
2154
2155
2156
2157
2158
2159
2160
2161
2162
2163int scsi_get_sense_info_fld(const u8 * sense_buffer, int sb_len,
2164 u64 * info_out)
2165{
2166 int j;
2167 const u8 * ucp;
2168 u64 ull;
2169
2170 if (sb_len < 7)
2171 return 0;
2172 switch (sense_buffer[0] & 0x7f) {
2173 case 0x70:
2174 case 0x71:
2175 if (sense_buffer[0] & 0x80) {
2176 *info_out = (sense_buffer[3] << 24) +
2177 (sense_buffer[4] << 16) +
2178 (sense_buffer[5] << 8) + sense_buffer[6];
2179 return 1;
2180 } else
2181 return 0;
2182 case 0x72:
2183 case 0x73:
2184 ucp = scsi_sense_desc_find(sense_buffer, sb_len,
2185 0 );
2186 if (ucp && (0xa == ucp[1])) {
2187 ull = 0;
2188 for (j = 0; j < 8; ++j) {
2189 if (j > 0)
2190 ull <<= 8;
2191 ull |= ucp[4 + j];
2192 }
2193 *info_out = ull;
2194 return 1;
2195 } else
2196 return 0;
2197 default:
2198 return 0;
2199 }
2200}
2201EXPORT_SYMBOL(scsi_get_sense_info_fld);
2202
2203
2204
2205
2206
2207
2208
2209
2210
2211
2212
2213void scsi_build_sense_buffer(int desc, u8 *buf, u8 key, u8 asc, u8 ascq)
2214{
2215 if (desc) {
2216 buf[0] = 0x72;
2217 buf[1] = key;
2218 buf[2] = asc;
2219 buf[3] = ascq;
2220 buf[7] = 0;
2221 } else {
2222 buf[0] = 0x70;
2223 buf[2] = key;
2224 buf[7] = 0xa;
2225 buf[12] = asc;
2226 buf[13] = ascq;
2227 }
2228}
2229EXPORT_SYMBOL(scsi_build_sense_buffer);
2230