nodecommon.py

   1
   2 import struct
   3 import reboot
   4 esc = struct.pack('i', 27)
   5 RED     = esc + "[1;31m"
   6 GREEN   = esc + "[1;32m"
   7 YELLOW  = esc + "[1;33m"
   8 BLUE    = esc + "[1;34m"
   9 NORMAL  = esc + "[0;39m"
  10
  11 def red(str):
  12         return RED + str + NORMAL
  13
  14 def yellow(str):
  15         return YELLOW + str + NORMAL
  16
  17 def green(str):
  18         return GREEN + str + NORMAL
  19
  20 def blue(str):
  21         return BLUE + str + NORMAL
  22
  23 def get_current_state(fbnode):
  24         if 'state' in fbnode:
  25                 state = fbnode['state']
  26         else:
  27                 state = "none"
  28         l = state.lower()
  29         if l == "debug": l = 'dbg '
  30         return l
  31
  32 def color_pcu_state(fbnode):
  33         import plc
  34
  35         if 'plcnode' in fbnode and 'pcu_ids' in fbnode['plcnode'] and len(fbnode['plcnode']['pcu_ids']) > 0 :
  36                 values = reboot.get_pcu_values(fbnode['plcnode']['pcu_ids'][0])
  37                 if values == None:
  38                         return fbnode['pcu']
  39         else:
  40                 return fbnode['pcu']
  41
  42         if 'reboot' in values:
  43                 rb = values['reboot']
  44                 if rb == 0 or rb == "0":
  45                         return fbnode['pcu'] + "OK  "
  46                         #return green(fbnode['pcu'])
  47                 elif "NetDown" == rb  or "Not_Run" == rb:
  48                         return fbnode['pcu'] + "DOWN"
  49                         #return yellow(fbnode['pcu'])
  50                 else:
  51                         return fbnode['pcu'] + "BAD "
  52                         #return red(fbnode['pcu'])
  53         else:
  54                 #return red(fbnode['pcu'])
  55                 return fbnode['pcu'] + "BAD "
  56
  57 def color_boot_state(l):
  58         if    l == "dbg": return yellow("dbg ")
  59         elif  l == "dbg ": return yellow(l)
  60         elif  l == "down": return red(l)
  61         elif  l == "boot": return green(l)
  62         elif  l == "rins": return blue(l)
  63         else:
  64                 return l
  65
  66 def nodegroup_display(node, fb):
  67         if node['hostname'] in fb['nodes']:
  68                 node['current'] = get_current_state(fb['nodes'][node['hostname']]['values'])
  69         else:
  70                 node['current'] = 'none'
  71
  72         if fb['nodes'][node['hostname']]['values'] == []:
  73                 return ""
  74
  75         s = fb['nodes'][node['hostname']]['values']['kernel'].split()
  76         if len(s) >=3:
  77                 node['kernel'] = s[2]
  78         else:
  79                 node['kernel'] = fb['nodes'][node['hostname']]['values']['kernel']
  80
  81         if '2.6' not in node['kernel']: node['kernel'] = ""
  82         node['boot_state']      = color_boot_state(node['boot_state'])
  83         node['current']         = color_boot_state(node['current'])
  84         #node['boot_state']     = node['boot_state']
  85         #node['current']        = node['current']
  86         node['pcu'] = fb['nodes'][node['hostname']]['values']['pcu']
  87         return "%(hostname)-38s %(boot_state)5s %(current)5s %(pcu)6s %(key)45s %(kernel)s" % node
  88
  89 from model import *
  90 import soltesz
  91
  92 def node_end_record(node):
  93         act_all = soltesz.dbLoad("act_all")
  94         if node not in act_all:
  95                 del act_all
  96                 return False
  97         a = Action(node, act_all[node][0])
  98         a.delField('rt')
  99         a.delField('found_rt_ticket')
 100         a.delField('second-mail-at-oneweek')
 101         a.delField('second-mail-at-twoweeks')
 102         a.delField('first-found')
 103         rec = a.get()
 104         rec['action'] = ["close_rt"]
 105         rec['category'] = "UNKNOWN"
 106         rec['stage'] = "monitor-end-record"
 107         rec['time'] = time.time() - 7*60*60*24
 108         act_all[node].insert(0,rec)
 109         soltesz.dbDump("act_all", act_all)
 110         del act_all
 111         return True