import soltesz
fb = soltesz.dbLoad("findbad")
+fbpcu = soltesz.dbLoad("findbadpcus")
from nodecommon import *
+from policy import Diagnose
import time
+import re
-from config import config
-from optparse import OptionParser
-parser = OptionParser()
-parser.set_defaults(node=None, category=None, nodelist=None)
-parser.add_option("", "--category", dest="category", metavar="category",
- help="List all nodes in the given category")
-parser.add_option("", "--nodelist", dest="nodelist", metavar="nodelist.txt",
- help="A list of nodes to bring out of debug mode.")
-config = config(parser)
-config.parse_args()
-
-def diff_time(timestamp):
- now = time.time()
- if timestamp == None:
- return "unknown"
- diff = now - timestamp
- # return the number of seconds as a difference from current time.
- t_str = ""
- if diff < 60: # sec in min.
- t = diff
- t_str = "%s sec ago" % t
- elif diff < 60*60: # sec in hour
- t = diff // (60)
- t_str = "%s min ago" % int(t)
- elif diff < 60*60*24: # sec in day
- t = diff // (60*60)
- t_str = "%s hours ago" % int(t)
- elif diff < 60*60*24*7: # sec in week
- t = diff // (60*60*24)
- t_str = "%s days ago" % int(t)
- elif diff < 60*60*24*30: # approx sec in month
- t = diff // (60*60*24*7)
- t_str = "%s weeks ago" % int(t)
- elif diff > 60*60*24*30: # approx sec in month
- t = diff // (60*60*24*7*30)
- t_str = "%s months ago" % int(t)
- return t_str
+def daysdown_print_nodeinfo(fbnode, hostname):
+ fbnode['hostname'] = hostname
+ fbnode['daysdown'] = Diagnose.getStrDaysDown(fbnode)
+ fbnode['intdaysdown'] = Diagnose.getDaysDown(fbnode)
+
+ print "%(intdaysdown)5s %(hostname)-44s | %(state)10.10s | %(daysdown)s" % fbnode
+
def fb_print_nodeinfo(fbnode, hostname):
fbnode['hostname'] = hostname
fbnode['checked'] = diff_time(fbnode['checked'])
fbnode['kernel'] = ""
else:
fbnode['kernel'] = fbnode['kernel'].split()[2]
- #fbnode['pcu'] = color_pcu_state(fbnode)
+ fbnode['pcu'] = color_pcu_state(fbnode)
print "%(hostname)-39s | %(checked)11.11s | %(state)10.10s | %(ssh)5.5s | %(pcu)6.6s | %(bootcd)6.6s | %(category)8.8s | %(kernel)s" % fbnode
-if config.nodelist:
- nodelist = config.getListFromFile(config.nodelist)
-else:
- nodelist = fb['nodes'].keys()
-
-
-for node in nodelist:
- config.node = node
+def verify(constraints, data):
+ """
+ constraints is a list of key, value pairs.
+ # [ {... : ...}==AND , ... , ... , ] == OR
+ """
+ con_or_true = False
+ for con in constraints:
+ #print "con: %s" % con
+ if len(con.keys()) == 0:
+ con_and_true = False
+ else:
+ con_and_true = True
+
+ for key in con.keys():
+ #print "looking at key: %s" % key
+ if key in data:
+ value_re = re.compile(con[key])
+ con_and_true = con_and_true & (value_re.search(data[key]) is not None)
+ elif key not in data:
+ print "missing key %s" % key
+ con_and_true = False
+
+ con_or_true = con_or_true | con_and_true
+
+ return con_or_true
+
+def query_to_dict(query):
+
+ ad = []
+
+ or_queries = query.split('||')
+ for or_query in or_queries:
+ and_queries = or_query.split('&&')
+
+ d = {}
+
+ for and_query in and_queries:
+ (key, value) = and_query.split('=')
+ d[key] = value
+
+ ad.append(d)
+
+ return ad
+
+def _pcu_in(fbdata):
+ if 'plcnode' in fbdata:
+ if 'pcu_ids' in fbdata['plcnode']:
+ if len(fbdata['plcnode']['pcu_ids']) > 0:
+ return True
+ return False
+
+def pcu_select(str_query):
+ pcunames = []
+ if str_query is None: return pcunames
+
+ #print str_query
+ dict_query = query_to_dict(str_query)
+ #print dict_query
+
+ for node in fb['nodes'].keys():
+
+ fb_nodeinfo = fb['nodes'][node]['values']
+ if _pcu_in(fb_nodeinfo):
+ pcuinfo = fbpcu['nodes']['id_%s' % fb_nodeinfo['plcnode']['pcu_ids'][0]]['values']
+ if verify(dict_query, pcuinfo):
+ pcunames.append(node)
+
+ return pcunames
+
+def node_select(str_query):
+ hostnames = []
+ if str_query is None: return hostnames
+
+ #print str_query
+ dict_query = query_to_dict(str_query)
+ #print dict_query
+
+ for node in fb['nodes'].keys():
+
+ fb_nodeinfo = fb['nodes'][node]['values']
+
+ if verify(dict_query, fb_nodeinfo):
+ #print node #fb_nodeinfo
+ hostnames.append(node)
+ else:
+ #print "NO MATCH", node
+ pass
+
+ return hostnames
+
+
+def main():
+ from config import config
+ from optparse import OptionParser
+ parser = OptionParser()
+ parser.set_defaults(node=None, select=None, pcuselect=None, nodelist=None, daysdown=None)
+ parser.add_option("", "--daysdown", dest="daysdown", action="store_true",
+ help="List the node state and days down...")
+ parser.add_option("", "--select", dest="select", metavar="key=value",
+ help="List all nodes with the given key=value pattern")
+ parser.add_option("", "--pcuselect", dest="pcuselect", metavar="key=value",
+ help="List all nodes with the given key=value pattern")
+ parser.add_option("", "--nodelist", dest="nodelist", metavar="nodelist.txt",
+ help="A list of nodes to bring out of debug mode.")
+ config = config(parser)
+ config.parse_args()
+
+ if config.nodelist:
+ nodelist = config.getListFromFile(config.nodelist)
+ elif config.select is not None:
+ nodelist = node_select(config.select)
+ elif config.pcuselect is not None:
+ nodelist = pcu_select(config.pcuselect)
+ else:
+ nodelist = fb['nodes'].keys()
- if node not in fb['nodes']:
- continue
+ for node in nodelist:
+ config.node = node
- fb_nodeinfo = fb['nodes'][node]['values']
+ if node not in fb['nodes']:
+ continue
- if config.category and \
- 'state' in fb_nodeinfo and \
- config.category == fb_nodeinfo['state']:
+ fb_nodeinfo = fb['nodes'][node]['values']
- fb_print_nodeinfo(fb_nodeinfo, node)
- elif 'state' in fb_nodeinfo:
- fb_print_nodeinfo(fb_nodeinfo, node)
- else:
- pass
+ if config.daysdown:
+ daysdown_print_nodeinfo(fb_nodeinfo, node)
+ else:
+ if config.select:
+ fb_print_nodeinfo(fb_nodeinfo, node)
+ elif not config.select and 'state' in fb_nodeinfo:
+ fb_print_nodeinfo(fb_nodeinfo, node)
+ else:
+ pass
-
-
+if __name__ == "__main__":
+ main()