- if used >= reboot_thresh:
- # Dump slice state before rebooting
- if verbose:
- print "Saving %s" % datafile
- f = open(datafile, "w")
- pickle.dump((version, slices), f)
- f.close()
-
- # Goodbye, cruel world
- print "%d%% swap consumed, rebooting" % used
- if not debug:
- bwlimit.run("/bin/sync; /sbin/reboot -f")
-
- elif used >= reset_thresh:
- if debug:
- print "Memory used = %s" %(used)
- # Try and find a hog
- slicelist = slices.values()
- slicelist.sort(lambda a, b: b['rss'] - a['rss'])
- for slice in slicelist:
- percent = 100. * slice['rss'] / total_mem
-
- if slice['rss'] < rss_min:
- continue
-
- print "%d%% swap consumed, slice %s is using %s (%d%%) of memory" % \
- (used,
- slice['name'],
- format_bytes(slice['rss'] * 1024, si = False),
- percent)
-
- slice['procs'].sort(lambda a, b: b['rss'] - a['rss'])
-
- table = "%5s %10s %10s %10s %4s %4s %s\n\n" % ("PID", "VIRT", "SZ", "RES", '%CPU', '%MEM', 'COMMAND')
- for proc in slice['procs']:
- table += "%5s %10s %10s %10s %4.1f %4.1f %s\n" % \
- (proc['pid'],
- format_bytes(proc['vsize'] * 1024, si = False),
- format_bytes(proc['sz'] * 1024, si = False),
- format_bytes(proc['rss'] * 1024, si = False),
- proc['pcpu'], proc['pmem'], proc['cmd'])
-
- params = {'hostname': socket.gethostname(),
- 'date': time.asctime(time.gmtime()) + " GMT",
- 'table': table,
- 'slice': slice['name'],
- 'rss': format_bytes(slice['rss'] * 1024, si = False),
- 'sz': format_bytes(slice['sz'] * 1024, si = False),
- 'percent': percent}
-
- # Match slice name against system slice patterns
- is_system_slice = filter(None, [re.match(pattern, slice['name']) for pattern in system_slices])
-
- if is_system_slice:
- # Do not reset system slices, just warn once
- if slice['name'] not in warned:
- warned.append(slice['name'])
- if debug:
- print alarm_subject % params
- print alarm_body % params
- else:
- print "Warning slice " + slice['name']
- slicemail(slice['name'], alarm_subject % params,
- alarm_body % params)
+ if used >= reboot_thresh:
+ # Dump slice state before rebooting
+ if verbose: print "Saving %s" % datafile
+ f = open(datafile, "w")
+ pickle.dump((version, slices), f)
+ f.close()
+
+ # Goodbye, cruel world
+ print "%d%% swap consumed, rebooting" % used
+ if not debug: bwlimit.run("/bin/sync; /sbin/reboot -f")
+
+ elif used >= reset_thresh:
+ if debug: print "Memory used = %s" %(used)
+ # Try and find a hog
+ slicelist = slices.values()
+ slicelist.sort(lambda a, b: b['rss'] - a['rss'])
+ for slice in slicelist:
+ percent = 100. * slice['rss'] / total_mem
+ if slice['rss'] < rss_min: continue
+ print "%d%% swap consumed, slice %s is using %s (%d%%) of memory" % \
+ (used,
+ slice['name'],
+ format_bytes(slice['rss'] * 1024, si = False),
+ percent)
+
+ slice['procs'].sort(lambda a, b: b['rss'] - a['rss'])
+ table = "%5s %10s %10s %10s %4s %4s %s\n\n" % \
+ ("PID", "VIRT", "SZ", "RES", '%CPU', '%MEM', 'COMMAND')
+ for proc in slice['procs']:
+ table += "%5s %10s %10s %10s %4.1f %4.1f %s\n" % \
+ (proc['pid'],
+ format_bytes(proc['vsize'] * 1024, si = False),
+ format_bytes(proc['sz'] * 1024, si = False),
+ format_bytes(proc['rss'] * 1024, si = False),
+ proc['pcpu'],
+ proc['pmem'],
+ proc['cmd'])
+
+ params = {'hostname': socket.gethostname(),
+ 'date': time.asctime(time.gmtime()) + " GMT",
+ 'table': table,
+ 'slice': slice['name'],
+ 'rss': format_bytes(slice['rss'] * 1024, si = False),
+ 'sz': format_bytes(slice['sz'] * 1024, si = False),
+ 'percent': percent}
+
+ # Match slice name against system slice patterns
+ is_system_slice = filter(None,
+ [re.match(pattern, slice['name']) for pattern in system_slices])
+
+ if is_system_slice:
+ # Do not reset system slices, just warn once
+ if slice['name'] not in warned:
+ warned.append(slice['name'])
+ if debug:
+ print alarm_subject % params
+ print alarm_body % params