From 34cbe7031415297ee5c2b6c7059801603398fa7f Mon Sep 17 00:00:00 2001 From: Kerim Gokarslan Date: Wed, 27 Sep 2017 16:43:36 -0700 Subject: NFVBENCH-35 Runlogdate is 0 in resultnfvbench Change-Id: Ib062a7c655b1e2f8bd9304e32e3ffc92948c02c4 Signed-off-by: Kerim Gokarslan --- nfvbench/nfvbenchd.py | 13 +++++++++---- 1 file changed, 9 insertions(+), 4 deletions(-) (limited to 'nfvbench/nfvbenchd.py') 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() -- cgit 1.2.3-korg