/
githubmirror
/
vgstation13
Обзор
Документация
Войти
/
githubmirror
/
vgstation13
Код
Запросы
0
Пакеты
0
Релизы
0
Аналитика
Безопасность
1.03
code/ZAS/Controller.dm
346 строк
9 KB
unid15
Changes some typepaths (#14522)
06 апр 2017, 22:38
06 апр 2017, 22:38
38f7bcd
Код
Авторство
О чём код?
var/datum/controller/air_system/air_master var/tick_multiplier = 2 /* Overview: The air controller does everything. There are tons of procs in here. Class Vars: zones - All zones currently holding one or more turfs. edges - All processing edges. tiles_to_update - Tiles scheduled to update next tick. zones_to_update - Zones which have had their air changed and need air archival. active_hotspots - All processing fire objects. active_zones - The number of zones which were archived last tick. Used in debug verbs. next_id - The next UID to be applied to a zone. Mostly useful for debugging purposes as zones do not need UIDs to function. Class Procs: mark_for_update(turf/T) Adds the turf to the update list. When updated, update_air_/properties() will be called. When stuff changes that might affect airflow, call this. It's basically the only thing you need. add_zone(zone/Z) and remove_zone(zone/Z) Adds zones to the zones list. Does not mark them for update. air_blocked(turf/A, turf/B) Returns a bitflag consisting of: AIR_BLOCKED - The connection between turfs is physically blocked. No air can pass. ZONE_BLOCKED - There is a door between the turfs, so zones cannot cross. Air may or may not be permeable. has_valid_zone(turf/T) Checks the presence and validity of T's zone. May be called on unsimulated turfs, returning 0. merge(zone/A, zone/B) Called when zones have a direct connection and equivalent pressure and temperature. Merges the zones to create a single zone. connect(turf/simulated/A, turf/B) Called by turf/update_air_/properties(). The first argument must be simulated. Creates a connection between A and B. mark_zone_update(zone/Z) Adds zone to the update list. Unlike mark_for_update(), this one is called automatically whenever air is returned from a simulated turf. equivalent_pressure(zone/A, zone/B) Currently identical to A.air.compare(B.air). Returns 1 when directly connected zones are ready to be merged. get_edge(zone/A, zone/B) get_edge(zone/A, turf/B) Gets a valid connection_edge between A and B, creating a new one if necessary. has_same_air(turf/A, turf/B) Used to determine if an unsimulated edge represents a specific turf. Simulated edges use connection_edge/contains_zone() for the same purpose. Returns 1 if A has identical gases and temperature to B. remove_edge(connection_edge/edge) Called when an edge is erased. Removes it from processing. */ //Geometry lists /datum/controller/air_system/var/list/zones = list() /datum/controller/air_system/var/list/edges = list() //Geometry updates lists /datum/controller/air_system/var/list/tiles_to_update = list() /datum/controller/air_system/var/list/zones_to_update = list() /datum/controller/air_system/var/list/active_hotspots = list() /datum/controller/air_system/var/active_zones = 0 /datum/controller/air_system/var/current_cycle = 0 /datum/controller/air_system/var/update_delay = 5 //How long between check should it try to process atmos again. /datum/controller/air_system/var/failed_ticks = 0 //How many ticks have runtimed? /datum/controller/air_system/var/tick_progress = 0 /datum/controller/air_system/var/next_id = 1 //Used to keep track of zone UIDs. /datum/controller/air_system/proc/Setup() //Purpose: Call this at the start to setup air groups geometry // (Warning: Very processor intensive but only must be done once per round) //Called by: Gameticker/Master controller //Inputs: None. //Outputs: None. #ifndef ZASDBG set background = 1 #endif to_chat(world, "<span class='danger'>Processing Geometry...</span>") sleep(-1) var/start_time = world.timeofday var/simulated_turf_count = 0 for(var/turf/simulated/S in world) simulated_turf_count++ if(!(simulated_turf_count % 50000)) sleep(world.tick_lag) S.update_air_properties() to_chat(world, {"<font color='red'><b>Geometry initialized in [round(0.1*(world.timeofday-start_time),0.1)] seconds.</b> Total Simulated Turfs: [simulated_turf_count] Total Zones: [zones.len] Total Unsimulated Turfs: [world.maxx*world.maxy*world.maxz - simulated_turf_count]</font>"}) // spawn Start() /datum/controller/air_system/proc/Start() //Purpose: This is kicked off by the master controller, and controls the processing of all atmosphere. //Called by: Master controller //Inputs: None. //Outputs: None. #ifndef ZASDBG set background = 1 #endif while(1) Tick() sleep(max(5,update_delay*tick_multiplier)) /datum/controller/air_system/proc/Tick() . = 1 //Set the default return value, for runtime detection. current_cycle++ //If there are tiles to update, do so. tick_progress = "updating turf properties" var/list/updating if(tiles_to_update.len) updating = tiles_to_update tiles_to_update = list() #ifdef ZASDBG var/updated = 0 #endif for(var/turf/T in updating) T.update_air_properties() T.post_update_air_properties() T.needs_air_update = 0 #ifdef ZASDBG T.overlays -= mark updated++ #endif //sleep(1) CHECK_TICK #ifdef ZASDBG if(updated != updating.len) tick_progress = "[updating.len - updated] tiles left unupdated." to_chat(world, "<span class='warning'>[tick_progress]</span>") . = 0 #endif //Where gas exchange happens. if(.) tick_progress = "processing edges" for(var/connection_edge/edge in edges) edge.tick() CHECK_TICK //Process fires. if(.) tick_progress = "processing fire" for(var/obj/effect/fire/fire in active_hotspots) fire.process() CHECK_TICK //Process zones. if(.) tick_progress = "updating zones" active_zones = zones_to_update.len if(zones_to_update.len) updating = zones_to_update zones_to_update = list() for(var/zone/zone in updating) zone.tick() CHECK_TICK zone.needs_update = 0 if(.) tick_progress = "success" /datum/controller/air_system/proc/add_zone(zone/z) zones.Add(z) z.name = "Zone [next_id++]" mark_zone_update(z) /datum/controller/air_system/proc/remove_zone(zone/z) zones.Remove(z) /datum/controller/air_system/proc/air_blocked(turf/A, turf/B) #ifdef ZASDBG ASSERT(isturf(A)) ASSERT(isturf(B)) #endif var/ablock = A.c_airblock(B) if(ablock == BLOCKED) return BLOCKED return ablock | B.c_airblock(A) /datum/controller/air_system/proc/has_valid_zone(turf/simulated/T) #ifdef ZASDBG ASSERT(istype(T)) #endif return istype(T) && T.zone && !T.zone.invalid /datum/controller/air_system/proc/merge(zone/A, zone/B) #ifdef ZASDBG ASSERT(istype(A)) ASSERT(istype(B)) ASSERT(!A.invalid) ASSERT(!B.invalid) ASSERT(A != B) #endif if(A.contents.len < B.contents.len) A.c_merge(B) mark_zone_update(B) else B.c_merge(A) mark_zone_update(A) /datum/controller/air_system/proc/connect(turf/simulated/A, turf/simulated/B) #ifdef ZASDBG ASSERT(istype(A)) ASSERT(isturf(B)) ASSERT(A.zone) ASSERT(!A.zone.invalid) //ASSERT(B.zone) ASSERT(A != B) #endif var/block = air_master.air_blocked(A,B) if(block & AIR_BLOCKED) return var/direct = !(block & ZONE_BLOCKED) var/space = (!istype(B)) if(direct && !space) if(equivalent_pressure(A.zone,B.zone) || current_cycle == 0) merge(A.zone,B.zone) return var a_to_b = get_dir(A,B) b_to_a = get_dir(B,A) if(!A.connections) A.connections = new if(!B.connections) B.connections = new if(A.connections.get(a_to_b)) return if(B.connections.get(b_to_a)) return if(!space) if(A.zone == B.zone) return var/connection/c = new /connection(A,B) A.connections.place(c, a_to_b) B.connections.place(c, b_to_a) if(direct) c.mark_direct() /datum/controller/air_system/proc/mark_for_update(turf/T) #ifdef ZASDBG ASSERT(isturf(T)) #endif if(T.needs_air_update) return tiles_to_update |= T #ifdef ZASDBG T.overlays += mark #endif T.needs_air_update = 1 /datum/controller/air_system/proc/mark_zone_update(zone/Z) #ifdef ZASDBG ASSERT(istype(Z)) #endif if(Z.needs_update) return zones_to_update.Add(Z) Z.needs_update = 1 /datum/controller/air_system/proc/equivalent_pressure(zone/A, zone/B) return A.air.compare(B.air) /datum/controller/air_system/proc/get_edge(zone/A, zone/B) if(istype(B)) for(var/connection_edge/zone/edge in A.edges) if(edge.contains_zone(B)) return edge var/connection_edge/edge = new/connection_edge/zone(A,B) edges.Add(edge) return edge else for(var/connection_edge/unsimulated/edge in A.edges) if(has_same_air(edge.B,B)) return edge var/connection_edge/edge = new/connection_edge/unsimulated(A,B) edges.Add(edge) return edge /datum/controller/air_system/proc/has_same_air(turf/A, turf/B) if(A.oxygen != B.oxygen) return 0 if(A.nitrogen != B.nitrogen) return 0 if(A.toxins != B.toxins) return 0 if(A.carbon_dioxide != B.carbon_dioxide) return 0 if(A.temperature != B.temperature) return 0 return 1 /datum/controller/air_system/proc/remove_edge(connection/c) edges.Remove(c)