Local test is ok.
JIRA: QTIP-131
Change-Id: I7009337903c7ded90dda47a05d6c1c95aa96815d
Signed-off-by: wu.zhihui <wu.zhihui1@zte.com.cn>
##############################################################################
# Copyright (c) 2015 Dell Inc and others.
+# Copyright (c) 2016 ZTE corp. and others.
#
# All rights reserved. This program and the accompanying materials
# are made available under the terms of the Apache License, Version 2.0
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
-from func.cli import Cli
+from utils.cli import Cli
def main():
import threading
from copy import copy
import db
-import func.args_handler as args_handler
+import utils.args_handler as args_handler
import restful_server.result_handler as result_handler
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
-from func.ansible_api import AnsibleApi
+from utils.ansible_api import AnsibleApi
class TestClass:
##############################################################################
import pytest
import mock
-import func.args_handler
+import utils.args_handler
class TestClass:
[('duration', 20), ('protocol', 'tcp'), ('bandwidthGbps', 10)],
[("10.20.0.24", [None]), ("10.20.0.23", [None])], {}])
])
- @mock.patch('func.args_handler.Env_setup.call_ping_test')
- @mock.patch('func.args_handler.Env_setup.call_ssh_test')
- @mock.patch('func.args_handler.Env_setup.update_ansible')
- @mock.patch('func.args_handler.SpawnVM')
- @mock.patch('func.args_handler.Driver.drive_bench')
+ @mock.patch('utils.args_handler.Env_setup.call_ping_test')
+ @mock.patch('utils.args_handler.Env_setup.call_ssh_test')
+ @mock.patch('utils.args_handler.Env_setup.update_ansible')
+ @mock.patch('utils.args_handler.SpawnVM')
+ @mock.patch('utils.args_handler.Driver.drive_bench')
def test_prepare_and_run_benchmark_successful(self, mock_driver, mock_sqawn_vm, mock_env_setup_ping,
mock_env_setup_ssh, mock_update_ansible, test_input, expected):
mock_ips = mock.Mock(return_value=["10.20.0.23", "10.20.0.24"])
- func.args_handler.Env_setup.fetch_compute_ips = mock_ips
- func.args_handler.prepare_and_run_benchmark(test_input[0], test_input[1], test_input[2])
+ utils.args_handler.Env_setup.fetch_compute_ips = mock_ips
+ utils.args_handler.prepare_and_run_benchmark(test_input[0], test_input[1], test_input[2])
call = mock_driver.call_args
call_args, call_kwargs = call
assert sorted(map(sorted, call_args)) == sorted(map(sorted, expected))
import mock
from mock import Mock, MagicMock
import os
-from func.create_zones import AvailabilityZone
+from utils.create_zones import AvailabilityZone
return_list = []
['create:compute1:compute1',
'add_host:compute1:10.20.0.4']),
])
- @mock.patch('func.create_zones.client', autospec=True)
- @mock.patch('func.create_zones.v2', autospec=True)
- @mock.patch('func.create_zones.session')
+ @mock.patch('utils.create_zones.client', autospec=True)
+ @mock.patch('utils.create_zones.v2', autospec=True)
+ @mock.patch('utils.create_zones.session')
def test_create_zones_success(self, mock_keystone_session, mock_keystone_v2, mock_nova_client, test_input, expected, capfd):
nova_obj = NovaMock()
mock_nova_client.Client.return_value = nova_obj()
'OS_TENANT_NAME': 'admin'})
k.start()
azone = AvailabilityZone()
- azone.create_agg(test_input)
+ azone.create_aggs(test_input)
k.stop()
resout, reserr = capfd.readouterr()
for x in expected:
([],
[]),
])
- @mock.patch('func.create_zones.client', autospec=True)
- @mock.patch('func.create_zones.v2', autospec=True)
- @mock.patch('func.create_zones.session')
+ @mock.patch('utils.create_zones.client', autospec=True)
+ @mock.patch('utils.create_zones.v2', autospec=True)
+ @mock.patch('utils.create_zones.session')
def test_clean_all_aggregates(self, mock_keystone_session, mock_keystone_v2, mock_nova_client, test_input, expected, capfd):
global return_list
return_list = test_input
import pytest
import mock
-from func.driver import Driver
+from utils.driver import Driver
from os.path import expanduser
HOME_DIR = expanduser('~')
'bandwidthGbps': 0,
"role": "2-host"}])
])
- @mock.patch('func.driver.AnsibleApi.execute_playbook')
- @mock.patch('func.driver.AnsibleApi.get_detail_playbook_stats')
+ @mock.patch('utils.driver.AnsibleApi.execute_playbook')
+ @mock.patch('utils.driver.AnsibleApi.get_detail_playbook_stats')
def test_driver_success(self, mock_stats, mock_ansible, test_input, expected):
mock_ansible.return_value = True
mock_stats.return_value = [(u'10.20.6.14', {'unreachable': 0,
import pytest
import filecmp
-from func.env_setup import Env_setup
+from utils.env_setup import Env_setup
import mock
'no_proxy': 'localhost,127.0.0.1,10.20.*,192.168.*'}])
])
def test_parse_success(self, test_input, expected):
- print (test_input)
- print (expected)
test_class = Env_setup()
mock_ips = mock.Mock(return_value=["10.20.0.28", "10.20.0.29"])
test_class.fetch_compute_ips = mock_ips
import mock
from mock import Mock, MagicMock
import os
-from func.spawn_vm import SpawnVM
+from utils.spawn_vm import SpawnVM
class KeystoneMock(MagicMock):
'role': ['1-server', '2-host']},
[('172.10.0.154', '')]),
])
- @mock.patch('func.spawn_vm.Env_setup')
- @mock.patch('func.spawn_vm.AvailabilityZone')
- @mock.patch('func.spawn_vm.keystoneclient.v2_0', autospec=True)
- @mock.patch('func.spawn_vm.heatclient.client', autospec=True)
+ @mock.patch('utils.spawn_vm.Env_setup')
+ @mock.patch('utils.spawn_vm.AvailabilityZone')
+ @mock.patch('utils.spawn_vm.keystoneclient.v2_0', autospec=True)
+ @mock.patch('utils.spawn_vm.heatclient.client', autospec=True)
def test_create_zones_success(self, mock_heat, mock_keystone,
mock_zone, mock_setup, test_input, expected):
open('./config/QtipKey.pub', 'a').close()
##############################################################################
import os
from collections import namedtuple
-
from ansible.executor.playbook_executor import PlaybookExecutor
from ansible.inventory import Inventory
from ansible.parsing.dataloader import DataLoader
from ansible.vars import VariableManager
-
-from utils import logger_utils
+import logger_utils
logger = logger_utils.QtipLogger('ansible_api').get
import os
from operator import add
import simplejson as json
-from func.env_setup import Env_setup
-from func.spawn_vm import SpawnVM
-from func.driver import Driver
+from env_setup import Env_setup
+from spawn_vm import SpawnVM
+from driver import Driver
def get_files_in_suite(suite_name, case_type='all'):
import os
import args_handler
import argparse
-from utils import logger_utils
+import logger_utils
logger = logger_utils.QtipLogger('cli').get
from novaclient import client\r
import os\r
import random\r
-from utils import logger_utils\r
+import logger_utils\r
\r
logger = logger_utils.QtipLogger('create_zones').get\r
\r
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
-from utils import logger_utils
+import logger_utils
from operator import add
from ansible_api import AnsibleApi
from os.path import expanduser
-
logger = logger_utils.QtipLogger('driver').get
# which accompanies this distribution, and is available at
# http://www.apache.org/licenses/LICENSE-2.0
##############################################################################
-
import os
import random
import socket
from os.path import expanduser
import paramiko
import yaml
-from utils import logger_utils
+import logger_utils
logger = logger_utils.QtipLogger('env_setup').get
import heatclient.client\r
import keystoneclient\r
import time\r
-from func.env_setup import Env_setup\r
-from func.create_zones import AvailabilityZone\r
-from utils import logger_utils\r
+from env_setup import Env_setup\r
+from create_zones import AvailabilityZone\r
+import logger_utils\r
\r
logger = logger_utils.QtipLogger('spawn_vm').get\r
\r