cyberpresidentvanellope/CHOMPStation2
1
0
Fork 0
mirror of https://github.com/CHOMPStation2/CHOMPStation2.git synced 2025-12-11 18:53:06 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge air_master into SSair, now its all one type

Browse Source
This commit is contained in:
Leshana
2018-01-26 00:33:40 -05:00
parent 4c8bce00b4
commit 393673baa4
2 changed files with 67 additions and 73 deletions
Download Patch File Download Diff File Expand all files Collapse all files

61
code/ZAS/Controller.dm
View File

@@ -1,4 +1,4 @@
var/datum/controller/air_system/air_master var/datum/controller/subsystem/air/air_master
var/tick_multiplier = 2 var/tick_multiplier = 2
@@ -65,34 +65,35 @@ Class Procs:
*/ */
//
// The rest of the air subsystem is defined in air.dm
//
//Geometry lists /datum/controller/subsystem/air
/datum/controller/air_system/var/list/zones = list() //Geometry lists
/datum/controller/air_system/var/list/edges = list() var/list/zones = list()
var/list/edges = list()
//Geometry updates lists
var/list/tiles_to_update = list()
var/list/zones_to_update = list()
var/list/active_fire_zones = list()
var/list/active_hotspots = list()
var/list/active_edges = list()
//Geometry updates lists var/active_zones = 0
/datum/controller/air_system/var/list/tiles_to_update = list() var/current_cycle = 0
/datum/controller/air_system/var/list/zones_to_update = list() var/next_id = 1 //Used to keep track of zone UIDs.
/datum/controller/air_system/var/list/active_fire_zones = list()
/datum/controller/air_system/var/list/active_hotspots = list()
/datum/controller/air_system/var/list/active_edges = list()
/datum/controller/air_system/var/active_zones = 0 /datum/controller/subsystem/air/proc/add_zone(zone/z)
/datum/controller/air_system/var/current_cycle = 0
/datum/controller/air_system/var/next_id = 1 //Used to keep track of zone UIDs.
/datum/controller/air_system/proc/add_zone(zone/z)
zones.Add(z) zones.Add(z)
z.name = "Zone [next_id++]" z.name = "Zone [next_id++]"
mark_zone_update(z) mark_zone_update(z)
/datum/controller/air_system/proc/remove_zone(zone/z) /datum/controller/subsystem/air/proc/remove_zone(zone/z)
zones.Remove(z) zones.Remove(z)
zones_to_update.Remove(z) zones_to_update.Remove(z)
/datum/controller/air_system/proc/air_blocked(turf/A, turf/B) /datum/controller/subsystem/air/proc/air_blocked(turf/A, turf/B)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(isturf(A)) ASSERT(isturf(A))
ASSERT(isturf(B)) ASSERT(isturf(B))
@@ -101,13 +102,13 @@ Class Procs:
if(ablock == BLOCKED) return BLOCKED if(ablock == BLOCKED) return BLOCKED
return ablock | B.c_airblock(A) return ablock | B.c_airblock(A)
/datum/controller/air_system/proc/has_valid_zone(turf/simulated/T) /datum/controller/subsystem/air/proc/has_valid_zone(turf/simulated/T)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(istype(T)) ASSERT(istype(T))
#endif #endif
return istype(T) && T.zone && !T.zone.invalid return istype(T) && T.zone && !T.zone.invalid
/datum/controller/air_system/proc/merge(zone/A, zone/B) /datum/controller/subsystem/air/proc/merge(zone/A, zone/B)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(istype(A)) ASSERT(istype(A))
ASSERT(istype(B)) ASSERT(istype(B))
@@ -122,7 +123,7 @@ Class Procs:
B.c_merge(A) B.c_merge(A)
mark_zone_update(A) mark_zone_update(A)
/datum/controller/air_system/proc/connect(turf/simulated/A, turf/simulated/B) /datum/controller/subsystem/air/proc/connect(turf/simulated/A, turf/simulated/B)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(istype(A)) ASSERT(istype(A))
ASSERT(isturf(B)) ASSERT(isturf(B))
@@ -163,7 +164,7 @@ Class Procs:
if(direct) c.mark_direct() if(direct) c.mark_direct()
/datum/controller/air_system/proc/mark_for_update(turf/T) /datum/controller/subsystem/air/proc/mark_for_update(turf/T)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(isturf(T)) ASSERT(isturf(T))
#endif #endif
@@ -174,7 +175,7 @@ Class Procs:
#endif #endif
T.needs_air_update = 1 T.needs_air_update = 1
/datum/controller/air_system/proc/mark_zone_update(zone/Z) /datum/controller/subsystem/air/proc/mark_zone_update(zone/Z)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(istype(Z)) ASSERT(istype(Z))
#endif #endif
@@ -182,7 +183,7 @@ Class Procs:
zones_to_update.Add(Z) zones_to_update.Add(Z)
Z.needs_update = 1 Z.needs_update = 1
/datum/controller/air_system/proc/mark_edge_sleeping(connection_edge/E) /datum/controller/subsystem/air/proc/mark_edge_sleeping(connection_edge/E)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(istype(E)) ASSERT(istype(E))
#endif #endif
@@ -190,7 +191,7 @@ Class Procs:
active_edges.Remove(E) active_edges.Remove(E)
E.sleeping = 1 E.sleeping = 1
/datum/controller/air_system/proc/mark_edge_active(connection_edge/E) /datum/controller/subsystem/air/proc/mark_edge_active(connection_edge/E)
#ifdef ZASDBG #ifdef ZASDBG
ASSERT(istype(E)) ASSERT(istype(E))
#endif #endif
@@ -198,10 +199,10 @@ Class Procs:
active_edges.Add(E) active_edges.Add(E)
E.sleeping = 0 E.sleeping = 0
/datum/controller/air_system/proc/equivalent_pressure(zone/A, zone/B) /datum/controller/subsystem/air/proc/equivalent_pressure(zone/A, zone/B)
return A.air.compare(B.air) return A.air.compare(B.air)
/datum/controller/air_system/proc/get_edge(zone/A, zone/B) /datum/controller/subsystem/air/proc/get_edge(zone/A, zone/B)
if(istype(B)) if(istype(B))
for(var/connection_edge/zone/edge in A.edges) for(var/connection_edge/zone/edge in A.edges)
@@ -218,7 +219,7 @@ Class Procs:
edge.recheck() edge.recheck()
return edge return edge
/datum/controller/air_system/proc/has_same_air(turf/A, turf/B) /datum/controller/subsystem/air/proc/has_same_air(turf/A, turf/B)
if(A.oxygen != B.oxygen) return 0 if(A.oxygen != B.oxygen) return 0
if(A.nitrogen != B.nitrogen) return 0 if(A.nitrogen != B.nitrogen) return 0
if(A.phoron != B.phoron) return 0 if(A.phoron != B.phoron) return 0
@@ -226,6 +227,6 @@ Class Procs:
if(A.temperature != B.temperature) return 0 if(A.temperature != B.temperature) return 0
return 1 return 1
/datum/controller/air_system/proc/remove_edge(connection_edge/E) /datum/controller/subsystem/air/proc/remove_edge(connection_edge/E)
edges.Remove(E) edges.Remove(E)
if(!E.sleeping) active_edges.Remove(E) if(!E.sleeping) active_edges.Remove(E)

79
code/controllers/subsystems/air.dm
View File

@@ -28,13 +28,12 @@ SUBSYSTEM_DEF(air)
var/list/selfblock_deferred = null var/list/selfblock_deferred = null
/datum/controller/subsystem/air/PreInit() /datum/controller/subsystem/air/PreInit()
// Initialize the singleton /datum/controller/air_system air_master = src
// TODO - We could actually incorporate that into this subsystem! But in the spirit of not fucking with ZAS more than necessary, lets not for now. ~Leshana
air_master = new()
/datum/controller/subsystem/air/Initialize(timeofday) /datum/controller/subsystem/air/Initialize(timeofday)
report_progress("Processing Geometry...") report_progress("Processing Geometry...")
current_cycle = 0
var/simulated_turf_count = 0 var/simulated_turf_count = 0
for(var/turf/simulated/S in world) for(var/turf/simulated/S in world)
simulated_turf_count++ simulated_turf_count++
@@ -44,17 +43,17 @@ SUBSYSTEM_DEF(air)
admin_notice({"<span class='danger'>Geometry initialized in [round(0.1*(REALTIMEOFDAY-timeofday),0.1)] seconds.</span> admin_notice({"<span class='danger'>Geometry initialized in [round(0.1*(REALTIMEOFDAY-timeofday),0.1)] seconds.</span>
<span class='info'> <span class='info'>
Total Simulated Turfs: [simulated_turf_count] Total Simulated Turfs: [simulated_turf_count]
Total Zones: [air_master.zones.len] Total Zones: [zones.len]
Total Edges: [air_master.edges.len] Total Edges: [edges.len]
Total Active Edges: [air_master.active_edges.len ? "<span class='danger'>[air_master.active_edges.len]</span>" : "None"] Total Active Edges: [active_edges.len ? "<span class='danger'>[active_edges.len]</span>" : "None"]
Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_count] Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_count]
</span>"}, R_DEBUG) </span>"}, R_DEBUG)
// Note - Baystation settles the air by running for one tick. We prefer to not have active edges. // Note - Baystation settles the air by running for one tick. We prefer to not have active edges.
// Maps should not have active edges on boot. If we've got some, log it so it can get fixed. // Maps should not have active edges on boot. If we've got some, log it so it can get fixed.
if(air_master.active_edges.len) if(active_edges.len)
var/list/edge_log = list() var/list/edge_log = list()
for(var/connection_edge/E in air_master.active_edges) for(var/connection_edge/E in active_edges)
edge_log += "Active Edge [E] ([E.type])" edge_log += "Active Edge [E] ([E.type])"
for(var/turf/T in E.connecting_turfs) for(var/turf/T in E.connecting_turfs)
edge_log += "+--- Connecting Turf [T] @ [T.x], [T.y], [T.z]" edge_log += "+--- Connecting Turf [T] @ [T.x], [T.y], [T.z]"
@@ -67,7 +66,7 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
if(!resumed) if(!resumed)
ASSERT(LAZYLEN(currentrun) == 0) // Santity checks to make sure we don't somehow have items left over from last cycle ASSERT(LAZYLEN(currentrun) == 0) // Santity checks to make sure we don't somehow have items left over from last cycle
ASSERT(current_step == null) // Or somehow didn't finish all the steps from last cycle ASSERT(current_step == null) // Or somehow didn't finish all the steps from last cycle
air_master.current_cycle++ // Begin a new air_master cycle! current_cycle++ // Begin a new air_master cycle!
current_step = SSAIR_TURFS // Start with Step 1 of course current_step = SSAIR_TURFS // Start with Step 1 of course
INTERNAL_PROCESS_STEP(SSAIR_TURFS, TRUE, process_tiles_to_update, cost_turfs, SSAIR_EDGES) INTERNAL_PROCESS_STEP(SSAIR_TURFS, TRUE, process_tiles_to_update, cost_turfs, SSAIR_EDGES)
@@ -86,8 +85,8 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
if (!resumed) if (!resumed)
// NOT a copy, because we are supposed to drain active turfs each cycle anyway, so just replace with empty list. // NOT a copy, because we are supposed to drain active turfs each cycle anyway, so just replace with empty list.
// We still use a separate list tho, to ensure we don't process a turf twice during a single cycle! // We still use a separate list tho, to ensure we don't process a turf twice during a single cycle!
src.currentrun = air_master.tiles_to_update src.currentrun = tiles_to_update
air_master.tiles_to_update = list() tiles_to_update = list()
//defer updating of self-zone-blocked turfs until after all other turfs have been updated. //defer updating of self-zone-blocked turfs until after all other turfs have been updated.
//this hopefully ensures that non-self-zone-blocked turfs adjacent to self-zone-blocked ones //this hopefully ensures that non-self-zone-blocked turfs adjacent to self-zone-blocked ones
@@ -141,7 +140,7 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
/datum/controller/subsystem/air/proc/process_active_edges(resumed = 0) /datum/controller/subsystem/air/proc/process_active_edges(resumed = 0)
if (!resumed) if (!resumed)
src.currentrun = air_master.active_edges.Copy() src.currentrun = active_edges.Copy()
//cache for sanic speed (lists are references anyways) //cache for sanic speed (lists are references anyways)
var/list/currentrun = src.currentrun var/list/currentrun = src.currentrun
while(currentrun.len) while(currentrun.len)
@@ -154,7 +153,7 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
/datum/controller/subsystem/air/proc/process_active_fire_zones(resumed = 0) /datum/controller/subsystem/air/proc/process_active_fire_zones(resumed = 0)
if (!resumed) if (!resumed)
src.currentrun = air_master.active_fire_zones.Copy() src.currentrun = active_fire_zones.Copy()
//cache for sanic speed (lists are references anyways) //cache for sanic speed (lists are references anyways)
var/list/currentrun = src.currentrun var/list/currentrun = src.currentrun
while(currentrun.len) while(currentrun.len)
@@ -167,7 +166,7 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
/datum/controller/subsystem/air/proc/process_active_hotspots(resumed = 0) /datum/controller/subsystem/air/proc/process_active_hotspots(resumed = 0)
if (!resumed) if (!resumed)
src.currentrun = air_master.active_hotspots.Copy() src.currentrun = active_hotspots.Copy()
//cache for sanic speed (lists are references anyways) //cache for sanic speed (lists are references anyways)
var/list/currentrun = src.currentrun var/list/currentrun = src.currentrun
while(currentrun.len) while(currentrun.len)
@@ -180,15 +179,15 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
/datum/controller/subsystem/air/proc/process_zones_to_update(resumed = 0) /datum/controller/subsystem/air/proc/process_zones_to_update(resumed = 0)
if (!resumed) if (!resumed)
air_master.active_zones = air_master.zones_to_update.len // Save how many zones there were to update this cycle (used by some debugging stuff) active_zones = zones_to_update.len // Save how many zones there were to update this cycle (used by some debugging stuff)
if(!air_master.zones_to_update.len) if(!zones_to_update.len)
return // Nothing to do here this cycle! return // Nothing to do here this cycle!
// NOT a copy, because we are supposed to drain active turfs each cycle anyway, so just replace with empty list. // NOT a copy, because we are supposed to drain active turfs each cycle anyway, so just replace with empty list.
// Blanking the public list means we actually are removing processed ones from the list! Maybe we could we use zones_for_update directly? // Blanking the public list means we actually are removing processed ones from the list! Maybe we could we use zones_for_update directly?
// But if we dom any zones added to zones_to_update DURING this step will get processed again during this step. // But if we dom any zones added to zones_to_update DURING this step will get processed again during this step.
// I don't know if that actually happens? But if it does, it could lead to an infinate loop. Better preserve original semantics. // I don't know if that actually happens? But if it does, it could lead to an infinate loop. Better preserve original semantics.
src.currentrun = air_master.zones_to_update src.currentrun = zones_to_update
air_master.zones_to_update = list() zones_to_update = list()
//cache for sanic speed (lists are references anyways) //cache for sanic speed (lists are references anyways)
var/list/currentrun = src.currentrun var/list/currentrun = src.currentrun
@@ -211,23 +210,8 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
msg += "H [round(cost_hotspots, 1)] | " msg += "H [round(cost_hotspots, 1)] | "
msg += "Z [round(cost_zones, 1)] " msg += "Z [round(cost_zones, 1)] "
msg += "}" msg += "}"
if(air_master) msg += "Z: [zones.len] "
msg += "T:[round((cost ? air_master.tiles_to_update.len/cost : 0), 0.1)]" msg += "E: [edges.len] "
..(msg.Join())
if(air_master)
air_master.stat_entry()
// Since air_master is still a separate controller from SSAir (Wait, why is that again? Get on that...)
// I want it showing up in the statpanel too. We'll just hack it in as a separate line for now.
/datum/controller/air_system/stat_entry()
if(!statclick)
statclick = new/obj/effect/statclick/debug(null, "Initializing...", src)
var/title = " air_master"
var/list/msg = list()
msg += "Zones: [zones.len] "
msg += "Edges: [edges.len] "
msg += "Cycle: [current_cycle] {" msg += "Cycle: [current_cycle] {"
msg += "T [tiles_to_update.len] | " msg += "T [tiles_to_update.len] | "
msg += "E [active_edges.len] | " msg += "E [active_edges.len] | "
@@ -235,8 +219,7 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
msg += "H [active_hotspots.len] | " msg += "H [active_hotspots.len] | "
msg += "Z [zones_to_update.len] " msg += "Z [zones_to_update.len] "
msg += "}" msg += "}"
..(msg.Join())
stat(title, statclick.update(msg.Join()))
// ZAS might displace objects as the map loads if an air tick is processed mid-load. // ZAS might displace objects as the map loads if an air tick is processed mid-load.
/datum/controller/subsystem/air/StartLoadingMap(var/quiet = TRUE) /datum/controller/subsystem/air/StartLoadingMap(var/quiet = TRUE)
@@ -248,7 +231,6 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
. = ..() . = ..()
// Reboot the air master. A bit hacky right now, but sometimes necessary still. // Reboot the air master. A bit hacky right now, but sometimes necessary still.
// TODO - Make this better by SSair and air_master together, then just reboot SSair
/datum/controller/subsystem/air/proc/RebootZAS() /datum/controller/subsystem/air/proc/RebootZAS()
can_fire = FALSE // Pause processing while we reboot can_fire = FALSE // Pause processing while we reboot
// If we should happen to be in the middle of processing... wait until that finishes. // If we should happen to be in the middle of processing... wait until that finishes.
@@ -257,19 +239,30 @@ Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_coun
while (state != SS_IDLE) while (state != SS_IDLE)
stoplag() stoplag()
var/datum/controller/air_system/old_air = global.air_master
// Invalidate all zones // Invalidate all zones
for(var/zone/zone in old_air.zones) for(var/zone/zone in zones)
zone.c_invalidate() zone.c_invalidate()
// Destroy the air_master and create a new one.
qdel(old_air) // Reset all the lists
global.air_master = new zones.Cut()
edges.Cut()
tiles_to_update.Cut()
zones_to_update.Cut()
active_fire_zones.Cut()
active_hotspots.Cut()
active_edges.Cut()
// Start it up again
Initialize(REALTIMEOFDAY) Initialize(REALTIMEOFDAY)
// Update next_fire so the MC doesn't try to make up for missed ticks. // Update next_fire so the MC doesn't try to make up for missed ticks.
next_fire = world.time + wait next_fire = world.time + wait
can_fire = TRUE // Unpause can_fire = TRUE // Unpause
//
// The procs from the ZAS Air Controller are in ZAS/Controller.dm
//
#undef SSAIR_TURFS #undef SSAIR_TURFS
#undef SSAIR_EDGES #undef SSAIR_EDGES
#undef SSAIR_FIREZONES #undef SSAIR_FIREZONES