summaryrefslogtreecommitdiffstats
path: root/nfvbench/nfvbenchd.py
diff options
context:
space:
mode:
authorKerim Gokarslan <kgokarsl@cisco.com>2017-10-17 10:42:58 -0700
committerKerim Gokarslan <kgokarsl@cisco.com>2017-10-17 12:41:49 -0700
commit5be3729e65156be16a88d94e8943b79edf3f7eb0 (patch)
treeb5d31fa7f0e8f71e4d6ad953d7b2d003534d83a6 /nfvbench/nfvbenchd.py
parenta79debff4a6436522feebd2221865a2a6a917a58 (diff)
NFVBENCH-41 Add fluentd result tag to nfvbench server
Change-Id: I8fc274d9f9ee2211636336bc58f43f4d105986ef Signed-off-by: Kerim Gokarslan <kgokarsl@cisco.com>
Diffstat (limited to 'nfvbench/nfvbenchd.py')
-rw-r--r--nfvbench/nfvbenchd.py7
1 files changed, 3 insertions, 4 deletions
diff --git a/nfvbench/nfvbenchd.py b/nfvbench/nfvbenchd.py
index 15b71c5..1797496 100644
--- a/nfvbench/nfvbenchd.py
+++ b/nfvbench/nfvbenchd.py
@@ -33,7 +33,6 @@ from log import LOG
from utils import byteify
from utils import RunLock
-
# this global cannot reside in Ctx because of the @app and @socketio decorators
app = None
socketio = None
@@ -211,14 +210,14 @@ class WebSocketIoServer(object):
of this class and pass a runner object then invoke the run method
"""
- def __init__(self, http_root, runner, logger):
+ def __init__(self, http_root, runner, logger, result_tag):
self.nfvbench_runner = runner
setup_flask(http_root)
self.fluent_logger = logger
self.result_fluent_logger = None
- if self.fluent_logger:
+ if result_tag:
self.result_fluent_logger = \
- FluentLogHandler("resultnfvbench",
+ FluentLogHandler(result_tag,
fluentd_ip=self.fluent_logger.sender.host,
fluentd_port=self.fluent_logger.sender.port)
self.result_fluent_logger.runlogdate = self.fluent_logger.runlogdate