c.close()
self.data = value
self.db.commit()
+ return """Set "%s" to "%s".""" % (self.key, self.data,)
class DurationsConfig:
def __init__(self, db):
"value" : value, })
c.close()
self.db.commit()
+ return """Accepted build duration of %s seconds.""" % (value,)
def get_avg(self):
sum = 0
for line in base64.b64decode(lines).split("\n"):
f.write("%s\n" % line.rstrip("\n"))
f.close()
+ return """Saved file content to %s.""" % (self.filename,)
class Builder:
def __init__(self, config, uuid):
self.state.set("unknown")
# If host was longer than four weels in distcc state we delete it.
- if self.state() == "unknown" and \
+ if self.state() in ("distcc", "unknown",) and \
(time.time() - self.state.time()) > 4*7*24*60*60:
del self.db
shutil.rmtree(self.path)
def set(self, key, value):
- eval("self.%s.set(\"%s\")" % (key, value,))
+ return eval("self.%s.set(\"%s\")" % (key, value,))
def get(self, key):
return eval("self.%s.get()" % (key,))
self.config = config
self.code = "200"
- self.mesg = "OK"
+ self.mesg = ""
def __call__(self, exit=0):
print "Status: %s" % self.code
def set_mesg(self, mesg):
self.mesg = mesg
+
+ def write(self, s):
+ if self.mesg:
+ self.mesg += "\n"
+ self.mesg += "[%s] - %s" % (time.ctime(), s,)
response = Response(config)
key = None
for key in [ "distcc", "duration", "hostname", "jobs", "log", "state", "package", "target", "cpu", "machine" ]:
for value in data.getlist(key):
- builder.set(key, value)
+ ret = builder.set(key, value)
+ if ret:
+ response.write(ret)
elif action == "get":
for key in [ "distcc", ]:
if key == "distcc":