Show which server a label warning is for
This commit is contained in:
parent
6513d35136
commit
4690f3f45d
1 changed files with 5 additions and 3 deletions
|
@ -50,7 +50,8 @@ class Module(ModuleManager.BaseModule):
|
||||||
|
|
||||||
def _recv(self, server, label, lines):
|
def _recv(self, server, label, lines):
|
||||||
if not label in server._label_cache:
|
if not label in server._label_cache:
|
||||||
self.log.warn("unknown label received: %s", [label])
|
self.log.warn("unknown label received on %s: %s",
|
||||||
|
[str(server), label])
|
||||||
return
|
return
|
||||||
|
|
||||||
cached = server._label_cache.pop(label)
|
cached = server._label_cache.pop(label)
|
||||||
|
@ -59,5 +60,6 @@ class Module(ModuleManager.BaseModule):
|
||||||
for label, other_cached in server._label_cache.items():
|
for label, other_cached in server._label_cache.items():
|
||||||
other_cached.labels_since += 1
|
other_cached.labels_since += 1
|
||||||
if other_cached.labels_since == 10:
|
if other_cached.labels_since == 10:
|
||||||
self.log.warn("%d labels seen while waiting for response to %s",
|
self.log.warn(
|
||||||
[other_cached.labels_since, label])
|
"%d labels seen while waiting for response to %s on %s",
|
||||||
|
[other_cached.labels_since, label, str(server)])
|
||||||
|
|
Loading…
Reference in a new issue