ブロードキャストストームの抑制

function switch_model_read(sw)
　　　　local rtn, str
　　　　local cmd = "switch control function get model-name " .. sw

　　　　rtn, str = rt.command(cmd)
　　　　if (not rtn) or (not str) then

　　　　　　　　str = string.format("failed to get model name : %s\r\n", sw)
　　　　end
　　　　return rtn, str
end

function switch_sys_name_read(sw)
　　　　local rtn, str
　　　　local cmd = "switch control function get system-name " .. sw

　　　　rtn, str = rt.command(cmd)
　　　　if (not rtn) or (not str) then
　　　　　　　　str = string.format("failed to get switch system name : %s\r\n", sw)
　　　　end
　　　　return rtn, str
end

function switch_set_counter(port, cnt_num)
　　　　local cmd = string.format("switch control function set "..
　　　　　　　　　　　　　　　　　　　　 "counter-frame-rx-type %d %d "..
　　　　　　　　　　　　　　　　　　　　 "broadcast-and-multicast-packets", port, cnt_num)

　　　　return rt.command(cmd)
end

function switch_read_frame_counter(sw, rx_tx, port, cnt_num)
　　　　local rtn, val
　　　　local cmd = string.format("switch control function get "..
　　　　　　　　　　　　　　　　　　　　 "status-counter-frame-%s %d %d %s",
　　　　　　　　　　　　　　　　　　　　 rx_tx, port, cnt_num, sw)

　　　　rtn, val = rt.command(cmd)
　　　　if (not rtn) or (not val) then
　　　　　　　　return nil
　　　　end
　　　　return rtn, tonumber(val)
end

function set_counter_watch_pkts(sw)
　　　　local rtn, str, port_num, cnt_id
　　　　local cmd = "switch select " .. sw

　　　　rtn = rt.command(cmd)
　　　　if (not rtn) then
　　　　　　　　return nil
　　　　end

　　　　rtn, str = switch_model_read(sw)
　　　　if (not rtn) or (not str) then
　　　　　　　　return nil
　　　　end

　　　　if (string.find(str, "SWX2200-8G", 1, true)) then
　　　　　　　　port_num = 8
　　　　　　　　cnt_id = 3
　　　　elseif (string.find(str, "SWX2200-24G", 1, true)) then
　　　　　　　　port_num = 24
　　　　　　　　cnt_id = 5
　　　　else
　　　　　　　　return nil
　　　　end

　　　　for i = 1, port_num do
　　　　　　　　rtn = switch_set_counter(i, cnt_id, "broadcast-and-multicast-packets")
　　　　　　　　if (not rtn) then
　　　　　　　　　　　　return nil
　　　　　　　　end
　　　　end

　　　　cmd = "switch select none"
　　　　rtn = rt.command(cmd)
　　　　return rtn
end

function read_counter_watch_pkts(sw)
　　　　local rtn, str, port_num, cnt_id
　　　　local val = {}

　　　　rtn, str = switch_model_read(sw)

　　　　if (not rtn) or (not str) then
　　　　　　　　return nil
　　　　end

　　　　if (string.find(str, "SWX2200-8G", 1, true)) then
　　　　　　　　port_num = 8
　　　　　　　　cnt_id = 3
　　　　elseif (string.find(str, "SWX2200-24G", 1, true)) then
　　　　　　　　port_num = 24
　　　　　　　　cnt_id = 5
　　　　else
　　　　　　　　return nil
　　　　end

　　　　for i = 1, port_num do
　　　　　　　　rtn, val[i] = switch_read_frame_counter(sw, "rx", i, cnt_id)
　　　　　　　　if (not rtn) or (not val[i]) then
　　　　　　　　　　　　return nil
　　　　　　　　end
　　　　end
　　　　return rtn, val
end

function time_stamp()
　　　　local t

　　　　t = os.date("*t")
　　　　return string.format("%d/%02d/%02d %02d:%02d:%02d",
　　　　　　　　t.year, t.month, t.day, t.hour, t.min, t.sec)
end

function get_port_cntinc_max(curr, prev)
　　　　local maxport
　　　　local maxinc = 0

　　　　if (curr == nil) or (prev == nil) then
　　　　　　　　return nil
　　　　end
　　　　if (#curr ~= #prev) then
　　　　　　　　return nil
　　　　end
　　　　for i, c in ipairs(curr) do
　　　　　　　　inc = curr[i] - prev[i]
　　　　　　　　if (inc > maxinc) then
　　　　　　　　　　　　maxinc = inc
　　　　　　　　　　　　maxport = i
　　　　　　　　end
　　　　end
　　　　return maxport
end

function get_storm_status(idx, sw)
　　　　local rtn, str, storm, limit

　　　　-- SWX2200の転送制限フラグを確認する
　　　　rtn = swx2200.is_storm_stt(sw)
　　　　if (rtn == true) then
　　　　　　　　limit = true
　　　　　　　　limit_cnt[idx] = limit_cnt[idx] + 1
　　　　　　　　-- SWX2200の転送制限フラグをクリアする
　　　　　　　　rtn = swx2200.clear_storm_stt(sw)
　　　　　　　　if (limit_cnt[idx] >= continue_time) then
　　　　　　　　　　　　storm = true
　　　　　　　　end
　　　　elseif (rtn == false) then
　　　　　　　　limit = false
　　　　　　　　limit_cnt[idx] = 0
　　　　else
　　　　　　　　if (limit_cnt[idx] > 0) then
　　　　　　　　　　　　limit = true
　　　　　　　　else
　　　　　　　　　　　　limit = false
　　　　　　　　end
　　　　　　　　str = string.format("failed to check packet storm status : "..
　　　　　　　　　　　　　　　　　　　　"'%s' swx2200_lua_bc_storm_ctl_rtx1200.lua", sw)
　　　　　　　　rt.syslog(log_level, str)
　　　　end
　　　　return storm, limit
end

function watch_switch(idx, sw)
　　　　local rtn, str, cnt_curr, msg, m_port, storm, limit

　　　　if (not limit_cfgd[idx]) then
　　　　　　　　-- SWX2200のパケットストーム制限・検出を有効にする
　　　　　　　　limit_cfgd[idx] = swx2200.set_storm_limit(sw, broadcast_rate,
　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　　 multicast_rate)
　　　　　　　　rtn = set_counter_watch_pkts(sw)
　　　　　　　　limit_cfgd[idx] = limit_cfgd[idx] and rtn
　　　　　　　　if (not limit_cfgd[idx]) then
　　　　　　　　　　　　str = string.format("failed to set packet storm limit : "..
　　　　　　　　　　　　　　　　　　　"'%s' swx2200_lua_bc_storm_ctl_rtx1200.lua", sw)
　　　　　　　　　　　　rt.syslog(log_level, str)
　　　　　　　　end
　　　　end

　　　　if (limit_cfgd[idx]) then
　　　　　　　　storm, limit = get_storm_status(idx, sw)
　　　　end

　　　　if (limit) then
　　　　　　　　rtn, cnt_curr = read_counter_watch_pkts(sw)
　　　　　　　　if (rtn) then
　　　　　　　　　　　　if (cnt_save[idx] == nil) then
　　　　　　　　　　　　　　　　cnt_save[idx] = {}
　　　　　　　　　　　　　　　　for p, c in ipairs(cnt_curr) do
　　　　　　　　　　　　　　　　　　　　cnt_save[idx][p] = c
　　　　　　　　　　　　　　　　end
　　　　　　　　　　　　end
　　　　　　　　　　　　m_port = get_port_cntinc_max(cnt_curr, cnt_save[idx])
　　　　　　　　end
　　　　　　　　str = string.format("broadcast-and-multicast-packets forwarding "..
　　　　　　　　　　　　　　"is limited : %s swx2200_lua_bc_storm_ctl_rtx1200.lua",
　　　　　　　　　　　　　　　　　　　　 sw)
　　　　　　　　rt.syslog(log_level, str)
　　　　else
　　　　　　　　cnt_save[idx] = nil
　　　　end

　　　　if (storm) then
　　　　　　　　rtn, str = switch_sys_name_read(sw)
　　　　　　　　str = string.split(str, "\r\n")
　　　　　　　　msg = string.format("* %s (%s)\r\n", str, sw)
　　　　　　　　rtn, str = switch_model_read(sw)
　　　　　　　　msg = msg .. string.format(" 機種名 : %s", str)
　　　　　　　　str = string.format("packet storm detected : %s "..
　　　　　　　　　　　　　　　　　　　　"swx2200_lua_bc_storm_ctl_rtx1200.lua", sw)
　　　　　　　　rt.syslog(log_level, str)
　　　　　　　　if (m_port ~= nil) then
　　　　　　　　　　　　msg = msg .. string.format(" (ポート %d で大量の"..
　　　　　　　　　　　　　　　　　　　　　　　　"パケットを受信しました)\r\n",
　　　　　　　　　　　　　　　　　　　　　　　　 m_port)
　　　　　　　　　　　　str = string.format("large amounts of broadcast-and-"..
　　　　　　　　　　　　　　　　　　　　　　　　"multicast-packets received : "..
　　　　　　　　　　　　　　　　　　　　　　　　"%s port %d swx2200_lua_bc_storm_ctl_rtx1200.lua",
　　　　　　　　　　　　　　　　　　　　　　　　 sw, m_port)
　　　　　　　　　　　　rt.syslog(log_level, str)
　　　　　　　　end
　　　　　　　　msg = msg .. "\r\n"
　　　　end
　　　　return storm, limit, msg
end

local rtn, rtn2, str, storm, limit, msg
if (_RT_LUA_VERSION_NUM < 101) then
　　　　str = "Lua script function version 1.01 or higher is required, terminated. "..
　　　　　　　 "swx2200_lua_bc_storm_ctl_rtx1200.lua"
　　　　rt.syslog(log_level, str)
　　　　return
end

while (true) do
　　　　storm = false
　　　　limit = false
　　　　msg = ""
　　　　for i, sw in ipairs(sw_list) do
　　　　　　　　rtn, rtn2, str = watch_switch(i, sw)
　　　　　　　　if (rtn) and (str) then
　　　　　　　　　　　　storm = true
　　　　　　　　　　　　msg = msg .. str
　　　　　　　　end
　　　　　　　　if (rtn2) then
　　　　　　　　　　　　limit = true
　　　　　　　　end
　　　　end

　　　　if (storm) and (mail) then
　　　　　　　　mail_tbl.text = "以下のスイッチでパケットストームを検出しました"..
　　　　　　　　　　　　　　　　"\r\n\r\n" .. msg
　　　　　　　　mail_tbl.subject = string.format("packet storm notify (%s)",
　　　　　　　　　　　　　　　　　　　　　　　　　　　　time_stamp())
　　　　　　　　rtn = rt.mail(mail_tbl)
　　　　　　　　if (rtn) then
　　　　　　　　　　　　str = "send packet storm notify mail. " ..
　　　　　　　　　　　　　　　　"swx2200_lua_bc_storm_ctl_rtx1200.lua"
　　　　　　　　　　　　rt.syslog(log_level, str)
　　　　　　　　else
　　　　　　　　　　　　str = "failed to send mail. swx2200_lua_bc_storm_ctl_rtx1200.lua"
　　　　　　　　　　　　rt.syslog(log_level, str)
　　　　　　　　end
　　　　end

　　　　if (limit) and (not storm) then
　　　　　　　　rt.sleep(1)
　　　　else
　　　　　　　　rt.sleep(idle_time)
　　　　end
end