Cancel consensus instances that are not needed anymore.

kape1395 · kape1395 · commit 82cea2fde2f7 · 2025-01-29T15:32:11.000+02:00
Signed-off-by: Karolis Petrauskas &lt;karolis.petrauskas@erisata.lt&gt;
diff --git a/packages/chain/node.go b/packages/chain/node.go
@@ -738,6 +738,7 @@ func (cni *chainNodeImpl) handleNeedConsensus(ctx context.Context, upd *chainman
 	cni.consensusInsts.ForEach(func(cmtAddr cryptolib.AddressKey, cmtInsts *shrinkingmap.ShrinkingMap[cmt_log.LogIndex, *consensusInst]) bool {
 		cmtInsts.ForEach(func(li cmt_log.LogIndex, ci *consensusInst) bool {
 			if ci.request != nil && !upd.Has(chainmanager.MakeConsensusKey(ci.request.CommitteeAddr, li)) {
+				ci.Cancel()
 				cmtInsts.Delete(li)
 			}
 			return true

Original file line number	Diff line number	Diff line change
`@@ -738,6 +738,7 @@ func (cni chainNodeImpl) handleNeedConsensus(ctx context.Context, upd chainman`
`738`	`738`	`cni.consensusInsts.ForEach(func(cmtAddr cryptolib.AddressKey, cmtInsts shrinkingmap.ShrinkingMap[cmt_log.LogIndex, consensusInst]) bool {`
`739`	`739`	`cmtInsts.ForEach(func(li cmt_log.LogIndex, ci *consensusInst) bool {`
`740`	`740`	`if ci.request != nil && !upd.Has(chainmanager.MakeConsensusKey(ci.request.CommitteeAddr, li)) {`
	`741`	`+ ci.Cancel()`
`741`	`742`	`cmtInsts.Delete(li)`
`742`	`743`	`}`
`743`	`744`	`return true`