OpenNebula

                    src/vmm_mad/remotes/kvm/migrate_local \

#!/bin/bash

# -------------------------------------------------------------------------- #

# Copyright 2002-2011, OpenNebula Project Leads (OpenNebula.org)             #

#                                                                            #

# Licensed under the Apache License, Version 2.0 (the "License"); you may    #

# not use this file except in compliance with the License. You may obtain    #

# a copy of the License at                                                   #

#                                                                            #

# http://www.apache.org/licenses/LICENSE-2.0                                 #

#                                                                            #

# Unless required by applicable law or agreed to in writing, software        #

# distributed under the License is distributed on an "AS IS" BASIS,          #

# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.   #

# See the License for the specific language governing permissions and        #

# limitations under the License.                                             #

#--------------------------------------------------------------------------- #

source $(dirname $0)/kvmrc

src_host=$1

deploy_id=$2

dest_host=$3

virsh --connect $QEMU_PROTOCOL://$src_host/system \

	migrate --live $deploy_id $QEMU_PROTOCOL://$dest_host/system

    def initialize(hypervisor, threads, retries, localpoll, localactions)

        @local_poll = localpoll

        @local_actions = localactions

        if @local_actions.include?('migrate')

            local_action("#{@actions_path}/migrate_local #{host} #{deploy_id} #{dest_host}",

                         id, :migrate)

        else

            remotes_action("#{@remote_path}/migrate #{deploy_id} #{dest_host}",

                           id, host, :migrate, @remote_dir)

        end

        elsif @local_actions.include?('poll')

            local_action("#{@actions_path}/poll_local #{host} #{deploy_id}",

                         id, :poll)

    [ '--localpoll',  '-p', GetoptLong::REQUIRED_ARGUMENT ],

    [ '--local',      '-L', GetoptLong::REQUIRED_ARGUMENT ]

hypervisor      = ''

retries         = 0

threads         = 15

localpoll       = nil

localactions    = []

            when '--local'

                arg.split(',').each do |action|

                    localactions.push(action)

                end

ssh_driver = SshDriver.new(hypervisor, threads, retries, localpoll, localactions)