coosld/ceremonyclient
1
0
Fork 0
mirror of https://github.com/QuilibriumNetwork/ceremonyclient.git synced 2026-02-21 10:27:26 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

refined to work across the board

Browse Source
This commit is contained in:
Cassandra Heart 2024-11-26 23:24:05 -06:00
parent 8a26318e1a
commit 28e8331ca1
No known key found for this signature in database
GPG Key ID: 6352152859385958
4 changed files with 13 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
node/consensus/data/consensus_frames.go
View File

@ -251,8 +251,7 @@ func (e *DataClockConsensusEngine) GetAheadPeers(frameNumber uint64) []internal.
if v.timestamp <= config.GetMinimumVersionCutoff().UnixMilli() {
continue
}
if bytes.Compare(v.version, config.GetMinimumVersion()) < 0 ||
v.patchVersion < config.GetMinimumPatchVersion() {
if bytes.Compare(v.version, config.GetMinimumVersion()) < 0 {
continue
}
maxDiff = max(maxDiff, v.maxFrame-frameNumber)

8
node/consensus/data/data_clock_consensus_engine.go
View File

@ -121,7 +121,9 @@ type DataClockConsensusEngine struct {
dependencyMapMx sync.Mutex
stagedTransactions *protobufs.TokenRequests
stagedTransactionsSet map[string]struct{}
stagedTransactionsMx sync.RWMutex
stagedTransactionsMx sync.Mutex
validationFilter map[string]struct{}
validationFilterMx sync.Mutex
peerMapMx sync.RWMutex
peerAnnounceMapMx sync.Mutex
lastKeyBundleAnnouncementFrame uint64
@ -270,8 +272,8 @@ func NewDataClockConsensusEngine(
rateLimit,
time.Minute,
),
requestSyncCh: make(chan struct{}, 1),
stagedTransactionsSet: map[string]struct{}{},
requestSyncCh: make(chan struct{}, 1),
validationFilter: map[string]struct{}{},
}
logger.Info("constructing consensus engine")

3
node/consensus/data/main_data_loop.go
View File

@ -145,6 +145,9 @@ func (e *DataClockConsensusEngine) runLoop() {
case <-e.ctx.Done():
return
case dataFrame := <-dataFrameCh:
e.validationFilterMx.Lock()
e.validationFilter = make(map[string]struct{}, len(e.validationFilter))
e.validationFilterMx.Unlock()
if e.GetFrameProverTries()[0].Contains(e.provingKeyAddress) {
if err = e.publishProof(dataFrame); err != nil {
e.logger.Error("could not publish", zap.Error(err))

7
node/consensus/data/message_validators.go
View File

@ -83,9 +83,10 @@ func (e *DataClockConsensusEngine) validateTxMessage(peerID peer.ID, message *pb
frameNumber,
mint.Signature.PublicKey.KeyValue,
)
e.stagedTransactionsMx.RLock()
_, ok := e.stagedTransactionsSet[id]
e.stagedTransactionsMx.RUnlock()
e.validationFilterMx.Lock()
_, ok := e.validationFilter[id]
e.validationFilter[id] = struct{}{}
e.validationFilterMx.Unlock()
if ok {
e.pubSub.AddPeerScore([]byte(peerID), -1000000)
return p2p.ValidationResultReject