Ensure that depth is 0 if readFileNum == writeFileNum and readPos == writePos.

kev1n80 · kev1n80 · commit 03359f678c50 · 2021-07-06T18:18:58.000Z
diff --git a/diskqueue.go b/diskqueue.go
@@ -608,6 +608,8 @@ func (d *diskQueue) handleReadError() {
 
 	// significant state change, schedule a sync on the next iteration
 	d.needSync = true
+
+	d.checkTailCorruption(d.depth)
 }
 
 // ioLoop provides the backend for exposing a go channel (via ReadChan())

Original file line number	Diff line number	Diff line change
`@@ -608,6 +608,8 @@ func (d *diskQueue) handleReadError() {`
`608`	`608`
`609`	`609`	`// significant state change, schedule a sync on the next iteration`
`610`	`610`	`d.needSync = true`
	`611`	`+`
	`612`	`+ d.checkTailCorruption(d.depth)`
`611`	`613`	`}`
`612`	`614`
`613`	`615`	`// ioLoop provides the backend for exposing a go channel (via ReadChan())`