VirtualDomain и KVM (Ubuntu Server 10.10)

VirtualDomain_Migrate_To() {
	ssh ${OCF_RESKEY_CRM_meta_migrate_target} drbdadm primary ${OCF_RESOURCE_INSTANCE}
	virsh migrate --live ${OCF_RESOURCE_INSTANCE} qemu+ssh://${OCF_RESKEY_CRM_meta_migrate_target}/system
	if [ $? -ne 0 ]; then
		ocf_log err "${OCF_RESOURCE_INSTANCE}: live migration to ${OCF_RESKEY_CRM_meta_migrate_target} failed"
		return $OCF_ERR_GENERIC
	else
		ocf_log info "${OCF_RESOURCE_INSTANCE}: live migration to ${OCF_RESKEY_CRM_meta_migrate_target} succeeded."
		drbdadm secondary ${OCF_RESOURCE_INSTANCE}
		return $OCF_SUCCESS
	fi
}

ms DataClone Data \
        meta master-max="1" master-node-max="1" clone-max="2" clone-node-max="1" notify="true" target-role="Started" is-managed="true"

#!/bin/sh

: ${OCF_FUNCTIONS_DIR=${OCF_ROOT}/resource.d/heartbeat}
. ${OCF_FUNCTIONS_DIR}/.ocf-shellfuncs
LC_ALL="C"
LANG="C"
VIRSH_OPTIONS="--connect=qemu:///system --quiet"
DOMAIN_NAME="${OCF_RESOURCE_INSTANCE}"

usage() {
  echo "usage: $0 {start|stop|monitor|migrate_to|migrate_from|meta-data}"
}

meta_data() {
	cat <<EOF
<?xml version="1.0"?>
<!DOCTYPE resource-agent SYSTEM "ra-api-1.dtd">
<resource-agent name="VirtualDomain">
<version>1.0</version>

<longdesc lang="en">
Resource agent for a virtual domain (a.k.a. domU, virtual machine,
virtual environment etc., depending on context) managed by libvirtd.
</longdesc>
<shortdesc lang="en">Manages virtual domains through the libvirt virtualization framework</shortdesc>

<parameters>

<parameter name="config" unique="1" required="1">
<longdesc lang="en">
Absolute path to the libvirt configuration file,
for this virtual domain.
</longdesc>
<shortdesc lang="en">Virtual domain configuration file</shortdesc>
<content type="string" default="" />
</parameter>

</parameters>

<actions>
<action name="start" timeout="90" />
<action name="stop" timeout="90" />
<action name="monitor" depth="0" timeout="30" interval="10" />
<action name="migrate_from" timeout="60" />
<action name="migrate_to" timeout="120" />
<action name="meta-data" timeout="5" />
</actions>
</resource-agent>
EOF
}

VirtualDomain_Status ()	{
	output=`virsh ${VIRSH_OPTIONS} domstate ${DOMAIN_NAME} 2>/dev/null`
    if [ $? -ne 0 ]; then
		#ocf_log info "Domain ${DOMAIN_NAME} not found."
		echo "not found"
	else
		#ocf_log info "Domain ${DOMAIN_NAME} ${output}."
		echo $output
    fi
}

VirtualDomain_Start() {
	case $(VirtualDomain_Status) in
	"not found")
		virsh ${VIRSH_OPTIONS} create ${OCF_RESKEY_config}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	"shut off")
		virsh ${VIRSH_OPTIONS} start ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	"running")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} running."	
		;;
	"paused")
		virsh ${VIRSH_OPTIONS} resume ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	esac
	return $OCF_SUCCESS
}

VirtualDomain_Stop ()	{
	case $(VirtualDomain_Status) in
	"not found")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} not found."	
		;;
	"shut off")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} shut off."
		;;
	"running")
		#Выявляем интревал ожидания
#		if [ -n "$OCF_RESKEY_CRM_meta_timeout" ]; then
#			timeout=$((OCF_RESKEY_CRM_meta_timeout/1500))
#			#Посылаем команду выключения
#			virsh ${VIRSH_OPTIONS} shutdown ${DOMAIN_NAME}
#			if [ $? -ne 0 ]; then
#				return $OCF_ERR_GENERIC
#			fi
#			#Цикл ожидания
#			echo $OCF_RESKEY_CRM_meta_timeout
#			local n=0
#			while [ $n -lt $timeout ]; do
#				if [ "$(VirtualDomain_Status)" == "running" ]; then 
#					echo -n "."
#					sleep 1
#				else
#					return $OCF_SUCCESS
#					break
#				fi
#				n=$(expr $n + 1)
#			done
#		fi
		
		#Интервал ожидания прошел
		virsh ${VIRSH_OPTIONS} destroy ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	"paused")
		virsh ${VIRSH_OPTIONS} destroy ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	esac
	return $OCF_SUCCESS
}

VirtualDomain_Monitor ()	{
	case $(VirtualDomain_Status) in
	"not found")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} not running."
		return $OCF_NOT_RUNNING
		;;
	"shut off")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} shut."
		return $OCF_NOT_RUNNING
		;;
	"running")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} running."	
		return $OCF_SUCCESS
		;;
	"paused")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} not running."	
		return $OCF_NOT_RUNNING
		;;
	*)
		ocf_log error "Do not understand the state of domain ${OCF_RESOURCE_INSTANCE}."	
		return $OCF_ERR_GENERIC
		;;
	esac
}

VirtualDomain_Migrate_From() {
    while ! VirtualDomain_Monitor; do
		sleep 1
    done
    ocf_log info "Live migration domain ${DOMAIN_NAME} from ${OCF_RESKEY_CRM_meta_migrate_source} succeeded."
    return $OCF_SUCCESS
}

VirtualDomain_Migrate_To() {
	virsh migrate --live ${DOMAIN_NAME} qemu+ssh://${OCF_RESKEY_CRM_meta_migrate_target}/system
	if [ $? -ne 0 ]; then
		ocf_log err "Live migration domain ${DOMAIN_NAME} to ${OCF_RESKEY_CRM_meta_migrate_target} failed"
		return $OCF_ERR_GENERIC
	else
		ocf_log info "Live migration domain ${DOMAIN_NAME} to ${OCF_RESKEY_CRM_meta_migrate_target} succeeded."
		return $OCF_SUCCESS
	fi
}

if [ $# -ne 1 ]; then
  usage
  exit $OCF_ERR_ARGS
fi

case $1 in
	meta-data)		
	meta_data
	exit $OCF_SUCCESS
	;;
	usage)
	usage
	exit $OCF_SUCCESS
	;;
esac

case $1 in
    start)
	VirtualDomain_Start
	;;
    stop)
	VirtualDomain_Stop
	;;
    migrate_to)
	VirtualDomain_Migrate_To
	;;
    migrate_from)
	VirtualDomain_Migrate_From
	;;
    monitor)
	VirtualDomain_Monitor
    ;;
    *)	
	usage
	exit $OCF_ERR_UNIMPLEMENTED
	;;
esac
exit $?

VirtualDomain_Stop ()   {
      .....
      #Выявляем интревал ожидания
      ......

primitive Data ocf:linbit:drbd \
        params drbd_resource="mt" \
        op monitor interval="20s" \
        op demote interval="0" timeout="90s" \
        op promote interval="0" timeout="90s"
primitive mt ocf:my:VirtualDomain \
        params config="/home/cluster/mt.domain" \
        meta allow-migrate="false" target-role="Started" \
        op start interval="0" timeout="90" \
        op stop interval="0" timeout="90" \
        op monitor interval="10" timeout="30" depth="0"

order mt-after-Data inf: DataClone:promote mt:start

 op demote interval="0" timeout="90s" \
        op promote interval="0" timeout="90s"

#!/bin/bash

#!/bin/sh

DOMAIN_NAME="${OCF_RESOURCE_INSTANCE}"

DOMAIN_NAME=`awk '$1~/^name(=|$)/{print}' ${OCF_RESKEY_xmfile} | sed 's/.*=[[:space:]]*//' | tr -d "[\"']"`

cat test.xml |awk -F "<name>" {'print $2'}|awk -F "</name>" {'print $1'}|grep -v ^$

#!/bin/bash

: ${OCF_FUNCTIONS_DIR=${OCF_ROOT}/resource.d/heartbeat}
: ${OCF_RESKEY_hypervisor=${OCF_RESKEY_hypervisor_default}}
: ${OCF_RESKEY_migration_transport=${OCF_RESKEY_migration_transport_default}}

. ${OCF_FUNCTIONS_DIR}/.ocf-shellfuncs

LC_ALL="C"
LANG="C"
OCF_RESKEY_hypervisor_default="$(virsh --quiet uri)"
OCF_RESKEY_migration_transport_default="ssh"
VIRSH_OPTIONS="--connect=${OCF_RESKEY_hypervisor} --quiet"
#DOMAIN_NAME="${OCF_RESOURCE_INSTANCE}"	
DOMAIN_NAME=`cat ${OCF_RESKEY_config} |awk -F "<name>" {'print $2'}|awk -F "</name>" {'print $1'}|grep -v ^$`

usage() {
  echo "usage: $0 {start|stop|status|monitor|migrate_to|migrate_from|meta-data|validate-all}"
}

meta_data() {
	cat <<EOF
<?xml version="1.0"?>
<!DOCTYPE resource-agent SYSTEM "ra-api-1.dtd">
<resource-agent name="VirtualDomain">
<version>1.0</version>

<longdesc lang="en">
Resource agent for a virtual domain (a.k.a. domU, virtual machine,
virtual environment etc., depending on context) managed by libvirtd.
</longdesc>
<shortdesc lang="en">Manages virtual domains through the libvirt virtualization framework</shortdesc>

<parameters>

<parameter name="config" unique="1" required="1">
<longdesc lang="en">
Absolute path to the libvirt configuration file,
for this virtual domain.
</longdesc>
<shortdesc lang="en">Virtual domain configuration file</shortdesc>
<content type="string" default="" />
</parameter>

<parameter name="hypervisor" unique="0" required="0">
<longdesc lang="en">
Hypervisor URI to connect to. See the libvirt documentation for
details on supported URI formats. The default is system dependent.
</longdesc>
<shortdesc lang="en">Hypervisor URI</shortdesc>
<content type="string" default="${OCF_RESKEY_hypervisor_default}"/>
</parameter>

<parameter name="shutdown_timeout" unique="1" required="1">
<longdesc lang="en">
shutdown_timeout
</longdesc>
<shortdesc lang="en">shutdown_timeout</shortdesc>
<content type="number" default="" />
</parameter>

<parameter name="migration_transport" unique="0" required="0">
<longdesc lang="en">
Transport used to connect to the remote hypervisor while
migrating. Please refer to the libvirt documentation for details on
transports available. If this parameter is omitted, the resource will
use libvirt's default transport to connect to the remote hypervisor.
</longdesc>
<shortdesc lang="en">Remote hypervisor transport</shortdesc>
<content type="string" default="${OCF_RESKEY_migration_transport_default}" />
</parameter>

</parameters>

<actions>
<action name="start" timeout="90" />
<action name="stop" timeout="90" />
<action name="status" depth="0" timeout="30" interval="10" />
<action name="monitor" depth="0" timeout="30" interval="10" />
<action name="migrate_from" timeout="60" />
<action name="migrate_to" timeout="120" />
<action name="meta-data" timeout="5" />
<action name="validate-all" timeout="5" />
</actions>
</resource-agent>
EOF
}

VirtualDomain_Status ()	{
	output=`virsh ${VIRSH_OPTIONS} domstate ${DOMAIN_NAME} 2>/dev/null`
    if [ $? -ne 0 ]; then
		#ocf_log info "Domain ${DOMAIN_NAME} not found."
		echo "not found"
	else
		#ocf_log info "Domain ${DOMAIN_NAME} ${output}."
		echo $output
    fi
}

VirtualDomain_Start() {
	case $(VirtualDomain_Status) in
	"not found")
		virsh ${VIRSH_OPTIONS} create ${OCF_RESKEY_config}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	"shut off")
		virsh ${VIRSH_OPTIONS} start ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	"running")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} running."	
		;;
	"paused")
		virsh ${VIRSH_OPTIONS} resume ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	esac
	return $OCF_SUCCESS
}

VirtualDomain_Stop ()	{
	local n
	local timeout
	
	case $(VirtualDomain_Status) in
	"not found")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} not found."	
		;;
	"shut off")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} shut off."
		;;
	"running")
		#Выявляем интревал ожидания
		if [ -n "$OCF_RESKEY_shutdown_timeout" ]; then
			timeout=$OCF_RESKEY_shutdown_timeout
#			timeout=35
			#Посылаем команду выключения
			virsh ${VIRSH_OPTIONS} shutdown ${DOMAIN_NAME}
			if [ $? -ne 0 ]; then
				return $OCF_ERR_GENERIC
			fi
			#Цикл ожидания
			local n=0
			while [ $n -lt $timeout ]; do
				if [ "$(VirtualDomain_Status)" == "running" ]; then 
					echo -n "." 
					sleep 1
				else
					return $OCF_SUCCESS
					break
				fi
				n=$(expr $n + 1)
			done
		fi
		#Интервал ожидания прошел
		virsh ${VIRSH_OPTIONS} destroy ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	"paused")
		virsh ${VIRSH_OPTIONS} destroy ${DOMAIN_NAME}
		if [ $? -ne 0 ]; then
			return $OCF_ERR_GENERIC
		fi
		;;
	esac
	return $OCF_SUCCESS
}

VirtualDomain_Monitor ()	{
	case $(VirtualDomain_Status) in
	"not found"|"shut off"|"paused")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} not running."
		return $OCF_NOT_RUNNING
		;;
	"running")
		ocf_log info "Domain ${OCF_RESOURCE_INSTANCE} running."	
		return $OCF_SUCCESS
		;;
	*)
		ocf_log error "Do not understand the state of domain ${OCF_RESOURCE_INSTANCE}."	
		return $OCF_ERR_GENERIC
		;;
	esac
}

VirtualDomain_Migrate_From() {
    while ! VirtualDomain_Monitor; do
		sleep 1
    done
    ocf_log info "Live migration domain ${DOMAIN_NAME} from ${OCF_RESKEY_CRM_meta_migrate_source} succeeded."
    return $OCF_SUCCESS
}

VirtualDomain_Migrate_To() {
	local target_node
    local remoteuri
    local transport_suffix
	
	if [ "$(VirtualDomain_Status)"  !=  "running" ]; then
		ocf_log err "$DOMAIN_NAME: migrate_to: Not active locally!"
		return $OCF_ERR_GENERIC
	fi
	
	target_node="$OCF_RESKEY_CRM_meta_migrate_target"
	if [ -n "${OCF_RESKEY_migration_transport}" ]; then
	    transport_suffix="+${OCF_RESKEY_migration_transport}"
	fi
	remoteuri=$(echo ${OCF_RESKEY_hypervisor} | sed -e "s,\(.*\)://[^/:]*\(:\?[0-9]*\)/\(.*\),\1${transport_suffix}://${target_node}\2/\3,")
	
	ocf_log info "$DOMAIN_NAME: Starting live migration to ${target_node} (using remote hypervisor URI ${remoteuri})."
	virsh ${VIRSH_OPTIONS} migrate --live $DOMAIN_NAME ${remoteuri}
	if [ $? -ne 0 ]; then
		ocf_log err "$DOMAIN_NAME: live migration to ${remoteuri} failed"
		return $OCF_ERR_GENERIC
	else
		ocf_log info "$DOMAIN_NAME: live migration to ${target_node} succeeded."
		return $OCF_SUCCESS
	fi
}

VirtualDomain_Validate_All() {
    # Required binaries:
    for binary in virsh sed; do
        check_binary $binary
    done

    if [ -z $OCF_RESKEY_config ]; then
	ocf_log error "Missing configuration parameter \"config\"."
	return $OCF_ERR_CONFIGURED
    fi

    # check if we can read the config file (otherwise we're unable to
    # deduce $DOMAIN_NAME from it, see below)
    if [ ! -r $OCF_RESKEY_config ]; then
	if ocf_is_probe; then
	    ocf_log info "Configuration file $OCF_RESKEY_config not readable during probe."
	else
	    ocf_log error "Configuration file $OCF_RESKEY_config does not exist or is not readable."
	    return $OCF_ERR_INSTALLED
	fi
    fi
}

if [ $# -ne 1 ]; then
  usage
  exit $OCF_ERR_ARGS
fi

case $1 in
	meta-data)		
	meta_data
	exit $OCF_SUCCESS
	;;
	usage)
	usage
	exit $OCF_SUCCESS
	;;
esac

VirtualDomain_Validate_All || exit $?

case $1 in
    start)
	VirtualDomain_Start
	;;
    stop)
	VirtualDomain_Stop
	;;
    migrate_to)
	VirtualDomain_Migrate_To
	;;
    migrate_from)
	VirtualDomain_Migrate_From
	;;
    status)
	VirtualDomain_Status
	;;
    monitor)
	VirtualDomain_Monitor
        ;;
    validate-all)		
	;;
    *)	
	usage
	exit $OCF_ERR_UNIMPLEMENTED
	;;

esac
exit $?