opendev
/
gerritlib
Code Issues Proposed changes

Merge "Allow startWatching to take in watcher connection limits"

This commit is contained in:
Jenkins 2014-01-31 18:10:36 +00:00 committed by Gerrit Code Review
parent f1544a182c de4cbc8141
commit 996343b115
1 changed files with 5 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
gerritlib/gerrit.py
View File

@ -166,9 +166,12 @@ class Gerrit(object):
self.watcher_thread = None
self.event_queue = None
def startWatching(self):
def startWatching(self, connection_attempts=-1, retry_delay=5):
self.event_queue = Queue.Queue()
self.watcher_thread = threading.Thread(target=GerritWatcher(self).run)
watcher = GerritWatcher(self,
connection_attempts=connection_attempts,
retry_delay=retry_delay)
self.watcher_thread = threading.Thread(target=watcher.run)
self.watcher_thread.daemon = True
self.watcher_thread.start()