flush pending

renaynay · renaynay · commit afb9469b4229 · 2025-11-02T16:07:04.000+01:00
diff --git a/block/internal/syncing/syncer.go b/block/internal/syncing/syncer.go
@@ -440,6 +440,9 @@ func (s *Syncer) waitForNewP2PHeights() {
 		if s.dataStore.Store().Height() < syncHeadData.Height() {
 			s.p2pHandler.ProcessDataRange(s.ctx, s.dataStore.Store().Height()+1, syncHeadData.Height(), s.heightInCh)
 		}
+
+		// and flush all pending
+		s.processPendingEvents()
 	}
 }
 

Original file line number	Diff line number	Diff line change
`@@ -440,6 +440,9 @@ func (s *Syncer) waitForNewP2PHeights() {`
`440`	`440`	`if s.dataStore.Store().Height() < syncHeadData.Height() {`
`441`	`441`	`s.p2pHandler.ProcessDataRange(s.ctx, s.dataStore.Store().Height()+1, syncHeadData.Height(), s.heightInCh)`
`442`	`442`	`}`
	`443`	`+`
	`444`	`+ // and flush all pending`
	`445`	`+ s.processPendingEvents()`
`443`	`446`	`}`
`444`	`447`	`}`
`445`	`448`