Merge pull request lxc#1262 from gibmat/parallel-evacuate-restore

Run cluster evacuate and restore in parallel
stgraber · Oct 2, 2024 · f152532 · f152532
2 parents d6fb2a5 + e6e7e0a
commit f152532
Show file tree

Hide file tree

Showing 2 changed files with 206 additions and 166 deletions.
diff --git a/cmd/incusd/api_cluster.go b/cmd/incusd/api_cluster.go
@@ -2894,7 +2894,7 @@ func clusterNodeStatePost(d *Daemon, r *http.Request) response.Response {
 		}
 
 		run := func(op *operations.Operation) error {
-			return evacuateClusterMember(context.Background(), s, d.gateway, op, name, req.Mode, stopFunc, migrateFunc)
+			return evacuateClusterMember(context.Background(), s, op, name, req.Mode, stopFunc, migrateFunc)
 		}
 
 		op, err := operations.OperationCreate(s, "", operations.OperationClassTask, operationtype.ClusterMemberEvacuate, nil, nil, run, nil, nil, r)