mirror of https://github.com/jackc/pgx.git
parent
057da9f8e7
commit
a2e078597b
|
@ -377,3 +377,17 @@ func benchmarkSelectWithLog(b *testing.B, conn *pgx.Conn) {
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
|
func BenchmarkLog15Discard(b *testing.B) {
|
||||||
|
logger := log.New()
|
||||||
|
lvl, err := log.LvlFromString("error")
|
||||||
|
if err != nil {
|
||||||
|
b.Fatal(err)
|
||||||
|
}
|
||||||
|
logger.SetHandler(log.LvlFilterHandler(lvl, log.DiscardHandler()))
|
||||||
|
|
||||||
|
b.ResetTimer()
|
||||||
|
for i := 0; i < b.N; i++ {
|
||||||
|
logger.Debug("benchmark", "i", i, "b.N", b.N)
|
||||||
|
}
|
||||||
|
}
|
||||||
|
|
4
conn.go
4
conn.go
|
@ -929,6 +929,10 @@ func (c *Conn) rxMsg() (t byte, r *msgReader, err error) {
|
||||||
|
|
||||||
c.lastActivityTime = time.Now()
|
c.lastActivityTime = time.Now()
|
||||||
|
|
||||||
|
if c.logger != dlogger {
|
||||||
|
c.logger.Debug("rxMsg", "Type", string(t), "Size", c.mr.msgBytesRemaining)
|
||||||
|
}
|
||||||
|
|
||||||
return t, &c.mr, err
|
return t, &c.mr, err
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue