commit 9e6621ffb04f8daef266ae07f8ded93b110b107c
author Carmelo Cascone <carmelo@onlab.us> Tue Jun 27 16:06:33 2017 -0400
committer Carmelo Cascone <carmelo@onlab.us> Tue Jun 27 20:14:13 2017 +0000
tree 7f7bce8521a1e0bfd36d6ddf5cd6181ab14abeab
parent f773b65f6dfdc7972d553ef9b0d1d2a1c6074f67

Fix for log handling in bmv2.py

Change-Id: Idf96ace58c4b1cb67c52e2c122ad644b945f4f99

tools/dev/mininet/bmv2.py

diff --git a/tools/dev/mininet/bmv2.py b/tools/dev/mininet/bmv2.py
index e23b11c..64be413 100644
--- a/tools/dev/mininet/bmv2.py
+++ b/tools/dev/mininet/bmv2.py
@@ -23,7 +23,7 @@
     instanceCount = 0
 
     def __init__(self, name, debugger=False, loglevel="warn", elogger=False, persistent=False,
-                 logflush=False, thriftPort=None, grpcPort=None, netcfg=True, **kwargs):
+                 thriftPort=None, grpcPort=None, netcfg=True, **kwargs):
         Switch.__init__(self, name, **kwargs)
         self.thriftPort = ONOSBmv2Switch.pickUnusedPort() if not thriftPort else thriftPort
         self.grpcPort = ONOSBmv2Switch.pickUnusedPort() if not grpcPort else grpcPort
@@ -37,7 +37,6 @@
         self.logfile = '/tmp/bmv2-%d.log' % self.deviceId
         self.elogger = elogger
         self.persistent = persistent
-        self.logflush = logflush
         self.netcfg = netcfg
         self.netcfgfile = '/tmp/bmv2-%d-netcfg.json' % self.deviceId
         if persistent:
@@ -118,9 +117,7 @@
             args.append('--nanolog %s' % nanomsg)
         if self.debugger:
             args.append('--debugger')
-        args.append('--log-file %s -L%s' % (self.logfile, self.loglevel))
-        if self.logflush:
-            args.append('--log-flush')
+        args.append('-L%s' % self.loglevel)
 
         args.append(INIT_BMV2_JSON)
 
@@ -136,9 +133,9 @@
             cmdStr = "(while [ -e {} ]; " \
                      "do {} ; " \
                      "sleep 1; " \
-                     "done;) &".format(self.exectoken, bmv2cmd)
+                     "done;) > {} 2>&1 &".format(self.exectoken, bmv2cmd, self.logfile)
         else:
-            cmdStr = "{} &".format(bmv2cmd)
+            cmdStr = "{} > {} 2>&1 &".format(bmv2cmd, self.logfile)
 
         # Starts the switch.
         out = self.cmd(cmdStr)
@@ -157,8 +154,7 @@
     def stop(self, deleteIntfs=True):
         """Terminate switch."""
         self.cmd("rm -f /tmp/bmv2-%d-*" % self.deviceId)
-        # wildcard end as BMv2 might create log files with .txt extension
-        self.cmd("rm -f /tmp/bmv2-%d.log*" % self.deviceId)
+        self.cmd("rm -f /tmp/bmv2-%d.log" % self.deviceId)
         self.cmd('kill %' + BMV2_TARGET)
         Switch.stop(self, deleteIntfs)