We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent bd0c833 commit 97aca17Copy full SHA for 97aca17
diskqueue.go
@@ -366,7 +366,7 @@ func (d *diskQueue) writeOne(data []byte) error {
366
}
367
368
// will not wrap-around if maxBytesPerFile + maxMsgSize < Int64Max
369
- if d.writePos > 0 && d.writePos + totalBytes > d.maxBytesPerFile {
+ if d.writePos > 0 && d.writePos+totalBytes > d.maxBytesPerFile {
370
if d.readFileNum == d.writeFileNum {
371
d.maxBytesPerFileRead = d.writePos
372
0 commit comments