def stop(self): self._q.put((self._stop,))
def _stop(self): self._acct.stop()
- def is_running(self): self._acct.is_running()
+ def is_running(self):
+ status = self._acct.is_running()
+ if not status: logger.verbose("Worker(%s): is not running" % self.name)
+ return status
def _destroy(self, curr_class):
self._acct = None
logger.log('%s: stopping' % self.name)
vserver.VServer.stop(self)
- def is_running(self): vserver.VServer.is_running(self)
+ def is_running(self):
+ return vserver.VServer.is_running(self)
def set_resources(self):
disk_max = self.rspec['disk_max']