Skip to content

Commit 8f5f86b

Browse files
committed
Apply suggestions for PR review
1 parent fe9513e commit 8f5f86b

File tree

2 files changed

+28
-9
lines changed

2 files changed

+28
-9
lines changed

cmd/consensus/main.go

Lines changed: 18 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -689,7 +689,24 @@ func main() {
689689
proposals := buffer.NewPendingBlocks()
690690

691691
logger := createLogger(node.Logger, node.RootChainID)
692-
complianceCore, err := compliance.NewCore(logger, node.Metrics.Engine, node.Metrics.Mempool, mainMetrics, node.Metrics.Compliance, node.Tracer, node.Storage.Headers, node.Storage.Payloads, mutableState, proposals, syncCore, hotstuffModules.Validator, hot, hotstuffModules.VoteAggregator, hotstuffModules.TimeoutAggregator, modulecompliance.WithSkipNewProposalsThreshold(node.ComplianceConfig.SkipNewProposalsThreshold))
692+
complianceCore, err := compliance.NewCore(
693+
logger,
694+
node.Metrics.Engine,
695+
node.Metrics.Mempool,
696+
mainMetrics,
697+
node.Metrics.Compliance,
698+
node.Tracer,
699+
node.Storage.Headers,
700+
node.Storage.Payloads,
701+
mutableState,
702+
proposals,
703+
syncCore,
704+
hotstuffModules.Validator,
705+
hot,
706+
hotstuffModules.VoteAggregator,
707+
hotstuffModules.TimeoutAggregator,
708+
modulecompliance.WithSkipNewProposalsThreshold(node.ComplianceConfig.SkipNewProposalsThreshold),
709+
)
693710
if err != nil {
694711
return nil, fmt.Errorf("could not initialize compliance core: %w", err)
695712
}

storage/badger/cleaner.go

Lines changed: 10 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -18,11 +18,11 @@ import (
1818
// to run an internal goroutine which run badger value log garbage collection at a semi-regular interval.
1919
// The Cleaner exists for 2 reasons:
2020
// - Run GC frequently enough that each GC is relatively inexpensive
21-
// - Avoid GC being synchronized across all nodes. Since in the happy path, all nodes have very similar
22-
// database load patterns, without intervention they are likely to schedule GC at the same time, which
21+
// - Avoid GC being synchronized across all nodes. Since in the happy path, all nodes have very similar
22+
// database load patterns, without intervention they are likely to schedule GC at the same time, which
2323
// can cause temporary consensus halts.
2424
type Cleaner struct {
25-
*component.ComponentManager
25+
component.Component
2626
log zerolog.Logger
2727
db *badger.DB
2828
metrics module.CleanerMetrics
@@ -47,14 +47,16 @@ func NewCleaner(log zerolog.Logger, db *badger.DB, metrics module.CleanerMetrics
4747
interval: interval,
4848
}
4949

50-
cmBuilder := component.NewComponentManagerBuilder()
51-
5250
// Disable if passed in 0 as interval
53-
if c.interval > 0 {
54-
cmBuilder.AddWorker(c.gcWorkerRoutine)
51+
if c.interval == 0 {
52+
c.Component = &module.NoopComponent{}
53+
return c
5554
}
5655

57-
c.ComponentManager = cmBuilder.Build()
56+
c.Component = component.NewComponentManagerBuilder().
57+
AddWorker(c.gcWorkerRoutine).
58+
Build()
59+
5860
return c
5961
}
6062

0 commit comments

Comments
 (0)