X-Git-Url: https://gerrit.opnfv.org/gerrit/gitweb?a=blobdiff_plain;ds=sidebyside;f=nfvbench%2Ffluentd.py;fp=nfvbench%2Ffluentd.py;h=ad0ea3423fd4dd056f4481f700d9c42b94f2d277;hb=1b35b646790002e960663a91b157eb209fcfc5a4;hp=628b968e0b2e60bfca2734f3165a7587db9969e8;hpb=0843235ecbb375d1d759a67791348e7812851029;p=nfvbench.git

diff --git a/nfvbench/fluentd.py b/nfvbench/fluentd.py
index 628b968..ad0ea34 100644
--- a/nfvbench/fluentd.py
+++ b/nfvbench/fluentd.py
@@ -35,7 +35,7 @@ class FluentLogHandler(logging.Handler):
         logging.Handler.__init__(self)
         self.log_senders = []
         self.result_senders = []
-        self.runlogdate = 0
+        self.runlogdate = "1970-01-01T00:00:00.000000+0000"
         self.formatter = logging.Formatter('%(message)s')
         for fluentd_config in fluentd_configs:
             if fluentd_config.logging_tag:
@@ -65,8 +65,9 @@ class FluentLogHandler(logging.Handler):
             "message": self.formatter.format(record),
             "@timestamp": self.__get_timestamp()
         }
-        # if runlogdate is 0, it's a log from server (not an nfvbench run) so do not send runlogdate
-        if self.runlogdate != 0:
+        # if runlogdate is Jan 1st 1970, it's a log from server (not an nfvbench run)
+        # so do not send runlogdate
+        if self.runlogdate != "1970-01-01T00:00:00.000000+0000":
             data["runlogdate"] = self.runlogdate
 
         self.__update_stats(record.levelno)
@@ -103,9 +104,9 @@ class FluentLogHandler(logging.Handler):
                 "numwarnings": self.__warning_counter,
                 "@timestamp": self.__get_timestamp()
             }
-            # if runlogdate is 0, it's a log from server (not an nfvbench run)
+            # if runlogdate is Jan 1st 1970, it's a log from server (not an nfvbench run)
             # so don't send runlogdate
-            if self.runlogdate != 0:
+            if self.runlogdate != "1970-01-01T00:00:00.000000+0000":
                 data["runlogdate"] = self.runlogdate
             for log_sender in self.log_senders:
                 log_sender.emit(None, data)