equal
deleted
inserted
replaced
456 self:setreadtimeout(false); |
456 self:setreadtimeout(false); |
457 self:pausefor(cost); |
457 self:pausefor(cost); |
458 return; |
458 return; |
459 end |
459 end |
460 end |
460 end |
461 if self._wantread and self.conn:dirty() then |
461 if not self._wantread then return end |
|
462 if self.conn:dirty() then |
462 self:setreadtimeout(false); |
463 self:setreadtimeout(false); |
463 self:pausefor(cfg.read_retry_delay); |
464 self:pausefor(cfg.read_retry_delay); |
464 else |
465 else |
465 self:setreadtimeout(); |
466 self:setreadtimeout(); |
466 end |
467 end |