1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
|
// Copyright 2018 The dexon-consensus Authors
// This file is part of the dexon-consensus library.
//
// The dexon-consensus library is free software: you can redistribute it
// and/or modify it under the terms of the GNU Lesser General Public License as
// published by the Free Software Foundation, either version 3 of the License,
// or (at your option) any later version.
//
// The dexon-consensus library is distributed in the hope that it will be
// useful, but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU Lesser
// General Public License for more details.
//
// You should have received a copy of the GNU Lesser General Public License
// along with the dexon-consensus library. If not, see
// <http://www.gnu.org/licenses/>.
package dex
import (
"sync"
coreCommon "github.com/dexon-foundation/dexon-consensus/common"
coreBlockdb "github.com/dexon-foundation/dexon-consensus/core/blockdb"
coreTypes "github.com/dexon-foundation/dexon-consensus/core/types"
)
type voteKey struct {
ProposerID coreTypes.NodeID
Type coreTypes.VoteType
BlockHash coreCommon.Hash
Period uint64
Position coreTypes.Position
}
func voteToKey(vote *coreTypes.Vote) voteKey {
return voteKey{
ProposerID: vote.ProposerID,
Type: vote.Type,
BlockHash: vote.BlockHash,
Period: vote.Period,
Position: vote.Position,
}
}
type cache struct {
lock sync.RWMutex
blockCache map[coreCommon.Hash]*coreTypes.Block
voteCache map[coreTypes.Position]map[voteKey]*coreTypes.Vote
votePosition []coreTypes.Position
db coreBlockdb.BlockDatabase
voteSize int
size int
}
func newCache(size int, db coreBlockdb.BlockDatabase) *cache {
return &cache{
blockCache: make(map[coreCommon.Hash]*coreTypes.Block),
voteCache: make(map[coreTypes.Position]map[voteKey]*coreTypes.Vote),
db: db,
size: size,
}
}
func (c *cache) addVote(vote *coreTypes.Vote) {
c.lock.Lock()
defer c.lock.Unlock()
if c.voteSize >= c.size {
pos := c.votePosition[0]
c.voteSize -= len(c.voteCache[pos])
delete(c.voteCache, pos)
}
if _, exist := c.voteCache[vote.Position]; !exist {
c.votePosition = append(c.votePosition, vote.Position)
c.voteCache[vote.Position] = make(map[voteKey]*coreTypes.Vote)
}
key := voteToKey(vote)
if _, exist := c.voteCache[vote.Position][key]; exist {
return
}
c.voteCache[vote.Position][key] = vote
c.voteSize++
}
func (c *cache) votes(pos coreTypes.Position) []*coreTypes.Vote {
c.lock.RLock()
defer c.lock.RUnlock()
votes := make([]*coreTypes.Vote, 0, len(c.voteCache[pos]))
for _, vote := range c.voteCache[pos] {
votes = append(votes, vote)
}
return votes
}
func (c *cache) addBlock(block *coreTypes.Block) {
c.lock.Lock()
defer c.lock.Unlock()
block = block.Clone()
block.Finalization.Height = 0
if len(c.blockCache) >= c.size {
// Randomly delete one entry.
for k := range c.blockCache {
delete(c.blockCache, k)
break
}
}
c.blockCache[block.Hash] = block
}
func (c *cache) blocks(hashes coreCommon.Hashes) []*coreTypes.Block {
c.lock.RLock()
defer c.lock.RUnlock()
cacheBlocks := make([]*coreTypes.Block, 0, len(hashes))
for _, hash := range hashes {
if block, exist := c.blockCache[hash]; exist {
cacheBlocks = append(cacheBlocks, block)
} else {
block, err := c.db.Get(hash)
if err != nil {
continue
}
// Blocks request from the cache do not need the finalization info.
block.Finalization = coreTypes.FinalizationResult{}
cacheBlocks = append(cacheBlocks, &block)
}
}
return cacheBlocks
}
|
