Broadcast current best block header over P2P network

diff --git a/p2pool/main.py b/p2pool/main.py
index 7f2c76f..1106645 100644 (file)
--- a/p2pool/main.py
+++ b/p2pool/main.py
@@ -382,6 +382,17 @@ def main(args, net, datadir_path, merged_urls, worker_endpoint):
                 f.write(json.dumps(p2p_node.addr_store.items()))
         task.LoopingCall(save_addrs).start(60)
         
+        best_block = variable.Variable(None)
+        @pre_current_work.changed.watch
+        def _(work):
+            best_block.set(work['previous_block'])
+        @best_block.changed.watch
+        @defer.inlineCallbacks
+        def _(block_hash):
+            header = yield factory.conn.value.get_block_header(block_hash)
+            for peer in p2p_node.peers.itervalues():
+                peer.send_bestblock(header=header)
+        
         def broadcast_share(share_hash):
             shares = []
             for share in tracker.get_chain(share_hash, min(5, tracker.get_height(share_hash))):

diff --git a/p2pool/p2p.py b/p2pool/p2p.py
index 15889e7..4170414 100644 (file)
--- a/p2pool/p2p.py
+++ b/p2pool/p2p.py
@@ -239,6 +239,11 @@ class Protocol(p2protocol.Protocol):
     def handle_sharereply(self, id, result, shares):
         self.node.handle_share_reply(id, result, shares, self)
     
+    message_bestblock = pack.ComposedType([
+        ('header', bitcoin_data.block_header_type),
+    ])
+    def handle_bestblock(self, header):
+        pass
     
     def connectionLost(self, reason):
         if self.connected2: