diff --git a/netmap/netmap.go b/netmap/netmap.go index 8343b89..c839df8 100644 --- a/netmap/netmap.go +++ b/netmap/netmap.go @@ -189,7 +189,7 @@ func (m NetMap) ContainerNodes(p PlacementPolicy, pivot []byte) ([][]NodeInfo, e s.SetCount(p.replicas[i].GetCount()) s.SetFilter(mainFilterName) - nodes, err := c.getSelection(p, s) + nodes, err := c.getSelection(s) if err != nil { return nil, err } diff --git a/netmap/selector.go b/netmap/selector.go index 5422372..51ceb47 100644 --- a/netmap/selector.go +++ b/netmap/selector.go @@ -23,7 +23,7 @@ func (c *context) processSelectors(p PlacementPolicy) error { c.processedSelectors[sName] = &p.selectors[i] - result, err := c.getSelection(p, p.selectors[i]) + result, err := c.getSelection(p.selectors[i]) if err != nil { return err } @@ -56,7 +56,7 @@ func calcBucketWeight(ns nodes, a aggregator, wf weightFunc) float64 { // getSelection returns nodes grouped by s.attribute. // Last argument specifies if more buckets can be used to fulfill CBF. -func (c *context) getSelection(p PlacementPolicy, s netmap.Selector) ([]nodes, error) { +func (c *context) getSelection(s netmap.Selector) ([]nodes, error) { bucketCount, nodesInBucket := calcNodesCount(s) buckets := c.getSelectionBase(s)