mirror of
https://github.com/Citadel-Station-13/Citadel-Station-13-RP.git
synced 2026-08-29 01:56:31 +01:00
experimental performance fixes (#4870)
Co-authored-by: VM_USER <VM_USER>
This commit is contained in:
silicons
co-authored by
VM_USER <VM_USER>
VM_USER <VM_USER>
parent
975cbb6acb
commit
2a1ab43518
@@ -1,171 +0,0 @@
|
||||
PROCESSING_SUBSYSTEM_DEF(radiation)
|
||||
name = "Radiation"
|
||||
subsystem_flags = SS_NO_INIT | SS_BACKGROUND
|
||||
wait = 1 SECONDS
|
||||
|
||||
/// atom refs we warned about already
|
||||
var/list/warned_atoms = list()
|
||||
/// z radiation listeners - nested list
|
||||
var/static/list/z_listeners = list()
|
||||
/// waves about to be sent out on next tick; list [ turf = list(burst) ]
|
||||
var/static/list/queued_waves = list()
|
||||
|
||||
/datum/controller/subsystem/processing/radiation/fire(resumed)
|
||||
if(!resumed)
|
||||
flush_queue()
|
||||
..()
|
||||
|
||||
/datum/controller/subsystem/processing/radiation/on_max_z_changed(old_z_count, new_z_count)
|
||||
var/old = z_listeners.len
|
||||
z_listeners.len = new_z_count
|
||||
for(var/i in old + 1 to z_listeners.len)
|
||||
z_listeners[i] = list()
|
||||
|
||||
/datum/controller/subsystem/processing/radiation/proc/warn(datum/component/radioactive/contamination)
|
||||
if(!contamination || QDELETED(contamination))
|
||||
return
|
||||
var/ref = REF(contamination.parent)
|
||||
if(warned_atoms[ref])
|
||||
return
|
||||
warned_atoms[ref] = TRUE
|
||||
var/atom/master = contamination.parent
|
||||
// SSblackbox.record_feedback("tally", "contaminated", 1, master.type)
|
||||
var/msg = "has become contaminated with enough radiation to contaminate other objects. || Strength: [contamination.strength]"
|
||||
master.investigate_log(msg, INVESTIGATE_RADIATION)
|
||||
|
||||
/datum/controller/subsystem/processing/radiation/proc/flush_queue()
|
||||
for(var/turf/T as anything in queued_waves)
|
||||
var/list/radiating = get_rad_contents(T)
|
||||
var/list/L = queued_waves[T]
|
||||
for(var/datum/radiation_burst/B as anything in L)
|
||||
var/insulation = 1
|
||||
var/intensity = B.intensity
|
||||
var/left
|
||||
if(intensity > RAD_MINIMUM_CONTAMINATION)
|
||||
var/list/contaminating = list()
|
||||
for(var/atom/A as anything in radiating)
|
||||
insulation *= A.rad_insulation
|
||||
A.rad_act(intensity)
|
||||
if(radiation_infect_ignore[A.type])
|
||||
continue
|
||||
if(A.rad_flags & RAD_NO_CONTAMINATE)
|
||||
continue
|
||||
if(SEND_SIGNAL(A, COMSIG_ATOM_RAD_CONTAMINATING, intensity) & COMPONENT_BLOCK_CONTAMINATION)
|
||||
continue
|
||||
contaminating += A
|
||||
var/contam_remaining = intensity * insulation * RAD_CONTAMINATION_STR_COEFFICIENT - RAD_CONTAMINATION_STR_ADJUST
|
||||
var/max_str = B.highest * insulation * RAD_CONTAMINATION_STR_COEFFICIENT - RAD_CONTAMINATION_STR_ADJUST
|
||||
var/apply_str = length(contaminating) && min(max_str, contam_remaining / length(contaminating), intensity * RAD_CONTAMINATION_MAXIMUM_OBJECT_RATIO)
|
||||
var/used = 0
|
||||
for(var/atom/A as anything in contaminating)
|
||||
var/datum/component/radioactive/R = A.GetComponent(/datum/component/radioactive)
|
||||
var/effective_stack = (isnull(A.rad_stickiness)? A.rad_insulation : A.rad_stickiness) * max_str // rad insulation helps against contamination by blocking it too
|
||||
if(effective_stack < RAD_CONTAMINATION_MEANINGFUL)
|
||||
continue
|
||||
if(!R)
|
||||
A.AddComponent(/datum/component/radioactive, min(apply_str, effective_stack))
|
||||
used += apply_str
|
||||
else
|
||||
used += R.constructive_interference(effective_stack, apply_str)
|
||||
left = max(0, contam_remaining - used)
|
||||
else
|
||||
left = 0
|
||||
for(var/atom/A as anything in radiating)
|
||||
insulation *= A.rad_insulation
|
||||
A.rad_act(intensity)
|
||||
new /datum/radiation_wave(T, NORTH, intensity * insulation, B.falloff, B.highest, TRUE, B.emitter_count, left)
|
||||
new /datum/radiation_wave(T, SOUTH, intensity * insulation, B.falloff, B.highest, TRUE, B.emitter_count, left)
|
||||
new /datum/radiation_wave(T, EAST, intensity * insulation, B.falloff, B.highest, TRUE, B.emitter_count, left)
|
||||
new /datum/radiation_wave(T, WEST, intensity * insulation, B.falloff, B.highest, TRUE, B.emitter_count, left)
|
||||
queued_waves.len = 0
|
||||
|
||||
/datum/controller/subsystem/processing/radiation/proc/queue_wave(turf/source, intensity, falloff, can_contaminate)
|
||||
// if not contaminating we immediately release, pointless to keep going
|
||||
if(!can_contaminate)
|
||||
new /datum/radiation_wave(source, NORTH, intensity, falloff, FALSE)
|
||||
new /datum/radiation_wave(source, SOUTH, intensity, falloff, FALSE)
|
||||
new /datum/radiation_wave(source, EAST, intensity, falloff, FALSE)
|
||||
new /datum/radiation_wave(source, WEST, intensity, falloff, FALSE)
|
||||
var/list/datum/radiation_burst/queue = queued_waves[source]
|
||||
if(!queue)
|
||||
queue = list()
|
||||
queued_waves[source] = queue
|
||||
for(var/datum/radiation_burst/B as anything in queue)
|
||||
if(B.falloff == falloff)
|
||||
B.intensity += intensity
|
||||
if(intensity > RAD_MOB_ACT_PROTECTION_PER_WAVE_SOURCE)
|
||||
++B.emitter_count
|
||||
B.highest = max(B.highest, intensity)
|
||||
return
|
||||
queue += new /datum/radiation_burst(intensity, falloff)
|
||||
|
||||
/**
|
||||
* todo: comment
|
||||
*/
|
||||
/datum/controller/subsystem/processing/radiation/proc/radiation_pulse(atom/source, intensity, falloff_modifier, log, can_contaminate)
|
||||
if(!can_fire) // we don't care
|
||||
return FALSE
|
||||
var/atom/nested = source
|
||||
if(!nested.loc)
|
||||
// we're not going to emit in nullspace at all, don't bother
|
||||
return
|
||||
var/waves = TRUE
|
||||
var/turf/T
|
||||
if(!isturf(nested))
|
||||
do
|
||||
nested = nested.loc
|
||||
if(nested.rad_flags & RAD_BLOCK_CONTENTS)
|
||||
waves = FALSE
|
||||
break
|
||||
while(nested.loc && !isarea(nested.loc))
|
||||
T = get_turf(nested)
|
||||
else
|
||||
T = nested
|
||||
if(waves && T)
|
||||
queue_wave(T, intensity, falloff_modifier, can_contaminate)
|
||||
var/static/last_huge_pulse = 0
|
||||
if(intensity > 1000 && world.time > last_huge_pulse + 10 SECONDS)
|
||||
last_huge_pulse = world.time
|
||||
log = TRUE
|
||||
else
|
||||
var/list/things = get_rad_contents(nested)
|
||||
for(var/atom/A as anything in things)
|
||||
A.rad_act(intensity)
|
||||
if(log)
|
||||
log_game("Pulse intensity [intensity] falloff [falloff_modifier] in [AREACOORD(T)][waves? "" : " (contained by [nested])"]")
|
||||
return TRUE
|
||||
|
||||
/**
|
||||
* does our best faith attempt at irradiating a whole zlevel without lagging the server to death
|
||||
*/
|
||||
/datum/controller/subsystem/processing/radiation/proc/z_radiation(turf/T, z, intensity, falloff_modifier, log, can_contaminate, z_radiate_flags)
|
||||
if(!T && !z)
|
||||
CRASH("need either turf or z")
|
||||
if(!z)
|
||||
z = T.z
|
||||
// you can tell that this proc is hand-optimized, huh.
|
||||
// :skull_crossbones:
|
||||
if(z_radiate_flags)
|
||||
if(falloff_modifier && T)
|
||||
for(var/atom/A as anything in z_listeners[z])
|
||||
if(z_radiate_flags & Z_RADIATE_CHECK_AREA_SHIELD)
|
||||
var/area/checking = get_area(A)
|
||||
if(checking.area_flags & AREA_RAD_SHIELDED)
|
||||
continue
|
||||
var/dist = max(1, get_dist(A, T) * falloff_modifier)
|
||||
A.z_rad_act(INVERSE_SQUARE(intensity, dist, 1))
|
||||
else
|
||||
for(var/atom/A as anything in z_listeners[z])
|
||||
if(z_radiate_flags & Z_RADIATE_CHECK_AREA_SHIELD)
|
||||
var/area/checking = get_area(A)
|
||||
if(checking.area_flags & AREA_RAD_SHIELDED)
|
||||
continue
|
||||
A.z_rad_act(intensity)
|
||||
else
|
||||
if(falloff_modifier && T)
|
||||
for(var/atom/A as anything in z_listeners[z])
|
||||
var/dist = max(1, get_dist(A, T) * falloff_modifier)
|
||||
A.z_rad_act(INVERSE_SQUARE(intensity, dist, 1))
|
||||
else
|
||||
for(var/atom/A as anything in z_listeners[z])
|
||||
A.z_rad_act(intensity)
|
||||
Reference in New Issue
Block a user