Commit aefa65a2 authored by Julien Muchembled's avatar Julien Muchembled

qa: new ConnectionFilter.retry()

Unused but it is likely to be useful in the future.
parent cb78e6b2
......@@ -526,6 +526,11 @@ class ConnectionFilter(object):
return True
return False
@classmethod
def retry(cls):
with cls.lock:
cls._retry()
@classmethod
def _retry(cls):
for conn, queue in cls.filter_queue.items():
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment