X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fmain.py;h=8ff9e0f565ef7517c9bb2a2c1f9c2531db189a54;hb=476b3fad23a607766bf7633e20472d4952f8c0d6;hp=ac137fd6f9cef7c3237c33c64c65130fbf2a45f3;hpb=48a6c3a25834847b9d159ff7a25740323cc5f00e;p=p2pool.git

diff --git a/p2pool/main.py b/p2pool/main.py
index ac137fd..8ff9e0f 100644
--- a/p2pool/main.py
+++ b/p2pool/main.py
@@ -264,7 +264,9 @@ def main(args, net, datadir_path, merged_urls, worker_endpoint):
             known_txs_var.set(new_known_txs)
         # forward transactions seen to bitcoind
         @known_txs_var.transitioned.watch
+        @defer.inlineCallbacks
         def _(before, after):
+            yield deferral.sleep(random.expovariate(1/1))
             for tx_hash in set(after) - set(before):
                 factory.conn.value.send_tx(tx=after[tx_hash])