fix: engine uses the consolidated map

Signed-off-by: Shuo Wu <[email protected]>
longhorn · Nov 5, 2024 · 42c6b02 · 42c6b02
1 parent 0e0e03d
commit 42c6b02
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/pkg/spdk/engine.go b/pkg/spdk/engine.go
@@ -1812,12 +1812,12 @@ func (e *Engine) waitForRestoreComplete() error {
 	var err error
 	for range periodicChecker.C {
 		isReplicaRestoreCompleted := true
-		for replicaName, replicaAddress := range e.ReplicaAddressMap {
-			if e.ReplicaModeMap[replicaName] != types.ModeRW {
+		for replicaName, replicaStatus := range e.ReplicaStatusMap {
+			if replicaStatus.Mode != types.ModeRW {
 				continue
 			}
 
-			isReplicaRestoreCompleted, err = e.isReplicaRestoreCompleted(replicaName, replicaAddress)
+			isReplicaRestoreCompleted, err = e.isReplicaRestoreCompleted(replicaName, replicaStatus.Address)
 			if err != nil {
 				return errors.Wrapf(err, "failed to check replica %s restore status", replicaName)
 			}