Skip to content

Commit

Permalink
Revert "Fix testing and mapload MILLA issues (ParadiseSS13#27850)"
Browse files Browse the repository at this point in the history
This reverts commit ec84f16.
  • Loading branch information
m-dzianishchyts committed Jan 12, 2025
1 parent 0642948 commit 6490b53
Show file tree
Hide file tree
Showing 4 changed files with 7 additions and 80 deletions.
73 changes: 0 additions & 73 deletions code/controllers/subsystem/SSair.dm
Original file line number Diff line number Diff line change
Expand Up @@ -87,7 +87,6 @@ SUBSYSTEM_DEF(air)

/// A list of callbacks waiting for MILLA to finish its tick and enter synchronous mode.
var/list/waiting_for_sync = list()
var/list/sleepable_waiting_for_sync = list()

/// The coordinates of the pressure image we're currently loading.
var/pressure_x = 0
Expand Down Expand Up @@ -710,9 +709,6 @@ SUBSYSTEM_DEF(air)
// Any proc that wants MILLA to be synchronous should not sleep.
SHOULD_NOT_SLEEP(TRUE)

// Just in case someone is naughty and decides to sleep, make sure that this method runs fully anyway.
set waitfor = FALSE

if(is_synchronous)
var/was_safe = SSair.in_milla_safe_code
SSair.in_milla_safe_code = TRUE
Expand All @@ -723,37 +719,18 @@ SUBSYSTEM_DEF(air)

waiting_for_sync += CB

/// Similar to addtimer, but triggers once MILLA enters synchronous mode. This version allows for sleeping if it's absolutely necessary.
/datum/controller/subsystem/air/proc/sleepable_synchronize(datum/milla_safe/CB)
sleepable_waiting_for_sync += CB

/datum/controller/subsystem/air/proc/is_in_milla_safe_code()
return in_milla_safe_code

/datum/controller/subsystem/air/proc/on_milla_tick_finished()
run_sleepless_callbacks()
run_sleeping_callbacks()
is_synchronous = TRUE

/datum/controller/subsystem/air/proc/run_sleepless_callbacks()
// Just in case someone is naughty and decides to sleep, make sure that this method runs fully anyway.
set waitfor = FALSE

in_milla_safe_code = TRUE
for(var/datum/milla_safe/CB as anything in waiting_for_sync)
// This is one of two intended places to call this otherwise-unsafe proc.
CB.private_unsafe_invoke()
waiting_for_sync.Cut()
in_milla_safe_code = FALSE

/datum/controller/subsystem/air/proc/run_sleeping_callbacks()
in_milla_safe_code = TRUE
for(var/datum/milla_safe_must_sleep/CB as anything in sleepable_waiting_for_sync)
// This is one of two intended places to call this otherwise-unsafe proc.
CB.private_unsafe_invoke()
sleepable_waiting_for_sync.Cut()
in_milla_safe_code = FALSE

/proc/milla_tick_finished()
// Any proc that wants MILLA to be synchronous should not sleep.
SHOULD_NOT_SLEEP(TRUE)
Expand Down Expand Up @@ -828,56 +805,6 @@ SUBSYSTEM_DEF(air)
var/datum/gas_mixture/turf_air = get_turf_air(T)
turf_air.copy_from(air)

/// Create a subclass of this and implement `on_run` to manipulate tile air safely. ONLY USE THIS VERSION IF YOU CAN'T AVOID SLEEPING; it will delay atmos ticks!
/datum/milla_safe_must_sleep
var/run_args = list()

/// All subclasses should implement this.
/datum/milla_safe_must_sleep/proc/on_run(...)
CRASH("[src.type] does not implement on_run")

/// Call this to make the subclass run when it's safe to do so. Args will be passed to on_run.
/datum/milla_safe_must_sleep/proc/invoke_async(...)
run_args = args.Copy()
SSair.sleepable_synchronize(src)

/// Do not call this yourself. This is what is called to run your code from a safe context.
/datum/milla_safe_must_sleep/proc/private_unsafe_invoke()
soft_assert_safe()
on_run(arglist(run_args))

/// Used internally to check that we're running safely, but without breaking things worse if we aren't.
/datum/milla_safe_must_sleep/proc/soft_assert_safe()
ASSERT(SSair.is_in_milla_safe_code())

/// Fetch the air for a turf. Only use from `on_run`.
/datum/milla_safe_must_sleep/proc/get_turf_air(turf/T)
RETURN_TYPE(/datum/gas_mixture)
soft_assert_safe()
// This is one of two intended places to call this otherwise-unsafe proc.
var/datum/gas_mixture/bound_to_turf/air = T.private_unsafe_get_air()
if(air.lastread < SSair.times_fired)
var/list/milla_tile = new/list(MILLA_TILE_SIZE)
get_tile_atmos(T, milla_tile)
air.copy_from_milla(milla_tile)
air.lastread = SSair.times_fired
air.readonly = null
air.dirty = FALSE
if(!air.synchronized)
air.synchronized = TRUE
SSair.bound_mixtures += air
return air

/// Add air to a turf. Only use from `on_run`.
/datum/milla_safe_must_sleep/proc/add_turf_air(turf/T, datum/gas_mixture/air)
var/datum/gas_mixture/turf_air = get_turf_air(T)
turf_air.merge(air)

/// Completely replace the air for a turf. Only use from `on_run`.
/datum/milla_safe_must_sleep/proc/set_turf_air(turf/T, datum/gas_mixture/air)
var/datum/gas_mixture/turf_air = get_turf_air(T)
turf_air.copy_from(air)

#undef SSAIR_DEFERREDPIPENETS
#undef SSAIR_PIPENETS
#undef SSAIR_ATMOSMACHINERY
Expand Down
4 changes: 2 additions & 2 deletions code/datums/helper_datums/map_template.dm
Original file line number Diff line number Diff line change
Expand Up @@ -62,13 +62,13 @@
stack_trace("One of the smoothing corners is bust")
catch(var/exception/e)
GLOB.space_manager.remove_dirt(placement.z)
var/datum/milla_safe_must_sleep/late_setup_level/milla = new()
var/datum/milla_safe/late_setup_level/milla = new()
milla.invoke_async(bot_left, top_right, block(ST_bot_left, ST_top_right))
message_admins("Map template [name] threw an error while loading. Safe exit attempted, but check for errors at [ADMIN_COORDJMP(placement)].")
log_admin("Map template [name] threw an error while loading. Safe exit attempted.")
throw e
GLOB.space_manager.remove_dirt(placement.z)
var/datum/milla_safe_must_sleep/late_setup_level/milla = new()
var/datum/milla_safe/late_setup_level/milla = new()
milla.invoke_async(bot_left, top_right, block(ST_bot_left, ST_top_right))

log_game("[name] loaded at [min_x],[min_y],[placement.z]")
Expand Down
4 changes: 2 additions & 2 deletions code/modules/awaymissions/zlevel_helpers.dm
Original file line number Diff line number Diff line change
@@ -1,7 +1,7 @@
/datum/milla_safe_must_sleep/late_setup_level
/datum/milla_safe/late_setup_level

// Ensures that atmos and environment are set up.
/datum/milla_safe_must_sleep/late_setup_level/on_run(turf/bot_left, turf/top_right, smoothTurfs)
/datum/milla_safe/late_setup_level/on_run(turf/bot_left, turf/top_right, smoothTurfs)
var/total_timer = start_watch()
var/subtimer = start_watch()
if(!smoothTurfs)
Expand Down
6 changes: 3 additions & 3 deletions code/tests/atmos/test_ventcrawl.dm
Original file line number Diff line number Diff line change
Expand Up @@ -4,9 +4,9 @@
var/obj/structure/table/table = null
var/setup_complete = FALSE

/datum/milla_safe_must_sleep/ventcrawl_test_setup
/datum/milla_safe/ventcrawl_test_setup

/datum/milla_safe_must_sleep/ventcrawl_test_setup/on_run(datum/game_test/ventcrawl/test)
/datum/milla_safe/ventcrawl_test_setup/on_run(datum/game_test/ventcrawl/test)
// I'm sure get_area_turfs is totally deterministic and this will never go wrong
var/turf/run_loc_bottom_left = test.available_turfs[1]
// This setup creates turfs that initialize themselves in MILLA on creation, which is why we need to be MILLA-safe.
Expand All @@ -26,7 +26,7 @@
TEST_FAIL("Couldn't find spawned test object of type: [test_object_type].")

/datum/game_test/ventcrawl/Run()
var/datum/milla_safe_must_sleep/ventcrawl_test_setup/milla = new()
var/datum/milla_safe/ventcrawl_test_setup/milla = new()
milla.invoke_async(src)
while(!setup_complete)
sleep(world.tick_lag)
Expand Down

0 comments on commit 6490b53

Please sign in to comment.