import time
import os
import sys
-if sys.version_info[0] == 2:
- import StringIO
-else:
- from io import StringIO
import re
import shutil
import atexit
import status
import build
import report
-#import messagebus
from lock import lock
from bqueue import B_Queue
def mycmp(r1, r2):
if r1.kind != 'group' or r2.kind != 'group':
raise Exception("non-group requests")
- pri_diff = cmp(r1.priority, r2.priority)
+ pri_diff = util.cmp(r1.priority, r2.priority)
if pri_diff == 0:
- return cmp(r1.time, r2.time)
+ return util.cmp(r1.time, r2.time)
else:
return pri_diff
q.requests.sort(key=util.cmp_to_key(mycmp))
return "FAIL"
status.push("building %s" % b.spec)
-# messagebus.notify(topic="build_srpm.start", spec=b.spec, flags=r.flags, batch=b, request=r)
b.src_rpm = ""
builder_opts = "-nu -nm --nodeps --http --define \'_tld_builder 1\'"
if res:
res = "FAIL"
-# messagebus.notify(topic="build_srpm.finish", spec=b.spec)
return res
def handle_request(r):