temp relay

elastos · Jan 15, 2025 · 0a766f4 · 0a766f4
1 parent a516cfc
commit 0a766f4
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 0 deletions.
diff --git a/mempool/blockpool.go b/mempool/blockpool.go
@@ -85,6 +85,10 @@ func (bm *BlockPool) AppendDposBlock(dposBlock *types.DposBlock) (bool, bool, er
 	return bm.appendBlockAndConfirm(dposBlock)
 }
 
+func (bm *BlockPool) RelayBlock(block *types.Block) {
+	events.Notify(events.ETBlockConfirmAccepted, block)
+}
+
 func (bm *BlockPool) appendBlock(dposBlock *types.DposBlock) (bool, bool, error) {
 	// add block
 	block := dposBlock.Block

diff --git a/pow/service.go b/pow/service.go
@@ -448,6 +448,15 @@ func (pow *Service) SubmitAuxBlock(hash *common.Uint256, auxPow *auxpow.AuxPow)
 func (pow *Service) DiscreteMining(n uint32) ([]*common.Uint256, error) {
 	pow.mutex.Lock()
 
+	// temp relay last block
+	block, err := pow.chain.GetBlockByHeight(pow.chain.GetBestChain().Height)
+	if err != nil {
+		return nil, err
+	}
+	pow.blkMemPool.RelayBlock(block)
+	log.Info("### [DiscreteMining] relay last block:", block.Hash().String())
+	time.Sleep(time.Second * 2)
+
 	if pow.started || pow.discreteMining {
 		pow.mutex.Unlock()
 		return nil, errors.New("node is mining")