summaryrefslogtreecommitdiffhomepage
path: root/applications/luci-app-nft-qos
diff options
context:
space:
mode:
authorRosy Song <rosysong@rosinson.com>2019-01-01 16:08:10 +0800
committerRosy Song <rosysong@rosinson.com>2019-01-01 16:08:10 +0800
commit8269351cf4362492fa191758d2cec61b688ff683 (patch)
treea521c42fc1acec0a3dcdfbaad586cd2c33d7e168 /applications/luci-app-nft-qos
parent1893892581707fcd83e684a7a03dd6b5d3c2c3a2 (diff)
luci-app-nft-qos: rework _action_rate function
Signed-off-by: Rosy Song <rosysong@rosinson.com>
Diffstat (limited to 'applications/luci-app-nft-qos')
-rw-r--r--applications/luci-app-nft-qos/luasrc/controller/nft-qos.lua27
1 files changed, 13 insertions, 14 deletions
diff --git a/applications/luci-app-nft-qos/luasrc/controller/nft-qos.lua b/applications/luci-app-nft-qos/luasrc/controller/nft-qos.lua
index f7e399352..637eb1173 100644
--- a/applications/luci-app-nft-qos/luasrc/controller/nft-qos.lua
+++ b/applications/luci-app-nft-qos/luasrc/controller/nft-qos.lua
@@ -17,30 +17,29 @@ function index()
end
function _action_rate(rv, n)
- local has_ipv6 = nixio.fs.access("/proc/net/ipv6_route")
- if has_ipv6 then
- local c = io.popen("nft list chain inet nft-qos-monitor " .. n .. " 2>/dev/null")
- else
- local c = io.popen("nft list chain ip nft-qos-monitor " .. n .. " 2>/dev/null")
- end
+ local c = nixio.fs.access("/proc/net/ipv6_route") and
+ io.popen("nft list chain inet nft-qos-monitor " .. n .. " 2>/dev/null") or
+ io.popen("nft list chain ip nft-qos-monitor " .. n .. " 2>/dev/null")
+
if c then
for l in c:lines() do
- local _, i, p, b = l:match('^%s+ip ([^%s]+) ([^%s]+) counter packets (%d+) bytes (%d+)')
+ local _, i, p, b = l:match(
+ '^%s+ip ([^%s]+) ([^%s]+) counter packets (%d+) bytes (%d+)'
+ )
if i and p and b then
-- handle expression
- local r = {
+ rv[#rv + 1] = {
rule = {
- family = "inet",
- table = "nft-qos-monitor",
- chain = n,
- handle = 0,
- expr = {
+ family = "inet",
+ table = "nft-qos-monitor",
+ chain = n,
+ handle = 0,
+ expr = {
{ match = { right = i } },
{ counter = { packets = p, bytes = b } }
}
}
}
- rv[#rv + 1] = r
end
end
c:close()