mirror of
https://github.com/ParadiseSS13/Paradise.git
synced 2025-12-24 17:22:23 +00:00
129 lines
3.7 KiB
Plaintext
129 lines
3.7 KiB
Plaintext
#define SSMACHINES_DEFERREDPOWERNETS 1
|
|
#define SSMACHINES_POWERNETS 2
|
|
#define SSMACHINES_PREMACHINERY 3
|
|
#define SSMACHINES_MACHINERY 4
|
|
SUBSYSTEM_DEF(machines)
|
|
name = "Machines"
|
|
init_order = INIT_ORDER_MACHINES
|
|
flags = SS_KEEP_TIMING
|
|
offline_implications = "Machinery will no longer process. Shuttle call recommended."
|
|
|
|
var/list/processing = list()
|
|
var/list/currentrun = list()
|
|
var/list/powernets = list()
|
|
var/list/deferred_powernet_rebuilds = list()
|
|
|
|
var/currentpart = SSMACHINES_DEFERREDPOWERNETS
|
|
|
|
/datum/controller/subsystem/machines/Initialize()
|
|
makepowernets()
|
|
fire()
|
|
return ..()
|
|
|
|
/datum/controller/subsystem/machines/get_metrics()
|
|
. = ..()
|
|
var/list/cust = list()
|
|
cust["processing"] = length(processing)
|
|
.["custom"] = cust
|
|
|
|
/datum/controller/subsystem/machines/proc/makepowernets()
|
|
for(var/datum/powernet/PN in powernets)
|
|
qdel(PN)
|
|
powernets.Cut()
|
|
|
|
for(var/obj/structure/cable/PC in GLOB.cable_list)
|
|
if(!PC.powernet)
|
|
var/datum/powernet/NewPN = new()
|
|
NewPN.add_cable(PC)
|
|
propagate_network(PC,PC.powernet)
|
|
|
|
/datum/controller/subsystem/machines/stat_entry()
|
|
..("Machines: [processing.len]\nPowernets: [powernets.len]\tDeferred: [deferred_powernet_rebuilds.len]")
|
|
|
|
/datum/controller/subsystem/machines/proc/process_defered_powernets(resumed = 0)
|
|
if(!resumed)
|
|
src.currentrun = deferred_powernet_rebuilds.Copy()
|
|
//cache for sanid speed (lists are references anyways)
|
|
var/list/currentrun = src.currentrun
|
|
while(currentrun.len)
|
|
var/obj/O = currentrun[currentrun.len]
|
|
currentrun.len--
|
|
if(O && !QDELETED(O))
|
|
var/datum/powernet/newPN = new() // create a new powernet...
|
|
propagate_network(O, newPN)//... and propagate it to the other side of the cable
|
|
|
|
deferred_powernet_rebuilds.Remove(O)
|
|
if(MC_TICK_CHECK)
|
|
return
|
|
|
|
/datum/controller/subsystem/machines/proc/process_powernets(resumed = 0)
|
|
if(!resumed)
|
|
src.currentrun = powernets.Copy()
|
|
//cache for sanid speed (lists are references anyways)
|
|
var/list/currentrun = src.currentrun
|
|
while(currentrun.len)
|
|
var/datum/powernet/P = currentrun[currentrun.len]
|
|
currentrun.len--
|
|
if(P)
|
|
P.reset() // reset the power state
|
|
else
|
|
powernets.Remove(P)
|
|
if(MC_TICK_CHECK)
|
|
return
|
|
|
|
/datum/controller/subsystem/machines/proc/process_machines(resumed = 0)
|
|
var/seconds = wait * 0.1
|
|
if(!resumed)
|
|
src.currentrun = processing.Copy()
|
|
//cache for sanic speed (lists are references anyways)
|
|
var/list/currentrun = src.currentrun
|
|
while(currentrun.len)
|
|
var/obj/machinery/thing = currentrun[currentrun.len]
|
|
currentrun.len--
|
|
if(!QDELETED(thing) && thing.process(seconds) != PROCESS_KILL)
|
|
if(thing.use_power)
|
|
thing.auto_use_power() //add back the power state
|
|
else
|
|
processing -= thing
|
|
if(!QDELETED(thing))
|
|
thing.isprocessing = FALSE
|
|
if(MC_TICK_CHECK)
|
|
return
|
|
|
|
/datum/controller/subsystem/machines/fire(resumed = 0)
|
|
if(currentpart == SSMACHINES_DEFERREDPOWERNETS || !resumed)
|
|
process_defered_powernets(resumed)
|
|
if(state != SS_RUNNING)
|
|
return
|
|
resumed = 0
|
|
currentpart = SSMACHINES_POWERNETS
|
|
|
|
if(currentpart == SSMACHINES_POWERNETS || !resumed)
|
|
process_powernets(resumed)
|
|
if(state != SS_RUNNING)
|
|
return
|
|
resumed = 0
|
|
currentpart = SSMACHINES_MACHINERY
|
|
|
|
if(currentpart == SSMACHINES_MACHINERY || !resumed)
|
|
process_machines(resumed)
|
|
if(state != SS_RUNNING)
|
|
return
|
|
resumed = 0
|
|
currentpart = SSMACHINES_DEFERREDPOWERNETS
|
|
|
|
|
|
/datum/controller/subsystem/machines/proc/setup_template_powernets(list/cables)
|
|
for(var/A in cables)
|
|
var/obj/structure/cable/PC = A
|
|
if(!PC.powernet)
|
|
var/datum/powernet/NewPN = new()
|
|
NewPN.add_cable(PC)
|
|
propagate_network(PC,PC.powernet)
|
|
|
|
/datum/controller/subsystem/machines/Recover()
|
|
if(istype(SSmachines.processing))
|
|
processing = SSmachines.processing
|
|
if(istype(SSmachines.powernets))
|
|
powernets = SSmachines.powernets
|