Skip to content

Commit

Permalink
Remove tabs from testrecv.lua
Browse files Browse the repository at this point in the history
  • Loading branch information
Nicola 'tekNico' Larosa authored and takikawa committed Aug 16, 2017
1 parent 4138072 commit 9615f89
Showing 1 changed file with 31 additions and 31 deletions.
62 changes: 31 additions & 31 deletions src/apps/intel_mp/testrecv.lua
Original file line number Diff line number Diff line change
Expand Up @@ -28,37 +28,37 @@ function test(pciaddr, qno, vmdq, poolno, macaddr, vlan)
end
config.app(c, "sink", basic.Sink)
if os.getenv("SNABB_RECV_EXPENSIVE") then
local filter = require("apps.packet_filter.pcap_filter")
local filter = require("apps.packet_filter.pcap_filter")

local count = 10
config.link(c, "nic.output -> filter0.input")
for i=0,count do
local n = tostring(i)
local s = "filter"..n
config.app(c, s, filter.PcapFilter, { filter = [[ not dst host 10.2.29.1 and not dst host 10.2.50.1 ]]})
end
for i=1,count do
local m = tostring(i-1)
local n = tostring(i)
local s = "filter"..m..".output -> filter"..n..".input"
config.link(c, s)
end
config.app(c, "sane", filter.PcapFilter, { filter = [[ src host 172.16.172.3 and dst net 1.2.0.0/16 and ip proto 0 ]] })
config.link(c, "filter"..tostring(count)..".output -> sane.input")
config.link(c, "sane.output -> sink.input")
local count = 10
config.link(c, "nic.output -> filter0.input")
for i=0,count do
local n = tostring(i)
local s = "filter"..n
config.app(c, s, filter.PcapFilter, { filter = [[ not dst host 10.2.29.1 and not dst host 10.2.50.1 ]]})
end
for i=1,count do
local m = tostring(i-1)
local n = tostring(i)
local s = "filter"..m..".output -> filter"..n..".input"
config.link(c, s)
end
config.app(c, "sane", filter.PcapFilter, { filter = [[ src host 172.16.172.3 and dst net 1.2.0.0/16 and ip proto 0 ]] })
config.link(c, "filter"..tostring(count)..".output -> sane.input")
config.link(c, "sane.output -> sink.input")
else
config.link(c, "nic.output -> sink.input")
config.link(c, "nic.output -> sink.input")
end

engine.configure(c)
local spinup = os.getenv("SNABB_RECV_SPINUP")
if spinup then
engine.main({duration = spinup})
engine.main({duration = spinup})
end

local counters = {
Intel82599 = { "GPRC", "RXDGPC" },
Intel1g = { "GPRC", "RPTHC" }
Intel82599 = { "GPRC", "RXDGPC" },
Intel1g = { "GPRC", "RPTHC" }
}

local duration = os.getenv("SNABB_RECV_DURATION") or 2
Expand All @@ -67,24 +67,24 @@ function test(pciaddr, qno, vmdq, poolno, macaddr, vlan)
local master = nic.master

if master then
for _,v in pairs(counters[nic.driver]) do
before[v] = nic.r[v]()
end
for _,v in pairs(counters[nic.driver]) do
before[v] = nic.r[v]()
end
end

if os.getenv("SNABB_RECV_DEBUG") then
for _=1,duration do
engine.main({duration = 1})
nic:debug()
end
for _=1,duration do
engine.main({duration = 1})
nic:debug()
end
else
engine.main({duration = duration})
engine.main({duration = duration})
end

if master then
for _,v in pairs(counters[nic.driver]) do
for _,v in pairs(counters[nic.driver]) do
print(string.format("%s %d", v, tonumber(nic.r[v]() - before[v])/duration))
end
end
end
main.exit(0)
end

0 comments on commit 9615f89

Please sign in to comment.