diff options
| author |   Kerim Gokarslan <kgokarsl@cisco.com> | 2017-09-27 16:43:36 -0700 |
|---|---|---|
| committer |   ahothan <ahothan@cisco.com> | 2017-10-20 00:37:13 -0700 |
| commit | 37da1d6d2530a94d5fa2e5644bf7ae30ac9553b3 (patch) | |
| tree | 3f4fc966ef363e80f54709429a4735eab56d6033 | |
| parent | a3b10cdbc47038d2048870e68fe805a5a86505c3 (diff) | |
NFVBENCH-35 Runlogdate is 0 in resultnfvbench
Change-Id: Ib062a7c655b1e2f8bd9304e32e3ffc92948c02c4
Signed-off-by: Kerim Gokarslan <kgokarsl@cisco.com>
| -rw-r--r-- | nfvbench/nfvbench.py | 11 | ||||
| -rw-r--r-- | nfvbench/nfvbenchd.py | 13 |
2 files changed, 16 insertions, 8 deletions
diff --git a/nfvbench/nfvbench.py b/nfvbench/nfvbench.py index 4256f24..84f9838 100644 --- a/nfvbench/nfvbench.py +++ b/nfvbench/nfvbench.py @@ -129,10 +129,13 @@ class NFVBench(object): def prepare_summary(self, result): """Prepares summary of the result to print and send it to logger (eg: fluentd)""" - sender = FluentLogHandler("resultnfvbench", - fluentd_ip=self.config.fluentd.ip, - fluentd_port=self.config.fluentd.port) \ - if self.config.fluentd.logging_tag else None + global fluent_logger + sender = None + if fluent_logger: + sender = FluentLogHandler("resultnfvbench", + fluentd_ip=self.config.fluentd.ip, + fluentd_port=self.config.fluentd.port) + sender.runlogdate = fluent_logger.runlogdate summary = NFVBenchSummarizer(result, sender) LOG.info(str(summary)) diff --git a/nfvbench/nfvbenchd.py b/nfvbench/nfvbenchd.py index 4657504..1e096ae 100644 --- a/nfvbench/nfvbenchd.py +++ b/nfvbench/nfvbenchd.py @@ -215,10 +215,13 @@ class WebSocketIoServer(object): self.nfvbench_runner = runner setup_flask(http_root) self.fluent_logger = logger - self.result_fluent_logger = FluentLogHandler("resultnfvbench", - fluentd_ip=self.fluent_logger.sender.host, - fluentd_port=self.fluent_logger.sender.port) \ - if self.fluent_logger else None + self.result_fluent_logger = None + if self.fluent_logger: + self.result_fluent_logger = \ + FluentLogHandler("resultnfvbench", + fluentd_ip=self.fluent_logger.sender.host, + fluentd_port=self.fluent_logger.sender.port) + self.result_fluent_logger.runlogdate = self.fluent_logger.runlogdate def run(self, host='127.0.0.1', port=7556): @@ -250,6 +253,8 @@ class WebSocketIoServer(object): else: # this might overwrite a previously unfetched result Ctx.set_result(results) + if self.fluent_logger: + self.result_fluent_logger.runlogdate = self.fluent_logger.runlogdate summary = NFVBenchSummarizer(results['result'], self.result_fluent_logger) LOG.info(str(summary)) Ctx.release() |