func()

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()
}