Method memberStateUpdates

onecache/onecache.go:234–263

Members should be called when serf members join or leave. Remove is set to true if nodes left. This method updates state, including the ring to reflect Nodes joining/leaving.

(members []serf.Member, remove bool)

// true if nodes left. This method updates state, including the ring to reflect
// Nodes joining/leaving.
func (n *Node) memberStateUpdates(members []serf.Member, remove bool) {
	n.lock.Lock()

	var peers []string
	for _, m := range members {
		p, err := buildPeerNode(m)
		if err != nil {
			n.logger.Printf("[ERROR] onecache: buildPeerNode(%v) failed: %v\n", m, err)
			continue
		}
		peers = append(peers, p.name)

		if err := n.memberStateUpdate(p, remove); err != nil {
			n.logger.Printf("[ERROR] onecache: memberStateUpdate(%v, %v) failed: %v\n", m, remove, err)
		}
	}
	n.lock.Unlock()

	// Want to mark after all state updates have been applied because the state of replicas can be in flux.
	if remove {
		n.replicator.NodesRemoved(peers)
	} else {
		if err := n.replicator.MarkPeersDirty(peers); err != nil {
			n.logger.Printf("[ERROR] onecache.replicator: %v", err)
		}
	}

	// The set of Nodes has changed so trigger garbage collection
	n.gc.Reset(10 * time.Minute)
}

// memberStateUpdate handles a single node joining or leaving.
func (n *Node) memberStateUpdate(p *peerNode, remove bool) error {