# returns a pair of bools

# the first indicates whether the node is the master

# the second indicates if the calling functions retry loop should continue

def _is_master(node, root):

    ces_node = root.find("./CrossEngineSupport")

    username = ces_node.find("./User").text

    password = ces_node.find("./Password").text

    if username is None:

        return False, False

    cmd = (f"mariadb -h {node} -u '{username}' --password='{password}' -sN -e \

            \"SELECT VARIABLE_VALUE FROM information_schema.GLOBAL_STATUS WHERE VARIABLE_NAME = 'SLAVE_CONNECTIONS';\"")

    ret = subprocess.run(cmd, stdout=subprocess.PIPE, shell = True)

    if ret.returncode == 0:

        response = ret.stdout.decode("utf-8").strip()

        if response > '0':

            return True, False

    else:

        return False, False

    return False, True

SELECT COUNT(1) AS `slave_threads`

FROM `information_schema`.`PROCESSLIST`

WHERE `USER`='system user'

  AND `COMMAND` LIKE 'Slave%';