X-Git-Url: https://git.novaco.in/?a=blobdiff_plain;f=p2pool%2Fnode.py;h=1c988667fcbe770ac75ad6c2d6bb4169a086d0d1;hb=19bf4eac02eb3e12ca168ebc87f61f561e848d90;hp=44ca05488ecb92ea6de93973f0d860024f11db27;hpb=0e325a45dc1c1d40eabcf066c3b52a381ece569a;p=p2pool.git

diff --git a/p2pool/node.py b/p2pool/node.py
index 44ca054..1c98866 100644
--- a/p2pool/node.py
+++ b/p2pool/node.py
@@ -76,7 +76,6 @@ class P2PNode(p2p.Node):
             raise p2p.PeerMisbehavingError('received block header fails PoW test')
         self.node.handle_header(header)
     
-    @defer.inlineCallbacks
     def broadcast_share(self, share_hash):
         shares = []
         for share in self.node.tracker.get_chain(share_hash, min(5, self.node.tracker.get_height(share_hash))):
@@ -85,8 +84,8 @@ class P2PNode(p2p.Node):
             self.shared_share_hashes.add(share.hash)
             shares.append(share)
         
-        for peer in list(self.peers.itervalues()):
-            yield peer.sendShares([share for share in shares if share.peer_addr != peer.addr], self.node.tracker, self.node.known_txs_var.value, include_txs_with=[share_hash])
+        for peer in self.peers.itervalues():
+            peer.sendShares([share for share in shares if share.peer_addr != peer.addr], self.node.tracker, self.node.known_txs_var.value, include_txs_with=[share_hash])
     
     def start(self):
         p2p.Node.start(self)