mirror of
https://github.com/ipfs/kubo.git
synced 2026-03-03 07:18:12 +08:00
skip logs when no writers connected
License: MIT Signed-off-by: Jeromy <jeromyj@gmail.com>
This commit is contained in:
parent
90896f283f
commit
67be6bbd57
5
thirdparty/eventlog/log.go
vendored
5
thirdparty/eventlog/log.go
vendored
@ -83,6 +83,11 @@ func (el *eventLogger) EventBegin(ctx context.Context, event string, metadata ..
|
||||
|
||||
func (el *eventLogger) Event(ctx context.Context, event string, metadata ...Loggable) {
|
||||
|
||||
// short circuit if theres nothing to write to
|
||||
if !WriterGroup.Active() {
|
||||
return
|
||||
}
|
||||
|
||||
// Collect loggables for later logging
|
||||
var loggables []Loggable
|
||||
|
||||
|
||||
7
thirdparty/eventlog/writer.go
vendored
7
thirdparty/eventlog/writer.go
vendored
@ -29,3 +29,10 @@ func (mw *MirrorWriter) AddWriter(w io.Writer) {
|
||||
mw.writers = append(mw.writers, w)
|
||||
mw.lk.Unlock()
|
||||
}
|
||||
|
||||
func (mw *MirrorWriter) Active() (active bool) {
|
||||
mw.lk.Lock()
|
||||
active = len(mw.writers) > 0
|
||||
mw.lk.Unlock()
|
||||
return
|
||||
}
|
||||
|
||||
Loading…
Reference in New Issue
Block a user