Show More
@@ -135,7 +135,8 b' class ConnectionManager(object):' | |||||
135 | del self._connmap[connection] |
|
135 | del self._connmap[connection] | |
136 | del self._readymap[connection] |
|
136 | del self._readymap[connection] | |
137 | self._hostmap[host].remove(connection) |
|
137 | self._hostmap[host].remove(connection) | |
138 |
if not self._hostmap[host]: |
|
138 | if not self._hostmap[host]: | |
|
139 | del self._hostmap[host] | |||
139 | finally: |
|
140 | finally: | |
140 | self._lock.release() |
|
141 | self._lock.release() | |
141 |
|
142 | |||
@@ -621,7 +622,8 b' def continuity(url):' | |||||
621 | f = fo.readline() |
|
622 | f = fo.readline() | |
622 | if f: |
|
623 | if f: | |
623 | foo = foo + f |
|
624 | foo = foo + f | |
624 |
else: |
|
625 | else: | |
|
626 | break | |||
625 | fo.close() |
|
627 | fo.close() | |
626 | m = md5(foo) |
|
628 | m = md5(foo) | |
627 | print(format % ('keepalive readline', m.hexdigest())) |
|
629 | print(format % ('keepalive readline', m.hexdigest())) |
@@ -60,7 +60,8 b' def bdiff(a, b):' | |||||
60 |
|
60 | |||
61 | bin = [] |
|
61 | bin = [] | |
62 | p = [0] |
|
62 | p = [0] | |
63 | for i in a: p.append(p[-1] + len(i)) |
|
63 | for i in a: | |
|
64 | p.append(p[-1] + len(i)) | |||
64 |
|
65 | |||
65 | d = difflib.SequenceMatcher(None, a, b).get_matching_blocks() |
|
66 | d = difflib.SequenceMatcher(None, a, b).get_matching_blocks() | |
66 | d = _normalizeblocks(a, b, d) |
|
67 | d = _normalizeblocks(a, b, d) |
@@ -75,7 +75,8 b' def patches(a, bins):' | |||||
75 | # copy all the patches into our segment so we can memmove from them |
|
75 | # copy all the patches into our segment so we can memmove from them | |
76 | pos = b2 + bl |
|
76 | pos = b2 + bl | |
77 | m.seek(pos) |
|
77 | m.seek(pos) | |
78 |
for p in bins: |
|
78 | for p in bins: | |
|
79 | m.write(p) | |||
79 |
|
80 | |||
80 | for plen in plens: |
|
81 | for plen in plens: | |
81 | # if our list gets too long, execute it |
|
82 | # if our list gets too long, execute it |
@@ -127,7 +127,8 b' class sshserver(wireproto.abstractserver' | |||||
127 | r = impl() |
|
127 | r = impl() | |
128 | if r is not None: |
|
128 | if r is not None: | |
129 | self.sendresponse(r) |
|
129 | self.sendresponse(r) | |
130 |
else: |
|
130 | else: | |
|
131 | self.sendresponse("") | |||
131 | return cmd != '' |
|
132 | return cmd != '' | |
132 |
|
133 | |||
133 | def _client(self): |
|
134 | def _client(self): |
@@ -1605,8 +1605,10 b' def mktempcopy(name, emptyok=False, crea' | |||||
1605 | ifp.close() |
|
1605 | ifp.close() | |
1606 | ofp.close() |
|
1606 | ofp.close() | |
1607 | except: # re-raises |
|
1607 | except: # re-raises | |
1608 |
try: |
|
1608 | try: | |
1609 | except OSError: pass |
|
1609 | os.unlink(temp) | |
|
1610 | except OSError: | |||
|
1611 | pass | |||
1610 | raise |
|
1612 | raise | |
1611 | return temp |
|
1613 | return temp | |
1612 |
|
1614 |
General Comments 0
You need to be logged in to leave comments.
Login now