equal
deleted
inserted
replaced
859 Signal(); |
859 Signal(); |
860 |
860 |
861 // release threads doing CancelAll() |
861 // release threads doing CancelAll() |
862 waiters->Signal(); |
862 waiters->Signal(); |
863 } |
863 } |
|
864 #ifndef DISABLE_MISSED_IRQ_RECOVERY |
864 // (iController may be NULL here if the channel was closed in the client callback.) |
865 // (iController may be NULL here if the channel was closed in the client callback.) |
865 else if (!error && |
866 else if (!error && |
866 iController && iController->IsIdle(*this) && |
867 iController && iController->IsIdle(*this) && |
867 !iReqQ.IsEmpty() && |
868 !iReqQ.IsEmpty() && |
868 !iDfc.Queued()) |
869 !iDfc.Queued()) |
917 } |
918 } |
918 } |
919 } |
919 req_count_after = iQueuedRequests; |
920 req_count_after = iQueuedRequests; |
920 Signal(); |
921 Signal(); |
921 } |
922 } |
|
923 #endif // #ifndef DISABLE_MISSED_IRQ_RECOVERY |
922 else |
924 else |
923 { |
925 { |
924 req_count_after = iQueuedRequests; |
926 req_count_after = iQueuedRequests; |
925 Signal(); |
927 Signal(); |
926 } |
928 } |