Skip to content

P
plugin
Commit 93acdf5c authored by yukang's avatar yukang Committed by vipwzw
Browse files
Options

Format code for ci

parent 3061ce77
Hide whitespace changes
Inline Side-by-side
Showing with 7 additions and 7 deletions
plugin/consensus/para/para.go
View file @ 93acdf5c
...@@ -154,12 +154,12 @@ func New(cfg *types.Consensus, sub []byte) queue.Module { ...@@ -154,12 +154,12 @@ func New(cfg *types.Consensus, sub []byte) queue.Module {
} }
para := &client{ para := &client{
BaseClient: c, BaseClient: c,
grpcClient: grpcCli, grpcClient: grpcCli,
authAccount: subcfg.AuthAccount, authAccount: subcfg.AuthAccount,
privateKey: priKey, privateKey: priKey,
subCfg: &subcfg, subCfg: &subcfg,
quitCreate: make(chan struct{}), quitCreate: make(chan struct{}),
} }
waitBlocks := int32(2) //最小是2 waitBlocks := int32(2) //最小是2
......
plugin/consensus/para/parasync.go
View file @ 93acdf5c
...@@ -105,7 +105,7 @@ func (client *client) batchSyncBlocks() { ...@@ -105,7 +105,7 @@ func (client *client) batchSyncBlocks() {
client.setBlockSyncState(BlockSyncStateSyncing) client.setBlockSyncState(BlockSyncStateSyncing)
plog.Info("Para sync - syncing") plog.Info("Para sync - syncing")
errCount := int32(0) errCount := int32(0)
for { for {
//获取同步状态,在需要同步的情况下执行同步 //获取同步状态,在需要同步的情况下执行同步
curSyncCaughtState, err := client.syncBlocksIfNeed() curSyncCaughtState, err := client.syncBlocksIfNeed()
......
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