Added log for unreachable version

skbkontur · Jul 1, 2024 · 00482ed · 00482ed
1 parent bb46b42
commit 00482ed
Showing 1 changed file with 8 additions and 1 deletion.
diff --git a/Cassandra.ThriftClient/Connections/ClusterConnection.cs b/Cassandra.ThriftClient/Connections/ClusterConnection.cs
@@ -61,7 +61,13 @@ public void WaitUntilSchemaAgreementIsReached(TimeSpan timeout)
             {
                 var schemaAgreementCommand = new SchemaAgreementCommand();
                 commandExecutor.Execute(schemaAgreementCommand);
-                if (schemaAgreementCommand.Output.Keys.Count(x => x != "UNREACHABLE") == 1)
+                if (schemaAgreementCommand.Output.ContainsKey(unreachableVersion))
+                {
+                    logger.Warn("Found unreachable version");
+                    LogVersions(schemaAgreementCommand.Output);
+                }
+
+                if (schemaAgreementCommand.Output.Keys.Count(x => x != unreachableVersion) == 1)
                     return;
                 LogVersions(schemaAgreementCommand.Output);
             } while (sw.Elapsed < timeout);
@@ -77,6 +83,7 @@ private void LogVersions(IDictionary<string, List<string>> versions)
             logger.Info(stringBuilder.ToString());
         }
 
+        private const string unreachableVersion = "UNREACHABLE";
         private readonly ICommandExecutor<IFierceCommand> commandExecutor;
         private readonly ILog logger;
     }