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

Function newPage

protocol/buffer.go:89–103  ·  view source on GitHub ↗
(offset int64)

Source from the content-addressed store, hash-verified

87}
88
89func newPage(offset int64) *page {
90 p, _ := pagePool.Get().(*page)
91 if p != nil {
92 p.offset = offset
93 p.length = 0
94 p.ref()
95 } else {
96 p = &page{
97 refc: 1,
98 offset: offset,
99 buffer: &[pageSize]byte{},
100 }
101 }
102 return p
103}
104
105func (p *page) ref() { p.refc.ref() }
106

Callers 1

newPageMethod · 0.85

Calls 2

GetMethod · 0.80
refMethod · 0.45

Tested by

no test coverage detected