mirror of
https://github.com/Ysurac/openmptcprouter-feeds.git
synced 2025-03-09 15:40:03 +00:00
116 lines
3.8 KiB
Lua
116 lines
3.8 KiB
Lua
-- Copyright 2008 Steven Barth <steven@midlink.org>
|
|
-- Copyright 2011 Jo-Philipp Wich <jow@openwrt.org>
|
|
-- Copyright 2018 Ycarus (Yannick Chabanois) <ycarus@zugaina.org>
|
|
-- Licensed to the public under the Apache License 2.0.
|
|
|
|
module("luci.controller.mptcp", package.seeall)
|
|
|
|
function index()
|
|
entry({"admin", "network", "mptcp"}, alias("admin", "network", "mptcp", "settings"), _("MPTCP"))
|
|
entry({"admin", "network", "mptcp", "settings"}, cbi("mptcp"), _("Settings"),2).leaf = true
|
|
entry({"admin", "network", "mptcp", "bandwidth"}, template("mptcp/multipath"), _("Bandwidth"), 3).leaf = true
|
|
entry({"admin", "network", "mptcp", "multipath_bandwidth"}, call("multipath_bandwidth")).leaf = true
|
|
entry({"admin", "network", "mptcp", "interface_bandwidth"}, call("interface_bandwidth")).leaf = true
|
|
entry({"admin", "network", "mptcp", "mptcp_check"}, template("mptcp/mptcp_check"), _("MPTCP Support Check"), 4).leaf = true
|
|
entry({"admin", "network", "mptcp", "mptcp_check_trace"}, post("mptcp_check_trace")).leaf = true
|
|
entry({"admin", "network", "mptcp", "mptcp_fullmesh"}, template("mptcp/mptcp_fullmesh"), _("MPTCP Fullmesh"), 5).leaf = true
|
|
entry({"admin", "network", "mptcp", "mptcp_fullmesh_data"}, post("mptcp_fullmesh_data")).leaf = true
|
|
entry({"admin", "network", "mptcp", "mptcp_connections"}, template("mptcp/mptcp_connections"), _("Established connections"), 6).leaf = true
|
|
entry({"admin", "network", "mptcp", "mptcp_connections_data"}, post("mptcp_connections_data")).leaf = true
|
|
end
|
|
|
|
function interface_bandwidth(iface)
|
|
luci.http.prepare_content("application/json")
|
|
local bwc = io.popen("luci-bwc -i %q 2>/dev/null" % iface)
|
|
if bwc then
|
|
luci.http.write("[")
|
|
while true do
|
|
local ln = bwc:read("*l")
|
|
if not ln then break end
|
|
luci.http.write(ln)
|
|
end
|
|
luci.http.write("]")
|
|
bwc:close()
|
|
end
|
|
end
|
|
|
|
function multipath_bandwidth()
|
|
local result = { };
|
|
local uci = luci.model.uci.cursor()
|
|
|
|
uci:foreach("network", "interface", function(s)
|
|
local dev = s["ifname"] or ""
|
|
if dev ~= "lo" and dev ~= "" then
|
|
local multipath = s["multipath"] or "off"
|
|
if multipath == "on" or multipath == "master" or multipath == "backup" or multipath == "handover" then
|
|
local bwc = luci.sys.exec("luci-bwc -i %q 2>/dev/null" % dev) or ""
|
|
if bwc ~= nil then
|
|
result[dev] = "[" .. string.gsub(bwc, '[\r\n]', '') .. "]"
|
|
else
|
|
result[dev] = "[]"
|
|
end
|
|
end
|
|
end
|
|
end)
|
|
|
|
luci.http.prepare_content("application/json")
|
|
luci.http.write_json(result)
|
|
end
|
|
|
|
function get_device(interface)
|
|
local dump = require("luci.util").ubus("network.interface.%s" % interface, "status", {})
|
|
return dump['l3_device']
|
|
end
|
|
|
|
function mptcp_check_trace(iface)
|
|
luci.http.prepare_content("text/plain")
|
|
local tracebox
|
|
local uci = require "luci.model.uci".cursor()
|
|
local interface = get_device(iface)
|
|
local server = uci:get("shadowsocks-libev", "sss0", "server") or ""
|
|
if server == "" then return end
|
|
if interface == "" then
|
|
tracebox = io.popen("tracebox -s /usr/share/tracebox/omr-mptcp-trace.lua " .. server)
|
|
else
|
|
tracebox = io.popen("tracebox -s /usr/share/tracebox/omr-mptcp-trace.lua -i " .. interface .. " " .. server)
|
|
end
|
|
if tracebox then
|
|
while true do
|
|
local ln = tracebox:read("*l")
|
|
if not ln then break end
|
|
luci.http.write(ln)
|
|
luci.http.write("\n")
|
|
end
|
|
end
|
|
return
|
|
end
|
|
|
|
function mptcp_fullmesh_data()
|
|
luci.http.prepare_content("text/plain")
|
|
local fullmesh
|
|
fullmesh = io.popen("multipath -f")
|
|
if fullmesh then
|
|
while true do
|
|
local ln = fullmesh:read("*l")
|
|
if not ln then break end
|
|
luci.http.write(ln)
|
|
luci.http.write("\n")
|
|
end
|
|
end
|
|
return
|
|
end
|
|
|
|
function mptcp_connections_data()
|
|
luci.http.prepare_content("text/plain")
|
|
local connections
|
|
connections = io.popen("multipath -c")
|
|
if connections then
|
|
while true do
|
|
local ln = connections:read("*l")
|
|
if not ln then break end
|
|
luci.http.write(ln)
|
|
luci.http.write("\n")
|
|
end
|
|
end
|
|
return
|
|
end
|