X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fmain.py;h=4073f7f6b4ffcb816b660654996019f044ae6239;hb=6f1a456b21db79b06cd6d3edd1904dd3c597b981;hp=29522dcbacebe931ea94718d974009becd1477d0;hpb=3116643b895d67e0c6744fe545a5c4c69f7d8207;p=p2pool.git

diff --git a/p2pool/main.py b/p2pool/main.py
index 29522dc..4073f7f 100644
--- a/p2pool/main.py
+++ b/p2pool/main.py
@@ -391,6 +391,7 @@ def main(args, net, datadir_path, merged_urls, worker_endpoint):
             for peer in p2p_node.peers.itervalues():
                 peer.send_bestblock(header=header)
         
+        @defer.inlineCallbacks
         def broadcast_share(share_hash):
             shares = []
             for share in tracker.get_chain(share_hash, min(5, tracker.get_height(share_hash))):
@@ -399,8 +400,8 @@ def main(args, net, datadir_path, merged_urls, worker_endpoint):
                 shared_share_hashes.add(share.hash)
                 shares.append(share)
             
-            for peer in p2p_node.peers.itervalues():
-                peer.sendShares([share for share in shares if share.peer is not peer])
+            for peer in list(p2p_node.peers.itervalues()):
+                yield peer.sendShares([share for share in shares if share.peer is not peer])
         
         # send share when the chain changes to their chain
         best_share_var.changed.watch(broadcast_share)