supervisor unit sessions now actually call txnctrl.cleanup

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

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

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

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

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
 

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