Function getOwner

onecache/replicator_test.go:182–211

getOwner returns the owner and the original set of nodes without the owner.

(key string, nodes []*Node)

// getOwner returns the owner and the original set of nodes without the owner.
func getOwner(key string, nodes []*Node) (*Node, []*Node) {
	if len(nodes) == 0 {
		return nil, nil
	}

	// Get a copy of the ring and clear it.
	r := nodes[0].ring.ringCopy()
	for _, m := range r.(*consistentRing).ring.Members() {
		r.remove(m)
	}

	lookup := make(map[string]*Node, len(nodes))
	for _, n := range nodes {
		lookup[n.name] = n
		r.add(n.name)
	}

	// Get the successor.
	s := r.successor(key)
	owner := lookup[s]

	var followers []*Node
	for name, node := range lookup {
		if name != s {
			followers = append(followers, node)
		}
	}

	return owner, followers
}

func TestMarkDirtyValue(t *testing.T) {
	nodes, err := connectedTestNodes(2, 2)