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

Method enter

conn.go:1335–1337  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1333}
1334
1335func (c *Conn) enter() {
1336 atomic.AddInt32(&c.inflight, +1)
1337}
1338
1339func (c *Conn) leave() {
1340 atomic.AddInt32(&c.inflight, -1)

Callers 1

doRequestMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected