MCPcopy
hub / github.com/segmentio/kafka-go / unref

Method unref

protocol/buffer.go:224–232  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

222}
223
224func (pb *pageBuffer) unref() {
225 pb.refc.unref(func() {
226 pb.pages.unref()
227 pb.pages.clear()
228 pb.pages = pb.pages[:0]
229 pb.length = 0
230 pageBufferPool.Put(pb)
231 })
232}
233
234func (pb *pageBuffer) newPage() *page {
235 return newPage(int64(pb.length))

Callers

nothing calls this directly

Calls 3

clearMethod · 0.80
PutMethod · 0.80
unrefMethod · 0.45

Tested by

no test coverage detected