X-Git-Url: https://git.novaco.in/?p=p2pool.git;a=blobdiff_plain;f=p2pool%2Futil%2Fdeferral.py;h=aed3adc4508b8229321826626e17e3278b864b2a;hp=0601d3987361939d9f6e1500ce42305090856f9d;hb=d421d7b2a349a934de652af810870c5b5df3223b;hpb=7a1a80d4e91d8d907f766d382e442e97868711ac diff --git a/p2pool/util/deferral.py b/p2pool/util/deferral.py index 0601d39..aed3adc 100644 --- a/p2pool/util/deferral.py +++ b/p2pool/util/deferral.py @@ -8,8 +8,8 @@ from twisted.internet import defer, reactor from twisted.python import failure, log def sleep(t): - d = defer.Deferred() - reactor.callLater(t, d.callback, None) + d = defer.Deferred(canceller=lambda d_: dc.cancel()) + dc = reactor.callLater(t, d.callback, None) return d def run_repeatedly(f, *args, **kwargs):