Merge pull request #655 from sergey-shilov/fix/INDY-1261

INDY-1261: add flushing of retry count per remote

Author: ashcherbakov

stp_core/config.py

@@ -20,7 +20,7 @@
 
 RETRY_TIMEOUT_NOT_RESTRICTED = 6
 RETRY_TIMEOUT_RESTRICTED = 15
-MAX_RECONNECT_RETRY_ON_SAME_SOCKET = 1
+MAX_RECONNECT_RETRY_ON_SAME_SOCKET = 5
 
 # Enables/disables debug mode for Looper class
 LOOPER_DEBUG = False

stp_zmq/kit_zstack.py

@@ -71,6 +71,8 @@ def retryDisconnected(self, exclude=None):
         exclude = exclude or {}
         for name, remote in self.remotes.items():
             if name in exclude or remote.isConnected:
+                if name in self._retry_connect:
+                    self._retry_connect.pop(name, None)
                 continue
 
             if name not in self._retry_connect: