# Integration with the oestats build statistics server, see: # # http://opensource.bolloretelecom.eu/projects/oestats # # To make use of this class, add to your local.conf: # # INHERIT += "oestats-client" # OESTATS_SERVER = "some.server.org" # OESTATS_BUILDER = "some_nickname" def oestats_setid(d, val): import bb f = file(bb.data.getVar('TMPDIR', d, True) + '/oestats.id', 'w') f.write(val) def oestats_getid(d): import bb f = file(bb.data.getVar('TMPDIR', d, True) + '/oestats.id', 'r') return f.read() def oestats_send(server, action, vars = {}, files = {}): import httplib # build body output = [] bound = '----------ThIs_Is_tHe_bouNdaRY_$' for key in vars: assert vars[key] output.append('--' + bound) output.append('Content-Disposition: form-data; name="%s"' % key) output.append('') output.append(vars[key]) for key in files: assert files[key] output.append('--' + bound) output.append('Content-Disposition: form-data; name="%s"; filename="%s"' % (key, files[key]['filename'])) output.append('Content-Type: %s' % files[key]['content-type']) output.append('') output.append(files[key]['content']) output.append('--' + bound + '--') output.append('') body = "\r\n".join(output) # build headers headers = { "User-agent": "oestats-client/0.3", "Content-type": "multipart/form-data; boundary=%s" % bound, "Content-length": str(len(body))} # send request conn = httplib.HTTPConnection(server) conn.request("POST", action, body, headers) response = conn.getresponse() data = response.read() conn.close() return data def oestats_start(server, builder, d): import bb import os.path import re # send report id = "" try: data = oestats_send(server, "/builds/", { 'builder': builder, 'revision': bb.data.getVar('METADATA_REVISION', d, True), 'machine': bb.data.getVar('MACHINE', d, True), 'distro': bb.data.getVar('DISTRO', d, True), }) if re.match("^\d+$", data): id=data except: pass # save the build id if id: bb.note("oestats: build %s" % id) else: bb.note("oestats: error starting build, disabling stats") oestats_setid(d, id) def oestats_stop(server, d, failures): import bb # retrieve build id id = oestats_getid(d) if not id: return # send report if failures > 0: status = "Failed" else: status = "Succeeded" try: response = oestats_send(server, "/builds/%s/" % id, { 'status': status, }) except: bb.note("oestats: error stopping build") def oestats_task(server, d, task, status): import bb import glob import time # retrieve build id id = oestats_getid(d) if not id: return # calculate build time try: elapsed = time.time() - float(bb.data.getVar('OESTATS_STAMP', d, True)) except: elapsed = 0 # send the log for failures files = {} if status == 'Failed': logs = glob.glob("%s/log.%s.*" % (bb.data.getVar('T', d, True), task)) if len(logs) > 0: log = logs[0] bb.note("oestats: sending log file : %s" % log) files['log'] = { 'filename': 'log.txt', 'content': file(log).read(), 'content-type': 'text/plain'} # send report try: response = oestats_send(server, "/tasks/", { 'build': id, 'package': bb.data.getVar('PN', d, True), 'version': bb.data.getVar('PV', d, True), 'revision': bb.data.getVar('PR', d, True), 'depends': bb.data.getVar('DEPENDS', d, True), 'task': task, 'status': status, 'time': str(elapsed), }, files) except: bb.note("oestats: error sending task, disabling stats") oestats_setid(d, "") addhandler oestats_eventhandler python oestats_eventhandler () { from bb.event import getName import bb import time if e.data is None or getName(e) == "MsgNote": return NotHandled server = bb.data.getVar('OESTATS_SERVER', e.data, True) builder = bb.data.getVar('OESTATS_BUILDER', e.data, True) if not server or not builder: return NotHandled if getName(e) == 'BuildStarted': oestats_start(server, builder, e.data) elif getName(e) == 'BuildCompleted': oestats_stop(server, e.data, e.getFailures()) elif getName(e) == 'TaskStarted': bb.data.setVar('OESTATS_STAMP', repr(time.time()), e.data) elif getName(e) == 'TaskSucceeded': oestats_task(server, e.data, e.task, 'Succeeded') elif getName(e) == 'TaskFailed': oestats_task(server, e.data, e.task, 'Failed') return NotHandled }