Skip to content

P
plugin
Commit 1c3182c2 authored by 袁兴强's avatar 袁兴强 Committed by vipwzw
Browse files
Options

fix_mempool.para_exit_bug

parent d4cffcdd
Hide whitespace changes
Inline Side-by-side
Showing with 1 addition and 0 deletions
plugin/mempool/para/base.go
View file @ 1c3182c2
...@@ -45,6 +45,7 @@ func (mem *Mempool) SetQueueClient(client queue.Client) { ...@@ -45,6 +45,7 @@ func (mem *Mempool) SetQueueClient(client queue.Client) {
mem.client.Sub(mem.key) mem.client.Sub(mem.key)
mem.wg.Add(1) mem.wg.Add(1)
go func() { go func() {
defer mem.wg.Done()
for msg := range client.Recv() { for msg := range client.Recv() {
switch msg.Ty { switch msg.Ty {
case types.EventTx: case types.EventTx:
......
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