From 33b54c68d5a1968e934ffe0069e8964e4090c95f Mon Sep 17 00:00:00 2001 From: Matt Jaffee Date: Fri, 15 Mar 2019 15:41:01 -0500 Subject: [PATCH] add lock on cluster.OwnsShard --- cluster.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/cluster.go b/cluster.go index 5c5c0e7f1..9ee35f4fa 100644 --- a/cluster.go +++ b/cluster.go @@ -851,6 +851,8 @@ func (c *cluster) shardNodes(index string, shard uint64) []*Node { // ownsShard returns true if a host owns a fragment. func (c *cluster) ownsShard(nodeID string, index string, shard uint64) bool { + c.mu.RLock() + defer c.mu.RUnlock() return Nodes(c.shardNodes(index, shard)).ContainsID(nodeID) }