libp2p/go-libp2p-resource-manager
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-resource-manager.git synced 2025-03-10 17:20:39 +08:00
Code Issues Projects Releases Wiki Activity

short circuit write/flush if there are no pending events

Browse Source
This commit is contained in:
vyzo 2022-01-15 17:40:26 +02:00
parent 83c13993f8
commit 8a60c5d336
1 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
trace.go
View File

@ -108,6 +108,10 @@ func (t *trace) background(out io.WriteCloser) {
case <-ticker.C: case <-ticker.C:
getEvents() getEvents()
if len(pend) == 0 {
continue
}
if err := t.writeEvents(pend, jsonOut); err != nil { if err := t.writeEvents(pend, jsonOut); err != nil {
log.Warnf("error writing rcmgr trace: %s", err) log.Warnf("error writing rcmgr trace: %s", err)
t.mx.Lock() t.mx.Lock()
@ -127,6 +131,10 @@ func (t *trace) background(out io.WriteCloser) {
case <-t.ctx.Done(): case <-t.ctx.Done():
getEvents() getEvents()
if len(pend) == 0 {
return
}
if err := t.writeEvents(pend, jsonOut); err != nil { if err := t.writeEvents(pend, jsonOut); err != nil {
log.Warnf("error writing rcmgr trace: %s", err) log.Warnf("error writing rcmgr trace: %s", err)
return return