ale64bit/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Issues Pull requests Projects Releases Packages Wiki Activity

[#478] innerring: Use dynamic epoch duration in epoch timer

Browse source 
Signed-off-by: Alex Vanin <alexey@nspcc.ru>
This commit is contained in:
Alex Vanin 2021-04-15 09:43:49 +03:00 committed by Alex Vanin
parent c33512d976
commit dc0bd782d2
3 changed files with 19 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
pkg/innerring/blocktimer.go
View file

@ -29,9 +29,9 @@ type (
cnrWrapper *container.Wrapper // to invoke stop container estimation cnrWrapper *container.Wrapper // to invoke stop container estimation
epoch epochState // to specify which epoch to stop epoch epochState // to specify which epoch to stop
epochDuration uint32 // in blocks epochDuration timers.BlockMeter // in blocks
stopEstimationDMul uint32 // X: X/Y of epoch in blocks stopEstimationDMul uint32 // X: X/Y of epoch in blocks
stopEstimationDDiv uint32 // Y: X/Y of epoch in blocks stopEstimationDDiv uint32 // Y: X/Y of epoch in blocks
collectBasicIncome subEpochEventHandler collectBasicIncome subEpochEventHandler
distributeBasicIncome subEpochEventHandler distributeBasicIncome subEpochEventHandler
@ -74,7 +74,7 @@ func (s *Server) tickTimers() {
func newEpochTimer(args *epochTimerArgs) *timers.BlockTimer { func newEpochTimer(args *epochTimerArgs) *timers.BlockTimer {
epochTimer := timers.NewBlockTimer( epochTimer := timers.NewBlockTimer(
timers.StaticBlockMeter(args.epochDuration), args.epochDuration,
func() { func() {
args.nm.HandleNewEpochTick(timers.NewEpochTick{}) args.nm.HandleNewEpochTick(timers.NewEpochTick{})
}, },

14
pkg/innerring/config/config.go
View file

@ -46,3 +46,17 @@ func (c *GlobalConfig) AuditFee() (uint64, error) {
return c.nm.AuditFee() return c.nm.AuditFee()
} }
func (c *GlobalConfig) EpochDuration() (uint32, error) {
value := c.cfg.GetUint32("timers.epoch")
if value != 0 {
return value, nil
}
epochDuration, err := c.nm.EpochDuration()
if err != nil {
return 0, err
}
return uint32(epochDuration), nil
}

2
pkg/innerring/innerring.go
View file

@ -585,7 +585,7 @@ func New(ctx context.Context, log *zap.Logger, cfg *viper.Viper) (*Server, error
nm: netmapProcessor, nm: netmapProcessor,
cnrWrapper: cnrClient, cnrWrapper: cnrClient,
epoch: server, epoch: server,
epochDuration: cfg.GetUint32("timers.epoch"), epochDuration: globalConfig.EpochDuration,
stopEstimationDMul: cfg.GetUint32("timers.stop_estimation.mul"), stopEstimationDMul: cfg.GetUint32("timers.stop_estimation.mul"),
stopEstimationDDiv: cfg.GetUint32("timers.stop_estimation.div"), stopEstimationDDiv: cfg.GetUint32("timers.stop_estimation.div"),
collectBasicIncome: subEpochEventHandler{ collectBasicIncome: subEpochEventHandler{