mirror of
https://github.com/MikaylaFischler/cc-mek-scada.git
synced 2024-08-30 18:22:34 +00:00
#11 standalone de-asserts SCRAM and resets ISS before check, added prints to ISS, fixed non-networked mode related bugs, cleaned up ISS check call in startup
This commit is contained in:
parent
ba1dd1b50e
commit
7e7e98ff6b
@ -50,14 +50,19 @@ function iss_init(reactor)
|
||||
|
||||
-- check system states in order of severity
|
||||
if damage_critical() then
|
||||
log._warning("ISS: damage critical!")
|
||||
status = "dmg_crit"
|
||||
elseif high_temp() then
|
||||
log._warning("ISS: high temperature!")
|
||||
status = "high_temp"
|
||||
elseif excess_heated_coolant() then
|
||||
log._warning("ISS: heated coolant backup!")
|
||||
status = "heated_coolant_backup"
|
||||
elseif excess_waste() then
|
||||
log._warning("ISS: full waste!")
|
||||
status = "full_waste"
|
||||
elseif insufficient_fuel() then
|
||||
log._warning("ISS: no fuel!")
|
||||
status = "no_fuel"
|
||||
elseif self.tripped then
|
||||
status = self.trip_cause
|
||||
@ -66,6 +71,7 @@ function iss_init(reactor)
|
||||
end
|
||||
|
||||
if status ~= "ok" then
|
||||
log._warning("ISS: reactor SCRAM")
|
||||
self.tripped = true
|
||||
self.trip_cause = status
|
||||
self.reactor.scram()
|
||||
@ -378,7 +384,7 @@ function comms_init(id, modem, local_port, server_port, reactor, iss)
|
||||
end
|
||||
|
||||
-- handle an RPLC packet
|
||||
local handle_packet = function (packet)
|
||||
local handle_packet = function (packet, plc_state)
|
||||
if packet ~= nil then
|
||||
if packet.scada_frame.protocol() == PROTOCOLS.RPLC then
|
||||
if self.linked then
|
||||
@ -424,10 +430,12 @@ function comms_init(id, modem, local_port, server_port, reactor, iss)
|
||||
elseif packet.type == RPLC_TYPES.MEK_SCRAM then
|
||||
-- disable the reactor
|
||||
self.scrammed = true
|
||||
plc_state.scram = true
|
||||
_send_ack(packet.type, self.reactor.scram())
|
||||
elseif packet.type == RPLC_TYPES.MEK_ENABLE then
|
||||
-- enable the reactor
|
||||
self.scrammed = false
|
||||
plc_state.scram = false
|
||||
_send_ack(packet.type, self.reactor.activate())
|
||||
elseif packet.type == RPLC_TYPES.MEK_BURN_RATE then
|
||||
-- set the burn rate
|
||||
|
@ -10,7 +10,7 @@ os.loadAPI("scada-common/comms.lua")
|
||||
os.loadAPI("config.lua")
|
||||
os.loadAPI("plc.lua")
|
||||
|
||||
local R_PLC_VERSION = "alpha-v0.1.2"
|
||||
local R_PLC_VERSION = "alpha-v0.1.3"
|
||||
|
||||
local print = util.print
|
||||
local println = util.println
|
||||
@ -32,7 +32,7 @@ local networked = config.NETWORKED
|
||||
|
||||
local plc_state = {
|
||||
init_ok = true,
|
||||
scram = true, -- treated as latching e-stop, all conditions must be OK to set false
|
||||
scram = true,
|
||||
degraded = false,
|
||||
no_reactor = false,
|
||||
no_modem = false
|
||||
@ -69,7 +69,7 @@ local conn_watchdog = nil
|
||||
local UPDATE_TICKS = 3
|
||||
local LINK_TICKS = 20
|
||||
|
||||
local loop_tick = nil
|
||||
local loop_clock = nil
|
||||
local ticks_to_update = LINK_TICKS -- start by linking
|
||||
|
||||
function init()
|
||||
@ -94,7 +94,7 @@ function init()
|
||||
end
|
||||
|
||||
-- loop clock (10Hz, 2 ticks)
|
||||
loop_tick = os.startTimer(0.05)
|
||||
loop_clock = os.startTimer(0.05)
|
||||
log._debug("loop clock started")
|
||||
|
||||
println("boot> completed");
|
||||
@ -198,43 +198,62 @@ while true do
|
||||
end
|
||||
end
|
||||
|
||||
-- check safety (SCRAM occurs if tripped)
|
||||
if not plc_state.degraded then
|
||||
local iss_tripped, iss_status, iss_first = iss.check()
|
||||
plc_state.scram = plc_state.scram or iss_tripped
|
||||
if networked and iss_first then
|
||||
plc_comms.send_iss_alarm(iss_status)
|
||||
-- ISS
|
||||
if plc_state.init_ok then
|
||||
-- if we are in standalone mode, continuously reset ISS
|
||||
-- ISS will trip again if there are faults, but if it isn't cleared, the user can't re-enable
|
||||
if not networked then
|
||||
plc_state.scram = false
|
||||
iss.reset()
|
||||
end
|
||||
|
||||
-- check safety (SCRAM occurs if tripped)
|
||||
if not plc_state.degraded then
|
||||
local iss_tripped, iss_status, iss_first = iss.check()
|
||||
plc_state.scram = plc_state.scram or iss_tripped
|
||||
|
||||
if iss_first then
|
||||
println_ts("[ISS] reactor shutdown, safety tripped: " .. iss_status)
|
||||
if networked then
|
||||
plc_comms.send_iss_alarm(iss_status)
|
||||
end
|
||||
end
|
||||
else
|
||||
reactor.scram()
|
||||
end
|
||||
elseif plc_state.init_ok then
|
||||
reactor.scram()
|
||||
end
|
||||
|
||||
-- handle event
|
||||
if event == "timer" and param1 == loop_tick and networked and not plc_state.no_modem then
|
||||
if event == "timer" and param1 == loop_clock then
|
||||
-- basic event tick, send updated data if it is time (~3.33Hz)
|
||||
-- iss was already checked (that's the main reason for this tick rate)
|
||||
ticks_to_update = ticks_to_update - 1
|
||||
if networked and not plc_state.no_modem then
|
||||
ticks_to_update = ticks_to_update - 1
|
||||
|
||||
if plc_comms.is_linked() then
|
||||
if ticks_to_update <= 0 then
|
||||
plc_comms.send_status(iss_tripped)
|
||||
ticks_to_update = UPDATE_TICKS
|
||||
end
|
||||
else
|
||||
if ticks_to_update <= 0 then
|
||||
plc_comms.send_link_req()
|
||||
ticks_to_update = LINK_TICKS
|
||||
if plc_comms.is_linked() then
|
||||
if ticks_to_update <= 0 then
|
||||
plc_comms.send_status(iss_tripped)
|
||||
ticks_to_update = UPDATE_TICKS
|
||||
end
|
||||
else
|
||||
if ticks_to_update <= 0 then
|
||||
plc_comms.send_link_req()
|
||||
ticks_to_update = LINK_TICKS
|
||||
end
|
||||
end
|
||||
end
|
||||
|
||||
-- start next clock timer
|
||||
loop_clock = os.startTimer(0.05)
|
||||
elseif event == "modem_message" and networked and not plc_state.no_modem then
|
||||
-- got a packet
|
||||
-- feed the watchdog first so it doesn't uhh...eat our packets
|
||||
conn_watchdog.feed()
|
||||
|
||||
-- handle the packet (plc_state passed to allow clearing SCRAM flag)
|
||||
local packet = plc_comms.parse_packet(p1, p2, p3, p4, p5)
|
||||
plc_comms.handle_packet(packet)
|
||||
plc_state.scram = plc_state.scram or plc_comms.is_scrammed()
|
||||
elseif event == "timer" and param1 == conn_watchdog.get_timer() and networked then
|
||||
plc_comms.handle_packet(packet, plc_state)
|
||||
elseif event == "timer" and networked and param1 == conn_watchdog.get_timer() then
|
||||
-- haven't heard from server recently? shutdown reactor
|
||||
plc_state.scram = true
|
||||
plc_comms.unlink()
|
||||
|
Loading…
Reference in New Issue
Block a user