aboutsummaryrefslogtreecommitdiffstats
diff options
context:
space:
mode:
Diffstat
-rw-r--r--vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go7
-rw-r--r--vendor/github.com/dexon-foundation/dexon-consensus/core/crypto/dkg/dkg.go25
-rw-r--r--vendor/vendor.json44
3 files changed, 44 insertions, 32 deletions
diff --git a/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go b/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go
index e657c6449..adaf51d62 100644
--- a/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go
+++ b/vendor/github.com/dexon-foundation/dexon-consensus/core/consensus.go
@@ -57,6 +57,8 @@ var (
"cannot verify block randomness")
)
+type selfAgreementResult types.AgreementResult
+
// consensusBAReceiver implements agreementReceiver.
type consensusBAReceiver struct {
consensus *Consensus
@@ -286,7 +288,8 @@ func (recv *consensusBAReceiver) ConfirmBlock(
IsEmptyBlock: isEmptyBlockConfirmed,
Randomness: block.Randomness,
}
- recv.consensus.baMgr.touchAgreementResult(result)
+ // touchAgreementResult does not support concurrent access.
+ recv.consensus.msgChan <- (*selfAgreementResult)(result)
recv.consensus.logger.Debug("Broadcast AgreementResult",
"result", result)
recv.consensus.network.BroadcastAgreementResult(result)
@@ -1217,6 +1220,8 @@ MessageLoop:
return
}
switch val := msg.(type) {
+ case *selfAgreementResult:
+ con.baMgr.touchAgreementResult((*types.AgreementResult)(val))
case *types.Block:
if ch, exist := func() (chan<- *types.Block, bool) {
con.lock.RLock()
diff --git a/vendor/github.com/dexon-foundation/dexon-consensus/core/crypto/dkg/dkg.go b/vendor/github.com/dexon-foundation/dexon-consensus/core/crypto/dkg/dkg.go
index b89ad100d..ab43f5130 100644
--- a/vendor/github.com/dexon-foundation/dexon-consensus/core/crypto/dkg/dkg.go
+++ b/vendor/github.com/dexon-foundation/dexon-consensus/core/crypto/dkg/dkg.go
@@ -450,11 +450,10 @@ func (prvs *PrivateKeyShares) Share(ID ID) (*PrivateKey, bool) {
// NewEmptyPublicKeyShares creates an empty public key shares.
func NewEmptyPublicKeyShares() *PublicKeyShares {
- cache := &publicKeySharesCache{
- index: make(map[ID]int),
- }
pubShares := &PublicKeyShares{}
- pubShares.cache.Store(cache)
+ pubShares.cache.Store(&publicKeySharesCache{
+ index: make(map[ID]int),
+ })
return pubShares
}
@@ -481,9 +480,9 @@ func (pubs *PublicKeyShares) Share(ID ID) (*PublicKey, error) {
}
// AddShare adds a share.
-func (pubs *PublicKeyShares) AddShare(ID ID, share *PublicKey) error {
+func (pubs *PublicKeyShares) AddShare(shareID ID, share *PublicKey) error {
cache := pubs.cache.Load().(*publicKeySharesCache)
- if idx, exist := cache.index[ID]; exist {
+ if idx, exist := cache.index[shareID]; exist {
if !share.publicKey.IsEqual(&cache.share[idx].publicKey) {
return ErrDuplicatedShare
}
@@ -492,9 +491,17 @@ func (pubs *PublicKeyShares) AddShare(ID ID, share *PublicKey) error {
pubs.lock.Lock()
defer pubs.lock.Unlock()
cache = pubs.cache.Load().(*publicKeySharesCache)
- cache.index[ID] = len(cache.share)
- cache.share = append(cache.share, *share)
- pubs.cache.Store(cache)
+ newCache := &publicKeySharesCache{
+ index: make(map[ID]int, len(cache.index)+1),
+ share: make([]PublicKey, len(cache.share), len(cache.share)+1),
+ }
+ for k, v := range cache.index {
+ newCache.index[k] = v
+ }
+ copy(newCache.share, cache.share)
+ newCache.index[shareID] = len(newCache.share)
+ newCache.share = append(newCache.share, *share)
+ pubs.cache.Store(newCache)
return nil
}
diff --git a/vendor/vendor.json b/vendor/vendor.json
index c83f22117..1b9700655 100644
--- a/vendor/vendor.json
+++ b/vendor/vendor.json
@@ -141,16 +141,16 @@
{
"checksumSHA1": "In6vBHYUsX7DUIGiFN2hQggBgvI=",
"path": "github.com/dexon-foundation/dexon-consensus/common",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
- "checksumSHA1": "IlhmhtgzSWYb1GTPVpYXHUMkSwM=",
+ "checksumSHA1": "RYHOTUhiRTYj3z6lXRP5Z1BHbso=",
"path": "github.com/dexon-foundation/dexon-consensus/core",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
@@ -165,64 +165,64 @@
{
"checksumSHA1": "tQSbYCu5P00lUhKsx3IbBZCuSLY=",
"path": "github.com/dexon-foundation/dexon-consensus/core/crypto",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
- "checksumSHA1": "mayhQ9KxdXeuzyssXiG5yW4ynGU=",
+ "checksumSHA1": "m5lUT04qSHKtFukvxjnFX5Jo2hI=",
"path": "github.com/dexon-foundation/dexon-consensus/core/crypto/dkg",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
"checksumSHA1": "BhLKK8RveoLaeXc9UyUKMwQqchU=",
"path": "github.com/dexon-foundation/dexon-consensus/core/crypto/ecdsa",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
"checksumSHA1": "hj/KetWUHp+1CX+50V0QnCthfWc=",
"path": "github.com/dexon-foundation/dexon-consensus/core/db",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
"checksumSHA1": "DILLD61kp1c3JZnyLZK84mMK9Jw=",
"path": "github.com/dexon-foundation/dexon-consensus/core/syncer",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
"checksumSHA1": "zIgCdN4FJiAuPGMhB+/9YGK/Wgk=",
"path": "github.com/dexon-foundation/dexon-consensus/core/types",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
"checksumSHA1": "lbG7yqVgzo2CV/CQPYjG78xp5jg=",
"path": "github.com/dexon-foundation/dexon-consensus/core/types/dkg",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
{
"checksumSHA1": "YooeNHTYxH05Ky5vnoyZsQR4/08=",
"path": "github.com/dexon-foundation/dexon-consensus/core/utils",
- "revision": "d433231363d622acb26f8fa9b072470c179dbc62",
- "revisionTime": "2019-04-04T14:16:31Z",
+ "revision": "99e3dfee0eb2ffbb4fb0afb8e65664a7c9d91bcd",
+ "revisionTime": "2019-04-06T09:04:11Z",
"version": "single-chain",
"versionExact": "single-chain"
},
generated by cgit v1.2.3 (git 2.25.1) at 2024-11-05 09:09:46 +0800