P2Pool/consensus
P2Pool/consensus
1
1
Fork 0
Code Issues 3 Pull requests Releases Activity

Only store last known tip on p2p peer when it's equal to or higher as current

Browse source
This commit is contained in:
DataHoarder 2023-07-31 19:42:50 +02:00
parent aae149677a
commit d52710eea4
Signed by: DataHoarder
SSH key fingerprint: SHA256:OLTRf6Fl87G52SiR7sWLGNzlJt4WOX+tfI2yxo0z7xk
1 changed files with 11 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

14
p2pool/p2p/client.go
View file

@ -516,7 +516,10 @@ func (c *Client) OnConnection() {
} else {
tipHash := types.HashFromBytes(block.CoinbaseExtra(sidechain.SideTemplateId))
if isChainTipBlockRequest {
c.LastKnownTip.Store(block)
if lastTip := c.LastKnownTip.Load(); lastTip == nil || lastTip.Side.Height <= block.Side.Height {
c.LastKnownTip.Store(block)
}
log.Printf("[P2PClient] Peer %s tip is at id = %s, height = %d, main height = %d", c.AddressPort.String(), tipHash, block.Side.Height, block.Main.Coinbase.GenHeight)
peerHeight := block.Main.Coinbase.GenHeight
ourHeight := c.Owner.MainChain().GetMinerDataTip().Height
@ -606,7 +609,10 @@ func (c *Client) OnConnection() {
c.BroadcastedHashes.Push(tipHash)
c.LastBroadcastTimestamp.Store(uint64(time.Now().Unix()))
c.LastKnownTip.Store(block)
if lastTip := c.LastKnownTip.Load(); lastTip == nil || lastTip.Side.Height <= block.Side.Height {
c.LastKnownTip.Store(block)
}
//log.Printf("[P2PClient] Peer %s broadcast tip is at id = %s, height = %d, main height = %d", c.AddressPort.String(), tipHash, block.Side.Height, block.Main.Coinbase.GenHeight)
if missingBlocks, err := c.Owner.SideChain().PreprocessBlock(block); err != nil {
@ -813,7 +819,9 @@ func (c *Client) OnConnection() {
}
} else {
c.LastKnownTip.Store(tip)
if lastTip := c.LastKnownTip.Load(); lastTip == nil || lastTip.Side.Height <= tip.Side.Height {
c.LastKnownTip.Store(tip)
}
}
case MessageInternal: