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

Method ref

transport.go:321–323  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

319}
320
321func (p *connPool) ref() {
322 atomic.AddUintptr(&p.refc, +1)
323}
324
325func (p *connPool) unref() {
326 if atomic.AddUintptr(&p.refc, ^uintptr(0)) == 0 {

Callers 1

grabPoolMethod · 0.45

Calls

no outgoing calls

Tested by

no test coverage detected