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

Method grabConn

transport.go:1075–1093  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

1073}
1074
1075func (g *connGroup) grabConn() *conn {
1076 g.mutex.Lock()
1077 defer g.mutex.Unlock()
1078
1079 if len(g.idleConns) == 0 {
1080 return nil
1081 }
1082
1083 n := len(g.idleConns) - 1
1084 c := g.idleConns[n]
1085 g.idleConns[n] = nil
1086 g.idleConns = g.idleConns[:n]
1087
1088 if c.timer != nil {
1089 c.timer.Stop()
1090 }
1091
1092 return c
1093}
1094
1095func (g *connGroup) removeConn(c *conn) bool {
1096 g.mutex.Lock()

Callers 1

grabConnOrConnectMethod · 0.95

Calls

no outgoing calls

Tested by

no test coverage detected