1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
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)
|
