diff --git a/supervisor/session/rtu/boiler.lua b/supervisor/session/rtu/boiler.lua index 552b3e2..f34dbc3 100644 --- a/supervisor/session/rtu/boiler.lua +++ b/supervisor/session/rtu/boiler.lua @@ -177,6 +177,8 @@ function boiler.new(session_id, unit_id, advert, out_queue) _request_tanks() self.periodics.next_tanks_req = time_now + PERIODICS.TANKS end + + self.session.post_update() end -- get the unit session database diff --git a/supervisor/session/rtu/emachine.lua b/supervisor/session/rtu/emachine.lua index 525fa07..fa34d21 100644 --- a/supervisor/session/rtu/emachine.lua +++ b/supervisor/session/rtu/emachine.lua @@ -117,6 +117,8 @@ function emachine.new(session_id, unit_id, advert, out_queue) _request_storage() self.periodics.next_storage_req = time_now + PERIODICS.STORAGE end + + self.session.post_update() end -- get the unit session database diff --git a/supervisor/session/rtu/redstone.lua b/supervisor/session/rtu/redstone.lua index e870201..3200eef 100644 --- a/supervisor/session/rtu/redstone.lua +++ b/supervisor/session/rtu/redstone.lua @@ -243,6 +243,8 @@ function redstone.new(session_id, unit_id, advert, out_queue) self.periodics.next_ir_req = time_now + PERIODICS.INPUT_READ end end + + self.session.post_update() end -- get the unit session database diff --git a/supervisor/session/rtu/turbine.lua b/supervisor/session/rtu/turbine.lua index 913f007..c6578fa 100644 --- a/supervisor/session/rtu/turbine.lua +++ b/supervisor/session/rtu/turbine.lua @@ -165,6 +165,8 @@ function turbine.new(session_id, unit_id, advert, out_queue) _request_tanks() self.periodics.next_tanks_req = time_now + PERIODICS.TANKS end + + self.session.post_update() end -- get the unit session database diff --git a/supervisor/session/rtu/unit_session.lua b/supervisor/session/rtu/unit_session.lua index ee7a217..ba2e988 100644 --- a/supervisor/session/rtu/unit_session.lua +++ b/supervisor/session/rtu/unit_session.lua @@ -111,6 +111,11 @@ function unit_session.new(unit_id, advert, out_queue, log_tag, txn_tags) return false end + -- post update tasks + function protected.post_update() + self.transaction_controller.cleanup() + end + -- get the public interface function protected.get() return public end diff --git a/supervisor/startup.lua b/supervisor/startup.lua index 8bffd4f..1e77fa9 100644 --- a/supervisor/startup.lua +++ b/supervisor/startup.lua @@ -13,7 +13,7 @@ local svsessions = require("supervisor.session.svsessions") local config = require("supervisor.config") local supervisor = require("supervisor.supervisor") -local SUPERVISOR_VERSION = "beta-v0.4.2" +local SUPERVISOR_VERSION = "beta-v0.4.3" local print = util.print local println = util.println