gogrlx/nats-server
1
0
Fork 0
mirror of https://github.com/gogrlx/nats-server.git synced 2026-04-02 03:38:42 -07:00
Code Issues Packages Projects Releases Wiki Activity

Don't recycle buffer more than once

Browse Source
This commit is contained in:
Neil Twigg
2023-03-17 09:25:17 +00:00
parent 5c437a233a
commit 4647e14b3e
1 changed files with 0 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
server/filestore.go
View File

@@ -4001,9 +4001,6 @@ func (mb *msgBlock) flushPendingMsgsLocked() (*LostStreamData, error) {
dst = make([]byte, lob)
}
mb.bek.XORKeyStream(dst, buf)
if cap(buf) <= defaultLargeBlockSize {
recycleMsgBlockBuf(buf)
}
buf = dst
}