config/cassandra: not supported tuples of server/port for cassandra-d…

…river < 3.17

Related-Jira-Bug: CEM-10731
Signed-off-by: Sahid Orentino Ferdjaoui <sferdjaoui@juniper.net>
Change-Id: I26112a9fa5032598925bfd09a52353ef5fe2125d

src/config/common/cfgm_common/datastore/drivers/cassandra_cql.py

@@ -31,6 +31,8 @@
     connector = None
 
 
+DEFAULT_CQL_PORT = 9042
+
 # Properties passed to the column familly
 TABLE_PROPERTIES = {
     'gc_grace_seconds': vns_constants.CASSANDRA_DEFAULT_GC_GRACE_SECONDS,
@@ -338,19 +340,31 @@ def _Init_Cluster(self):
         }
 
         # Addresses, ports related options
-        endpoints = []
+        endpoints, port = [], None
         for address in self._server_list:
             try:
-                server, port = address.split(':', 1)
-
-                endpoints.append((server, int(port)))
+                server, _port = address.split(':', 1)
+                _port = int(_port)
+
+                if port is not None:
+                    if port != _port:
+                        self.options.logger(
+                            "Please consider fixing port for '{}', all "
+                            "servers should have same port. "
+                            "Using '{}'".format(
+                                address, port), level=SandeshLevel.SYS_WARN)
+                else:
+                    port = _port
+
+                endpoints.append(server)
             except ValueError:
                 endpoints.append(address)
 
         connector.ProtocolVersion.SUPPORTED_VERSIONS = self.ProtocolVersions
         try:
             self._cluster = connector.cluster.Cluster(
                 endpoints,
+                port=(port or DEFAULT_CQL_PORT),
                 ssl_options=ssl_options,
                 auth_provider=auth_provider,
                 execution_profiles=profiles,