Function DeployNameserver

tools/deploy.py:174–210

(zk_cluster, zk_root_path, ns_conf, teardown)

def DeployNameserver(zk_cluster, zk_root_path, ns_conf, teardown):
    source_file = ns_conf["package"]
    file_name = os.path.basename(source_file)
    version = file_name.split("-")[-1][:-7]
    for item in ns_conf["address_arr"]:
        real_path = ''
        if "path" in item:
            real_path = item["path"]
        else:
            real_path = ns_conf["path"]
        host = item["address"].split(":")[0]
        (prefix, suffix, is_local) = GetPrefixAndSuffix(host)
        work_path = real_path + "/fedb-nameserver-" + version 
        cmd_arr = []
        if teardown:
            print("teardown nameserver on {}. path: {}".format(host, real_path))
            cmd_arr.append("{} cd {}; sh bin/start_ns.sh stop {}".format(prefix, work_path, suffix))
            cmd_arr.append("{} cd {}; rm {}; rm -rf {} {}".format(prefix, real_path, file_name, "fedb-nameserver-*", suffix))
        else:    
            print("start nameserver on {}. path: {}".format(host, real_path))
            cmd_arr.append("{} mkdir -p {} {}".format(prefix, real_path, suffix))
            if is_local:
                cmd_arr.append("cp {} {}".format(source_file, real_path))
            else:    
                cmd_arr.append("scp {} {}:{}".format(source_file, host, real_path))
            cmd_arr.append("{} cd {}; tar -zxvf {}; mv {} fedb-nameserver-{} {}".format(prefix, real_path, file_name, file_name[:-7], version, suffix))
            cmd_arr.append("{} cd {}; sed -i 's/--endpoint=.*/--endpoint={}/g' conf/nameserver.flags;"
                                            "sed -i 's/--zk_cluster=.*/--zk_cluster={}/g' conf/nameserver.flags;"
                                            "sed -i 's/--zk_root_path=.*/--zk_root_path={}/g' conf/nameserver.flags {}".format(
                                            prefix, work_path, item["address"], zk_cluster, zk_root_path.replace("/", "\/"), suffix))
            cmd_arr.append("{} cd {}; sh bin/start_ns.sh start {}".format(prefix, work_path, suffix))
        for cmd in cmd_arr:
            (returncode,output,errout) = RunWithRetunCode(cmd)
            if returncode != 0:
                print("execute cmd[{}] failed! error msg: {}".format(cmd, errout))    
                return
            print("execute cmd[{}] success".format(cmd))

def DeployTablet(zk_cluster, zk_root_path, tablet_conf, teardown):
    source_file = tablet_conf["package"]