X-Git-Url: https://git.novaco.in/?p=p2pool.git;a=blobdiff_plain;f=p2pool%2Futil%2Fexpiring_dict.py;h=8a3c9eede5635a68b1c565ce4b190063ed1707d9;hp=92fb5b302324cd14796ae4b473602182f0781479;hb=0a3493d6873cfef4fb189d39e64dfbc6e162e2a7;hpb=d421d7b2a349a934de652af810870c5b5df3223b

diff --git a/p2pool/util/expiring_dict.py b/p2pool/util/expiring_dict.py
index 92fb5b3..8a3c9ee 100644
--- a/p2pool/util/expiring_dict.py
+++ b/p2pool/util/expiring_dict.py
@@ -3,7 +3,7 @@ from __future__ import division
 import time
 import weakref
 
-from twisted.internet import task
+from p2pool.util import deferral
 
 class Node(object):
     def __init__(self, contents, prev=None, next=None):
@@ -106,7 +106,7 @@ class ExpiringDict(object):
         self.d = dict() # key -> node, value
         
         self_ref = weakref.ref(self, lambda _: expire_loop.stop() if expire_loop.running else None)
-        self._expire_loop = expire_loop = task.LoopingCall(lambda: self_ref().expire())
+        self._expire_loop = expire_loop = deferral.RobustLoopingCall(lambda: self_ref().expire())
         expire_loop.start(1)
     
     def stop(self):