Reduce amount of 'Waiting on logger' messages sent
Change-Id: If76e730673ac80e254c878c46b17181e14b4a5de
This commit is contained in:
parent
e65ae79d46
commit
6e3b0025f4
|
@ -132,6 +132,7 @@ class CallbackModule(default.CallbackModule):
|
||||||
def _read_log(self, host, ip, port, log_id, task_name, hosts):
|
def _read_log(self, host, ip, port, log_id, task_name, hosts):
|
||||||
self._log("[%s] Starting to log %s for task %s"
|
self._log("[%s] Starting to log %s for task %s"
|
||||||
% (host, log_id, task_name), job=False, executor=True)
|
% (host, log_id, task_name), job=False, executor=True)
|
||||||
|
logger_retries = 0
|
||||||
while True:
|
while True:
|
||||||
try:
|
try:
|
||||||
s = socket.create_connection((ip, port), 5)
|
s = socket.create_connection((ip, port), 5)
|
||||||
|
@ -152,8 +153,10 @@ class CallbackModule(default.CallbackModule):
|
||||||
% (ip, port))
|
% (ip, port))
|
||||||
return
|
return
|
||||||
except Exception:
|
except Exception:
|
||||||
self._log("[%s] Waiting on logger" % host,
|
if logger_retries % 10 == 0:
|
||||||
executor=True, debug=True)
|
self._log("[%s] Waiting on logger" % host,
|
||||||
|
executor=True, debug=True)
|
||||||
|
logger_retries += 1
|
||||||
time.sleep(0.1)
|
time.sleep(0.1)
|
||||||
continue
|
continue
|
||||||
msg = "%s\n" % log_id
|
msg = "%s\n" % log_id
|
||||||
|
|
Loading…
Reference in New Issue