deleting README.livemigration.txt and nova/livemigration_test/*
This commit is contained in:
Kei Masumoto
@@ -1,154 +0,0 @@
|
||||
#
|
||||
# Live migration feature usage:
|
||||
#
|
||||
# @auther Kei Masumoto <masumotok@nttdata.co.jp>
|
||||
# @date 2010.12.01
|
||||
#
|
||||
# @history ver.1 2010.12.01 ( masumotok )
|
||||
# initial version
|
||||
#
|
||||
|
||||
|
||||
0. pre-requisit settings
|
||||
OS: Ubuntu lucid 10.04 for both instances and host.
|
||||
NFS: nova-install-dir/instances has to be mounted by shared storage.
|
||||
( this version is tested using NFS)
|
||||
Network manager: Only VlanManager can be used in this version.
|
||||
instances : Instance must keep running without any EBS volume.
|
||||
|
||||
|
||||
1. pre-requisite settings.
|
||||
|
||||
(a) shared storage
|
||||
As mentioned above, shared storage is inevitable for the live_migration functionality.
|
||||
An example is NFS( my test environment ), and example setting is as follows.
|
||||
|
||||
Prepare NFS server machine( nova-api server is OK), and add below line /etc/exports:
|
||||
|
||||
> nova-install-dir/instances a.b.c.d/255.255.0.0(rw,sync,fsid=0,no_root_squash)
|
||||
|
||||
where "nova-install-dir" is the directory which openstack is installed, and
|
||||
add appropriate ip address and netmask for "a.b.c.d/255.255.0.0" , which should include
|
||||
compute nodes which try to mount this directory.
|
||||
|
||||
Then restart nfs server.
|
||||
|
||||
> /etc/init.d/nfs-kernel-server restart
|
||||
> /etc/init.d/idmapd restart
|
||||
|
||||
Also, at any compute nodes, add below line to /etc/fstab:
|
||||
|
||||
>172.19.0.131:/ DIR nfs4 defaults 0 0
|
||||
|
||||
where "DIR" must be same as 'instances_path'( see nova.compute.manager for the default value)
|
||||
|
||||
Then try to mount,
|
||||
|
||||
> mount -a -v
|
||||
|
||||
Check exported directory is successfully mounted. if fail, try this at any hosts,
|
||||
|
||||
> iptables -F
|
||||
|
||||
Also, check file/daemon permissions.
|
||||
we expect any nova daemons are running as root.
|
||||
> root@openstack2-api:/opt/nova-2010.4# ps -ef | grep nova
|
||||
> root 5948 5904 9 11:29 pts/4 00:00:00 python /opt/nova-2010.4//bin/nova-api
|
||||
> root 5952 5908 6 11:29 pts/5 00:00:00 python /opt/nova-2010.4//bin/nova-objectstore
|
||||
> ... (snip)
|
||||
|
||||
"instances/" directory can be seen from server side:
|
||||
> root@openstack:~# ls -ld nova-install-dir/instances/
|
||||
> drwxr-xr-x 2 root root 4096 2010-12-07 14:34 nova-install-dir/instances/
|
||||
|
||||
also, client side:
|
||||
> root@openstack-client:~# ls -ld nova-install-dir/instances/
|
||||
> drwxr-xr-x 2 root root 4096 2010-12-07 14:34 nova-install-dir/instances/
|
||||
|
||||
|
||||
|
||||
(b) libvirt settings
|
||||
In default configuration, this feature use simple tcp protocol(qemu+tcp://).
|
||||
To use this protocol, below configuration is necessary.
|
||||
|
||||
a. modify /etc/libvirt/libvirt.conf
|
||||
|
||||
before : #listen_tls = 0
|
||||
after : listen_tls = 0
|
||||
|
||||
before : #listen_tcp = 1
|
||||
after : listen_tcp = 1
|
||||
|
||||
append : auth_tcp = "none"
|
||||
|
||||
b. modify /etc/init/libvirt-bin.conf
|
||||
|
||||
before : exec /usr/sbin/libvirtd -d
|
||||
after : exec /usr/sbin/libvirtd -d -l
|
||||
|
||||
c. modify /etc/default/libvirt-bin
|
||||
|
||||
before :libvirtd_opts=" -d"
|
||||
after :libvirtd_opts=" -d -l"
|
||||
|
||||
then, restart libvirt
|
||||
stop libvirt-bin && start libvirt-bin
|
||||
ps -ef | grep libvirt
|
||||
|
||||
make sure you get the below result.
|
||||
> root@openstack2:/opt/nova-2010.2# ps -ef | grep libvirt
|
||||
> root 1145 1 0 Nov27 ? 00:00:03 /usr/sbin/libvirtd -d -l
|
||||
|
||||
if you would like to use qemu+ssh or other protocol, change "live_migration_uri" flag.
|
||||
by adding "--live_migration_uri" to /etc/nova/nova.conf (Note that file name may be
|
||||
changed depends on version).
|
||||
|
||||
|
||||
2. command usage
|
||||
|
||||
To get a list of physical hosts,
|
||||
nova-manage host list
|
||||
|
||||
To get a available pysical resource of each host,
|
||||
nova-manage host show hostname
|
||||
|
||||
an example result is below:
|
||||
> HOST PROJECT cpu mem(mb) disk(gb)
|
||||
> openstack2-c2 16 32232 878
|
||||
> openstack2-c2 admin 1 2048 20
|
||||
|
||||
The 1st line shows total amount of resource that the specified host has.
|
||||
The 2nd and latter lines show usage resource per project.
|
||||
This command is created because admins can decide which host should be
|
||||
a destination of live migration.
|
||||
|
||||
For live migration,
|
||||
nova-manage instances live_migration ec2-id(i-xxxx) destination-host-name.
|
||||
|
||||
once this command is executed, admins will check the status through
|
||||
euca-describe-instances. The status is changed from 'running' to 'migrating',
|
||||
and changed to 'running' when live migration finishes.
|
||||
Note that it depends on an environment how long it takes to live migration finishes.
|
||||
If it finishes too fast, admins cannot see 'migrating' status.
|
||||
|
||||
> root@openstack2:/opt/nova-2010.2# euca-describe-instances
|
||||
> Reservation:r-qlg3favp
|
||||
> RESERVATION r-qlg3favp admin
|
||||
> INSTANCE i-2ah453 ami-tiny 172.19.0.134 10.0.0.3
|
||||
> migrating testkey (admin, openstack2-c2) 0 m1.small
|
||||
> 2010-11-28 16:09:16 openstack2-c2
|
||||
|
||||
When live migration finishes successfully, admin can check the last part of
|
||||
euca-describe-instances which shows physical node information.
|
||||
( only when euca-describe-instances is executed by admin user )
|
||||
Admins also can check live migration source compute node logfile which may
|
||||
show a log.
|
||||
> Live migration i-xxxx to DESTHOST finishes successfully.
|
||||
|
||||
|
||||
3. error checking
|
||||
When live migration fails somehow, error messages are shown at:
|
||||
a. scheduler logfile
|
||||
b. source compute node logfile
|
||||
c. dest compute node logfile
|
||||
|
||||
Binary file not shown.
Binary file not shown.
Binary file not shown.
@@ -1,39 +0,0 @@
|
||||
#!/bin/bash
|
||||
|
||||
DIR=/opt/nova-2010.1
|
||||
|
||||
# 1. 管理者ユーザを作成する
|
||||
# nova-manage user admin ユーザ名 access-key secret-key
|
||||
#
|
||||
#$DIR/bin/nova-manage user admin admin admin admin
|
||||
|
||||
# 2. プロジェクトを作成する
|
||||
# nova-manage create project プロジェクト名 プロジェクトに属するユーザ名
|
||||
#
|
||||
#$DIR/bin/nova-manage project create admin admin
|
||||
|
||||
# 3. クラウドを使うための認証情報を生成する
|
||||
# nova-manage project environment プロジェクト名 ユーザ名 認証情報を格納するファイル
|
||||
#
|
||||
#$DIR/bin/nova-manage project environment admin admin $DIR/novarc
|
||||
|
||||
# 4. 認証情報の読み込み
|
||||
. $DIR/novarc
|
||||
|
||||
# 5. プロジェクト用仮想マシンネットワークの作成を行う
|
||||
# nova-manage user admin ユーザ名 access-key secret-key
|
||||
#
|
||||
$DIR/bin/nova-manage network create 10.0.0.0/8 3 16
|
||||
|
||||
# 6. 初回ログインにはSSHの公開鍵認証が必要
|
||||
#
|
||||
if [ "" == "`euca-describe-keypairs | grep testkey`" ]; then
|
||||
euca-add-keypair testkey > testkey.pem
|
||||
fi
|
||||
|
||||
# 7.
|
||||
for i in 172.19.0.134 172.19.0.135 172.19.0.136 172.19.0.137 ; do
|
||||
sudo ip addr del $i dev eth0 2> /dev/null
|
||||
done
|
||||
|
||||
|
||||
@@ -1,57 +0,0 @@
|
||||
#!/bin/bash
|
||||
|
||||
DIR=/opt/nova-2010.1
|
||||
|
||||
function inc_assigned(){
|
||||
assigned=`expr $assigned + 1`
|
||||
}
|
||||
|
||||
|
||||
# 1. 認証情報の読み込み
|
||||
. $DIR/novarc
|
||||
|
||||
# 3. 仮想マシンの起動
|
||||
#
|
||||
ret=`euca-run-instances -t m1.small -k testkey ami-centos`
|
||||
#ret=`euca-run-instances -t m1.small -k testkey ami-tiny`
|
||||
|
||||
# 4. 仮想マシン用IPの確保
|
||||
# 未登録なら登録しておく
|
||||
registered=`euca-describe-addresses`
|
||||
for ip in 172.19.0.134 172.19.0.135 172.19.0.136 172.19.0.137 ; do
|
||||
|
||||
not_registered=`echo $registered | grep $ip`
|
||||
if [ "" == "$not_registered" ]; then
|
||||
echo "[INFO] registed $ip"
|
||||
$DIR/bin/nova-manage floating create `hostname` $ip
|
||||
fi
|
||||
done
|
||||
|
||||
# 5. IPの割当
|
||||
echo 0 > /tmp/demo-runinstance
|
||||
euca-describe-addresses | grep -v reserved | while read line; do
|
||||
# 割り当てられてないものを仮想マシンに割り当てる
|
||||
ip=`echo $line | cut -d ' ' -f 2`
|
||||
id=`echo $ret | cut -d ' ' -f 5`
|
||||
if [ "" == "`echo $id | grep i- `" ] ; then
|
||||
echo "[INFO] try again" $ret
|
||||
break
|
||||
fi
|
||||
echo "[INFO] assigned to ipaddr($ip) to instance($id) "
|
||||
euca-associate-address -i $id $ip
|
||||
echo 1 > /tmp/demo-runinstance
|
||||
break
|
||||
done
|
||||
|
||||
echo $assigned
|
||||
if [ 0 -eq "`cat /tmp/demo-runinstance`" ] ; then
|
||||
echo "[INFO] address is full."
|
||||
fi
|
||||
rm -rf /tmp/demo-runinstance
|
||||
|
||||
|
||||
# 6. FWの設定
|
||||
euca-authorize -P tcp -p 22 default 2> /dev/null > /dev/null
|
||||
euca-authorize -P tcp -p 80 default 2> /dev/null > /dev/null
|
||||
euca-authorize -P tcp -p 5555 default 2> /dev/null > /dev/null
|
||||
|
||||
@@ -1,18 +0,0 @@
|
||||
--verbose
|
||||
--nodaemon
|
||||
--dhcpbridge_flagfile=/etc/nova/nova-manage.conf
|
||||
--FAKE_subdomain=ec2
|
||||
--libvirt_type=qemu
|
||||
--no_internet_conn=True
|
||||
--public_netif=eth0
|
||||
--public_interface=eth0
|
||||
|
||||
--cc-host=172.19.0.131
|
||||
--routing_source_ip=172.19.0.131
|
||||
--sql_connection=mysql://root:nova@172.19.0.131/nova
|
||||
--rabbit_host=172.19.0.131
|
||||
--redis_host=172.19.0.131
|
||||
--s3_host=172.19.0.131
|
||||
--auth_driver=nova.auth.ldapdriver.LdapDriver
|
||||
--ldap_url=ldap://172.19.0.131
|
||||
|
||||
@@ -1,10 +0,0 @@
|
||||
--verbose
|
||||
--nodaemon
|
||||
--dhcpbridge_flagfile=/opt/nova-2010.4//bin/nova.conf
|
||||
--network_manager=nova.network.manager.VlanManager
|
||||
--cc_host=172.19.0.131
|
||||
--routing_source_ip=172.19.0.131
|
||||
--sql_connection=mysql://root:nova@localhost/nova
|
||||
--auth_driver=nova.auth.ldapdriver.LdapDriver
|
||||
--libvirt_type=qemu
|
||||
--public_interface=eth0
|
||||
@@ -1,180 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
DIR=`pwd`
|
||||
CMD=$1
|
||||
SOURCE_BRANCH=lp:nova
|
||||
if [ -n "$2" ]; then
|
||||
SOURCE_BRANCH=$2
|
||||
fi
|
||||
#DIRNAME=nova
|
||||
DIRNAME=""
|
||||
NOVA_DIR=$DIR/$DIRNAME
|
||||
if [ -n "$3" ]; then
|
||||
NOVA_DIR=$DIR/$3
|
||||
fi
|
||||
|
||||
if [ ! -n "$HOST_IP" ]; then
|
||||
# NOTE(vish): This will just get the first ip in the list, so if you
|
||||
# have more than one eth device set up, this will fail, and
|
||||
# you should explicitly set HOST_IP in your environment
|
||||
HOST_IP=`ifconfig | grep -m 1 'inet addr:'| cut -d: -f2 | awk '{print $1}'`
|
||||
fi
|
||||
|
||||
#USE_MYSQL=${USE_MYSQL:-0}
|
||||
USE_MYSQL=1
|
||||
MYSQL_PASS=${MYSQL_PASS:-nova}
|
||||
TEST=${TEST:-0}
|
||||
#USE_LDAP=${USE_LDAP:-0}
|
||||
USE_LDAP=1
|
||||
LIBVIRT_TYPE=${LIBVIRT_TYPE:-qemu}
|
||||
NET_MAN=${NET_MAN:-VlanManager}
|
||||
# NOTE(vish): If you are using FlatDHCP on multiple hosts, set the interface
|
||||
# below but make sure that the interface doesn't already have an
|
||||
# ip or you risk breaking things.
|
||||
# FLAT_INTERFACE=eth0
|
||||
|
||||
if [ "$USE_MYSQL" == 1 ]; then
|
||||
SQL_CONN=mysql://root:$MYSQL_PASS@localhost/nova
|
||||
else
|
||||
SQL_CONN=sqlite:///$NOVA_DIR/nova.sqlite
|
||||
fi
|
||||
|
||||
if [ "$USE_LDAP" == 1 ]; then
|
||||
AUTH=ldapdriver.LdapDriver
|
||||
else
|
||||
AUTH=dbdriver.DbDriver
|
||||
fi
|
||||
|
||||
mkdir -p /etc/nova
|
||||
cat >$NOVA_DIR/bin/nova.conf << NOVA_CONF_EOF
|
||||
--verbose
|
||||
--nodaemon
|
||||
--dhcpbridge_flagfile=$NOVA_DIR/bin/nova.conf
|
||||
--network_manager=nova.network.manager.$NET_MAN
|
||||
--cc_host=$HOST_IP
|
||||
--routing_source_ip=$HOST_IP
|
||||
--sql_connection=$SQL_CONN
|
||||
--auth_driver=nova.auth.$AUTH
|
||||
--libvirt_type=$LIBVIRT_TYPE
|
||||
--public_interface=eth0
|
||||
NOVA_CONF_EOF
|
||||
|
||||
if [ -n "$FLAT_INTERFACE" ]; then
|
||||
echo "--flat_interface=$FLAT_INTERFACE" >>$NOVA_DIR/bin/nova.conf
|
||||
fi
|
||||
|
||||
if [ "$CMD" == "branch" ]; then
|
||||
sudo apt-get install -y bzr
|
||||
rm -rf $NOVA_DIR
|
||||
bzr branch $SOURCE_BRANCH $NOVA_DIR
|
||||
cd $NOVA_DIR
|
||||
mkdir -p $NOVA_DIR/instances
|
||||
mkdir -p $NOVA_DIR/networks
|
||||
fi
|
||||
|
||||
# You should only have to run this once
|
||||
if [ "$CMD" == "install" ]; then
|
||||
sudo apt-get install -y python-software-properties
|
||||
sudo add-apt-repository ppa:nova-core/ppa
|
||||
sudo apt-get update
|
||||
sudo apt-get install -y dnsmasq kpartx kvm gawk iptables ebtables
|
||||
sudo apt-get install -y user-mode-linux kvm libvirt-bin
|
||||
sudo apt-get install -y screen euca2ools vlan curl rabbitmq-server
|
||||
sudo apt-get install -y lvm2 iscsitarget open-iscsi
|
||||
echo "ISCSITARGET_ENABLE=true" | sudo tee /etc/default/iscsitarget
|
||||
sudo /etc/init.d/iscsitarget restart
|
||||
sudo modprobe kvm
|
||||
sudo /etc/init.d/libvirt-bin restart
|
||||
sudo apt-get install -y python-twisted python-sqlalchemy python-mox python-greenlet python-carrot
|
||||
sudo apt-get install -y python-daemon python-eventlet python-gflags python-tornado python-ipy
|
||||
sudo apt-get install -y python-libvirt python-libxml2 python-routes
|
||||
if [ "$USE_MYSQL" == 1 ]; then
|
||||
cat <<MYSQL_PRESEED | debconf-set-selections
|
||||
mysql-server-5.1 mysql-server/root_password password $MYSQL_PASS
|
||||
mysql-server-5.1 mysql-server/root_password_again password $MYSQL_PASS
|
||||
mysql-server-5.1 mysql-server/start_on_boot boolean true
|
||||
MYSQL_PRESEED
|
||||
apt-get install -y mysql-server python-mysqldb
|
||||
fi
|
||||
wget http://c2477062.cdn.cloudfiles.rackspacecloud.com/images.tgz
|
||||
tar -C $DIR -zxf images.tgz
|
||||
fi
|
||||
|
||||
NL=`echo -ne '\015'`
|
||||
|
||||
function screen_it {
|
||||
screen -S nova -X screen -t $1
|
||||
screen -S nova -p $1 -X stuff "$2$NL"
|
||||
}
|
||||
|
||||
if [ "$CMD" == "run" ]; then
|
||||
killall dnsmasq
|
||||
screen -d -m -S nova -t nova
|
||||
sleep 1
|
||||
if [ "$USE_MYSQL" == 1 ]; then
|
||||
mysql -p$MYSQL_PASS -e 'DROP DATABASE nova;'
|
||||
mysql -p$MYSQL_PASS -e 'CREATE DATABASE nova;'
|
||||
else
|
||||
rm $NOVA_DIR/nova.sqlite
|
||||
fi
|
||||
if [ "$USE_LDAP" == 1 ]; then
|
||||
sudo $NOVA_DIR/nova/auth/slap.sh
|
||||
fi
|
||||
rm -rf $NOVA_DIR/instances
|
||||
mkdir -p $NOVA_DIR/instances
|
||||
rm -rf $NOVA_DIR/networks
|
||||
mkdir -p $NOVA_DIR/networks
|
||||
$NOVA_DIR/tools/clean-vlans
|
||||
if [ ! -d "$NOVA_DIR/images" ]; then
|
||||
#ln -s $DIR/images $NOVA_DIR/images
|
||||
ln -s /opt/images $NOVA_DIR/images
|
||||
fi
|
||||
|
||||
if [ "$TEST" == 1 ]; then
|
||||
cd $NOVA_DIR
|
||||
python $NOVA_DIR/run_tests.py
|
||||
cd $DIR
|
||||
fi
|
||||
|
||||
# create an admin user called 'admin'
|
||||
$NOVA_DIR/bin/nova-manage user admin admin admin admin
|
||||
# create a project called 'admin' with project manager of 'admin'
|
||||
$NOVA_DIR/bin/nova-manage project create admin admin
|
||||
# export environment variables for project 'admin' and user 'admin'
|
||||
$NOVA_DIR/bin/nova-manage project environment admin admin $NOVA_DIR/novarc
|
||||
# create a small network
|
||||
$NOVA_DIR/bin/nova-manage network create 10.0.0.0/8 1 32
|
||||
|
||||
# nova api crashes if we start it with a regular screen command,
|
||||
# so send the start command by forcing text into the window.
|
||||
screen_it api "$NOVA_DIR/bin/nova-api"
|
||||
screen_it objectstore "$NOVA_DIR/bin/nova-objectstore"
|
||||
#screen_it compute "$NOVA_DIR/bin/nova-compute"
|
||||
screen_it network "$NOVA_DIR/bin/nova-network"
|
||||
screen_it scheduler "$NOVA_DIR/bin/nova-scheduler"
|
||||
screen_it volume "$NOVA_DIR/bin/nova-volume"
|
||||
#screen_it test ". $NOVA_DIR/novarc"
|
||||
screen -S nova -x
|
||||
fi
|
||||
|
||||
if [ "$CMD" == "run" ] || [ "$CMD" == "terminate" ]; then
|
||||
# shutdown instances
|
||||
. $NOVA_DIR/novarc; euca-describe-instances | grep i- | cut -f2 | xargs euca-terminate-instances
|
||||
sleep 2
|
||||
# delete volumes
|
||||
. $NOVA_DIR/novarc; euca-describe-volumes | grep vol- | cut -f2 | xargs -n1 euca-delete-volume
|
||||
fi
|
||||
|
||||
if [ "$CMD" == "run" ] || [ "$CMD" == "clean" ]; then
|
||||
screen -S nova -X quit
|
||||
rm *.pid*
|
||||
fi
|
||||
|
||||
if [ "$CMD" == "scrub" ]; then
|
||||
$NOVA_DIR/tools/clean-vlans
|
||||
if [ "$LIBVIRT_TYPE" == "uml" ]; then
|
||||
virsh -c uml:///system list | grep i- | awk '{print \$1}' | xargs -n1 virsh -c uml:///system destroy
|
||||
else
|
||||
virsh list | grep i- | awk '{print \$1}' | xargs -n1 virsh destroy
|
||||
fi
|
||||
vblade-persist ls | grep vol- | awk '{print \$1\" \"\$2}' | xargs -n2 vblade-persist destroy
|
||||
fi
|
||||
@@ -1,37 +0,0 @@
|
||||
#!/usr/bin/env bash
|
||||
|
||||
DIRNAME=nova
|
||||
NOVA_DIR=$DIR/$DIRNAME
|
||||
if [ -n "$3" ]; then
|
||||
NOVA_DIR=$DIR/$3
|
||||
fi
|
||||
|
||||
DIR=/opt/nova-2010.4
|
||||
REDIS_DIR=/opt/redis-2.0.0-rc4/
|
||||
NOVA_DIR=$DIR/nova
|
||||
HOST_IP=172.19.0.131
|
||||
|
||||
mkdir -p /etc/nova
|
||||
cat >/etc/nova/nova-manage.conf << NOVA_CONF_EOF
|
||||
--verbose
|
||||
--nodaemon
|
||||
--dhcpbridge_flagfile=/etc/nova/nova-manage.conf
|
||||
--FAKE_subdomain=ec2
|
||||
--libvirt_type=qemu
|
||||
--no_internet_conn=True
|
||||
--public_netif=eth0
|
||||
--public_interface=eth0
|
||||
|
||||
--cc-host=$HOST_IP
|
||||
--routing_source_ip=$HOST_IP
|
||||
--sql_connection=mysql://root:nova@$HOST_IP/nova
|
||||
--rabbit_host=$HOST_IP
|
||||
--redis_host=$HOST_IP
|
||||
--s3_host=$HOST_IP
|
||||
--auth_driver=nova.auth.ldapdriver.LdapDriver
|
||||
--ldap_url=ldap://$HOST_IP
|
||||
|
||||
NOVA_CONF_EOF
|
||||
|
||||
$DIR/bin/nova-compute --flagfile=/etc/nova/nova-manage.conf
|
||||
|
||||
@@ -1,411 +0,0 @@
|
||||
#!/usr/bin/python
|
||||
# -*- coding: UTF-8 -*-
|
||||
|
||||
|
||||
import sys
|
||||
import os
|
||||
import unittest
|
||||
import commands
|
||||
import re
|
||||
import logging
|
||||
|
||||
from mock import Mock
|
||||
import twisted
|
||||
|
||||
# getting /nova-inst-dir
|
||||
NOVA_DIR = os.path.abspath(sys.argv[0])
|
||||
for i in range(4):
|
||||
NOVA_DIR = os.path.dirname(NOVA_DIR)
|
||||
|
||||
try:
|
||||
print
|
||||
print 'checking %s/bin/nova-manage exists, set the NOVA_DIR properly..' \
|
||||
% NOVA_DIR
|
||||
print
|
||||
|
||||
sys.path.append(NOVA_DIR)
|
||||
|
||||
from nova.compute.manager import ComputeManager
|
||||
from nova.virt.libvirt_conn import LibvirtConnection
|
||||
|
||||
from nova import context
|
||||
from nova import db
|
||||
from nova import exception
|
||||
from nova import flags
|
||||
from nova import quota
|
||||
from nova import utils
|
||||
from nova.auth import manager
|
||||
from nova.cloudpipe import pipelib
|
||||
from nova import rpc
|
||||
from nova.api.ec2 import cloud
|
||||
from nova.compute import power_state
|
||||
|
||||
from nova.db.sqlalchemy.models import *
|
||||
|
||||
|
||||
except:
|
||||
print 'set correct NOVA_DIR in this script. '
|
||||
raise
|
||||
|
||||
|
||||
class tmpStdout:
|
||||
def __init__(self):
|
||||
self.buffer = ""
|
||||
|
||||
def write(self, arg):
|
||||
self.buffer += arg
|
||||
|
||||
def writelines(self, arg):
|
||||
self.buffer += arg
|
||||
|
||||
def flush(self):
|
||||
print 'flush'
|
||||
self.buffer = ''
|
||||
|
||||
|
||||
class tmpStderr(tmpStdout):
|
||||
def write(self, arg):
|
||||
self.buffer += arg
|
||||
|
||||
def flush(self):
|
||||
pass
|
||||
|
||||
def realFlush(self):
|
||||
self.buffer = ''
|
||||
|
||||
dummyCallReturnValue={ 0:True }
|
||||
dummyCallCount=0
|
||||
def dummyCall(context, topic, method):
|
||||
global dummyCallReturnValue, dummyCallCount
|
||||
if dummyCallCount in dummyCallReturnValue.keys() :
|
||||
ret = dummyCallReturnValue[ dummyCallCount ]
|
||||
dummyCallCount += 1
|
||||
return ret
|
||||
else :
|
||||
dummyCallCount += 1
|
||||
return False
|
||||
|
||||
|
||||
class ComputeTestFunctions(unittest.TestCase):
|
||||
|
||||
stdout = None
|
||||
stdoutBak = None
|
||||
stderr = None
|
||||
stderrBak = None
|
||||
manager = None
|
||||
|
||||
# 共通の初期化処理
|
||||
def setUp(self):
|
||||
"""common init method. """
|
||||
|
||||
#if self.stdout is None:
|
||||
# self.__class__.stdout = tmpStdout()
|
||||
#self.stdoutBak = sys.stdout
|
||||
#sys.stdout = self.stdout
|
||||
if self.stderr is None:
|
||||
self.__class__.stderr = tmpStderr()
|
||||
self.stderrBak = sys.stderr
|
||||
sys.stderr = self.stderr
|
||||
|
||||
self.host = 'openstack2-api'
|
||||
if self.manager is None:
|
||||
self.__class__.manager = ComputeManager(host=self.host)
|
||||
|
||||
self.setTestData()
|
||||
self.setMocks()
|
||||
|
||||
def setTestData(self):
|
||||
|
||||
self.host1 = Host()
|
||||
for key, val in [('name', 'host1'), ('cpu', 5),
|
||||
('memory_mb', 20480), ('hdd_gb', 876)]:
|
||||
self.host1.__setitem__(key, val)
|
||||
|
||||
self.host2 = Host()
|
||||
for key, val in [('name', 'host2'), ('cpu', 5),
|
||||
('memory_mb', 20480), ('hdd_gb', 876)]:
|
||||
self.host2.__setitem__(key, val)
|
||||
|
||||
self.instance1 = Instance()
|
||||
for key, val in [('id', 1), ('host', 'host1'),
|
||||
('hostname', 'i-12345'), ('state', power_state.RUNNING),
|
||||
('project_id', 'testPJ'), ('vcpus', 3), ('memory_mb', 1024),
|
||||
('hdd_gb', 5), ('internal_id', 12345)]:
|
||||
self.instance1.__setitem__(key, val)
|
||||
|
||||
self.instance2 = Instance()
|
||||
for key, val in [('id', 2), ('host', 'host1'),
|
||||
('hostname', 'i-12345'), ('state', power_state.RUNNING),
|
||||
('project_id', 'testPJ'), ('vcpus', 3), ('memory_mb', 1024),
|
||||
('hdd_gb', 5)]:
|
||||
self.instance2.__setitem__(key, val)
|
||||
|
||||
self.fixed_ip1 = FixedIp()
|
||||
for key, val in [('id', 1), ('address', '1.1.1.1'),
|
||||
('network_id', '1'), ('instance_id', 1)]:
|
||||
self.fixed_ip1.__setitem__(key, val)
|
||||
|
||||
self.vol1 = Volume()
|
||||
for key, val in [('id', 1), ('ec2_id', 'vol-qijjuc7e'),
|
||||
('availability_zone', 'nova'), ('host', 'host1')]:
|
||||
self.vol1.__setitem__(key, val)
|
||||
|
||||
self.vol2 = Volume()
|
||||
for key, val in [('id', 2), ('ec2_id', 'vol-qi22222'),
|
||||
('availability_zone', 'nova'), ('host', 'host1')]:
|
||||
self.vol2.__setitem__(key, val)
|
||||
|
||||
self.secgrp1 = Volume()
|
||||
for key, val in [('id', 1), ('ec2_id', 'default')]:
|
||||
self.secgrp1.__setitem__(key, val)
|
||||
|
||||
self.secgrp2 = Volume()
|
||||
for key, val in [('id', 2), ('ec2_id', 'def2')]:
|
||||
self.secgrp2.__setitem__(key, val)
|
||||
|
||||
self.netref1 = Network()
|
||||
|
||||
def setMocks(self):
|
||||
|
||||
# mocks for pre_live_migration
|
||||
self.ctxt = context.get_admin_context()
|
||||
db.instance_get = Mock(return_value=self.instance1)
|
||||
db.volume_get_by_ec2_id = Mock(return_value=[self.vol1, self.vol2])
|
||||
db.volume_get_shelf_and_blade = Mock(return_value=(3, 4))
|
||||
db.instance_get_fixed_address = Mock(return_value=self.fixed_ip1)
|
||||
db.security_group_get_by_instance \
|
||||
= Mock(return_value=[self.secgrp1, self.secgrp2])
|
||||
self.manager.driver.setup_nwfilters_for_instance \
|
||||
= Mock(return_value=None)
|
||||
self.manager.driver.nwfilter_for_instance_exists = Mock(return_value=None)
|
||||
self.manager.network_manager.setup_compute_network \
|
||||
= Mock(return_value=None)
|
||||
# mocks for live_migration_
|
||||
rpc.call = Mock(return_value=True)
|
||||
db.instance_set_state = Mock(return_value=True)
|
||||
|
||||
# ---> test for nova.compute.manager.pre_live_migration()
|
||||
def test01(self):
|
||||
"""01: NotFound error occurs on finding instance on DB. """
|
||||
|
||||
db.instance_get = Mock(side_effect=exception.NotFound('ERR'))
|
||||
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test02(self):
|
||||
"""02: NotAuthrized occurs on finding volume on DB. """
|
||||
|
||||
db.volume_get_by_ec2_id \
|
||||
= Mock(side_effect=exception.NotAuthorized('ERR'))
|
||||
|
||||
self.assertRaises(exception.NotAuthorized,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test03(self):
|
||||
"""03: Unexpected exception occurs on finding volume on DB. """
|
||||
|
||||
db.volume_get_by_ec2_id = Mock(side_effect=TypeError('ERR'))
|
||||
|
||||
self.assertRaises(TypeError,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test04(self):
|
||||
"""04: no volume and fixed ip found on DB, """
|
||||
|
||||
db.volume_get_by_ec2_id = Mock(side_effect=exception.NotFound('ERR'))
|
||||
db.instance_get_fixed_address = Mock(return_value=None)
|
||||
|
||||
self.assertRaises(rpc.RemoteError,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
c1 = (0 <= sys.stderr.buffer.find('has no volume'))
|
||||
|
||||
self.assertEqual(c1, True)
|
||||
|
||||
def test05(self):
|
||||
"""05: volume found and no fixed_ip found on DB. """
|
||||
|
||||
db.instance_get_fixed_address \
|
||||
= Mock(side_effect=exception.NotFound('ERR'))
|
||||
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test06(self):
|
||||
"""06: self.driver.setup_nwfilters_for_instance causes NotFound. """
|
||||
self.manager.driver.setup_nwfilters_for_instance \
|
||||
= Mock(side_effect=exception.NotFound("ERR"))
|
||||
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test07(self):
|
||||
"""07: self.network_manager.setup_compute_network causes ProcessExecutionError. """
|
||||
self.manager.network_manager.setup_compute_network \
|
||||
= Mock(side_effect=exception.ProcessExecutionError("ERR"))
|
||||
|
||||
self.assertRaises(exception.ProcessExecutionError,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
|
||||
def test08(self):
|
||||
"""08: self.manager.network_manager.setup_compute_network
|
||||
exception.NotFound. """
|
||||
self.manager.network_manager.setup_compute_network \
|
||||
= Mock(side_effect=exception.NotFound("ERR"))
|
||||
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.pre_live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
# those 2 cases are omitted :
|
||||
# self.driver.setup_nwfilters_for_instance causes
|
||||
# twisted.python.failure.Failure.
|
||||
# self.driver.refresh_security_group causes twisted.python.failure.Failure.
|
||||
#
|
||||
# twisted.python.failure.Failure can not be used with assertRaises,
|
||||
# it doesnt have __call___
|
||||
#
|
||||
|
||||
def test09(self):
|
||||
"""09: volume/fixed_ip found on DB, all procedure finish
|
||||
successfully.. """
|
||||
|
||||
result = self.manager.pre_live_migration(self.ctxt, 'dummy_ec2_id',
|
||||
'host2')
|
||||
self.assertEqual(result, True)
|
||||
|
||||
# ---> test for nova.compute.manager.live_migration()
|
||||
|
||||
def test10(self):
|
||||
"""10: rpc.call(pre_live_migration returns Error(Not None). """
|
||||
rpc.call = Mock(side_effect=exception.NotFound("ERR"))
|
||||
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test11(self):
|
||||
"""11: if rpc.call returns rpc.RemoteError. """
|
||||
|
||||
rpc.call = Mock(return_value=rpc.RemoteError(None, None, None))
|
||||
db.instance_set_state = Mock(return_value=True)
|
||||
result = self.manager.live_migration(self.ctxt, 'dummy_ec2_id',
|
||||
'host2')
|
||||
c1 = (None == result)
|
||||
c2 = (0 <= sys.stderr.buffer.find('err at'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test12(self):
|
||||
"""12: if rpc.call returns rpc.RemoteError and instance_set_state
|
||||
also ends up err. (then , unexpected err occurs, in this case
|
||||
TypeError)
|
||||
"""
|
||||
rpc.call = Mock(return_value=rpc.RemoteError(None, None, None))
|
||||
db.instance_set_state = Mock(side_effect=TypeError("ERR"))
|
||||
self.assertRaises(TypeError,
|
||||
self.manager.live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test13(self):
|
||||
"""13: if wait for pre_live_migration, but timeout. """
|
||||
rpc.call = dummyCall
|
||||
|
||||
db.instance_get = Mock(return_value=self.instance1)
|
||||
|
||||
result = self.manager.live_migration(self.ctxt, 'dummy_ec2_id',
|
||||
'host2')
|
||||
c1 = (None == result)
|
||||
c2 = (0 <= sys.stderr.buffer.find('Timeout for'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test14(self):
|
||||
"""14: if db_instance_get issues NotFound.
|
||||
"""
|
||||
rpc.call = Mock(return_value=True)
|
||||
db.instance_get = Mock(side_effect=exception.NotFound("ERR"))
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test15(self):
|
||||
"""15: if rpc.call returns True, and instance_get() cause other
|
||||
exception. (Unexpected case - b/c it already checked by
|
||||
nova-manage)
|
||||
"""
|
||||
rpc.call = Mock(return_value=True)
|
||||
db.instance_get = Mock(side_effect=TypeError("ERR"))
|
||||
|
||||
self.assertRaises(TypeError,
|
||||
self.manager.live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test16(self):
|
||||
"""16: if rpc.call returns True, and live_migration issues
|
||||
ProcessExecutionError. """
|
||||
rpc.call = Mock(return_value=True)
|
||||
db.instance_get = Mock(return_value=self.instance1)
|
||||
ret = self.manager.driver.live_migration \
|
||||
= Mock(side_effect=utils.ProcessExecutionError("ERR"))
|
||||
|
||||
self.assertRaises(utils.ProcessExecutionError,
|
||||
self.manager.live_migration,
|
||||
self.ctxt,
|
||||
'dummy_ec2_id',
|
||||
'host2')
|
||||
|
||||
def test17(self):
|
||||
"""17: everything goes well. """
|
||||
self.manager.driver.live_migration = Mock(return_value=True)
|
||||
ret = self.manager.live_migration(self.ctxt, 'i-12345', 'host1')
|
||||
self.assertEqual(True, True)
|
||||
|
||||
def tearDown(self):
|
||||
"""common terminating method. """
|
||||
self.stderr.realFlush()
|
||||
sys.stderr = self.stderrBak
|
||||
#sys.stdout = self.stdoutBak
|
||||
|
||||
if __name__ == '__main__':
|
||||
logging.getLogger().setLevel(logging.DEBUG)
|
||||
#unittest.main()
|
||||
|
||||
suite = unittest.TestLoader().loadTestsFromTestCase(ComputeTestFunctions)
|
||||
unittest.TextTestRunner(verbosity=2).run(suite)
|
||||
|
||||
#suite = unittest.TestSuite()
|
||||
#suite.addTest(ComputeTestFunctions("test15"))
|
||||
#suite.addTest(ComputeTestFunctions("test16"))
|
||||
#unittest.TextTestRunner(verbosity=2).run(suite)
|
||||
@@ -1,382 +0,0 @@
|
||||
#!/usr/bin/python
|
||||
# -*- coding: UTF-8 -*-
|
||||
|
||||
|
||||
import sys
|
||||
import os
|
||||
import unittest
|
||||
import commands
|
||||
import re
|
||||
import logging
|
||||
import libvirt
|
||||
|
||||
from mock import Mock
|
||||
import twisted
|
||||
|
||||
# getting /nova-inst-dir
|
||||
NOVA_DIR = os.path.abspath(sys.argv[0])
|
||||
for i in range(4):
|
||||
NOVA_DIR = os.path.dirname(NOVA_DIR)
|
||||
|
||||
|
||||
try :
|
||||
print
|
||||
print 'checking %s/bin/nova-manage exists, set the NOVA_DIR properly..' % NOVA_DIR
|
||||
print
|
||||
|
||||
sys.path.append(NOVA_DIR)
|
||||
|
||||
from nova.compute.manager import ComputeManager
|
||||
from nova.virt import libvirt_conn
|
||||
|
||||
from nova import context
|
||||
from nova import db
|
||||
from nova import exception
|
||||
from nova import flags
|
||||
from nova import quota
|
||||
from nova import utils
|
||||
from nova.auth import manager
|
||||
from nova.cloudpipe import pipelib
|
||||
from nova import rpc
|
||||
from nova.api.ec2 import cloud
|
||||
from nova.compute import power_state
|
||||
|
||||
from nova.db.sqlalchemy.models import *
|
||||
|
||||
|
||||
except:
|
||||
print 'set correct NOVA_DIR in this script. '
|
||||
raise
|
||||
|
||||
|
||||
class tmpStdout:
|
||||
def __init__(self):
|
||||
self.buffer = ""
|
||||
def write(self,arg):
|
||||
self.buffer += arg
|
||||
def writelines(self, arg):
|
||||
self.buffer += arg
|
||||
def flush(self):
|
||||
print 'flush'
|
||||
self.buffer = ''
|
||||
|
||||
class tmpStderr(tmpStdout):
|
||||
def write(self,arg):
|
||||
self.buffer += arg
|
||||
def flush(self):
|
||||
pass
|
||||
def realFlush(self):
|
||||
self.buffer = ''
|
||||
|
||||
class DummyLibvirtConn(object):
|
||||
nwfilterLookupByName = None
|
||||
def __init__(self):
|
||||
pass
|
||||
|
||||
|
||||
class LibvirtConnectionTestFunctions(unittest.TestCase):
|
||||
|
||||
stdout = None
|
||||
stdoutBak = None
|
||||
stderr = None
|
||||
stderrBak = None
|
||||
manager = None
|
||||
|
||||
# 共通の初期化処理
|
||||
def setUp(self):
|
||||
"""common init method. """
|
||||
|
||||
#if self.stdout is None:
|
||||
# self.__class__.stdout = tmpStdout()
|
||||
#self.stdoutBak = sys.stdout
|
||||
#sys.stdout = self.stdout
|
||||
if self.stderr is None:
|
||||
self.__class__.stderr = tmpStderr()
|
||||
self.stderrBak = sys.stderr
|
||||
sys.stderr = self.stderr
|
||||
|
||||
self.host = 'openstack2-api'
|
||||
if self.manager is None:
|
||||
self.__class__.manager = libvirt_conn.get_connection(False)
|
||||
|
||||
self.setTestData()
|
||||
self.setMocks()
|
||||
|
||||
def setTestData(self):
|
||||
|
||||
self.host1 = Host()
|
||||
for key, val in [ ('name', 'host1'), ('cpu', 5), ('memory_mb', 20480), ('hdd_gb', 876) ]:
|
||||
self.host1.__setitem__(key, val)
|
||||
|
||||
self.instance1 = Instance()
|
||||
for key, val in [ ('id', 1), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ'),
|
||||
('vcpus', 3), ('memory_mb', 1024), ('hdd_gb', 5), ('internal_id',12345) ]:
|
||||
self.instance1.__setitem__(key, val)
|
||||
|
||||
|
||||
self.instance2 = Instance()
|
||||
for key, val in [ ('id', 2), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ'),
|
||||
('vcpus', 3), ('memory_mb', 1024), ('hdd_gb', 5) ]:
|
||||
self.instance2.__setitem__(key, val)
|
||||
|
||||
|
||||
self.fixed_ip1 = FixedIp()
|
||||
for key, val in [ ('id', 1), ('address', '1.1.1.1'), ('network_id', '1'),
|
||||
('instance_id', 1)]:
|
||||
self.fixed_ip1.__setitem__(key, val)
|
||||
|
||||
self.floating_ip1 = FloatingIp()
|
||||
for key, val in [ ('id', 1), ('address', '1.1.1.200') ]:
|
||||
self.floating_ip1.__setitem__(key, val)
|
||||
|
||||
self.netref1 = Network()
|
||||
for key, val in [ ('id', 1) ]:
|
||||
self.netref1.__setitem__(key, val)
|
||||
|
||||
|
||||
def setMocks(self):
|
||||
|
||||
self.ctxt = context.get_admin_context()
|
||||
db.instance_get_fixed_address = Mock(return_value = '1.1.1.1')
|
||||
db.fixed_ip_update = Mock(return_value = None)
|
||||
db.fixed_ip_get_network = Mock(return_value = self.netref1)
|
||||
db.network_update = Mock(return_value = None)
|
||||
db.instance_get_floating_address = Mock(return_value = '1.1.1.200')
|
||||
db.floating_ip_get_by_address = Mock(return_value = self.floating_ip1)
|
||||
db.floating_ip_update = Mock(return_value = None)
|
||||
db.instance_update = Mock(return_value = None)
|
||||
|
||||
|
||||
# ---> test for nova.virt.libvirt_conn.nwfilter_for_instance_exists()
|
||||
|
||||
def test01(self):
|
||||
"""01: libvirt.libvirtError occurs. """
|
||||
|
||||
self.manager._wrapped_conn = DummyLibvirtConn()
|
||||
self.manager._test_connection = Mock(return_value=True)
|
||||
self.manager._conn.nwfilterLookupByName = \
|
||||
Mock(side_effect=libvirt.libvirtError("ERR"))
|
||||
ret = self.manager.nwfilter_for_instance_exists(self.instance1)
|
||||
self.assertEqual(ret, False)
|
||||
|
||||
def test02(self):
|
||||
"""02: libvirt.libvirtError not occurs. """
|
||||
|
||||
self.manager._wrapped_conn = DummyLibvirtConn()
|
||||
self.manager._test_connection = Mock(return_value=True)
|
||||
self.manager._conn.nwfilterLookupByName = \
|
||||
Mock(return_value=True)
|
||||
ret = self.manager.nwfilter_for_instance_exists(self.instance1)
|
||||
self.assertEqual(ret, True)
|
||||
|
||||
# ---> test for nova.virt.libvirt_conn.live_migraiton()
|
||||
|
||||
def test03(self):
|
||||
"""03: Unexpected exception occurs on finding volume on DB. """
|
||||
|
||||
utils.execute = Mock( side_effect=exception.ProcessExecutionError('ERR') )
|
||||
|
||||
self.assertRaises(exception.ProcessExecutionError,
|
||||
self.manager._live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host2')
|
||||
|
||||
# ---> other case cannot be tested because live_migraiton
|
||||
# is synchronized/asynchronized method are mixed together
|
||||
|
||||
|
||||
# ---> test for nova.virt.libvirt_conn._post_live_migraiton
|
||||
|
||||
def test04(self):
|
||||
"""04: instance_ref is not nova.db.sqlalchemy.models.Instances"""
|
||||
|
||||
self.assertRaises(TypeError,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
"dummy string",
|
||||
'host2')
|
||||
|
||||
def test05(self):
|
||||
"""05: db.instance_get_fixed_address return None"""
|
||||
|
||||
db.instance_get_fixed_address = Mock( return_value=None )
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('fixed_ip is not found'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test06(self):
|
||||
"""06: db.instance_get_fixed_address raises NotFound"""
|
||||
|
||||
db.instance_get_fixed_address = Mock( side_effect=exception.NotFound('ERR') )
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host2')
|
||||
|
||||
def test07(self):
|
||||
"""07: db.instance_get_fixed_address raises Unknown exception"""
|
||||
|
||||
db.instance_get_fixed_address = Mock( side_effect=TypeError('ERR') )
|
||||
self.assertRaises(TypeError,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def test08(self):
|
||||
"""08: db.fixed_ip_update return NotFound. """
|
||||
|
||||
db.fixed_ip_update = Mock( side_effect=exception.NotFound('ERR') )
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def test09(self):
|
||||
"""09: db.fixed_ip_update return NotAuthorized. """
|
||||
db.fixed_ip_update = Mock( side_effect=exception.NotAuthorized('ERR') )
|
||||
self.assertRaises(exception.NotAuthorized,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def test10(self):
|
||||
"""10: db.fixed_ip_update return Unknown exception. """
|
||||
db.fixed_ip_update = Mock( side_effect=TypeError('ERR') )
|
||||
self.assertRaises(TypeError,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def test11(self):
|
||||
"""11: db.fixed_ip_get_network causes NotFound. """
|
||||
|
||||
db.fixed_ip_get_network = Mock( side_effect=exception.NotFound('ERR') )
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
# not tested db.fixed_ip_get_network raises NotAuthorized
|
||||
# because same test has been done at previous test.
|
||||
|
||||
def test12(self):
|
||||
"""12: db.fixed_ip_get_network causes Unknown exception. """
|
||||
|
||||
db.fixed_ip_get_network = Mock( side_effect=TypeError('ERR') )
|
||||
self.assertRaises(TypeError,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def test13(self):
|
||||
"""13: db.network_update raises Unknown exception. """
|
||||
db.network_update = Mock( side_effect=TypeError('ERR') )
|
||||
self.assertRaises(TypeError,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def test14(self):
|
||||
"""14: db.instance_get_floating_address raises NotFound. """
|
||||
db.instance_get_floating_address = Mock(side_effect=exception.NotFound("ERR"))
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('doesnt have floating_ip'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
|
||||
def test15(self):
|
||||
"""15: db.instance_get_floating_address returns None. """
|
||||
|
||||
db.instance_get_floating_address = Mock( return_value=None )
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('floating_ip is not found'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test16(self):
|
||||
"""16: db.instance_get_floating_address raises NotFound. """
|
||||
|
||||
db.instance_get_floating_address = Mock(side_effect=exception.NotFound("ERR"))
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('doesnt have floating_ip'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test17(self):
|
||||
"""17: db.instance_get_floating_address raises Unknown exception. """
|
||||
db.instance_get_floating_address = Mock(side_effect=TypeError("ERR"))
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('Live migration: Unexpected error'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
|
||||
def test18(self):
|
||||
"""18: db.floating_ip_get_by_address raises NotFound """
|
||||
|
||||
db.floating_ip_get_by_address = Mock(side_effect=exception.NotFound("ERR"))
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('doesnt have floating_ip'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test19(self):
|
||||
"""19: db.floating_ip_get_by_address raises Unknown exception. """
|
||||
db.floating_ip_get_by_address = Mock(side_effect=TypeError("ERR"))
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('Live migration: Unexpected error'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
|
||||
def test20(self):
|
||||
"""20: db.floating_ip_update raises Unknown exception.
|
||||
"""
|
||||
db.floating_ip_update = Mock(side_effect=TypeError("ERR"))
|
||||
ret = self.manager._post_live_migration(self.ctxt, self.instance1, 'host1')
|
||||
c1 = (ret == None)
|
||||
c2 = (0 <= sys.stderr.buffer.find('Live migration: Unexpected error'))
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test21(self):
|
||||
"""21: db.instance_update raises unknown exception. """
|
||||
|
||||
db.instance_update = Mock(side_effect=TypeError("ERR"))
|
||||
self.assertRaises(TypeError,
|
||||
self.manager._post_live_migration,
|
||||
self.ctxt,
|
||||
self.instance1,
|
||||
'host1')
|
||||
|
||||
def tearDown(self):
|
||||
"""common terminating method. """
|
||||
self.stderr.realFlush()
|
||||
sys.stderr = self.stderrBak
|
||||
#sys.stdout = self.stdoutBak
|
||||
|
||||
if __name__ == '__main__':
|
||||
logging.getLogger().setLevel(logging.DEBUG)
|
||||
#unittest.main()
|
||||
|
||||
suite = unittest.TestLoader().loadTestsFromTestCase(LibvirtConnectionTestFunctions)
|
||||
unittest.TextTestRunner(verbosity=2).run(suite)
|
||||
|
||||
#suite = unittest.TestSuite()
|
||||
#suite.addTest(LibvirtConnectionTestFunctions("test14"))
|
||||
#suite.addTest(LibvirtConnectionTestFunctions("test16"))
|
||||
#unittest.TextTestRunner(verbosity=2).run(suite)
|
||||
|
||||
|
||||
@@ -1,313 +0,0 @@
|
||||
#!/usr/bin/python
|
||||
# -*- coding: UTF-8 -*-
|
||||
|
||||
NOVA_DIR='/opt/nova-2010.4'
|
||||
|
||||
import sys
|
||||
import os
|
||||
import unittest
|
||||
import commands
|
||||
import re
|
||||
|
||||
from mock import Mock
|
||||
|
||||
# getting /nova-inst-dir
|
||||
NOVA_DIR = os.path.abspath(sys.argv[0])
|
||||
for i in range(4):
|
||||
NOVA_DIR = os.path.dirname(NOVA_DIR)
|
||||
|
||||
|
||||
try :
|
||||
print
|
||||
print 'Testing %s/bin/nova-manage, set the NOVA_DIR properly..' % NOVA_DIR
|
||||
print
|
||||
|
||||
sys.path.append(NOVA_DIR)
|
||||
|
||||
from nova import context
|
||||
from nova import db
|
||||
from nova import exception
|
||||
from nova import flags
|
||||
from nova import quota
|
||||
from nova import utils
|
||||
from nova.auth import manager
|
||||
from nova.cloudpipe import pipelib
|
||||
from nova import rpc
|
||||
from nova.api.ec2 import cloud
|
||||
from nova.compute import power_state
|
||||
|
||||
from nova.db.sqlalchemy.models import *
|
||||
|
||||
|
||||
except:
|
||||
print 'set correct NOVA_DIR in this script. '
|
||||
raise
|
||||
|
||||
|
||||
class tmpStdout:
|
||||
def __init__(self):
|
||||
self.buffer = ""
|
||||
def write(self,arg):
|
||||
self.buffer += arg
|
||||
def flush(self):
|
||||
self.buffer = ''
|
||||
|
||||
class tmpStderr(tmpStdout):
|
||||
def write(self, arg):
|
||||
self.buffer += arg
|
||||
def flush(self):
|
||||
pass
|
||||
def realFlush(self):
|
||||
self.buffer = ''
|
||||
|
||||
|
||||
class NovaManageTestFunctions(unittest.TestCase):
|
||||
|
||||
stdout = None
|
||||
stdoutBak = None
|
||||
stderr = None
|
||||
stderrBak = None
|
||||
|
||||
hostCmds = None
|
||||
|
||||
# 共通の初期化処理
|
||||
def setUp(self):
|
||||
"""common init method. """
|
||||
|
||||
commands.getstatusoutput('cp -f %s/bin/nova-manage %s' % ( NOVA_DIR, self.getNovaManageCopyPath() ))
|
||||
commands.getstatusoutput('touch %s' % self.getInitpyPath() )
|
||||
try :
|
||||
import bin.novamanagetest
|
||||
except:
|
||||
print 'Fail to import nova-manage . check bin/nova-manage exists'
|
||||
raise
|
||||
|
||||
# replace stdout for checking nova-manage output
|
||||
if self.stdout is None :
|
||||
self.__class__.stdout = tmpStdout()
|
||||
self.stdoutBak = sys.stdout
|
||||
sys.stdout = self.stdout
|
||||
|
||||
# replace stderr for checking nova-manage output
|
||||
if self.stderr is None:
|
||||
self.__class__.stderr = tmpStderr()
|
||||
self.stderrBak = sys.stderr
|
||||
sys.stderr = self.stderr
|
||||
|
||||
# prepare test data
|
||||
self.setTestData()
|
||||
|
||||
|
||||
def setTestData(self):
|
||||
import bin.novamanagetest
|
||||
|
||||
if self.hostCmds is None :
|
||||
self.__class__.hostCmds = bin.novamanagetest.HostCommands()
|
||||
self.instanceCmds = bin.novamanagetest.InstanceCommands()
|
||||
|
||||
self.host1 = Host()
|
||||
self.host1.__setitem__('name', 'host1')
|
||||
|
||||
self.host2 = Host()
|
||||
self.host2.__setitem__('name', 'host2')
|
||||
|
||||
self.instance1 = Instance()
|
||||
self.instance1.__setitem__('id', 1)
|
||||
self.instance1.__setitem__('host', 'host1')
|
||||
self.instance1.__setitem__('hostname', 'i-12345')
|
||||
self.instance1.__setitem__('state', power_state.NOSTATE)
|
||||
self.instance1.__setitem__('state_description', 'running')
|
||||
|
||||
self.instance2 = Instance()
|
||||
self.instance2.__setitem__('id', 2)
|
||||
self.instance2.__setitem__('host', 'host1')
|
||||
self.instance2.__setitem__('hostname', 'i-12345')
|
||||
self.instance2.__setitem__('state', power_state.RUNNING)
|
||||
self.instance2.__setitem__('state_description', 'pending')
|
||||
|
||||
self.instance3 = Instance()
|
||||
self.instance3.__setitem__('id', 3)
|
||||
self.instance3.__setitem__('host', 'host1')
|
||||
self.instance3.__setitem__('hostname', 'i-12345')
|
||||
self.instance3.__setitem__('state', power_state.RUNNING)
|
||||
self.instance3.__setitem__('state_description', 'running')
|
||||
|
||||
db.host_get_all = Mock(return_value=[self.host1, self.host2])
|
||||
|
||||
def getInitpyPath(self):
|
||||
return '%s/bin/__init__.py' % NOVA_DIR
|
||||
|
||||
def getNovaManageCopyPath(self):
|
||||
return '%s/bin/novamanagetest.py' % NOVA_DIR
|
||||
|
||||
# -----> Test for nova-manage host list
|
||||
|
||||
def test01(self):
|
||||
"""01: Got some host lists. """
|
||||
|
||||
self.hostCmds.list()
|
||||
|
||||
c1 = (2 == self.stdout.buffer.count('\n'))
|
||||
c2 = (0 <= self.stdout.buffer.find('host1'))
|
||||
c3 = (0 <= self.stdout.buffer.find('host2'))
|
||||
self.assertEqual(c1 and c2 and c3, True)
|
||||
|
||||
def test02(self):
|
||||
"""02: Got empty lsit. """
|
||||
|
||||
db.host_get_all = Mock(return_value=[])
|
||||
self.hostCmds.list()
|
||||
|
||||
# result should be empty
|
||||
c = (0 == len(self.stdout.buffer) )
|
||||
self.assertEqual(c, True)
|
||||
|
||||
def test03(self):
|
||||
"""03: Got notFound """
|
||||
|
||||
db.host_get_all = Mock(side_effect=exception.NotFound("ERR"))
|
||||
self.assertRaises(exception.NotFound, self.hostCmds.list)
|
||||
|
||||
# --------> Test For nova-manage host show
|
||||
|
||||
def test04(self):
|
||||
"""04: args are not enough(nova-manage host show) """
|
||||
self.assertRaises(TypeError, self.hostCmds.show )
|
||||
|
||||
|
||||
def test05(self):
|
||||
"""05: nova-manage host show not-registered-host, and got an error"""
|
||||
|
||||
rpc.call = Mock(return_value={'ret' : False, 'msg': 'ERR'} )
|
||||
self.hostCmds.show('host1')
|
||||
self.assertEqual( self.stdout.buffer[:3]=='ERR', True )
|
||||
|
||||
|
||||
def test06(self):
|
||||
"""06: nova-manage host show registerd-host, and no project uses the host"""
|
||||
|
||||
dic = {'ret': True,
|
||||
'phy_resource': {'vcpus':1, 'memory_mb':2, 'local_gb':3},
|
||||
'usage': {}}
|
||||
|
||||
rpc.call = Mock(return_value=dic )
|
||||
self.hostCmds.show('host1')
|
||||
|
||||
# result should be :
|
||||
# HOST PROJECT cpu mem(mb) disk(gb)
|
||||
# host1 1 2 3
|
||||
line = self.stdout.buffer.split('\n')[1]
|
||||
line = re.compile('\t+').sub(' ', line).strip()
|
||||
c1 = ( 'host1 1 2 3' == line )
|
||||
c2 = ( self.stdout.buffer.count('\n') == 2 )
|
||||
|
||||
self.assertEqual( c1 and c2, True )
|
||||
|
||||
def test07(self):
|
||||
"""07: nova-manage host show registerd-host,
|
||||
and some projects use the host
|
||||
"""
|
||||
dic = {'ret': True,
|
||||
'phy_resource': {'vcpus':1, 'memory_mb':2, 'local_gb':3},
|
||||
'usage': {'p1': {'vcpus':1, 'memory_mb':2, 'local_gb':3},
|
||||
'p2': {'vcpus':1, 'memory_mb':2, 'local_gb':3} }}
|
||||
|
||||
rpc.call = Mock(return_value=dic )
|
||||
self.hostCmds.show('host1')
|
||||
|
||||
# result should be :
|
||||
# HOST PROJECT cpu mem(mb) disk(gb)
|
||||
# host1 1 2 3
|
||||
# host1 p1 1 2 3
|
||||
# host1 p2 4 5 6
|
||||
line = self.stdout.buffer.split('\n')[1]
|
||||
ret = re.compile('\t+').sub(' ', line).strip()
|
||||
c1 = ( 'host1 1 2 3' == ret )
|
||||
|
||||
line = self.stdout.buffer.split('\n')[2]
|
||||
line = re.compile('\t+').sub(' ', line).strip()
|
||||
c2 = ( 'host1 p1 1 2 3' == line ) or ( 'host1 p2 1 2 3' == line )
|
||||
|
||||
line = self.stdout.buffer.split('\n')[3]
|
||||
ret = re.compile('\t+').sub(' ', line).strip()
|
||||
c3 = ( 'host1 p1 1 2 3' == ret ) or ( 'host1 p2 1 2 3' == ret )
|
||||
|
||||
self.assertEqual( c1 and c2 and c3, True )
|
||||
|
||||
def test08(self):
|
||||
"""08: nova-manage host show registerd-host, and rpc.call returns None
|
||||
(unexpected error)
|
||||
"""
|
||||
rpc.call = Mock(return_value=None )
|
||||
self.hostCmds.show('host1')
|
||||
c1 = ( 0 <= self.stdout.buffer.find('Unexpected error') )
|
||||
self.assertEqual( c1, True )
|
||||
|
||||
# ----------> Test for bin/nova-manage instance live_migration
|
||||
|
||||
def test09(self):
|
||||
"""09: arguments are not enough(nova-manage instances live_migration)
|
||||
"""
|
||||
self.assertRaises(TypeError, self.instanceCmds.live_migration )
|
||||
|
||||
def test10(self):
|
||||
"""10: arguments are not enough(nova-manage instances live_migration ec2_id)
|
||||
"""
|
||||
self.assertRaises(TypeError, self.instanceCmds.live_migration, 'i-xxx' )
|
||||
|
||||
def test11(self):
|
||||
"""11: nova-manage instances live_migration ec2_id(invalid id) host"""
|
||||
|
||||
db.instance_get_by_internal_id = Mock( side_effect=exception.NotFound('ERR') )
|
||||
try :
|
||||
self.instanceCmds.live_migration('i-xxx', 'host1')
|
||||
except exception.NotFound, e:
|
||||
c1 = (0 < str(e.args).find('is not found') )
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
def test12(self):
|
||||
"""12: nova-manage instances live_migration ec2_id host
|
||||
and db.instance_get_by_internal_id raises unexpected exceptioin.
|
||||
"""
|
||||
db.instance_get_by_internal_id = Mock( side_effect=TypeError('ERR') )
|
||||
self.assertRaises(TypeError, self.instanceCmds.live_migration, 'i-xxx' )
|
||||
|
||||
def test13(self):
|
||||
"""13: nova-manage instances live_migration ec2_id host,
|
||||
rpc.call raises RemoteError because destination doesnt have enough resource.
|
||||
"""
|
||||
db.host_get_by_name = Mock(return_value = self.host1)
|
||||
db.instance_get_by_internal_id = Mock( return_value = self.instance3 )
|
||||
rpc.call = Mock(return_value = rpc.RemoteError(TypeError, 'val', 'traceback'))
|
||||
self.assertRaises(rpc.RemoteError, self.instanceCmds.live_migration, 'i-xxx', 'host2' )
|
||||
|
||||
|
||||
def test14(self):
|
||||
"""14: nova-manage instances live_migration ec2_id host,
|
||||
everything goes well, ang gets success messages.
|
||||
"""
|
||||
db.host_get_by_name = Mock(return_value = self.host1)
|
||||
db.instance_get_by_internal_id = Mock( return_value = self.instance3 )
|
||||
rpc.call = Mock(return_value = None)
|
||||
|
||||
self.instanceCmds.live_migration('i-12345', 'host2')
|
||||
c1 = (0 <= self.stdout.buffer.find('Finished all procedure') )
|
||||
self.assertEqual( c1, True )
|
||||
|
||||
|
||||
def tearDown(self):
|
||||
"""common terminating method. """
|
||||
commands.getstatusoutput('rm -rf %s' % self.getInitpyPath() )
|
||||
commands.getstatusoutput('rm -rf %s' % self.getNovaManageCopyPath() )
|
||||
sys.stdout.flush()
|
||||
sys.stdout = self.stdoutBak
|
||||
self.stderr.realFlush()
|
||||
sys.stderr = self.stderrBak
|
||||
|
||||
if __name__ == '__main__':
|
||||
#unittest.main()
|
||||
suite = unittest.TestLoader().loadTestsFromTestCase(NovaManageTestFunctions)
|
||||
unittest.TextTestRunner(verbosity=3).run(suite)
|
||||
|
||||
|
||||
@@ -1,456 +0,0 @@
|
||||
#!/usr/bin/python
|
||||
# -*- coding: UTF-8 -*-
|
||||
|
||||
|
||||
import sys
|
||||
import os
|
||||
import unittest
|
||||
import commands
|
||||
import re
|
||||
import libvirt
|
||||
|
||||
from mock import Mock
|
||||
|
||||
# getting /nova-inst-dir
|
||||
NOVA_DIR = os.path.abspath(sys.argv[0])
|
||||
for i in range(4):
|
||||
NOVA_DIR = os.path.dirname(NOVA_DIR)
|
||||
|
||||
try :
|
||||
print
|
||||
print 'Checking %s/bin/nova-manage exists, set the NOVA_DIR properly..' % NOVA_DIR
|
||||
print
|
||||
|
||||
sys.path.append(NOVA_DIR)
|
||||
|
||||
from nova.scheduler.manager import SchedulerManager
|
||||
|
||||
from nova import context
|
||||
from nova import db
|
||||
from nova import exception
|
||||
from nova import flags
|
||||
from nova import quota
|
||||
from nova import utils
|
||||
from nova.auth import manager
|
||||
from nova.cloudpipe import pipelib
|
||||
from nova import rpc
|
||||
from nova.api.ec2 import cloud
|
||||
from nova.compute import power_state
|
||||
|
||||
from nova.db.sqlalchemy.models import *
|
||||
|
||||
except:
|
||||
print 'set correct NOVA_DIR in this script. '
|
||||
raise
|
||||
|
||||
|
||||
class tmpStdout:
|
||||
def __init__(self):
|
||||
self.buffer = ""
|
||||
def write(self,arg):
|
||||
self.buffer += arg
|
||||
def flush(self):
|
||||
self.buffer = ''
|
||||
|
||||
|
||||
class SchedulerTestFunctions(unittest.TestCase):
|
||||
|
||||
manager = None
|
||||
|
||||
# 共通の初期化処理
|
||||
def setUp(self):
|
||||
"""common init method. """
|
||||
|
||||
self.host = 'openstack2-api'
|
||||
if self.manager is None:
|
||||
self.manager = SchedulerManager(host=self.host)
|
||||
|
||||
self.setTestData()
|
||||
self.setMocks()
|
||||
|
||||
def setTestData(self):
|
||||
|
||||
self.host1 = Host()
|
||||
self.host1.__setitem__('name', 'host1')
|
||||
self.host1.__setitem__('vcpus', 5)
|
||||
self.host1.__setitem__('memory_mb', 20480)
|
||||
self.host1.__setitem__('local_gb', 876)
|
||||
self.host1.__setitem__('cpu_info', 1)
|
||||
|
||||
self.host2 = Host()
|
||||
self.host2.__setitem__('name', 'host2')
|
||||
self.host2.__setitem__('vcpus', 5)
|
||||
self.host2.__setitem__('memory_mb', 20480)
|
||||
self.host2.__setitem__('local_gb', 876)
|
||||
self.host2.__setitem__('hypervisor_type', 'QEMU')
|
||||
self.host2.__setitem__('hypervisor_version', 12003)
|
||||
xml="<cpu><arch>x86_64</arch><model>Nehalem</model><vendor>Intel</vendor><topology sockets='2' cores='4' threads='2'/><feature name='rdtscp'/><feature name='dca'/><feature name='xtpr'/><feature name='tm2'/><feature name='est'/><feature name='vmx'/><feature name='ds_cpl'/><feature name='monitor'/><feature name='pbe'/><feature name='tm'/><feature name='ht'/><feature name='ss'/><feature name='acpi'/><feature name='ds'/><feature name='vme'/></cpu>"
|
||||
self.host2.__setitem__('cpu_info', xml)
|
||||
|
||||
self.instance1 = Instance()
|
||||
for key, val in [ ('id', 1), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ'),
|
||||
('vcpus', 3), ('memory_mb', 1024), ('local_gb', 5) ]:
|
||||
self.instance1.__setitem__(key, val)
|
||||
|
||||
|
||||
self.instance2 = Instance()
|
||||
for key, val in [ ('id', 2), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ'),
|
||||
('vcpus', 3), ('memory_mb', 1024), ('local_gb', 5) ]:
|
||||
self.instance2.__setitem__(key, val)
|
||||
|
||||
|
||||
self.instance3 = Instance()
|
||||
for key, val in [ ('id', 3), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ2'),
|
||||
('vcpus', 1), ('memory_mb', 1024), ('local_gb', 5),
|
||||
('internal_id', 123456), ('state', 1),
|
||||
('state_description', 'running') ]:
|
||||
self.instance3.__setitem__(key, val)
|
||||
|
||||
self.instance4 = Instance()
|
||||
for key, val in [ ('id', 4), ('host', 'host2'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ2'),
|
||||
('vcpus', 1), ('memory_mb', 1024), ('local_gb', 5),
|
||||
('internal_id', 123456), ('state', 0),
|
||||
('state_description', 'running') ]:
|
||||
self.instance4.__setitem__(key, val)
|
||||
|
||||
self.instance5 = Instance()
|
||||
for key, val in [ ('id', 5), ('host', 'host2'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ2'),
|
||||
('vcpus', 1), ('memory_mb', 1024), ('local_gb', 5),
|
||||
('internal_id', 123456), ('state', 1),
|
||||
('state_description', 'migrating') ]:
|
||||
self.instance5.__setitem__(key, val)
|
||||
|
||||
self.instance6 = Instance()
|
||||
for key, val in [ ('id', 6), ('host', 'host2'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ2'),
|
||||
('vcpus', 3), ('memory_mb', 1024), ('local_gb', 5) ]:
|
||||
self.instance6.__setitem__(key, val)
|
||||
|
||||
self.instance7 = Instance()
|
||||
for key, val in [ ('id', 7), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING), ('project_id', 'testPJ2'),
|
||||
('vcpus', 1), ('memory_mb', 18432), ('local_gb', 5) ]:
|
||||
self.instance7.__setitem__(key, val)
|
||||
|
||||
self.instance8 = Instance()
|
||||
for key, val in [ ('id', 8), ('host', 'host1'), ('hostname', 'i-12345'),
|
||||
('state', power_state.RUNNING),
|
||||
('state_description', 'running'),('project_id', 'testPJ2'),
|
||||
('vcpus', 1), ('memory_mb', 1024), ('local_gb', 866) ]:
|
||||
self.instance8.__setitem__(key, val)
|
||||
|
||||
self.service1 = Service()
|
||||
for key, val in [ ('id', 1), ('host', 'host1'), ('binary', 'nova-compute'),
|
||||
('topic', 'compute')]:
|
||||
self.service1.__setitem__(key, val)
|
||||
|
||||
self.service2 = Service()
|
||||
for key, val in [ ('id', 2), ('host', 'host2'), ('binary', 'nova-compute'),
|
||||
('topic', 'compute')]:
|
||||
self.service1.__setitem__(key, val)
|
||||
|
||||
def setMocks(self):
|
||||
self.ctxt = context.get_admin_context()
|
||||
# Mocks for has_enough_resource()
|
||||
db.instance_get = Mock(return_value = self.instance3)
|
||||
db.host_get_by_name = Mock(return_value = self.host2)
|
||||
db.instance_get_all_by_host = Mock(return_value = [self.instance4, self.instance5] )
|
||||
|
||||
# Mocks for live_migration
|
||||
db.service_get_all_by_topic = Mock(return_value = [self.service1] )
|
||||
self.manager.service_ip_up = Mock(return_value = True)
|
||||
rpc.call = Mock(return_value=1)
|
||||
db.instance_set_state = Mock(return_value = True)
|
||||
self.manager.driver.service_is_up = Mock(return_value = True)
|
||||
|
||||
def check_format(self, val):
|
||||
"""check result format of show_host_resource """
|
||||
|
||||
if dict != type(val) :
|
||||
sys.stderr.write('return value is not dict')
|
||||
return False
|
||||
|
||||
if not val.has_key('ret'):
|
||||
sys.stderr.write('invalid format(missing "ret"). ')
|
||||
return False
|
||||
|
||||
if not val['ret'] :
|
||||
if not val.has_key('msg') :
|
||||
sys.stderr.write( 'invalid format(missing "msg").' )
|
||||
return False
|
||||
|
||||
else :
|
||||
if not val.has_key('phy_resource') :
|
||||
sys.stderr.write('invalid format(missing "phy_resource"). ')
|
||||
return False
|
||||
|
||||
if not val.has_key('usage'):
|
||||
sys.stderr.write('invalid format(missing "usage"). ')
|
||||
return False
|
||||
|
||||
if not self._check_format(val['phy_resource']):
|
||||
return False
|
||||
|
||||
for key, dic in val['usage'].items() :
|
||||
if not self._check_format(dic):
|
||||
return False
|
||||
return True
|
||||
|
||||
def _check_format(self, val):
|
||||
if dict != type(val) :
|
||||
sys.stderr.write('return value is not dict')
|
||||
return False
|
||||
|
||||
for key in ['vcpus', 'memory_mb', 'local_gb']:
|
||||
if not val.has_key(key) :
|
||||
sys.stderr.write('invalid format(missing "%s"). ' % key )
|
||||
return False
|
||||
|
||||
return True
|
||||
|
||||
|
||||
# ---> test for nova.scheduler.manager.show_host_resource()
|
||||
|
||||
def test01(self):
|
||||
"""01: get NotFound exception when dest host not found on DB """
|
||||
|
||||
db.host_get_by_name = Mock( side_effect=exception.NotFound('ERR') )
|
||||
result = self.manager.show_host_resource(self.ctxt, 'not-registered-host')
|
||||
c1 = ( not result['ret'] )
|
||||
c2 = ( 0 == result['msg'].find('No such') )
|
||||
self.assertEqual(c1 and c2, True)
|
||||
|
||||
def test02(self):
|
||||
"""02: get other exception if unexpected err. """
|
||||
|
||||
db.host_get_by_name = Mock( side_effect=TypeError('ERR') )
|
||||
self.assertRaises(TypeError, self.manager.show_host_resource, self.ctxt, 'host1' )
|
||||
|
||||
def test03(self):
|
||||
"""03: no instance found on dest host. """
|
||||
|
||||
db.host_get_by_name = Mock( return_value = self.host1 )
|
||||
db.instance_get_all_by_host = Mock( return_value=[])
|
||||
ret= self.manager.show_host_resource(self.ctxt, 'host1')
|
||||
|
||||
c1 = self.check_format(ret)
|
||||
v = ret['phy_resource']
|
||||
c2 = ( (5 == v['vcpus']) and (20480 == v['memory_mb']) and (876 == v['local_gb']))
|
||||
c3 = ( 0 == len(ret['usage']) )
|
||||
|
||||
self.assertEqual(c1 and c2 and c3, True)
|
||||
|
||||
def test04(self):
|
||||
"""04: some instance found on dest host. """
|
||||
|
||||
db.host_get_by_name = Mock( return_value = self.host1 )
|
||||
db.instance_get_all_by_host = Mock( return_value=[ self.instance1,
|
||||
self.instance2,
|
||||
self.instance3] )
|
||||
|
||||
db.instance_get_vcpu_sum_by_host_and_project = Mock(return_value=3)
|
||||
db.instance_get_memory_sum_by_host_and_project = Mock(return_value=1024)
|
||||
db.instance_get_disk_sum_by_host_and_project = Mock(return_value=5)
|
||||
|
||||
ret= self.manager.show_host_resource(self.ctxt, 'host1')
|
||||
|
||||
c1 = self.check_format(ret)
|
||||
v = ret['phy_resource']
|
||||
c2 = ( (5 == v['vcpus']) and (20480 == v['memory_mb']) and (876 == v['local_gb']))
|
||||
c3 = ( 2 == len(ret['usage']) )
|
||||
c4 = ( self.instance1['project_id'] in ret['usage'].keys())
|
||||
c5 = ( self.instance3['project_id'] in ret['usage'].keys())
|
||||
|
||||
self.assertEqual(c1 and c2 and c3 and c4 and c5, True)
|
||||
|
||||
|
||||
# ---> test for nova.scheduler.manager.has_enough_resource()
|
||||
def test05(self):
|
||||
"""05: when cpu is exccded some instance found on dest host. """
|
||||
|
||||
db.instance_get = Mock(return_value = self.instance6)
|
||||
try :
|
||||
self.manager.driver.has_enough_resource(self.ctxt, 'i-12345', 'host1')
|
||||
except exception.NotEmpty, e:
|
||||
# dont do e.message.find(), because the below message is occured.
|
||||
# DeprecationWarning: BaseException.message has been deprecated
|
||||
# as of Python 2.6
|
||||
c1 = ( 0 < str(e.args).find('doesnt have enough resource') )
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
|
||||
def test06(self):
|
||||
"""06: when memory is exccded some instance found on dest host. """
|
||||
|
||||
db.instance_get = Mock(return_value = self.instance7)
|
||||
try :
|
||||
self.manager.driver.has_enough_resource(self.ctxt, 'i-12345', 'host1')
|
||||
except exception.NotEmpty, e:
|
||||
c1 = ( 0 <= str(e.args).find('doesnt have enough resource') )
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
def test07(self):
|
||||
"""07: when hdd is exccded some instance found on dest host. """
|
||||
|
||||
db.instance_get = Mock(return_value = self.instance8)
|
||||
try :
|
||||
self.manager.driver.has_enough_resource(self.ctxt, 'i-12345', 'host1')
|
||||
except exception.NotEmpty, e:
|
||||
c1 = ( 0 <= str(e.args).find('doesnt have enough resource') )
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
|
||||
def test08(self):
|
||||
"""08: everything goes well. (instance_get_all_by_host returns list)"""
|
||||
|
||||
ret= self.manager.driver.has_enough_resource(self.ctxt, 'i-12345', 'host1')
|
||||
self.assertEqual(ret, None)
|
||||
|
||||
|
||||
def test09(self):
|
||||
"""09: everything goes well(instance_get_all_by_host returns[]). """
|
||||
|
||||
db.instance_get_all_by_host = Mock(return_value = [] )
|
||||
ret= self.manager.driver.has_enough_resource(self.ctxt, 'i-12345', 'host1')
|
||||
self.assertEqual(ret, None)
|
||||
|
||||
|
||||
# ---> test for nova.scheduler.manager.live_migration()
|
||||
|
||||
|
||||
def test10(self):
|
||||
"""10: instance_get issues NotFound. """
|
||||
|
||||
db.instance_get = Mock(side_effect=exception.NotFound("ERR"))
|
||||
self.assertRaises(exception.NotFound,
|
||||
self.manager.driver.schedule_live_migration,
|
||||
self.ctxt,
|
||||
'i-12345',
|
||||
'host1')
|
||||
|
||||
def test11(self):
|
||||
"""11: instance_get issues Unexpected error. """
|
||||
|
||||
db.instance_get = Mock(side_effect=TypeError("ERR"))
|
||||
self.assertRaises(TypeError,
|
||||
self.manager.driver.schedule_live_migration,
|
||||
self.ctxt,
|
||||
'i-12345',
|
||||
'host1')
|
||||
|
||||
def test12(self):
|
||||
"""12: instance state is not power_state.RUNNING. """
|
||||
|
||||
db.instance_get = Mock(return_value=self.instance4)
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host1')
|
||||
except exception.Invalid, e:
|
||||
c1 = (0 <= str(e.args).find('is not running'))
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
def test13(self):
|
||||
"""13: instance state_description is not running. """
|
||||
|
||||
db.instance_get = Mock(return_value=self.instance5)
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host1')
|
||||
except exception.Invalid, e:
|
||||
c1 = (0 <= str(e.args).find('is not running'))
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
def test14(self):
|
||||
"""14: dest is not compute node.
|
||||
(dest is not included in the result of db.service_get_all_by_topic)
|
||||
"""
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host2')
|
||||
except exception.Invalid, e:
|
||||
c1 = (0 <= str(e.args).find('must be compute node'))
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
def test15(self):
|
||||
""" 15: dest is not alive.(service_is up returns False) """
|
||||
|
||||
self.manager.driver.service_is_up = Mock(return_value=False)
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host2')
|
||||
except exception.Invalid, e:
|
||||
c1 = (0 <= str(e.args).find('is not alive'))
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
# Cannot test the case of hypervisor type difference and hypervisor
|
||||
# version difference, since we cannot set different mocks to same method..
|
||||
|
||||
def test16(self):
|
||||
""" 16: stored "cpuinfo" is not string """
|
||||
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host2')
|
||||
except exception.Invalid, e:
|
||||
c1 = (0 <= str(e.args).find('Unexpected err') )
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
|
||||
def test17(self):
|
||||
"""17: rpc.call raises RemoteError(Unexpected error occurs when executing compareCPU) """
|
||||
rpc.call = Mock(return_value = rpc.RemoteError(libvirt.libvirtError, 'val', 'traceback'))
|
||||
self.assertRaises(rpc.RemoteError,
|
||||
self.manager.driver.schedule_live_migration,
|
||||
self.ctxt,
|
||||
'i-12345',
|
||||
'host2')
|
||||
|
||||
def test18(self):
|
||||
"""18: rpc.call returns 0 (cpu is not compatible between src and dest) """
|
||||
rpc.call = Mock(return_value = 0)
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host2')
|
||||
except exception.Invalid, e:
|
||||
c1 = ( 0 <= str(e.args).find('doesnt have compatibility to'))
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
def test19(self):
|
||||
"""19: raise NotEmpty if host doesnt have enough resource. """
|
||||
|
||||
db.instance_get = Mock(return_value = self.instance8)
|
||||
try :
|
||||
self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host2')
|
||||
except exception.NotEmpty, e:
|
||||
c1 = ( 0 <= str(e.args).find('doesnt have enough resource') )
|
||||
self.assertTrue(c1, True)
|
||||
return False
|
||||
|
||||
|
||||
def test20(self):
|
||||
"""20: everything goes well. """
|
||||
|
||||
#db.instance_get = Mock(return_value = self.instance8)
|
||||
ret= self.manager.driver.schedule_live_migration(self.ctxt, 'i-12345', 'host2')
|
||||
self.assertEqual(ret, self.instance8['host'])
|
||||
|
||||
|
||||
def tearDown(self):
|
||||
"""common terminating method. """
|
||||
#sys.stdout = self.stdoutBak
|
||||
pass
|
||||
|
||||
if __name__ == '__main__':
|
||||
#unittest.main()
|
||||
suite = unittest.TestLoader().loadTestsFromTestCase(SchedulerTestFunctions)
|
||||
unittest.TextTestRunner(verbosity=3).run(suite)
|
||||
|
||||
|
||||
Binary file not shown.
Reference in New Issue
Block a user