diff options
| -rw-r--r-- | internal/serialize_reads/sr.go | 1 |
1 files changed, 0 insertions, 1 deletions
diff --git a/internal/serialize_reads/sr.go b/internal/serialize_reads/sr.go index 9b45bf6..96cec4f 100644 --- a/internal/serialize_reads/sr.go +++ b/internal/serialize_reads/sr.go @@ -120,7 +120,6 @@ func (sr *serializerState) eventLoop() { tlog.Warn.Printf("serialize_reads: queue full, forcing unblock") sr.unblockOne() } - continue case <-time.After(time.Microsecond * 500): // Looks like we have waited out all concurrent requests. empty = sr.unblockOne() |