Skip to content
This repository was archived by the owner on Oct 15, 2025. It is now read-only.

Commit 439873e

Browse files
committed
VolatilityMonitor AddAll() called to monitor all blocks
Signed-off-by: Jimmy Moore <[email protected]>
1 parent 83f5435 commit 439873e

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

pkg/peer/migrate_from.go

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -203,6 +203,7 @@ func (peer *Peer[L, R, G]) MigrateFrom(
203203

204204
dirtyLocal, dirtyRemote := dirtytracker.NewDirtyTracker(local, int(di.BlockSize))
205205
vmonitor := volatilitymonitor.NewVolatilityMonitor(dirtyLocal, int(di.BlockSize), volatilityExpiry)
206+
vmonitor.AddAll()
206207

207208
dev.SetProvider(vmonitor)
208209

@@ -507,6 +508,7 @@ func (peer *Peer[L, R, G]) MigrateFrom(
507508

508509
dirtyLocal, dirtyRemote := dirtytracker.NewDirtyTracker(local, int(input.BlockSize))
509510
vmonitor := volatilitymonitor.NewVolatilityMonitor(dirtyLocal, int(input.BlockSize), volatilityExpiry)
511+
vmonitor.AddAll()
510512

511513
dev.SetProvider(vmonitor)
512514

0 commit comments

Comments
 (0)