cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

complain if head change processing is building backlog

Browse Source
This commit is contained in:
vyzo 2023-03-16 17:38:46 +02:00 committed by Maciej Witowski
parent 3d58ef1c21
commit e11e0eb32a
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
chain/index/msgindex.go
View File

@ -290,9 +290,14 @@ func (x *msgIndex) onHeadChange(rev, app []*types.TipSet) error {
// do it in the background to avoid blocking head change processing // do it in the background to avoid blocking head change processing
x.mx.Lock() x.mx.Lock()
x.pend = append(x.pend, headChange{rev: rev, app: app}) x.pend = append(x.pend, headChange{rev: rev, app: app})
// TODO log loudly if this is building backlog (it shouldn't but better be safe on this) pendLen := len(x.pend)
x.mx.Unlock() x.mx.Unlock()
// complain loudly if this is building backlog
if pendLen > 10 {
log.Warnf("message index head change processing is building backlog: %d pending head changes", pendLen)
}
select { select {
case x.sema <- struct{}{}: case x.sema <- struct{}{}:
default: default: