Call observer only when retain height changes (cometbft#1490)

osmosis-labs · Jan 24, 2024 · ad5bff2 · ad5bff2
1 parent d736369
commit ad5bff2
Showing 1 changed file with 12 additions and 8 deletions.
diff --git a/state/pruner.go b/state/pruner.go
@@ -237,10 +237,12 @@ func (p *Pruner) pruneABCIResponses() {
 			return
 		default:
 			newRetainHeight := p.pruneABCIResToRetainHeight(lastRetainHeight)
-			p.observer.PrunerPrunedABCIRes(&ABCIResponsesPrunedInfo{
-				FromHeight: lastRetainHeight,
-				ToHeight:   newRetainHeight - 1,
-			})
+			if newRetainHeight != lastRetainHeight {
+				p.observer.PrunerPrunedABCIRes(&ABCIResponsesPrunedInfo{
+					FromHeight: lastRetainHeight,
+					ToHeight:   newRetainHeight - 1,
+				})
+			}
 			lastRetainHeight = newRetainHeight
 			time.Sleep(p.interval)
 		}
@@ -256,10 +258,12 @@ func (p *Pruner) pruneBlocks() {
 			return
 		default:
 			newRetainHeight := p.pruneBlocksToRetainHeight(lastRetainHeight)
-			p.observer.PrunerPrunedBlocks(&BlocksPrunedInfo{
-				FromHeight: lastRetainHeight,
-				ToHeight:   newRetainHeight - 1,
-			})
+			if newRetainHeight != lastRetainHeight {
+				p.observer.PrunerPrunedBlocks(&BlocksPrunedInfo{
+					FromHeight: lastRetainHeight,
+					ToHeight:   newRetainHeight - 1,
+				})
+			}
 			lastRetainHeight = newRetainHeight
 			time.Sleep(p.interval)
 		}