fix for issue https://github.com/StackExchange/StackExchange.Redis/issues/300

Ensure cluster configuration is upto-date before returning the connection multiplexer

StackExchange.Redis/StackExchange/Redis/ClusterConfiguration.cs

@@ -281,14 +281,8 @@ internal ClusterNode(ClusterConfiguration configuration, string raw, EndPoint or
 
             var flags = parts[2].Split(StringSplits.Comma);
             
-            if (flags.Contains("myself"))
-            {
-                endpoint = origin;
-            }
-            else
-            {
-                endpoint = Format.TryParseEndPoint(parts[1]);
-            }
+            endpoint = Format.TryParseEndPoint(parts[1]);
+            
             nodeId = parts[0];
             isSlave = flags.Contains("slave");
             parentNodeId = string.IsNullOrWhiteSpace(parts[3]) ? null : parts[3];

StackExchange.Redis/StackExchange/Redis/ConnectionMultiplexer.cs

@@ -1263,7 +1263,7 @@ internal async Task<bool> ReconfigureAsync(bool first, bool reconfigureAll, Text
                             {
                                 servers[i].ClearUnselectable(UnselectableFlags.DidNotRespond);
                                 LogLocked(log, "{0} returned with success", Format.ToString(endpoints[i]));
-
+                                UpdateClusterConfigIfNeeded(server, log);
                                 // count the server types
                                 switch (server.ServerType) 
                                 {
@@ -1419,6 +1419,33 @@ internal async Task<bool> ReconfigureAsync(bool first, bool reconfigureAll, Text
             }
         }
 
+        private void UpdateClusterConfigIfNeeded(ServerEndPoint server, TextWriter log) 
+        {
+            var message = Message.Create(-1, CommandFlags.None, RedisCommand.CLUSTER, RedisLiterals.NODES);
+            ClusterConfiguration clusterConfig = null;
+            try 
+            {
+                clusterConfig = this.ExecuteSyncImpl(message, ResultProcessor.ClusterNodes, server);
+            } 
+            catch (Exception ex) 
+            {
+                if (ex.Message.Contains("ERR This instance has cluster support disabled")) 
+                {
+                    LogLocked(log, "Cluster support disabled. Continuing without updating cluster config...");
+                    return;
+                }
+
+                LogLocked(log, "Encountered error while updating cluster config: " + ex.Message);
+            }
+
+            if (clusterConfig != null) 
+            {
+                this.UpdateClusterRange(clusterConfig);
+                LogLocked(log, "Updated cluster config");
+
+            }
+        }
+
         private void ResetAllNonConnected()
         {
             var snapshot = serverSnapshot;