[fireball] 26200: - Implement a simple error handling branch, however it gets hit due to an error somewhere else.

Author: fireball
Date: Fri Mar 30 01:18:28 2007
New Revision: 26200

URL: http://svn.reactos.org/svn/reactos?rev=26200&view=rev
Log:
- Implement a simple error handling branch, however it gets hit due to an error somewhere else.

Modified:
    trunk/reactos/drivers/storage/scsiport-new/scsiport.c

Modified: trunk/reactos/drivers/storage/scsiport-new/scsiport.c
URL: http://svn.reactos.org/svn/reactos/trunk/reactos/drivers/storage/scsiport-ne...
==============================================================================
--- trunk/reactos/drivers/storage/scsiport-new/scsiport.c (original)
+++ trunk/reactos/drivers/storage/scsiport-new/scsiport.c Fri Mar 30 01:18:28 2007
@@ -2012,6 +2012,7 @@
     IO_STATUS_BLOCK IoStatusBlock;
     PIO_STACK_LOCATION IrpStack;
     KEVENT Event;
+    KIRQL Irql;
     PIRP Irp;
     NTSTATUS Status;
     PINQUIRYDATA InquiryBuffer;
@@ -2020,8 +2021,12 @@
     ULONG RetryCount = 0;
     SCSI_REQUEST_BLOCK Srb;
     PCDB Cdb;
+    PSCSI_PORT_LUN_EXTENSION LunExtension;
+    PSCSI_PORT_DEVICE_EXTENSION DeviceExtension;

DPRINT ("SpiSendInquiry() called\n");
+
+    DeviceExtension = (PSCSI_PORT_DEVICE_EXTENSION)DeviceObject->DeviceExtension;

InquiryBuffer = ExAllocatePool (NonPagedPool, INQUIRYDATABUFFERSIZE);
     if (InquiryBuffer == NULL)
@@ -2114,9 +2119,27 @@
             /* Check if the queue is frozen */
             if (Srb.SrbStatus & SRB_STATUS_QUEUE_FROZEN)
             {
-                /* Something weird happeend */
+                /* Something weird happened, deal with it (unfreeze the queue) */
                 KeepTrying = FALSE;
-                ASSERT(FALSE);
+
+                DPRINT("SpiSendInquiry(): the queue is frozen at TargetId %d\n", Srb.TargetId);
+
+                LunExtension = SpiGetLunExtension(DeviceExtension,
+                                                  LunInfo->PathId,
+                                                  LunInfo->TargetId,
+                                                  LunInfo->Lun);
+
+                /* Clear frozen flag */
+                LunExtension->Flags &= ~LUNEX_FROZEN_QUEUE;
+
+                /* Acquire the spinlock */
+                KeAcquireSpinLock(&DeviceExtension->SpinLock, &Irql);
+
+                /* Process the request */
+                SpiGetNextRequestFromLun(DeviceObject->DeviceExtension, LunExtension);
+
+                /* Lower irql back */
+                KeLowerIrql(Irql);
             }

/* Check if data overrun happened */