in pkg/bufferpool/bufferpool.go [61:77]
func (b *BufferPool) Return(buf *[]byte) {
b.lock.Lock()
// Rejecting buffer if already in pool
if b.isBufferAlreadyInPool(buf) {
b.lock.Unlock()
return
}
buffers := b.Buffers
buffersCap := cap(buffers)
buffersLen := len(buffers)
if buffersLen < buffersCap {
buffers = append(buffers, buf)
b.Buffers = buffers
b.bufferHeadHash[getBufferPointer(buf)] = true
}
b.lock.Unlock()
}