Connect every instance and collect ro info

Author: DifferentialOrange

tarantool/mesh_connection.py

@@ -243,6 +243,7 @@ def __init__(self, host=None, port=None,
 
         self.strategy_class = strategy_class
         self.strategy = strategy_class(addrs)
+        self.addrs = addrs
 
         addr = self.strategy.getnext()
         host = addr['host']
@@ -252,6 +253,9 @@ def __init__(self, host=None, port=None,
         self.cluster_discovery_delay = cluster_discovery_delay
         self.last_nodes_refresh = 0
 
+        self.pool = {}
+        self.ro = {}
+
         super(MeshConnection, self).__init__(
             host=host,
             port=port,
@@ -265,11 +269,44 @@ def __init__(self, host=None, port=None,
             call_16=call_16,
             connection_timeout=connection_timeout)
 
+        self.pool[self._addr_key(addr)] = self
+
+        for addr in self.addrs:
+            key = self._addr_key(addr)
+            if key not in self.pool:
+                self.pool[key] = Connection(
+                host=addr['host'],
+                port=addr['port'],
+                user=user,
+                password=password,
+                socket_timeout=socket_timeout,
+                reconnect_max_attempts=reconnect_max_attempts,
+                reconnect_delay=reconnect_delay,
+                connect_now=connect_now,
+                encoding=encoding,
+                call_16=call_16,
+                connection_timeout=connection_timeout)
+
+    def _addr_key(_, addr):
+        return f"{addr['host']}:{addr['port']}"
+
     def connect(self):
         super(MeshConnection, self).connect()
         if self.connected and self.cluster_discovery_function:
             self._opt_refresh_instances()
 
+        for key in self.pool:
+            conn = self.pool[key]
+
+            if not conn.connected:
+                conn.connect()
+            if not conn.connected:
+                warn("can't connect to instance to get rw/ro state", ClusterDiscoveryWarning)
+                continue
+
+            # box.cfg was called at least once since we can connect.
+            self.ro[key] = conn.eval("return box.info.ro")
+
     def _opt_reconnect(self):
         '''
         Attempt to connect "reconnect_max_attempts" times to each