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

Method setState

transport.go:317–319  ·  view source on GitHub ↗
(state connPoolState)

Source from the content-addressed store, hash-verified

315}
316
317func (p *connPool) setState(state connPoolState) {
318 p.state.Store(state)
319}
320
321func (p *connPool) ref() {
322 atomic.AddUintptr(&p.refc, +1)

Callers 3

TestIssue672Function · 0.95
TestIssue806Function · 0.95
updateMethod · 0.95

Calls

no outgoing calls

Tested by 2

TestIssue672Function · 0.76
TestIssue806Function · 0.76