X-Git-Url: https://git.novaco.in/?p=p2pool.git;a=blobdiff_plain;f=p2pool%2Fnode.py;h=2b25fbe55bf157278fcf204f2b620915f0cacc7e;hp=d73a0f2a9924be0ee8b6b816c1aaf611a30c80da;hb=0a3493d6873cfef4fb189d39e64dfbc6e162e2a7;hpb=d421d7b2a349a934de652af810870c5b5df3223b

diff --git a/p2pool/node.py b/p2pool/node.py
index d73a0f2..2b25fbe 100644
--- a/p2pool/node.py
+++ b/p2pool/node.py
@@ -2,7 +2,7 @@ import random
 import sys
 import time
 
-from twisted.internet import defer, reactor, task
+from twisted.internet import defer, reactor
 from twisted.python import log
 
 from p2pool import data as p2pool_data, p2p
@@ -283,11 +283,11 @@ class Node(object):
                     if tx_hash in self.known_txs_var.value:
                         new_known_txs[tx_hash] = self.known_txs_var.value[tx_hash]
             self.known_txs_var.set(new_known_txs)
-        t = task.LoopingCall(forget_old_txs)
+        t = deferral.RobustLoopingCall(forget_old_txs)
         t.start(10)
         stop_signal.watch(t.stop)
         
-        t = task.LoopingCall(self.clean_tracker)
+        t = deferral.RobustLoopingCall(self.clean_tracker)
         t.start(5)
         stop_signal.watch(t.stop)