apps.interlink: add duration parameter to selftest.snabb

snabbco · Feb 9, 2018 · 022ab0c · 022ab0c
1 parent cae2554
commit 022ab0c
Showing 1 changed file with 6 additions and 3 deletions.
diff --git a/src/apps/interlink/selftest.snabb b/src/apps/interlink/selftest.snabb
@@ -7,6 +7,9 @@ local interlink = require("lib.interlink")
 local Receiver = require("apps.interlink.receiver")
 local Sink = require("apps.basic.basic_apps").Sink
 
+-- Synopsis: selftest.snabb [duration]
+local DURATION = tonumber(main.parameters[1]) or 10
+
 interlink.create("group/test.mcp")
 
 worker.start("source",
@@ -19,15 +22,15 @@ config.app(c, "sink", Sink)
 config.link(c, "rx.output->sink.input")
 
 engine.configure(c)
-engine.main({duration=10, report={showlinks=true}})
+engine.main({duration=DURATION, report={showlinks=true}})
 
 for w, s in pairs(worker.status()) do
    print(("worker %s: pid=%s alive=%s status=%s"):format(
          w, s.pid, s.alive, s.status))
 end
 local stats = link.stats(engine.app_table["sink"].input.input)
-print(stats.txpackets / 1e6 / 10 .. " Mpps")
+print(stats.txpackets / 1e6 / DURATION .. " Mpps")
 
 -- test teardown
 interlink.free(interlink.open("group/test.mcp"))
-engine.main({duration=1})
+engine.main({duration=0.1})