cleanup and version increments
This commit is contained in:
parent
a7b3a2a0b8
commit
2e978db859
@ -168,12 +168,12 @@ function pocket.new_session(id, s_addr, i_seq_num, in_queue, out_queue, timeout)
|
|||||||
|
|
||||||
-- continue if valid unit id
|
-- continue if valid unit id
|
||||||
if util.is_int(uid) and uid > 0 and uid <= #db.units then
|
if util.is_int(uid) and uid > 0 and uid <= #db.units then
|
||||||
if cmd == UNIT_COMMAND.START then
|
if cmd == UNIT_COMMAND.SCRAM then
|
||||||
log.info(util.c(log_tag, "UNIT[", uid, "] START"))
|
|
||||||
self.proc_handle.start(uid)
|
|
||||||
elseif cmd == UNIT_COMMAND.SCRAM then
|
|
||||||
log.info(util.c(log_tag, "UNIT[", uid, "] SCRAM"))
|
log.info(util.c(log_tag, "UNIT[", uid, "] SCRAM"))
|
||||||
self.proc_handle.scram(uid)
|
self.proc_handle.scram(uid)
|
||||||
|
elseif cmd == UNIT_COMMAND.START then
|
||||||
|
log.info(util.c(log_tag, "UNIT[", uid, "] START"))
|
||||||
|
self.proc_handle.start(uid)
|
||||||
elseif cmd == UNIT_COMMAND.RESET_RPS then
|
elseif cmd == UNIT_COMMAND.RESET_RPS then
|
||||||
log.info(util.c(log_tag, "UNIT[", uid, "] RESET RPS"))
|
log.info(util.c(log_tag, "UNIT[", uid, "] RESET RPS"))
|
||||||
self.proc_handle.reset_rps(uid)
|
self.proc_handle.reset_rps(uid)
|
||||||
|
|||||||
@ -19,7 +19,7 @@ local renderer = require("coordinator.renderer")
|
|||||||
local sounder = require("coordinator.sounder")
|
local sounder = require("coordinator.sounder")
|
||||||
local threads = require("coordinator.threads")
|
local threads = require("coordinator.threads")
|
||||||
|
|
||||||
local COORDINATOR_VERSION = "v1.5.7"
|
local COORDINATOR_VERSION = "v1.5.8"
|
||||||
|
|
||||||
local CHUNK_LOAD_DELAY_S = 30.0
|
local CHUNK_LOAD_DELAY_S = 30.0
|
||||||
|
|
||||||
|
|||||||
@ -7,7 +7,7 @@ local flasher = require("graphics.flasher")
|
|||||||
|
|
||||||
local core = {}
|
local core = {}
|
||||||
|
|
||||||
core.version = "2.3.3"
|
core.version = "2.3.4"
|
||||||
|
|
||||||
core.flasher = flasher
|
core.flasher = flasher
|
||||||
core.events = events
|
core.events = events
|
||||||
|
|||||||
@ -152,7 +152,7 @@ local function hazard_button(args)
|
|||||||
tcd.abort(on_success)
|
tcd.abort(on_success)
|
||||||
tcd.abort(on_failure)
|
tcd.abort(on_failure)
|
||||||
|
|
||||||
-- operation timeout handling
|
-- operation timeout animation
|
||||||
tcd.dispatch(timeout, on_timeout)
|
tcd.dispatch(timeout, on_timeout)
|
||||||
|
|
||||||
args.callback()
|
args.callback()
|
||||||
|
|||||||
@ -307,15 +307,15 @@ function coordinator.new_session(id, s_addr, i_seq_num, in_queue, out_queue, tim
|
|||||||
local unit = self.units[uid] ---@type reactor_unit
|
local unit = self.units[uid] ---@type reactor_unit
|
||||||
local manual = facility.get_group(uid) == 0
|
local manual = facility.get_group(uid) == 0
|
||||||
|
|
||||||
if cmd == UNIT_COMMAND.START then
|
if cmd == UNIT_COMMAND.SCRAM then
|
||||||
|
out_queue.push_data(SV_Q_DATA.SCRAM, data)
|
||||||
|
elseif cmd == UNIT_COMMAND.START then
|
||||||
if manual then
|
if manual then
|
||||||
out_queue.push_data(SV_Q_DATA.START, data)
|
out_queue.push_data(SV_Q_DATA.START, data)
|
||||||
else
|
else
|
||||||
-- denied
|
-- denied
|
||||||
_send(CRDN_TYPE.UNIT_CMD, { cmd, uid, false })
|
_send(CRDN_TYPE.UNIT_CMD, { cmd, uid, false })
|
||||||
end
|
end
|
||||||
elseif cmd == UNIT_COMMAND.SCRAM then
|
|
||||||
out_queue.push_data(SV_Q_DATA.SCRAM, data)
|
|
||||||
elseif cmd == UNIT_COMMAND.RESET_RPS then
|
elseif cmd == UNIT_COMMAND.RESET_RPS then
|
||||||
out_queue.push_data(SV_Q_DATA.RESET_RPS, data)
|
out_queue.push_data(SV_Q_DATA.RESET_RPS, data)
|
||||||
elseif cmd == UNIT_COMMAND.SET_BURN then
|
elseif cmd == UNIT_COMMAND.SET_BURN then
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user