diff options
Diffstat (limited to 'glustolibs-gluster/glustolibs/gluster/tiering_ops.py')
-rw-r--r-- | glustolibs-gluster/glustolibs/gluster/tiering_ops.py | 1019 |
1 files changed, 1019 insertions, 0 deletions
diff --git a/glustolibs-gluster/glustolibs/gluster/tiering_ops.py b/glustolibs-gluster/glustolibs/gluster/tiering_ops.py new file mode 100644 index 000000000..38890f5ca --- /dev/null +++ b/glustolibs-gluster/glustolibs/gluster/tiering_ops.py @@ -0,0 +1,1019 @@ +#!/usr/bin/env python +# Copyright (C) 2015-2016 Red Hat, Inc. <http://www.redhat.com> +# +# This program is free software; you can redistribute it and/or modify +# it under the terms of the GNU General Public License as published by +# the Free Software Foundation; either version 2 of the License, or +# any later version. +# +# This program is distributed in the hope that it will be useful, +# but WITHOUT ANY WARRANTY; without even the implied warranty of +# MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the +# GNU General Public License for more details. +# +# You should have received a copy of the GNU General Public License along +# with this program; if not, write to the Free Software Foundation, Inc., +# 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. + +""" + Description: Library for gluster tiering operations. +""" + +import re +from glusto.core import Glusto as g +from glustolibs.gluster.peer_ops import peer_probe_servers +from glustolibs.gluster.gluster_init import start_glusterd +from glustolibs.gluster.lib_utils import list_files + +try: + import xml.etree.cElementTree as etree +except ImportError: + import xml.etree.ElementTree as etree + + +def add_extra_servers_to_cluster(mnode, extra_servers): + """Adds the given extra servers to cluster + + Args: + mnode (str): Node on which cmd has to be executed. + extra_servers (list) : list of extra servers to be attached to cluster + + Returns: + bool: True, if extra servers are attached to cluster + False, otherwise + + Example: + add_extra_servers_to_cluster("abc.com", ['peer_node1','peer_node2']) + """ + + if not isinstance(extra_servers, list): + extra_servers = [extra_servers] + + ret = start_glusterd(servers=extra_servers) + if not ret: + g.log.error("glusterd did not start in peer nodes") + return False + + ret = peer_probe_servers(mnode, servers=extra_servers) + if not ret: + g.log.error("Unable to do peer probe on extra server machines") + return False + + return True + + +def tier_attach(mnode, volname, num_bricks_to_add, extra_servers, + extra_servers_info, replica=1, force=False): + """Attaches tier to the volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + num_bricks_to_add (str): number of bricks to be added as hot tier + extra_servers (list): from these servers, hot tier will be added + to volume + extra_servers_info (dict): dict of server info of each extra servers + + Kwargs: + replica (str): replica count of the hot tier + force (bool): If this option is set to True, then attach tier + will get executed with force option. If it is set to False, + then attach tier will get executed without force option + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_attach("abc.com", testvol, '2', ['extra_server1','extra_server2'], + extra_server_info) + """ + + replica = int(replica) + repc = '' + if replica != 1: + repc = "replica %d" % replica + + frce = '' + if force: + frce = 'force' + + num_bricks_to_add = int(num_bricks_to_add) + + from glustolibs.gluster.lib_utils import form_bricks_list + bricks_list = form_bricks_list(mnode, volname, num_bricks_to_add, + extra_servers[:], extra_servers_info) + if bricks_list is None: + g.log.error("number of bricks required are greater than " + "unused bricks") + return (-1, '', '') + + bricks_path = ' '.join(bricks_list) + bricks_path = [re.sub(r"(.*\/\S+\_)brick(\d+)", r"\1tier\2", item) + for item in bricks_path.split() if item] + tier_bricks_path = " ".join(bricks_path) + cmd = ("gluster volume tier %s attach %s %s %s --mode=script" + % (volname, repc, tier_bricks_path, frce)) + + return g.run(mnode, cmd) + + +def tier_start(mnode, volname, force=False): + """Starts the tier volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Kwargs: + force (bool): If this option is set to True, then attach tier + will get executed with force option. If it is set to False, + then attach tier will get executed without force option + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_start("abc.com", testvol) + """ + + frce = '' + if force: + frce = 'force' + + cmd = ("gluster volume tier %s start %s --mode=script" + % (volname, frce)) + return g.run(mnode, cmd) + + +def tier_status(mnode, volname): + """executes tier status command + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_status("abc.com", testvol) + """ + + cmd = "gluster volume tier %s status" % volname + ret = g.run(mnode, cmd) + + return ret + + +def get_tier_status(mnode, volname): + """Parse the output of 'gluster tier status' command. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + dict: dict on success. + + Examples: + >>> get_tier_status('abc.lab.eng.xyz.com', 'testvol') + {'node': [{'promotedFiles': '0', 'demotedFiles': '0', 'nodeName': + 'localhost', 'statusStr': 'in progress'}, {'promotedFiles': '0', + 'demotedFiles': '0', 'nodeName': '10.70.47.16', 'statusStr': + 'in progress'}], 'task-id': '2ed28cbd-4246-493a-87b8-1fdcce313b34', + 'nodeCount': '4', 'op': '7'} + """ + + cmd = "gluster volume tier %s status --xml" % volname + ret, out, _ = g.run(mnode, cmd) + if ret != 0: + g.log.error("Failed to execute 'tier status' on node %s. " + "Hence failed to get tier status.", mnode) + return None + + try: + root = etree.XML(out) + except etree.ParseError: + g.log.error("Failed to parse the gluster tier status xml output.") + return None + + tier_status = {} + tier_status["node"] = [] + for info in root.findall("volRebalance"): + for element in info.getchildren(): + if element.tag == "node": + status_info = {} + for elmt in element.getchildren(): + status_info[elmt.tag] = elmt.text + tier_status[element.tag].append(status_info) + else: + tier_status[element.tag] = element.text + return tier_status + + +def tier_detach_start(mnode, volname): + """starts detaching tier on given volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_detach_start("abc.com", testvol) + + """ + + cmd = "gluster volume tier %s detach start --mode=script" % volname + return g.run(mnode, cmd) + + +def tier_detach_status(mnode, volname): + """executes detach tier status on given volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_detach_status("abc.com", testvol) + + """ + + cmd = "gluster volume tier %s detach status --mode=script" % volname + return g.run(mnode, cmd) + + +def tier_detach_stop(mnode, volname): + """stops detaching tier on given volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_detach_stop("abc.com", testvol) + + """ + + cmd = "gluster volume tier %s detach stop --mode=script" % volname + return g.run(mnode, cmd) + + +def tier_detach_commit(mnode, volname): + """commits detach tier on given volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_detach_commit("abc.com", testvol) + + """ + + cmd = "gluster volume tier %s detach commit --mode=script" % volname + return g.run(mnode, cmd) + + +def tier_detach_force(mnode, volname): + """detaches tier forcefully on given volume + + Args: + mnode (str): Node on which cmd has to be executed. + volname (str): volume name + + Returns: + tuple: Tuple containing three elements (ret, out, err). + The first element 'ret' is of type 'int' and is the return value + of command execution. + + The second element 'out' is of type 'str' and is the stdout value + of the command execution. + + The third element 'err' is of type 'str' and is the stderr value + of the command execution. + + Example: + tier_detach_force("abc.com", testvol) + + """ + + cmd = "gluster volume tier %s detach force --mode=script" % volname + return g.run(mnode, cmd) + + +def get_detach_tier_status(mnode, volname): + """Parse the output of 'gluster volume tier detach status' command. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + dict: dict on success. + + Examples: + >>> get_detach_tier_status('abc.lab.eng.xyz.com', "testvol") + {'node': [{'files': '0', 'status': '3', 'lookups': '1', 'skipped': '0', + 'nodeName': 'localhost', 'failures': '0', 'runtime': '0.00', 'id': + '11336017-9561-4e88-9ac3-a94d4b403340', 'statusStr': 'completed', + 'size': '0'}, {'files': '0', 'status': '3', 'lookups': '0', 'skipped': + '0', 'nodeName': '10.70.47.16', 'failures': '0', 'runtime': '0.00', + 'id': 'a2b88b10-eba2-4f97-add2-8dc37df08b27', 'statusStr': 'completed', + 'size': '0'}], 'nodeCount': '4', 'aggregate': {'files': '0', 'status': + '3', 'lookups': '1', 'skipped': '0', 'failures': '0', 'runtime': '0.0', + 'statusStr': 'completed', 'size': '0'}} + """ + + cmd = "gluster volume tier %s detach status --xml" % volname + ret, out, _ = g.run(mnode, cmd) + if ret != 0: + g.log.error("Failed to execute 'detach tier status' on node %s. " + "Hence failed to get detach tier status.", mnode) + return None + + try: + root = etree.XML(out) + except etree.ParseError: + g.log.error("Failed to parse the detach tier status xml output.") + return None + + tier_status = {} + tier_status["node"] = [] + for info in root.findall("volDetachTier"): + for element in info.getchildren(): + if element.tag == "node": + status_info = {} + for elmt in element.getchildren(): + status_info[elmt.tag] = elmt.text + tier_status[element.tag].append(status_info) + elif element.tag == "aggregate": + status_info = {} + for elmt in element.getchildren(): + status_info[elmt.tag] = elmt.text + tier_status[element.tag] = status_info + else: + tier_status[element.tag] = element.text + return tier_status + + +def tier_detach_start_and_get_taskid(mnode, volname): + """Parse the output of 'gluster volume tier detach start' command. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + dict: dict on success. + + Examples: + >>> tier_detach_start_and_get_taskid('abc.lab.eng.xyz.com', + "testvol") + {'task-id': '8020835c-ff0d-4ea1-9f07-62dd067e92d4'} + """ + + cmd = "gluster volume tier %s detach start --xml" % volname + ret, out, _ = g.run(mnode, cmd) + if ret != 0: + g.log.error("Failed to execute 'detach tier start' on node %s. " + "Hence failed to parse the detach tier start.", mnode) + return None + + try: + root = etree.XML(out) + except etree.ParseError: + g.log.error("Failed to parse the gluster detach tier " + "start xml output.") + return None + + tier_status = {} + for info in root.findall("volDetachTier"): + for element in info.getchildren(): + tier_status[element.tag] = element.text + return tier_status + + +def tier_detach_stop_and_get_status(mnode, volname): + """Parse the output of 'gluster volume tier detach stop' command. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + dict: dict on success. + + Examples: + >>> tier_detach_stop_and_get_status('abc.lab.eng.xyz.com', + "testvol") + {'node': [{'files': '0', 'status': '3', 'lookups': '1', 'skipped': '0', + 'nodeName': 'localhost', 'failures': '0', 'runtime': '0.00', 'id': + '11336017-9561-4e88-9ac3-a94d4b403340', 'statusStr': 'completed', + 'size': '0'}, {'files': '0', 'status': '3', 'lookups': '0', 'skipped': + '0', 'nodeName': '10.70.47.16', 'failures': '0', 'runtime': '0.00', + 'id': 'a2b88b12-eba2-4f97-add2-8dc37df08b27', 'statusStr': 'completed', + 'size': '0'}], 'nodeCount': '4', 'aggregate': {'files': '0', 'status': + '3', 'lookups': '1', 'skipped': '0', 'failures': '0', 'runtime': '0.0', + 'statusStr': 'completed', 'size': '0'}} + """ + + cmd = "gluster volume tier %s detach stop --xml" % volname + ret, out, _ = g.run(mnode, cmd) + if ret != 0: + g.log.error("Failed to execute 'tier start' on node %s. " + "Hence failed to parse the tier start.", mnode) + return None + + try: + root = etree.XML(out) + except etree.ParseError: + g.log.error("Failed to parse the gluster detach tier stop" + " xml output.") + return None + + tier_status = {} + tier_status["node"] = [] + for info in root.findall("volDetachTier"): + for element in info.getchildren(): + if element.tag == "node": + status_info = {} + for elmt in element.getchildren(): + status_info[elmt.tag] = elmt.text + tier_status[element.tag].append(status_info) + elif element.tag == "aggregate": + status_info = {} + for elmt in element.getchildren(): + status_info[elmt.tag] = elmt.text + tier_status[element.tag] = status_info + else: + tier_status[element.tag] = element.text + return tier_status + + +def wait_for_detach_tier_to_complete(mnode, volname, timeout=300): + """Waits for the detach tier to complete + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Kwargs: + timeout (int): timeout value to wait for detach tier to complete + + Returns: + True on success, False otherwise + + Examples: + >>> wait_for_detach_tier_to_complete(mnode, "testvol") + """ + + count = 0 + flag = 0 + while (count < timeout): + status_info = get_detach_tier_status(mnode, volname) + if status_info is None: + return False + + status = status_info['aggregate']['statusStr'] + if status == 'completed': + flag = 1 + break + + time.sleep(10) + count = count + 10 + if not flag: + g.log.error("detach tier is not completed") + return False + else: + g.log.info("detach tier is successfully completed") + return True + + +def get_files_from_hot_tier(mnode, volname): + """Lists files from hot tier for the given volume + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + Emptylist: if there are no files in hot tier. + list: list of files in hot tier on success. + + Examples: + >>>get_files_from_hot_tier(mnode, "testvol") + """ + + files = [] + from glustolibs.gluster.volume_libs import get_subvols + subvols = get_subvols(mnode, volname) + for subvol in subvols['hot_tier_subvols']: + info = subvol[0].split(':') + file_list = list_files(info[0], info[1]) + for file in file_list: + if ".glusterfs" not in file: + files.append(file) + + return files + + +def get_files_from_cold_tier(mnode, volname): + """Lists files from cold tier for the given volume + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + Emptylist: if there are no files in cold tier. + list: list of files in cold tier on success. + + Examples: + >>>get_files_from_hot_tier("testvol") + """ + + files = [] + from glustolibs.gluster.volume_libs import get_subvols + subvols = get_subvols(mnode, volname) + for subvol in subvols['cold_tier_subvols']: + info = subvol[0].split(':') + file_list = list_files(info[0], info[1]) + for file in file_list: + if ".glusterfs" not in file: + files.append(file) + + return files + + +def get_tier_promote_frequency(mnode, volname): + """Gets tier promote frequency value for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: promote frequency value on success. + + Examples: + >>>get_tier_promote_frequency("abc.com", "testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.tier-promote-frequency'] + + +def get_tier_demote_frequency(mnode, volname): + """Gets tier demote frequency value for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: demote frequency value on success. + + Examples: + >>>get_tier_demote_frequency("abc.com", "testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.tier-demote-frequency'] + + +def get_tier_mode(mnode, volname): + """Gets tier mode for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: tier mode on success. + + Examples: + >>>get_tier_mode("testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.tier-mode'] + + +def get_tier_max_mb(mnode, volname): + """Gets tier max mb for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: tier max mb on success. + + Examples: + >>>get_tier_max_mb("abc.com", "testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.tier-max-mb'] + + +def get_tier_max_files(mnode, volname): + """Gets tier max files for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: tier max files on success. + + Examples: + >>>get_tier_max_files("abc.com", "testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.tier-max-files'] + + +def get_tier_watermark_high_limit(mnode, volname): + """Gets tier watermark high limit for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: tier watermark high limit on success. + + Examples: + >>>get_tier_watermark_high_limit(mnode, "testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.watermark-hi'] + + +def get_tier_watermark_low_limit(mnode, volname): + """Gets tier watermark low limit for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: tier watermark low limit on success. + + Examples: + >>>get_tier_watermark_low_limit("abc.com", "testvol") + """ + + from glustolibs.gluster.volume_ops import get_volume_options + vol_options = get_volume_options(mnode, volname) + if vol_options is None: + g.log.error("Failed to get volume options") + return None + + return vol_options['cluster.watermark-low'] + + +def set_tier_promote_frequency(mnode, volname, value): + """Sets tier promote frequency value for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): promote frequency value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_promote_frequency("abc.com", "testvol", '1000') + """ + + option = {'cluster.tier-promote-frequency': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set promote frequency to %s" + % value) + return False + + return True + + +def set_tier_demote_frequency(mnode, volname, value): + """Sets tier demote frequency value for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): demote frequency value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_demote_frequency("abc.com", "testvol", "500") + """ + + option = {'cluster.tier-demote-frequency': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set demote frequency to %s" + % value) + return False + + return True + + +def set_tier_mode(mnode, volname, value): + """Sets tier mode for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): tier mode value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_mode("abc.com", "testvol", "cache") + """ + + option = {'cluster.tier-mode': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set tier mode to %s" + % value) + return False + + return True + + +def set_tier_max_mb(mnode, volname, value): + """Sets tier max mb for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): tier mode value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_max_mb("abc.com", "testvol", "50") + """ + + option = {'cluster.tier-max-mb': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set tier max mb to %s" + % value) + return False + + return True + + +def set_tier_max_files(mnode, volname, value): + """Sets tier max files for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): tier mode value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_max_files("abc.com", "testvol", "10") + """ + + option = {'cluster.tier-max-files': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set tier max files to %s" + % value) + return False + + return True + + +def set_tier_watermark_high_limit(mnode, volname, value): + """Sets tier watermark high limit for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): tier mode value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_watermark_high_limit("abc.com", "testvol", "95") + """ + + option = {'cluster.watermark-hi': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set tier watermark high limit to %s" + % value) + return False + + return True + + +def set_tier_watermark_low_limit(mnode, volname, value): + """Sets tier watermark low limit for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + value (str): tier mode value + + Returns: + bool: True on success, False Otherwise + + Examples: + >>>set_tier_watermark_low_limit("abc.com", "testvol", "40") + """ + + option = {'cluster.watermark-low': value} + + from glustolibs.gluster.volume_ops import set_volume_options + if not set_volume_options(mnode, volname, + options=option): + g.log.error("Failed to set tier watermark low limit to %s" + % value) + return False + + return True + + +def get_tier_pid(mnode, volname): + """Gets tier pid for given volume. + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + NoneType: None if command execution fails, parse errors. + str: pid of tier process on success. + + Examples: + >>>get_tier_pid("abc.xyz.com", "testvol") + """ + + cmd = ("ps -ef | grep -v grep | grep '/var/log/glusterfs/%s-tier.log' |" + "awk '{print $2}'" % volname) + ret, out, err = g.run(mnode, cmd) + if ret != 0: + g.log.error("Failed to execute 'ps' cmd") + return None + + return out.strip("\n") + + +def is_tier_process_running(mnode, volname): + """Checks whether tier process is running + + Args: + mnode (str): Node on which command has to be executed. + volname (str): volume name + + Returns: + True on success, False otherwise + + Examples: + >>>is_tier_process_running("abc.xyz.com", "testvol") + """ + + pid = get_tier_pid(mnode, volname) + if pid == '': + return False + return True |