diff options
author | Mission Liao <mission.liao@dexon.org> | 2019-03-21 14:27:41 +0800 |
---|---|---|
committer | Mission Liao <mission.liao@dexon.org> | 2019-03-21 14:27:41 +0800 |
commit | b5950047c700a337c8b074481e6b9638aa33692f (patch) | |
tree | d44d905a864e4110e9dfd3d9a9a8c48fadd089f3 | |
parent | 89200f8e67d5ada9cd919fb62926f9264788e5ea (diff) | |
download | dexon-consensus-b5950047c700a337c8b074481e6b9638aa33692f.tar.gz dexon-consensus-b5950047c700a337c8b074481e6b9638aa33692f.tar.zst dexon-consensus-b5950047c700a337c8b074481e6b9638aa33692f.zip |
Tmp
-rw-r--r-- | core/consensus.go | 32 | ||||
-rw-r--r-- | core/dkg-tsig-protocol.go | 4 |
2 files changed, 18 insertions, 18 deletions
diff --git a/core/consensus.go b/core/consensus.go index 0b46ea8..227959a 100644 --- a/core/consensus.go +++ b/core/consensus.go @@ -639,22 +639,22 @@ func newConsensusForRound( tsigVerifierCache, signer, logger) // Construct Consensus instance. con := &Consensus{ - ID: ID, - app: appModule, - debugApp: debugApp, - gov: gov, - db: db, - network: network, - baConfirmedBlock: make(map[common.Hash]chan<- *types.Block), - dkgReady: sync.NewCond(&sync.Mutex{}), - cfgModule: cfgModule, - bcModule: bcModule, - dMoment: dMoment, - nodeSetCache: nodeSetCache, - tsigVerifierCache: tsigVerifierCache, - signer: signer, - event: common.NewEvent(), - logger: logger, + ID: ID, + app: appModule, + debugApp: debugApp, + gov: gov, + db: db, + network: network, + baConfirmedBlock: make(map[common.Hash]chan<- *types.Block), + dkgReady: sync.NewCond(&sync.Mutex{}), + cfgModule: cfgModule, + bcModule: bcModule, + dMoment: dMoment, + nodeSetCache: nodeSetCache, + tsigVerifierCache: tsigVerifierCache, + signer: signer, + event: common.NewEvent(), + logger: logger, resetDeliveryGuardTicker: make(chan struct{}), msgChan: make(chan interface{}, 1024), processBlockChan: make(chan *types.Block, 1024), diff --git a/core/dkg-tsig-protocol.go b/core/dkg-tsig-protocol.go index 067bc13..c85f545 100644 --- a/core/dkg-tsig-protocol.go +++ b/core/dkg-tsig-protocol.go @@ -157,8 +157,8 @@ func (d *dkgProtocol) toDKGProtocolInfo() db.DKGProtocolInfo { PrvSharesReceived: d.prvSharesReceived, NodeComplained: d.nodeComplained, AntiComplaintReceived: d.antiComplaintReceived, - Step: uint64(d.step), - Reset: d.reset, + Step: uint64(d.step), + Reset: d.reset, } if d.masterPrivateShare != nil { |