Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Pchain validators repackaging #1284

Merged
merged 35 commits into from
May 18, 2023
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
35 commits
Select commit Hold shift + click to select a range
795a10a
repack pchain validators
abi87 Apr 3, 2023
629ffd8
nit
abi87 Apr 3, 2023
61fd676
Merge branch 'dev' into pchain_proposers_repack
StephenButtolph Apr 4, 2023
e725784
nits
abi87 Apr 5, 2023
0c8bc40
nits
abi87 Apr 5, 2023
7bd3093
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 10, 2023
d91c656
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 11, 2023
97bafa4
minor renaming
abi87 Apr 11, 2023
d9b9452
clock cleanup
abi87 Apr 11, 2023
2248f3c
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 13, 2023
bea7c15
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 17, 2023
816dd86
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 20, 2023
da0d822
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 21, 2023
18e9bb8
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 24, 2023
9a978cc
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 26, 2023
db2e956
Merge branch 'dev' into pchain_proposers_repack
abi87 Apr 26, 2023
bcbe002
Merge branch 'dev' into pchain_proposers_repack
abi87 May 1, 2023
d53f5e9
Merge branch 'dev' into pchain_proposers_repack
abi87 May 2, 2023
fa3ee2b
Merge branch 'dev' into pchain_proposers_repack
abi87 May 3, 2023
4f24a50
Merge branch 'dev' into pchain_proposers_repack
abi87 May 4, 2023
ee25500
nits
abi87 May 4, 2023
42b1dd5
cleanup
abi87 May 4, 2023
a736dfc
fixed cleanup
abi87 May 4, 2023
40e6092
Merge branch 'dev' into pchain_proposers_repack
abi87 May 10, 2023
cb1eafb
nits
abi87 May 11, 2023
1e3d889
Merge branch 'dev' into pchain_proposers_repack
abi87 May 16, 2023
c2ccff7
Merge branch 'dev' into pchain_proposers_repack
abi87 May 17, 2023
4855ec9
Merge branch 'dev' into pchain_proposers_repack
abi87 May 18, 2023
330e83a
fix merge
StephenButtolph May 18, 2023
79262a5
nit rename
StephenButtolph May 18, 2023
d55469b
nit rename
StephenButtolph May 18, 2023
cfbd56f
remove duplicate comments
StephenButtolph May 18, 2023
dcc6aa7
minimize interface size
StephenButtolph May 18, 2023
bb3be27
license
StephenButtolph May 18, 2023
12590b2
Merge branch 'dev' into pchain_proposers_repack
StephenButtolph May 18, 2023
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
Prev Previous commit
Next Next commit
clock cleanup
  • Loading branch information
abi87 committed Apr 11, 2023
commit d9b9452254153bb4bf47f058fe1ffbaae396d32f
4 changes: 2 additions & 2 deletions vms/platformvm/blocks/builder/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -323,9 +323,9 @@ func defaultConfig() *config.Config {

func defaultClock() *mockable.Clock {
// set time after Banff fork (and before default nextStakerTime)
clk := mockable.Clock{}
clk := &mockable.Clock{}
clk.Set(defaultGenesisTime)
return &clk
return clk
}

type fxVMInt struct {
Expand Down
4 changes: 2 additions & 2 deletions vms/platformvm/blocks/executor/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -354,9 +354,9 @@ func defaultConfig() *config.Config {
}

func defaultClock() *mockable.Clock {
clk := mockable.Clock{}
clk := &mockable.Clock{}
clk.Set(defaultGenesisTime)
return &clk
return clk
}

type fxVMInt struct {
Expand Down
14 changes: 7 additions & 7 deletions vms/platformvm/txs/executor/helpers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -123,19 +123,19 @@ func newEnvironment(postBanff, postCortina bool) *environment {
baseDB := versiondb.New(baseDBManager.Current().Database)
ctx, msm := defaultCtx(baseDB)

fx := defaultFx(&clk, ctx.Log, isBootstrapped.Get())
fx := defaultFx(clk, ctx.Log, isBootstrapped.Get())

rewards := reward.NewCalculator(config.RewardConfig)
baseState := defaultState(&config, ctx, baseDB, rewards)

atomicUTXOs := avax.NewAtomicUTXOManager(ctx.SharedMemory, txs.Codec)
uptimes := uptime.NewManager(baseState)
utxoHandler := utxo.NewHandler(ctx, &clk, fx)
utxoHandler := utxo.NewHandler(ctx, clk, fx)

txBuilder := builder.New(
ctx,
&config,
&clk,
clk,
fx,
baseState,
atomicUTXOs,
Expand All @@ -145,7 +145,7 @@ func newEnvironment(postBanff, postCortina bool) *environment {
backend := Backend{
Config: &config,
Ctx: ctx,
Clk: &clk,
Clk: clk,
Bootstrapped: &isBootstrapped,
Fx: fx,
FlowChecker: utxoHandler,
Expand All @@ -156,7 +156,7 @@ func newEnvironment(postBanff, postCortina bool) *environment {
env := &environment{
isBootstrapped: &isBootstrapped,
config: &config,
clk: &clk,
clk: clk,
baseDB: baseDB,
ctx: ctx,
msm: msm,
Expand Down Expand Up @@ -321,13 +321,13 @@ func defaultConfig(postBanff, postCortina bool) config.Config {
}
}

func defaultClock(postFork bool) mockable.Clock {
func defaultClock(postFork bool) *mockable.Clock {
now := defaultGenesisTime
if postFork {
// 1 second after Banff fork
now = defaultValidateEndTime.Add(-2 * time.Second)
}
clk := mockable.Clock{}
clk := &mockable.Clock{}
clk.Set(now)
return clk
}
Expand Down
6 changes: 3 additions & 3 deletions vms/platformvm/validators/manager.go
Original file line number Diff line number Diff line change
Expand Up @@ -55,17 +55,17 @@ func NewManager(
cfg config.Config,
state state.State,
metrics metrics.Metrics,
clk mockable.Clock,
clk *mockable.Clock,
) Manager {
return &manager{
cfg: cfg,
state: state,
metrics: metrics,
clk: &clk,
clk: clk,
caches: make(map[ids.ID]cache.Cacher[uint64, map[ids.NodeID]*validators.GetValidatorOutput]),
recentlyAccepted: window.New[ids.ID](
window.Config{
Clock: &clk,
Clock: clk,
MaxSize: maxRecentlyAcceptedWindowSize,
TTL: recentlyAcceptedWindowTTL,
},
Expand Down
2 changes: 1 addition & 1 deletion vms/platformvm/validators/manager_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -384,7 +384,7 @@ func TestVM_GetValidatorSet(t *testing.T) {
metrics, err := metrics.New("", prometheus.NewRegistry(), cfg.TrackedSubnets)
r.NoError(err)

clk := mockable.Clock{}
clk := &mockable.Clock{}
validatorssSet := NewManager(cfg, mockState, metrics, clk)

// Mock the VM's validators
Expand Down
2 changes: 1 addition & 1 deletion vms/platformvm/vm.go
Original file line number Diff line number Diff line change
Expand Up @@ -139,7 +139,7 @@ func (vm *VM) Initialize(
return err
}

validatorsSet := pvalidators.NewManager(vm.Config, vm.state, vm.metrics, vm.clock)
validatorsSet := pvalidators.NewManager(vm.Config, vm.state, vm.metrics, &vm.clock)
vm.QueryManager = validatorsSet
vm.atomicUtxosManager = avax.NewAtomicUTXOManager(chainCtx.SharedMemory, txs.Codec)
utxoHandler := utxo.NewHandler(vm.ctx, &vm.clock, vm.fx)
Expand Down