Skip to content

P
plugin
Commit 835ba11c authored by pengjun's avatar pengjun
Browse files
Options

fix dpos test case data race

parent 01d20edd
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 1 deletion
plugin/consensus/dpos/node_test.go
View file @ 835ba11c
...@@ -559,6 +559,8 @@ func initEnvDpos1(configName string) (queue.Queue, *blockchain.BlockChain, queue ...@@ -559,6 +559,8 @@ func initEnvDpos1(configName string) (queue.Queue, *blockchain.BlockChain, queue
q.SetConfig(chain33Cfg) q.SetConfig(chain33Cfg)
cfg := chain33Cfg.GetModuleConfig() cfg := chain33Cfg.GetModuleConfig()
sub := chain33Cfg.GetSubConfig() sub := chain33Cfg.GetSubConfig()
rpc.InitCfg(cfg.RPC)
chain := blockchain.New(chain33Cfg) chain := blockchain.New(chain33Cfg)
chain.SetQueueClient(q.Client()) chain.SetQueueClient(q.Client())
...@@ -578,7 +580,6 @@ func initEnvDpos1(configName string) (queue.Queue, *blockchain.BlockChain, queue ...@@ -578,7 +580,6 @@ func initEnvDpos1(configName string) (queue.Queue, *blockchain.BlockChain, queue
network.SetQueueClient(q.Client()) network.SetQueueClient(q.Client())
rpc.InitCfg(cfg.RPC)
gapi := rpc.NewGRpcServer(q.Client(), nil) gapi := rpc.NewGRpcServer(q.Client(), nil)
go gapi.Listen() go gapi.Listen()
......
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