1 files changed, 102 insertions, 0 deletions
diff --git a/buildbot/buildbot/util.py b/buildbot/buildbot/util.py
new file mode 100644
index 0000000..071cf5f
--- /dev/null
+++ b/buildbot/buildbot/util.py
@@ -0,0 +1,102 @@
+# -*- test-case-name: buildbot.test.test_util -*-
+
+from twisted.internet.defer import Deferred
+from twisted.spread import pb
+import time, re
+
+def naturalSort(l):
+    """Returns a sorted copy of l, so that numbers in strings are sorted in the
+    proper order.
+
+    e.g. ['foo10', 'foo1', 'foo2'] will be sorted as ['foo1', 'foo2', 'foo10']
+    instead of the default ['foo1', 'foo10', 'foo2']"""
+    l = l[:]
+    def try_int(s):
+        try:
+            return int(s)
+        except:
+            return s
+    def key_func(item):
+        return [try_int(s) for s in re.split('(\d+)', item)]
+    l.sort(key=key_func)
+    return l
+
+def now():
+    #return int(time.time())
+    return time.time()
+
+def earlier(old, new):
+    # minimum of two things, but "None" counts as +infinity
+    if old:
+        if new < old:
+            return new
+        return old
+    return new
+
+def later(old, new):
+    # maximum of two things, but "None" counts as -infinity
+    if old:
+        if new > old:
+            return new
+        return old
+    return new
+
+def formatInterval(eta):
+    eta_parts = []
+    if eta > 3600:
+        eta_parts.append("%d hrs" % (eta / 3600))
+        eta %= 3600
+    if eta > 60:
+        eta_parts.append("%d mins" % (eta / 60))
+        eta %= 60
+    eta_parts.append("%d secs" % eta)
+    return ", ".join(eta_parts)
+
+class CancelableDeferred(Deferred):
+    """I am a version of Deferred that can be canceled by calling my
+    .cancel() method. After being canceled, no callbacks or errbacks will be
+    executed.
+    """
+    def __init__(self):
+        Deferred.__init__(self)
+        self.canceled = 0
+    def cancel(self):
+        self.canceled = 1
+    def _runCallbacks(self):
+        if self.canceled:
+            self.callbacks = []
+            return
+        Deferred._runCallbacks(self)
+
+def ignoreStaleRefs(failure):
+    """d.addErrback(util.ignoreStaleRefs)"""
+    r = failure.trap(pb.DeadReferenceError, pb.PBConnectionLost)
+    return None
+
+class _None:
+    pass
+
+class ComparableMixin:
+    """Specify a list of attributes that are 'important'. These will be used
+    for all comparison operations."""
+
+    compare_attrs = []
+
+    def __hash__(self):
+        alist = [self.__class__] + \
+                [getattr(self, name, _None) for name in self.compare_attrs]
+        return hash(tuple(alist))
+
+    def __cmp__(self, them):
+        result = cmp(type(self), type(them))
+        if result:
+            return result
+
+        result = cmp(self.__class__, them.__class__)
+        if result:
+            return result
+
+        assert self.compare_attrs == them.compare_attrs
+        self_list= [getattr(self, name, _None) for name in self.compare_attrs]
+        them_list= [getattr(them, name, _None) for name in self.compare_attrs]
+        return cmp(self_list, them_list)