Skip to content

P
plugin
Commit 5cd041d5 authored by mdj33's avatar mdj33 Committed by vipwzw
Browse files
Options

add chan buff

parent c523c1bf
Hide whitespace changes
Inline Side-by-side
Showing with 2 additions and 2 deletions
plugin/consensus/para/para.go
View file @ 5cd041d5
...@@ -184,7 +184,7 @@ func New(cfg *types.Consensus, sub []byte) queue.Module { ...@@ -184,7 +184,7 @@ func New(cfg *types.Consensus, sub []byte) queue.Module {
para.blockSyncClient = &BlockSyncClient{ para.blockSyncClient = &BlockSyncClient{
paraClient: para, paraClient: para,
notifyChan: make(chan bool), notifyChan: make(chan bool, 1),
quitChan: make(chan struct{}), quitChan: make(chan struct{}),
maxCacheCount: DefaultMaxCacheCount, maxCacheCount: DefaultMaxCacheCount,
maxSyncErrCount: DefaultMaxSyncErrCount, maxSyncErrCount: DefaultMaxSyncErrCount,
......
plugin/consensus/para/parasync.go
View file @ 5cd041d5
...@@ -104,7 +104,7 @@ out: ...@@ -104,7 +104,7 @@ out:
} }
} }
client.printDebugInfo("Para sync - quit block sync goroutine") plog.Info("Para sync - quit block sync goroutine")
client.paraClient.wg.Done() client.paraClient.wg.Done()
} }
......
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