Merge pull request #260 from dennis-tra/dev

Fix concurrent map iteration and map write error on GetMemberPIDs
asynkron · Nov 30, 2018 · aa58a65 · aa58a65
2 parents f5cb0c4 + e4a2f7c
commit aa58a65
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/cluster/cluster.go b/cluster/cluster.go
@@ -100,8 +100,11 @@ func Get(name string, kind string) (*actor.PID, remote.ResponseStatusCode) {
 	}
 }
 
-// Get PIDs of members for the specified kind
+// GetMemberPIDs returns PIDs of members for the specified kind
 func GetMemberPIDs(kind string) actor.PIDSet {
+	memberList.mutex.RLock()
+	defer memberList.mutex.RUnlock()
+
 	pids := actor.PIDSet{}
 	if memberList == nil {
 		return pids