Make sure self.__retry_timeout is set (#2440)

The default value was None, which is the same as no timeout.
This commit is contained in:
Alexander Kukushkin
2022-10-25 14:14:16 +02:00
committed by GitHub
parent 5a21ffa3e4
commit bda2bedf48
+2 -3
View File
@@ -97,7 +97,7 @@ class KVStoreTTL(DynMemberSyncObj):
self.__on_set = on_set
self.__on_delete = on_delete
self.__limb = {}
self.__retry_timeout = None
self.set_retry_timeout(int(config.get('retry_timeout') or 10))
self_addr = config.get('self_addr')
partner_addrs = set(config.get('partner_addrs', []))
@@ -121,8 +121,7 @@ class KVStoreTTL(DynMemberSyncObj):
journalFile=(file_template + '.journal' if self_addr else None),
onReady=on_ready, dynamicMembershipChange=True)
retry_timeout = int(config.get('retry_timeout') or 10)
super(KVStoreTTL, self).__init__(self_addr, partner_addrs, conf, retry_timeout)
super(KVStoreTTL, self).__init__(self_addr, partner_addrs, conf, self.__retry_timeout)
self.__data = {}
@staticmethod