achuprov/frostfs-node
1
0
Fork 0
forked from TrueCloudLab/frostfs-node
Code Pull requests Activity

[#281] service/audit: Fix typos

Browse source 
Signed-off-by: Alex Vanin <alexey@nspcc.ru>
This commit is contained in:
Alex Vanin 2020-12-25 10:45:59 +03:00 committed by Alex Vanin
parent e5108cf135
commit 7174abcc7c
3 changed files with 6 additions and 6 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
cmd/neofs-ir/defaults.go
View file

@ -99,5 +99,5 @@ func defaultConfiguration(cfg *viper.Viper) {
cfg.SetDefault("audit.timeout.search", "10s") cfg.SetDefault("audit.timeout.search", "10s")
cfg.SetDefault("audit.pdp.max_sleep_interval", "5s") cfg.SetDefault("audit.pdp.max_sleep_interval", "5s")
cfg.SetDefault("audit.pdp.pairs_pool_size", "10") cfg.SetDefault("audit.pdp.pairs_pool_size", "10")
cfg.SetDefault("audit.por.pairs_pool_size", "10") cfg.SetDefault("audit.por.pool_size", "10")
} }

2
pkg/innerring/innerring.go
View file

@ -226,7 +226,7 @@ func New(ctx context.Context, log *zap.Logger, cfg *viper.Viper) (*Server, error
}) })
pdpPoolSize := cfg.GetInt("audit.pdp.pairs_pool_size") pdpPoolSize := cfg.GetInt("audit.pdp.pairs_pool_size")
porPoolSize := cfg.GetInt("audit.por.pairs_pool_size") porPoolSize := cfg.GetInt("audit.por.pool_size")
auditTaskManager := audittask.New( auditTaskManager := audittask.New(
audittask.WithQueueCapacity(cfg.GetUint32("audit.task.queue_capacity")), audittask.WithQueueCapacity(cfg.GetUint32("audit.task.queue_capacity")),

8
pkg/services/audit/auditor/por.go
View file

@ -71,16 +71,16 @@ func (c *Context) checkStorageGroupPoR(ind int, sg *object.ID) {
flat[i], flat[j] = flat[j], flat[i] flat[i], flat[j] = flat[j], flat[i]
}) })
for i := range flat { for j := range flat {
accRequests++ accRequests++
if i > 0 { // in best case audit get object header on first iteration if j > 0 { // in best case audit get object header on first iteration
accRetries++ accRetries++
} }
hdr, err := c.cnrCom.GetHeader(c.task, flat[i], members[i], true) hdr, err := c.cnrCom.GetHeader(c.task, flat[j], members[i], true)
if err != nil { if err != nil {
c.log.Debug("can't head object", c.log.Debug("can't head object",
zap.String("remote_node", flat[i].Address()), zap.String("remote_node", flat[j].Address()),
zap.Stringer("oid", members[i])) zap.Stringer("oid", members[i]))
continue continue