#543 reset remote sequence numbers when linking

This commit is contained in:
Mikayla Fischler 2024-08-28 21:01:04 -04:00
parent 705494bb7e
commit 035a26cc07
8 changed files with 9 additions and 4 deletions

View File

@ -296,6 +296,7 @@ function coordinator.comms(version, nic, sv_watchdog)
-- attempt connection establishment
local function _send_establish()
self.sv_r_seq_num = nil
_send_sv(PROTOCOL.SCADA_MGMT, MGMT_TYPE.ESTABLISH, { comms.version, version, DEVICE_TYPE.CRD })
end

View File

@ -19,7 +19,7 @@ local renderer = require("coordinator.renderer")
local sounder = require("coordinator.sounder")
local threads = require("coordinator.threads")
local COORDINATOR_VERSION = "v1.5.6"
local COORDINATOR_VERSION = "v1.5.7"
local CHUNK_LOAD_DELAY_S = 30.0

View File

@ -439,11 +439,13 @@ function pocket.comms(version, nic, sv_watchdog, api_watchdog, nav)
-- attempt supervisor connection establishment
local function _send_sv_establish()
self.sv.r_seq_num = nil
_send_sv(MGMT_TYPE.ESTABLISH, { comms.version, version, DEVICE_TYPE.PKT })
end
-- attempt coordinator API connection establishment
local function _send_api_establish()
self.api.r_seq_num = nil
_send_crd(MGMT_TYPE.ESTABLISH, { comms.version, version, DEVICE_TYPE.PKT, comms.api_version })
end

View File

@ -20,7 +20,7 @@ local pocket = require("pocket.pocket")
local renderer = require("pocket.renderer")
local threads = require("pocket.threads")
local POCKET_VERSION = "v0.11.8-alpha"
local POCKET_VERSION = "v0.11.9-alpha"
local println = util.println
local println_ts = util.println_ts

View File

@ -735,6 +735,7 @@ function plc.comms(version, nic, reactor, rps, conn_watchdog)
-- attempt to establish link with supervisor
function public.send_link_req()
self.r_seq_num = nil
_send_mgmt(MGMT_TYPE.ESTABLISH, { comms.version, version, DEVICE_TYPE.PLC, config.UnitID })
end

View File

@ -18,7 +18,7 @@ local plc = require("reactor-plc.plc")
local renderer = require("reactor-plc.renderer")
local threads = require("reactor-plc.threads")
local R_PLC_VERSION = "v1.8.6"
local R_PLC_VERSION = "v1.8.7"
local println = util.println
local println_ts = util.println_ts

View File

@ -378,6 +378,7 @@ function rtu.comms(version, nic, conn_watchdog)
-- send establish request (includes advertisement)
---@param units table
function public.send_establish(units)
self.r_seq_num = nil
_send(MGMT_TYPE.ESTABLISH, { comms.version, version, DEVICE_TYPE.RTU, _generate_advertisement(units) })
end

View File

@ -31,7 +31,7 @@ local sna_rtu = require("rtu.dev.sna_rtu")
local sps_rtu = require("rtu.dev.sps_rtu")
local turbinev_rtu = require("rtu.dev.turbinev_rtu")
local RTU_VERSION = "v1.10.6"
local RTU_VERSION = "v1.10.7"
local RTU_UNIT_TYPE = types.RTU_UNIT_TYPE
local RTU_UNIT_HW_STATE = databus.RTU_UNIT_HW_STATE