Function runGuestsMigrate

internal/cli/guests.go:1213–1311

(cmd *cobra.Command, args []string)

}

func runGuestsMigrate(cmd *cobra.Command, args []string) error {
	vmid, err := parseVMID(args[0])
	if err != nil {
		return printError(err)
	}
	targetNode := args[1]

	session, err := initCLISession(cmd)
	if err != nil {
		return printError(err)
	}
	if session == nil {
		return nil
	}

	ctx := context.Background()

	vm, err := session.findVM(ctx, vmid)
	if err != nil {
		return printError(err)
	}

	// Validate target node exists and is online.
	target, err := session.findNodeByName(ctx, targetNode)
	if err != nil {
		return printError(err)
	}
	if !target.Online {
		return printError(fmt.Errorf("target node %q is offline", targetNode))
	}
	if target.Name == vm.Node {
		return printError(fmt.Errorf("guest %d is already on node %q", vmid, targetNode))
	}

	forceOnline, _ := cmd.Flags().GetBool("online")
	forceOffline, _ := cmd.Flags().GetBool("offline")

	if vm.Type == api.VMTypeLXC && (forceOnline || forceOffline) {
		return printError(fmt.Errorf("--online/--offline are not applicable to LXC containers"))
	}
	if forceOnline && forceOffline {
		return printError(fmt.Errorf("--online and --offline are mutually exclusive"))
	}

	// Build migration options with auto mode selection.
	options := &api.MigrationOptions{Target: targetNode}
	mode := "offline"
	switch vm.Type {
	case api.VMTypeLXC:
		mode = "restart"
	case api.VMTypeQemu:
		online := vm.Status == api.VMStatusRunning
		if forceOnline {
			online = true
		}
		if forceOffline {
			online = false
		}