command=['ps','-o','pid,command'] + [ pid for pid in pids.split("\n") if pid]
self.run_ssh(box,command,"Active build processes on %s (%s)"%(box,uptime),True)
+ # this one is more accurate as it locates processes in the vservers as well
+ # but it's so sloooowww
+ def handle_build_box_deep (self,box):
+ if not self.options.probe:
+ self.reboot(box)
+ else:
+ command=['uptime']
+ uptime=self.backquote_ssh(box,command,True).strip()
+
+ command=['vps','-e']
+ if self.options.dry_run:
+ self.run_ssh(box,command,None)
+ else:
+ # simulate grep vbuild
+ vps_lines=[ line for line in self.backquote_ssh(box,command,True).split("\n")
+ if line.find('vbuild') >= 0]
+ pids=[ line.split()[0] for line in vps_lines ]
+ if not pids:
+ self.header ('No build process on %s (%s)'%(box,uptime))
+ else:
+ command=['vps','-o','pid,command'] + pids
+ self.run_ssh(box,command,"Active build processes on %s (%s)"%(box,uptime),True)
+
+
vplc_matcher = re.compile(".*(vplc[0-9]+$)")
def vplcname (self, vservername):
match = self.vplc_matcher.match(vservername)
elif box in self.testmaster_boxes:
if type=='testmaster': self.handle_testmaster_box(self.fqdn(box))
elif type=="build":
- self.handle_build_box(self.fqdn(box))
+ if self.options.deep:
+ self.handle_build_box_deep(self.fqdn(box))
+ else:
+ self.handle_build_box(self.fqdn(box))
def handle_disk (self,box):
box=self.fqdn(box)
help="Acts on build and test boxes")
parser.add_option ("-b","--build",action="store_true",dest="build_only",default=False,
help="Acts on build boxes only")
+ parser.add_option ("-e","--deep",action="store_true", dest="deep", default=False,
+ help="on build boxes, shows vbuild processes in vservers as well; signif. slower")
parser.add_option ("-q","--qemu",action="store_true",dest="qemu_only",default=False,
help="Only acts on the qemu boxes")
parser.add_option ("-t","--trackers",action="store_true",dest="trackers_only",default=False,