forked from TrueCloudLab/frostfs-node
162 lines
3.6 KiB
Go
162 lines
3.6 KiB
Go
|
package auditor
|
||
|
|
||
|
import (
|
||
|
"github.com/nspcc-dev/neofs-api-go/pkg/netmap"
|
||
|
"github.com/nspcc-dev/neofs-api-go/pkg/object"
|
||
|
"go.uber.org/zap"
|
||
|
)
|
||
|
|
||
|
func (c *Context) executePoP() {
|
||
|
c.buildCoverage()
|
||
|
|
||
|
c.report.SetPlacementCounters(
|
||
|
c.counters.hit,
|
||
|
c.counters.miss,
|
||
|
c.counters.fail,
|
||
|
)
|
||
|
}
|
||
|
|
||
|
func (c *Context) buildCoverage() {
|
||
|
replicas := c.task.ContainerStructure().PlacementPolicy().Replicas()
|
||
|
|
||
|
// select random member from another storage group
|
||
|
// and process all placement vectors
|
||
|
c.iterateSGMembersPlacementRand(func(id *object.ID, ind int, nodes netmap.Nodes) bool {
|
||
|
c.processObjectPlacement(id, nodes, replicas[ind].Count())
|
||
|
return c.containerCovered()
|
||
|
})
|
||
|
}
|
||
|
|
||
|
func (c *Context) containerCovered() bool {
|
||
|
// number of container nodes can be calculated once
|
||
|
return c.cnrNodesNum <= len(c.pairedNodes)
|
||
|
}
|
||
|
|
||
|
func (c *Context) processObjectPlacement(id *object.ID, nodes netmap.Nodes, replicas uint32) {
|
||
|
var (
|
||
|
ok uint32
|
||
|
optimal bool
|
||
|
|
||
|
unpairedCandidate1, unpairedCandidate2 = -1, -1
|
||
|
|
||
|
pairedCandidate = -1
|
||
|
)
|
||
|
|
||
|
for i := 0; !optimal && ok < replicas && i < len(nodes); i++ {
|
||
|
// try to get object header from node
|
||
|
_, err := c.cnrCom.GetHeader(c.task, nodes[i], id)
|
||
|
if err != nil {
|
||
|
c.log.Debug("could not get object header from candidate",
|
||
|
zap.Stringer("id", id),
|
||
|
zap.String("error", err.Error()),
|
||
|
)
|
||
|
|
||
|
continue
|
||
|
}
|
||
|
|
||
|
// increment success counter
|
||
|
ok++
|
||
|
|
||
|
// update optimal flag
|
||
|
optimal = ok == replicas && uint32(i) < replicas
|
||
|
|
||
|
// update potential candidates to be paired
|
||
|
if _, ok := c.pairedNodes[nodes[i].Hash()]; !ok {
|
||
|
if unpairedCandidate1 < 0 {
|
||
|
unpairedCandidate1 = i
|
||
|
} else if unpairedCandidate2 < 0 {
|
||
|
unpairedCandidate2 = i
|
||
|
}
|
||
|
} else if pairedCandidate < 0 {
|
||
|
pairedCandidate = i
|
||
|
}
|
||
|
}
|
||
|
|
||
|
if optimal {
|
||
|
c.counters.hit++
|
||
|
} else if ok == replicas {
|
||
|
c.counters.miss++
|
||
|
} else {
|
||
|
c.counters.fail++
|
||
|
}
|
||
|
|
||
|
if unpairedCandidate1 >= 0 {
|
||
|
if unpairedCandidate2 >= 0 {
|
||
|
c.composePair(id, nodes[unpairedCandidate1], nodes[unpairedCandidate2])
|
||
|
} else if pairedCandidate >= 0 {
|
||
|
c.composePair(id, nodes[unpairedCandidate1], nodes[pairedCandidate])
|
||
|
}
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func (c *Context) composePair(id *object.ID, n1, n2 *netmap.Node) {
|
||
|
c.pairs = append(c.pairs, gamePair{
|
||
|
n1: n1,
|
||
|
n2: n2,
|
||
|
id: id,
|
||
|
})
|
||
|
|
||
|
c.pairedNodes[n1.Hash()] = pairMemberInfo{
|
||
|
node: n1,
|
||
|
}
|
||
|
c.pairedNodes[n2.Hash()] = pairMemberInfo{
|
||
|
node: n2,
|
||
|
}
|
||
|
}
|
||
|
|
||
|
func (c *Context) iterateSGMembersPlacementRand(f func(*object.ID, int, netmap.Nodes) bool) {
|
||
|
// iterate over storage groups members for all storage groups (one by one)
|
||
|
// with randomly shuffled members
|
||
|
c.iterateSGMembersRand(func(id *object.ID) bool {
|
||
|
// build placement vector for the current object
|
||
|
nn, err := c.buildPlacement(id)
|
||
|
if err != nil {
|
||
|
c.log.Debug("could not build placement for object",
|
||
|
zap.Stringer("id", id),
|
||
|
zap.String("error", err.Error()),
|
||
|
)
|
||
|
|
||
|
return false
|
||
|
}
|
||
|
|
||
|
for i, nodes := range nn {
|
||
|
if f(id, i, nodes) {
|
||
|
return true
|
||
|
}
|
||
|
}
|
||
|
|
||
|
return false
|
||
|
})
|
||
|
}
|
||
|
|
||
|
func (c *Context) iterateSGMembersRand(f func(*object.ID) bool) {
|
||
|
c.iterateSGInfo(func(members []*object.ID) bool {
|
||
|
ln := len(members)
|
||
|
|
||
|
processed := make(map[uint64]struct{}, ln-1)
|
||
|
|
||
|
for len(processed) < ln {
|
||
|
ind := nextRandUint64(uint64(ln), processed)
|
||
|
processed[ind] = struct{}{}
|
||
|
|
||
|
if f(members[ind]) {
|
||
|
return true
|
||
|
}
|
||
|
}
|
||
|
|
||
|
return false
|
||
|
})
|
||
|
}
|
||
|
|
||
|
func (c *Context) iterateSGInfo(f func([]*object.ID) bool) {
|
||
|
// we can add randomization like for SG members,
|
||
|
// but list of storage groups is already expected
|
||
|
// to be shuffled since it is a Search response
|
||
|
// with unpredictable order
|
||
|
for _, members := range c.sgMembersCache {
|
||
|
if f(members) {
|
||
|
return
|
||
|
}
|
||
|
}
|
||
|
}
|