TrueCloudLab/frostfs-node
20
1
Fork 27
Code Issues 101 Pull requests 6 Projects Releases 1 Activity Actions

[#1382] policer: Replace deprecated methods

Browse source 
Signed-off-by: Dmitrii Stepanov <d.stepanov@yadro.com>
This commit is contained in:
Dmitrii Stepanov 2024-09-18 12:21:53 +03:00
parent b807d8c400
commit 1e7f9909da
3 changed files with 3 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
pkg/services/policer/check.go
View file

@ -110,7 +110,7 @@ func (p *Policer) processRepNodes(ctx context.Context, requirements *placementRe
requirements.needLocalCopy = true requirements.needLocalCopy = true
shortage-- shortage--
} else if nodes[i].IsMaintenance() { } else if nodes[i].Status().IsMaintenance() {
shortage, uncheckedCopies = p.handleMaintenance(nodes[i], checkedNodes, shortage, uncheckedCopies) shortage, uncheckedCopies = p.handleMaintenance(nodes[i], checkedNodes, shortage, uncheckedCopies)
} else { } else {
if status := checkedNodes.processStatus(nodes[i]); status.Processed() { if status := checkedNodes.processStatus(nodes[i]); status.Processed() {

2
pkg/services/policer/ec.go
View file

@ -106,7 +106,7 @@ func (p *Policer) processECChunk(ctx context.Context, objInfo objectcore.Info, n
validPlacement: true, validPlacement: true,
} }
} }
if requiredNode.IsMaintenance() { if requiredNode.Status().IsMaintenance() {
// consider maintenance mode has object, but do not drop local copy // consider maintenance mode has object, but do not drop local copy
p.log.Debug(logs.PolicerConsiderNodeUnderMaintenanceAsOK, zap.String("node", netmap.StringifyPublicKey(requiredNode))) p.log.Debug(logs.PolicerConsiderNodeUnderMaintenanceAsOK, zap.String("node", netmap.StringifyPublicKey(requiredNode)))
return ecChunkProcessResult{} return ecChunkProcessResult{}

2
pkg/services/policer/policer_test.go
View file

@ -174,7 +174,7 @@ func TestProcessObject(t *testing.T) {
nodes[i].SetPublicKey([]byte{byte(i)}) nodes[i].SetPublicKey([]byte{byte(i)})
} }
for _, i := range ti.maintenanceNodes { for _, i := range ti.maintenanceNodes {
nodes[i].SetMaintenance() nodes[i].SetStatus(netmap.Maintenance)
} }
var policy netmap.PlacementPolicy var policy netmap.PlacementPolicy