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

[#271] placement: Add BuildObjectPlacement function

Browse source 
This function allows to shuffle prepared container nodes
according to HRW weights from network map.

Signed-off-by: Alex Vanin <alexey@nspcc.ru>
This commit is contained in:
Alex Vanin 2020-12-23 12:53:11 +03:00 committed by Alex Vanin
parent a8c26378b1
commit 58033a3adc
1 changed files with 9 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

16
pkg/services/object_manager/placement/netmap.go
View file

@ -37,19 +37,21 @@ func (b *netMapBuilder) BuildPlacement(a *object.Address, p *netmapSDK.Placement
return nil, errors.Wrap(err, "could not get network map") return nil, errors.Wrap(err, "could not get network map")
} }
aV2 := a.ToV2() cn, err := nm.GetContainerNodes(p, a.ContainerID().ToV2().GetValue())
cn, err := nm.GetContainerNodes(p, aV2.GetContainerID().GetValue())
if err != nil { if err != nil {
return nil, errors.Wrap(err, "could not get container nodes") return nil, errors.Wrap(err, "could not get container nodes")
} }
oid := aV2.GetObjectID() return BuildObjectPlacement(nm, cn, a.ObjectID())
if oid == nil { }
return cn.Replicas(), nil
func BuildObjectPlacement(nm *netmapSDK.Netmap, cnrNodes netmapSDK.ContainerNodes, id *object.ID) ([]netmapSDK.Nodes, error) {
objectID := id.ToV2()
if objectID == nil {
return cnrNodes.Replicas(), nil
} }
on, err := nm.GetPlacementVectors(cn, oid.GetValue()) on, err := nm.GetPlacementVectors(cnrNodes, objectID.GetValue())
if err != nil { if err != nil {
return nil, errors.Wrap(err, "could not get placement vectors for object") return nil, errors.Wrap(err, "could not get placement vectors for object")
} }