Commit 8703305a authored by jiangpeng's avatar jiangpeng Committed by vipwzw

p2p/gossip:udpate test

parent ad322388
...@@ -44,6 +44,9 @@ func processMsg(q queue.Queue) { ...@@ -44,6 +44,9 @@ func processMsg(q queue.Queue) {
wcli := wallet.New(cfg) wcli := wallet.New(cfg)
client := q.Client() client := q.Client()
wcli.SetQueueClient(client) wcli.SetQueueClient(client)
defer func(path string) {
_ = os.RemoveAll(path)
}(cfg.GetModuleConfig().Wallet.DbPath)
//导入种子,解锁钱包 //导入种子,解锁钱包
password := "a12345678" password := "a12345678"
seed := "cushion canal bitter result harvest sentence ability time steel basket useful ask depth sorry area course purpose search exile chapter mountain project ranch buffalo" seed := "cushion canal bitter result harvest sentence ability time steel basket useful ask depth sorry area course purpose search exile chapter mountain project ranch buffalo"
......
...@@ -127,7 +127,7 @@ func (n *Node) sendBlock(block *types.P2PBlock, p2pData *types.BroadCastData, pe ...@@ -127,7 +127,7 @@ func (n *Node) sendBlock(block *types.P2PBlock, p2pData *types.BroadCastData, pe
// cache block // cache block
if !totalBlockCache.Contains(blockHash) { if !totalBlockCache.Contains(blockHash) {
totalBlockCache.Add(blockHash, block.Block, ltBlock.Size) totalBlockCache.Add(blockHash, block.Block, int(ltBlock.Size))
} }
p2pData.Value = &types.BroadCastData_LtBlock{LtBlock: ltBlock} p2pData.Value = &types.BroadCastData_LtBlock{LtBlock: ltBlock}
...@@ -355,7 +355,7 @@ func (n *Node) recvLtBlock(ltBlock *types.LightBlock, pid, peerAddr string, pubP ...@@ -355,7 +355,7 @@ func (n *Node) recvLtBlock(ltBlock *types.LightBlock, pid, peerAddr string, pubP
//pub to specified peer //pub to specified peer
pubPeerFunc(query, pid) pubPeerFunc(query, pid)
//需要将不完整的block预存 //需要将不完整的block预存
ltBlockCache.Add(blockHash, block, int64(block.Size())) ltBlockCache.Add(blockHash, block, block.Size())
} }
func (n *Node) recvQueryData(query *types.P2PQueryData, pid, peerAddr string, pubPeerFunc pubFuncType) { func (n *Node) recvQueryData(query *types.P2PQueryData, pid, peerAddr string, pubPeerFunc pubFuncType) {
...@@ -443,7 +443,7 @@ func (n *Node) recvQueryReply(rep *types.P2PBlockTxReply, pid, peerAddr string, ...@@ -443,7 +443,7 @@ func (n *Node) recvQueryReply(rep *types.P2PBlockTxReply, pid, peerAddr string,
//pub to specified peer //pub to specified peer
pubPeerFunc(query, pid) pubPeerFunc(query, pid)
block.Txs = nil block.Txs = nil
ltBlockCache.Add(rep.BlockHash, block, int64(block.Size())) ltBlockCache.Add(rep.BlockHash, block, block.Size())
} }
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment