Skip to content

Commit 0b8cf90

Browse files
committed
scylla: scyllaConnPicker fix logging so that each log line has address
1 parent 3e0a445 commit 0b8cf90

File tree

1 file changed

+8
-2
lines changed

1 file changed

+8
-2
lines changed

scylla.go

+8-2
Original file line numberDiff line numberDiff line change
@@ -325,6 +325,9 @@ func (p *scyllaConnPicker) Close() {
325325

326326
func (p *scyllaConnPicker) closeConns() {
327327
if len(p.conns) == 0 {
328+
if gocqlDebug {
329+
Logger.Printf("scylla: %s no connections to close", p.address)
330+
}
328331
return
329332
}
330333

@@ -333,21 +336,24 @@ func (p *scyllaConnPicker) closeConns() {
333336
p.nrConns = 0
334337

335338
if gocqlDebug {
336-
Logger.Printf("scylla: closing %d connections", len(conns))
339+
Logger.Printf("scylla: %s closing %d connections", p.address, len(conns))
337340
}
338341
go closeConns(conns)
339342
}
340343

341344
func (p *scyllaConnPicker) closeExcessConns() {
342345
if len(p.excessConns) == 0 {
346+
if gocqlDebug {
347+
Logger.Printf("scylla: %s no excess connections to close", p.address)
348+
}
343349
return
344350
}
345351

346352
conns := p.excessConns
347353
p.excessConns = nil
348354

349355
if gocqlDebug {
350-
Logger.Printf("scylla: closing %d excess connections", len(conns))
356+
Logger.Printf("scylla: %s closing %d excess connections", p.address, len(conns))
351357
}
352358
go closeConns(conns)
353359
}

0 commit comments

Comments
 (0)