Skip to content

Commit cfc941b

Browse files
committed
fix internal logger
1 parent 01ca3a7 commit cfc941b

File tree

2 files changed

+37
-1
lines changed

2 files changed

+37
-1
lines changed

log/driver.go

Lines changed: 36 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,42 @@ func Driver(log Logger, details trace.Details) trace.Driver {
103103
if details&trace.DriverCoreEvents != 0 {
104104
//nolint: govet
105105
log := log.WithName(`core`)
106+
t.OnInit = func(info trace.InitStartInfo) func(trace.InitDoneInfo) {
107+
log.Infof(`init start`)
108+
start := time.Now()
109+
return func(info trace.InitDoneInfo) {
110+
if info.Error == nil {
111+
log.Infof(
112+
`init done {latency:"%s"}`,
113+
time.Since(start),
114+
)
115+
} else {
116+
log.Warnf(
117+
`init failed {latency:"%s",error:"%s"}`,
118+
time.Since(start),
119+
info.Error,
120+
)
121+
}
122+
}
123+
}
124+
t.OnClose = func(info trace.CloseStartInfo) func(trace.CloseDoneInfo) {
125+
log.Infof(`close start`)
126+
start := time.Now()
127+
return func(info trace.CloseDoneInfo) {
128+
if info.Error == nil {
129+
log.Infof(
130+
`close done {latency:"%s"}`,
131+
time.Since(start),
132+
)
133+
} else {
134+
log.Warnf(
135+
`close failed {latency:"%s",error:"%s"}`,
136+
time.Since(start),
137+
info.Error,
138+
)
139+
}
140+
}
141+
}
106142
t.OnConnTake = func(info trace.ConnTakeStartInfo) func(trace.ConnTakeDoneInfo) {
107143
address := info.Endpoint.Address()
108144
local := info.Endpoint.LocalDC()

log/table.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -362,7 +362,7 @@ func Table(log Logger, details trace.Details) trace.Table {
362362
log.Infof(`close start`)
363363
start := time.Now()
364364
return func(info trace.PoolCloseDoneInfo) {
365-
if info.Error != nil {
365+
if info.Error == nil {
366366
log.Infof(`close done {latency:"%s"}`,
367367
time.Since(start),
368368
)

0 commit comments

Comments
 (0)