delete unuse code in directory legacy

Change-Id: I31427e8a59ea241e882f41222f211fffe709043f
Signed-off-by: zhihui wu <wu.zhihui1@zte.com.cn>

10 files changed, 0 insertions, 758 deletions

diff --git a/legacy/utils/ansible_api.py b/legacy/utils/ansible_api.py
deleted file mode 100644
index 9e1d249e..00000000
--- a/legacy/utils/ansible_api.py
+++ /dev/null
@@ -1,65 +0,0 @@
-##############################################################################
-# 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
-##############################################################################
-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
-import logger_utils
-
-logger = logger_utils.QtipLogger('ansible_api').get
-
-
-class AnsibleApi:
-
-    def __init__(self):
-        self.variable_manager = VariableManager()
-        self.loader = DataLoader()
-        self.passwords = {}
-        self.pbex = None
-
-    def _check_path(self, file_path):
-        if not os.path.exists(file_path):
-            logger.error('The playbook %s does not exist' % file_path)
-            return False
-        else:
-            return True
-
-    def execute_playbook(self, hosts_file, playbook_path, pub_key_file, vars):
-        if not self._check_path(hosts_file):
-            return False
-
-        inventory = Inventory(loader=self.loader, variable_manager=self.variable_manager,
-                              host_list=hosts_file)
-        Options = namedtuple('Options', ['listtags', 'listtasks', 'listhosts', 'syntax',
-                                         'connection', 'module_path', 'forks', 'remote_user',
-                                         'private_key_file', 'ssh_common_args', 'ssh_extra_args',
-                                         'sftp_extra_args', 'scp_extra_args', 'become',
-                                         'become_method', 'become_user', 'verbosity', 'check'])
-        options = Options(listtags=False, listtasks=False, listhosts=False, syntax=False,
-                          connection='ssh', module_path=None, forks=100, remote_user='root',
-                          private_key_file=pub_key_file, ssh_common_args=None,
-                          ssh_extra_args=None, sftp_extra_args=None, scp_extra_args=None,
-                          become=True, become_method=None, become_user='root', verbosity=None,
-                          check=False)
-        self.variable_manager.extra_vars = vars
-
-        self.pbex = PlaybookExecutor(playbooks=[playbook_path], inventory=inventory,
-                                     variable_manager=self.variable_manager, loader=self.loader,
-                                     options=options, passwords=self.passwords)
-
-        return self.pbex.run()
-
-    def get_detail_playbook_stats(self):
-        if self.pbex:
-            stats = self.pbex._tqm._stats
-            return map(lambda x: (x, stats.summarize(x)), stats.processed.keys())
-        else:
-            return None
diff --git a/legacy/utils/args_handler.py b/legacy/utils/args_handler.py
deleted file mode 100644
index 993b1035..00000000
--- a/legacy/utils/args_handler.py
+++ /dev/null
@@ -1,73 +0,0 @@
-##############################################################################
-# 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
-##############################################################################
-import os
-from operator import add
-import simplejson as json
-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'):
-    benchmark_list = json.load(file('benchmarks/suite/{0}'.format(suite_name)))
-    return reduce(add, benchmark_list.values()) \
-        if case_type == 'all' else benchmark_list[case_type]
-
-
-def get_files_in_test_plan(lab, suite_name, case_type='all'):
-    test_case_all = os.listdir('benchmarks/testplan/{0}/{1}'.format(lab, suite_name))
-    return test_case_all if case_type == 'all' else \
-        filter(lambda x: case_type in x, test_case_all)
-
-
-def get_benchmark_path(lab, suit, benchmark):
-    return 'benchmarks/testplan/{0}/{1}/{2}'.format(lab, suit, benchmark)
-
-
-def check_suite(suite_name):
-    return True if os.path.isfile('benchmarks/suite/' + suite_name) else False
-
-
-def check_lab_name(lab_name):
-    return True if os.path.isdir('benchmarks/testplan/' + lab_name) else False
-
-
-def check_benchmark_name(lab, file, benchmark):
-    return os.path.isfile('benchmarks/testplan/' + lab + '/' + file + '/' + benchmark)
-
-
-def _get_f_name(test_case_path):
-    return test_case_path.split('/')[-1]
-
-
-def prepare_ansible_env(benchmark_test_case):
-    env_setup = Env_setup()
-    [benchmark, vm_info, benchmark_details, proxy_info] = env_setup.parse(benchmark_test_case)
-    SpawnVM(vm_info) if len(vm_info) else None
-    env_setup.call_ping_test()
-    env_setup.call_ssh_test()
-    env_setup.update_ansible()
-    return benchmark, benchmark_details, proxy_info, env_setup
-
-
-def run_benchmark(installer_type, pwd, benchmark, benchmark_details,
-                  proxy_info, env_setup, benchmark_test_case):
-    driver = Driver()
-    result = driver.drive_bench(installer_type, pwd, benchmark,
-                                env_setup.roles_dict.items(),
-                                _get_f_name(benchmark_test_case),
-                                benchmark_details, env_setup.ip_pw_dict.items(), proxy_info)
-    env_setup.cleanup_authorized_keys()
-    return result
-
-
-def prepare_and_run_benchmark(installer_type, pwd, benchmark_test_case):
-    benchmark, benchmark_details, proxy_info, env_setup = prepare_ansible_env(benchmark_test_case)
-    return run_benchmark(installer_type, pwd, benchmark, benchmark_details,
-                         proxy_info, env_setup, benchmark_test_case)
diff --git a/legacy/utils/cli.py b/legacy/utils/cli.py
deleted file mode 100644
index 5e566f27..00000000
--- a/legacy/utils/cli.py
+++ /dev/null
@@ -1,76 +0,0 @@
-##############################################################################
-# Copyright (c) 2015 Dell Inc  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
-##############################################################################
-
-import sys
-import os
-import args_handler
-import argparse
-import logger_utils
-
-logger = logger_utils.QtipLogger('cli').get
-
-
-class Cli:
-
-    @staticmethod
-    def _parse_args(args):
-        parser = argparse.ArgumentParser()
-        parser.add_argument('-l ', '--lab', required=True, help='Name of Lab '
-                            'on which being tested, These can'
-                            'be found in the benchmarks/testplan/ directory. Please '
-                            'ensure that you have edited the respective files '
-                            'before using them. For testing other than through Jenkins'
-                            ' The user should list default after -l . all the fields in'
-                            ' the files are necessary and should be filled')
-        parser.add_argument('-f', '--file', required=True, help='File in '
-                            'benchmarks/suite/ with the list of tests. there are three files'
-                            '\n compute '
-                            '\n storage '
-                            '\n network '
-                            'They contain all the tests that will be run. They are listed by suite.'
-                            'Please ensure there are no empty lines')
-        parser.add_argument('-b', '--benchmark', help='Name of the benchmark.'
-                            'Can be found in benchmarks/suite/file_name')
-
-        return parser.parse_args(args)
-
-    def __init__(self, args=sys.argv[1:]):
-
-        args = self._parse_args(args)
-        if not args_handler.check_suite(args.file):
-            logger.error("ERROR: This suite file %s doesn't exist under benchmarks/suite/.\
-                Please enter correct file." % str(args.file))
-            sys.exit(1)
-
-        if not args_handler.check_lab_name(args.lab):
-            logger.error("You have specified a lab that is not present under benchmarks/testplan/.\
-                Please enter correct file. If unsure how to proceed, use -l default.")
-            sys.exit(1)
-        suite = args.file
-        benchmarks = args_handler.get_files_in_suite(suite)
-        test_cases = args_handler.get_files_in_test_plan(args.lab, suite)
-        benchmarks_list = filter(lambda x: x in test_cases, benchmarks)
-
-        if args.benchmark:
-            if not args_handler.check_benchmark_name(args.lab, args.file, args.benchmark):
-                logger.error("You have specified an incorrect benchmark.\
-                    Please enter the correct one.")
-                sys.exit(1)
-            else:
-                logger.info("Starting with " + args.benchmark)
-                args_handler.prepare_and_run_benchmark(
-                    os.environ['INSTALLER_TYPE'], os.environ['PWD'],
-                    args_handler.get_benchmark_path(args.lab.lower(), args.file, args.benchmark))
-        else:
-            map(lambda x: args_handler.prepare_and_run_benchmark(
-                os.environ['INSTALLER_TYPE'], os.environ['PWD'],
-                args_handler.get_benchmark_path(args.lab.lower(), suite, x)), benchmarks_list)
-
-        logger.info("{0} is not a Template in the Directory Enter a Valid file name.\
-            or use qtip.py -h for list".format(filter(lambda x: x not in test_cases, benchmarks)))
diff --git a/legacy/utils/driver.py b/legacy/utils/driver.py
deleted file mode 100644
index 9894e0f5..00000000
--- a/legacy/utils/driver.py
+++ /dev/null
@@ -1,92 +0,0 @@
-##############################################################################
-# Copyright (c) 2015 Dell Inc, ZTE  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
-##############################################################################
-import logger_utils
-from operator import add
-from ansible_api import AnsibleApi
-from os.path import expanduser
-
-logger = logger_utils.QtipLogger('driver').get
-
-
-class Driver:
-
-    def __init__(self):
-
-        logger.info("Class driver initialized\n")
-        self.installer_username = {'fuel': 'root',
-                                   'joid': 'ubuntu',
-                                   'apex': 'heat-admin'}
-
-    @staticmethod
-    def merge_two_dicts(x, y):
-        '''
-        It is from http://stackoverflow.com/questions/38987/
-        how-can-i-merge-two-python-dictionaries-in-a-single-expression
-        '''
-        z = x.copy()
-        z.update(y)
-        return z
-
-    def get_common_var_json(self, installer_type, pwd, benchmark_fname,
-                            benchmark_detail, pip_dict, proxy_info):
-        common_json = {'Dest_dir': expanduser('~') + '/qtip/results',
-                       'ip1': '',
-                       'ip2': '',
-                       'installer': str(installer_type),
-                       'workingdir': str(pwd),
-                       'fname': str(benchmark_fname),
-                       'username': self.installer_username[str(installer_type)]}
-        common_json.update(benchmark_detail) if benchmark_detail else None
-        common_json.update(proxy_info) if proxy_info else None
-        return common_json
-
-    def get_special_var_json(self, role, roles, benchmark_detail, pip_dict):
-        special_json = {}
-        index = roles.index(role) + 1
-        private_ip = pip_dict[0][1] if pip_dict[0][1][0] else 'NONE'
-        map(lambda x: special_json.update({'ip' + str(index): x}), role[1])\
-            if benchmark_detail and (role[0] == '1-server') else None
-        map(lambda x: special_json.update({'privateip' + str(index): private_ip}), role[1])\
-            if benchmark_detail and (role[0] == '1-server') else None
-        special_json = self.get_special_var_json(filter(lambda x: x[0] == '1-server', roles)[0],
-                                                 roles,
-                                                 benchmark_detail,
-                                                 pip_dict) if role[0] == '2-host' else special_json
-        special_json.update({'role': role[0]})
-        return special_json
-
-    def run_ansible_playbook(self, benchmark, extra_vars):
-        logger.info(extra_vars)
-        ansible_api = AnsibleApi()
-        ansible_api.execute_playbook('./config/hosts',
-                                     './benchmarks/perftest/{0}.yaml'.format(benchmark),
-                                     './config/QtipKey', extra_vars)
-        return self.get_ansible_result(extra_vars['role'], ansible_api.get_detail_playbook_stats())
-
-    def drive_bench(self, installer_type, pwd, benchmark, roles, benchmark_fname,
-                    benchmark_detail=None, pip_dict=None, proxy_info=None):
-        roles = sorted(roles)
-        pip_dict = sorted(pip_dict)
-        var_json = self.get_common_var_json(installer_type, pwd, benchmark_fname,
-                                            benchmark_detail, pip_dict, proxy_info)
-        result = map(lambda role: self.run_ansible_playbook
-                     (benchmark, self.merge_two_dicts(var_json,
-                                                      self.get_special_var_json(role, roles,
-                                                                                benchmark_detail,
-                                                                                pip_dict))), roles)
-        return reduce(self._merge_ansible_result, result)
-
-    def get_ansible_result(self, role, stats):
-        result = reduce(add, map(lambda x: x[1]['failures'] + x[1]['unreachable'], stats))
-        return {'result': result,
-                'detail': {role: stats}}
-
-    def _merge_ansible_result(self, result_1, result_2):
-        return {'result': result_1['result'] + result_2['result'],
-                'detail': self.merge_two_dicts(result_1['detail'], result_2['detail'])}
diff --git a/legacy/utils/env_setup.py b/legacy/utils/env_setup.py
deleted file mode 100644
index 7bbedfcf..00000000
--- a/legacy/utils/env_setup.py
+++ /dev/null
@@ -1,214 +0,0 @@
-##############################################################################
-# Copyright (c) 2016 Dell Inc, ZTE 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
-##############################################################################
-import os
-import random
-import socket
-import sys
-import time
-from collections import defaultdict
-from os.path import expanduser
-import paramiko
-import yaml
-import logger_utils
-
-logger = logger_utils.QtipLogger('env_setup').get
-
-
-class Env_setup:
-
-    roles_ip_list = []  # ROLE and its corresponding IP address list
-    ip_pw_list = []  # IP and password, this will be used to ssh
-    roles_dict = defaultdict(list)
-    ip_pw_dict = defaultdict(list)
-    ip_pip_list = []
-    vm_parameters = defaultdict(list)
-    benchmark_details = defaultdict()
-    benchmark = ''
-
-    def __init__(self):
-        print '\nParsing class initiated\n'
-        self.roles_ip_list[:] = []
-        self.ip_pw_list[:] = []
-        self.roles_dict.clear()
-        self.ip_pw_dict.clear()
-        self.ip_pip_list[:] = []
-        self.proxy_info = {}
-        self.vm_parameters.clear()
-        self.benchmark_details.clear()
-        self.benchmark = ''
-
-    @staticmethod
-    def write_to_file(role):
-        f_name_2 = open('./config/hosts', 'w')
-        print role.items()
-        for k in role:
-            f_name_2.write('[' + k + ']\n')
-            num = len(role[k])
-            for x in range(num):
-                f_name_2.write(role[k][x] + '\n')
-        f_name_2.close()
-
-    @staticmethod
-    def ssh_test(hosts):
-        for ip, pw in hosts:
-            logger.info('Beginning SSH Test: %s \n' % ip)
-            os.system('ssh-keyscan %s >> /root/.ssh/known_hosts' % ip)
-            time.sleep(2)
-
-            ssh_cmd = './scripts/qtip_creds.sh %s' % ip
-            logger.info("run command: %s " % ssh_cmd)
-            os.system(ssh_cmd)
-
-            ssh = paramiko.SSHClient()
-            ssh.set_missing_host_key_policy(paramiko.AutoAddPolicy())
-            ssh.connect(ip, key_filename='./config/QtipKey')
-
-            for attempts in range(100):
-                try:
-                    stdin, stdout, stderr = ssh.exec_command('uname')
-                    if not stderr.readlines():
-                        logger.info('SSH successful')
-                        break
-                except socket.error:
-                    logger.error('SSH is still unavailable, retry!')
-                    time.sleep(2)
-                    if attempts == 99:
-                        logger.error("Try 99 times, SSH failed: %s" % ip)
-
-    @staticmethod
-    def ping_test(lister, attempts=30):
-        for k, v in lister.iteritems():
-            time.sleep(10)
-            for val in v:
-                ipvar = val
-                ping_cmd = 'ping -D -c1 {0}'.format(ipvar)
-                for i in range(attempts):
-                    if os.system(ping_cmd) != 0:
-                        print '\nWaiting for machine\n'
-                        time.sleep(10)
-                    else:
-                        break
-                print ('\n\n %s is UP \n\n ' % ipvar)
-
-    @staticmethod
-    def fetch_compute_ips():
-        logger.info("Fetch compute ips through installer")
-        ips = []
-
-        installer_type = str(os.environ['INSTALLER_TYPE'].lower())
-        installer_ip = str(os.environ['INSTALLER_IP'])
-        if installer_type not in ["fuel", "compass"]:
-            raise RuntimeError("%s is not supported" % installer_type)
-        if not installer_ip:
-            raise RuntimeError("undefine environment variable INSTALLER_IP")
-
-        cmd = "bash ./scripts/fetch_compute_ips.sh -i %s -a %s" % \
-            (installer_type, installer_ip)
-        logger.info(cmd)
-        os.system(cmd)
-        with open(expanduser('~') + "/qtip/ips.log", "r") as file:
-            data = file.read()
-        if data:
-            ips.extend(data.rstrip('\n').split('\n'))
-        logger.info("All compute ips: %s" % ips)
-        return ips
-
-    def check_machine_ips(self, host_tag):
-        logger.info("Check machine ips")
-        ips = self.fetch_compute_ips()
-        ips_num = len(ips)
-        num = len(host_tag)
-        if num > ips_num:
-            err = "host num %s > compute ips num %s" % (num, ips_num)
-            raise RuntimeError(err)
-
-        for x in range(num):
-            hostlabel = 'machine_' + str(x + 1)
-            if host_tag[hostlabel]['ip']:
-                if host_tag[hostlabel]['ip'] in ips:
-                    info = "%s's ip %s is defined by test case yaml file" % \
-                        (hostlabel, host_tag[hostlabel]['ip'])
-                    logger.info(info)
-                else:
-                    err = "%s is not in %s" % (host_tag[hostlabel]['ip'], ips)
-                    raise RuntimeError(err)
-            else:
-                host_tag[hostlabel]['ip'] = random.choice(ips)
-                info = "assign ip %s to %s" % (host_tag[hostlabel]['ip'], hostlabel)
-            ips.remove(host_tag[hostlabel]['ip'])
-
-    def get_host_machine_info(self, host_tag):
-        num = len(host_tag)
-        offset = len(self.roles_ip_list)
-        self.check_machine_ips(host_tag)
-        for x in range(num):
-            hostlabel = 'machine_' + str(x + 1)
-            self.roles_ip_list.insert(
-                offset, (host_tag[hostlabel]['role'], host_tag[hostlabel]['ip']))
-            self.ip_pw_list.insert(
-                offset, (host_tag[hostlabel]['ip'], host_tag[hostlabel]['pw']))
-
-    def get_virtual_machine_info(self, virtual_tag):
-
-        num = len(virtual_tag)
-        for x in range(num):
-            host_label = 'virtualmachine_' + str(x + 1)
-            for k, v in virtual_tag[host_label].iteritems():
-                self.vm_parameters[k].append(v)
-
-    def get_bench_mark_details(self, detail_dic):
-
-        print detail_dic
-        for k, v in detail_dic.items():
-            self.benchmark_details[k] = v
-
-    def parse(self, config_file_path):
-        try:
-            f_name = open(config_file_path, 'r+')
-            doc = yaml.safe_load(f_name)
-            f_name.close()
-            if doc['Scenario']['benchmark']:
-                self.benchmark = doc['Scenario']['benchmark']
-            if doc['Context']['Virtual_Machines']:
-                self.get_virtual_machine_info(doc['Context']['Virtual_Machines'])
-            if doc['Context']['Host_Machines']:
-                self.get_host_machine_info(doc['Context']['Host_Machines'])
-            if doc.get('Scenario', {}).get('benchmark_details', {}):
-                self.get_bench_mark_details(doc.get('Scenario', {}).get('benchmark_details', {}))
-            if 'Proxy_Environment' in doc['Context'].keys():
-                self.proxy_info['http_proxy'] = doc['Context']['Proxy_Environment']['http_proxy']
-                self.proxy_info['https_proxy'] = doc['Context']['Proxy_Environment']['https_proxy']
-                self.proxy_info['no_proxy'] = doc['Context']['Proxy_Environment']['no_proxy']
-            for k, v in self.roles_ip_list:
-                self.roles_dict[k].append(v)
-            for k, v in self.ip_pw_list:
-                self.ip_pw_dict[k].append(v)
-            return (
-                self.benchmark,
-                self.vm_parameters,
-                self.benchmark_details.items(),
-                self.proxy_info)
-        except KeyboardInterrupt:
-            print 'ConfigFile Closed: exiting!'
-            sys.exit(0)
-
-    def update_ansible(self):
-        self.write_to_file(self.roles_dict)
-
-    def call_ping_test(self):
-        self.ping_test(self.roles_dict)
-
-    def call_ssh_test(self):
-        self.ssh_test(self.ip_pw_list)
-
-    def cleanup_authorized_keys(self):
-        for ip, pw in self.ip_pw_list:
-            cmd = './scripts/cleanup_creds.sh %s' % ip
-            logger.info("cleanup authorized_keys: %s " % cmd)
-            os.system(cmd)
diff --git a/legacy/utils/transform/dpi_transform.py b/legacy/utils/transform/dpi_transform.py
deleted file mode 100644
index bc837311..00000000
--- a/legacy/utils/transform/dpi_transform.py
+++ /dev/null
@@ -1,55 +0,0 @@
-##############################################################################
-# Copyright (c) 2017 ZTE Corporation 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
-##############################################################################
-import os
-import pickle
-import datetime
-
-sum_dpi_pps = float(0)
-sum_dpi_bps = float(0)
-
-for x in range(1, 11):
-    dpi_result_pps = float(
-        os.popen(
-            "cat $HOME/qtip_result/dpi_dump.txt | grep 'nDPI throughput:' | awk 'NR=='" +
-            str(x) +
-            " | awk '{print $3}'").read().lstrip())
-    dpi_result_bps = float(
-        os.popen(
-            "cat $HOME/qtip_result/dpi_dump.txt | grep 'nDPI throughput:' | awk 'NR=='" +
-            str(x) +
-            " | awk '{print $7}'").read().rstrip())
-
-    if (dpi_result_pps > 100):
-        dpi_result_pps = dpi_result_pps / 1000
-
-    if (dpi_result_bps > 100):
-        dpi_result_bps = dpi_result_bps / 1000
-
-    sum_dpi_pps += dpi_result_pps
-    sum_dpi_bps += dpi_result_bps
-
-dpi_result_pps = sum_dpi_pps / 10
-dpi_result_bps = sum_dpi_bps / 10
-
-host = os.popen("hostname").read().rstrip()
-log_time_stamp = str(datetime.datetime.utcnow().isoformat())
-
-os.popen(
-    "cat $HOME/qtip_result/dpi_dump.txt > $HOME/qtip_result/" +
-    host +
-    "-" +
-    log_time_stamp +
-    ".log")
-
-home_dir = str(os.popen("echo $HOME").read().rstrip())
-host = os.popen("echo $HOSTNAME")
-result = {'pps': round(dpi_result_pps, 3),
-          'bps': round(dpi_result_bps, 3)}
-with open('./result_temp', 'w+') as result_file:
-    pickle.dump(result, result_file)
diff --git a/legacy/utils/transform/final_report.py b/legacy/utils/transform/final_report.py
deleted file mode 100644
index 1d7c3001..00000000
--- a/legacy/utils/transform/final_report.py
+++ /dev/null
@@ -1,32 +0,0 @@
-##############################################################################
-# Copyright (c) 2017 ZTE Corporation 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
-##############################################################################
-import pickle
-import json
-import datetime
-import os
-import sys
-
-home_dir = str((os.popen("echo $HOME").read().rstrip()))
-
-with open('./sys_info_temp', 'r') as sys_info_f:
-    sys_info_dict = pickle.load(sys_info_f)
-with open('./result_temp', 'r') as result_f:
-    result_dict = pickle.load(result_f)
-
-host_name = (os.popen("hostname").read().rstrip())
-benchmark_name = str(sys.argv[1])
-testcase_name = str(sys.argv[2])
-report_time_stamp = str(datetime.datetime.utcnow().isoformat())
-final_dict = {"name": testcase_name,
-              "time": report_time_stamp,
-              "system_information": sys_info_dict,
-              "details": result_dict}
-
-with open('./' + host_name + '-' + report_time_stamp + '.json', 'w+') as result_json:
-    json.dump(final_dict, result_json, indent=4, sort_keys=True)
diff --git a/legacy/utils/transform/ramspeed_transform.py b/legacy/utils/transform/ramspeed_transform.py
deleted file mode 100644
index 9aa713ff..00000000
--- a/legacy/utils/transform/ramspeed_transform.py
+++ /dev/null
@@ -1,49 +0,0 @@
-##############################################################################
-# Copyright (c) 2017 ZTE Corporation 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
-##############################################################################
-import os
-import pickle
-import datetime
-
-intmem_copy = os.popen("cat Intmem | grep 'BatchRun   Copy' | awk '{print $4}'").read().rstrip()
-intmem_scale = os.popen("cat Intmem | grep 'BatchRun   Scale' | awk '{print $4}'").read().rstrip()
-intmem_add = os.popen("cat Intmem | grep 'BatchRun   Add' | awk '{print $4}'").read().rstrip()
-intmem_triad = os.popen("cat Intmem | grep 'BatchRun   Triad' | awk '{print $4}'").read().rstrip()
-intmem_average = os.popen("cat Intmem | grep 'BatchRun   AVERAGE' | awk '{print $4}'").read().rstrip()
-
-print intmem_copy
-print intmem_average
-
-floatmem_copy = os.popen("cat Floatmem | grep 'BatchRun  Copy' | awk '{print $4}'").read().rstrip()
-floatmem_scale = os.popen("cat Floatmem | grep 'BatchRun  Scale' | awk '{print $4}'").read().rstrip()
-floatmem_add = os.popen("cat Floatmem | grep 'BatchRun  Add' | awk '{print $4}'").read().rstrip()
-floatmem_triad = os.popen("cat Floatmem | grep 'BatchRun  Triad' | awk '{print $4}'").read().rstrip()
-floatmem_average = os.popen("cat Floatmem | grep 'BatchRun  AVERAGE' | awk '{print $4}'").read().rstrip()
-
-print floatmem_copy
-print floatmem_average
-
-hostname = os.popen("hostname").read().rstrip()
-time_stamp = str(datetime.datetime.utcnow().isoformat())
-
-os.system("mv Intmem " + hostname + "-" + time_stamp + ".log")
-os.system("cp  Floatmem >> " + hostname + "-" + time_stamp + ".log")
-
-result = {"int_bandwidth": {"copy": intmem_copy,
-                            "add": intmem_add,
-                            "scale": intmem_scale,
-                            "triad": intmem_triad,
-                            "average": intmem_average},
-          "float_bandwidth": {"copy": floatmem_copy,
-                              "add": floatmem_add,
-                              "scale": floatmem_scale,
-                              "triad": floatmem_triad,
-                              "average": floatmem_average}}
-
-with open('./result_temp', 'w+') as result_file:
-    pickle.dump(result, result_file)
diff --git a/legacy/utils/transform/ssl_transform.py b/legacy/utils/transform/ssl_transform.py
deleted file mode 100644
index 24b696e5..00000000
--- a/legacy/utils/transform/ssl_transform.py
+++ /dev/null
@@ -1,62 +0,0 @@
-##############################################################################
-# Copyright (c) 2017 ZTE Corporation 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
-##############################################################################
-import os
-import pickle
-import datetime
-
-openssl_version = os.popen("cat RSA_dump | head -1").read().rstrip()
-rsa_512_sps = os.popen(
-    "cat RSA_dump | grep  '512 bits ' | awk '{print $6}' ").read().rstrip()
-rsa_512_vps = os.popen(
-    "cat RSA_dump | grep  '512 bits ' | awk '{print $7}' ").read().rstrip()
-rsa_1024_sps = os.popen(
-    "cat RSA_dump | grep  '1024 bits ' | awk '{print $6}' ").read().rstrip()
-rsa_1024_vps = os.popen(
-    "cat RSA_dump | grep  '1024 bits ' | awk '{print $7}' ").read().rstrip()
-rsa_2048_sps = os.popen(
-    "cat RSA_dump | grep  '2048 bits ' | awk '{print $6}' ").read().rstrip()
-rsa_2048_vps = os.popen(
-    "cat RSA_dump | grep  '2048 bits ' | awk '{print $7}' ").read().rstrip()
-rsa_4096_sps = os.popen(
-    "cat RSA_dump | grep  '4096 bits ' | awk '{print $6}' ").read().rstrip()
-rsa_4096_vps = os.popen(
-    "cat RSA_dump | grep  '4096 bits ' | awk '{print $7}' ").read().rstrip()
-
-aes_16B = os.popen(
-    "cat AES-128-CBC_dump | grep  'aes-128-cbc  ' | awk '{print $2}' ").read().rstrip()
-aes_64B = os.popen(
-    "cat AES-128-CBC_dump | grep  'aes-128-cbc  ' | awk '{print $3}' ").read().rstrip()
-aes_256B = os.popen(
-    "cat AES-128-CBC_dump | grep  'aes-128-cbc  ' | awk '{print $4}' ").read().rstrip()
-aes_1024B = os.popen(
-    "cat AES-128-CBC_dump | grep  'aes-128-cbc  ' | awk '{print $5}' ").read().rstrip()
-aes_8192B = os.popen(
-    "cat AES-128-CBC_dump | grep  'aes-128-cbc  ' | awk '{print $6}' ").read().rstrip()
-
-hostname = os.popen("hostname").read().rstrip()
-time_stamp = str(datetime.datetime.utcnow().isoformat())
-
-os.system("mv RSA_dump " + hostname + "-" + time_stamp + ".log")
-os.system("cat AES-128-CBC_dump >> " + hostname + "-" + time_stamp + ".log")
-
-result = {"version": [openssl_version],
-          "rsa_sig": {"512_bits": rsa_512_sps,
-                      "1024_bits": rsa_1024_sps,
-                      "2048_bits": rsa_2048_sps,
-                      "4096_bits": rsa_4096_sps,
-                      "unit": "sig/sec"},
-          "aes_128_cbc": {"16B_block": aes_16B,
-                          "64B_block": aes_64B,
-                          "256B_block": aes_256B,
-                          "1024B_block": aes_1024B,
-                          "8192B_block": aes_8192B,
-                          "unit": "B/sec"}}
-
-with open('./result_temp', 'w+') as result_file:
-    pickle.dump(result, result_file)
diff --git a/legacy/utils/transform/ubench_transform.py b/legacy/utils/transform/ubench_transform.py
deleted file mode 100644
index fe687118..00000000
--- a/legacy/utils/transform/ubench_transform.py
+++ /dev/null
@@ -1,40 +0,0 @@
-##############################################################################
-# Copyright (c) 2017 ZTE Corporation 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
-##############################################################################
-import os
-import json
-import pickle
-
-total_cpu = os.popen(
-    "cat $HOME/tempT/UnixBench/results/* | grep 'of tests' | awk '{print $1;}' | awk 'NR==1'").read().rstrip()
-
-cpu_1 = os.popen(
-    "cat $HOME/tempT/UnixBench/results/* | grep 'of tests' | awk '{print $6;}' | awk 'NR==1'").read().rstrip()
-
-
-cpu_2 = os.popen(
-    "cat $HOME/tempT/UnixBench/results/* | grep 'of tests' | awk '{print $6;}' | awk 'NR==2'").read().rstrip()
-
-
-index_1 = os.popen(
-    "cat $HOME/tempT/UnixBench/results/* | grep 'Index Score (Partial Only)  ' | awk '{print $7;}' | awk 'NR==1'").read().rstrip()
-index_2 = os.popen(
-    "cat $HOME/tempT/UnixBench/results/* | grep 'Index Score (Partial Only)  ' | awk '{print $7;}' | awk 'NR==2'").read().rstrip()
-
-
-result = {"n_cpu": total_cpu,
-          "single": {"n_para_test": cpu_1,
-                     "score": index_1},
-          "multi": {"n_para_test": cpu_2,
-                    "score": index_2}
-          }
-
-with open('result_temp', 'w+') as result_file:
-    pickle.dump(result, result_file)
-print json.dumps(result, indent=4, sort_keys=True)
-# print result.items()