parent
4ad6401449
commit
585b56cd2b
|
@ -109,7 +109,7 @@ class RandomTrackingDict(object):
|
||||||
with self.lock:
|
with self.lock:
|
||||||
# reset if we've requested all
|
# reset if we've requested all
|
||||||
# and if last object received too long time ago
|
# and if last object received too long time ago
|
||||||
if self.pendingLen == self.len and self.lastObject + self.pendingTimeout > time():
|
if self.pendingLen == self.len and self.lastObject + self.pendingTimeout < time():
|
||||||
self.pendingLen = 0
|
self.pendingLen = 0
|
||||||
self.setLastObject()
|
self.setLastObject()
|
||||||
available = self.len - self.pendingLen
|
available = self.len - self.pendingLen
|
||||||
|
|
Reference in New Issue
Block a user