Merge pull request #3085 from VOREStation/aro-qdels

Fix several Destroy() related things
This commit is contained in:
Aronai Sieyes
2018-02-20 09:57:02 -05:00
committed by GitHub
13 changed files with 127 additions and 49 deletions
+6 -1
View File
@@ -169,7 +169,12 @@ SUBSYSTEM_DEF(garbage)
#endif
var/type = D.type
var/datum/qdel_item/I = items[type]
testing("GC: -- \ref[D] | [type] was unable to be GC'd --")
var/extrainfo = "--"
if(istype(D,/image))
var/image/img = D
var/icon/ico = img.icon
extrainfo = "L:[img.loc] -- I:[ico] -- IS:[img.icon_state] --"
testing("GC: -- \ref[D] | [type] was unable to be GC'd [extrainfo]")
I.failures++
if (GC_QUEUE_HARDDELETE)
HardDelete(D)
+80 -11
View File
@@ -1,3 +1,6 @@
#define SSTRANSCORE_IMPLANTS 1
#define SSTRANSCORE_BACKUPS 2
////////////////////////////////
//// Mind/body data storage system
//// for the resleeving tech
@@ -6,39 +9,102 @@
SUBSYSTEM_DEF(transcore)
name = "Transcore"
priority = 20
wait = 1 MINUTE
flags = SS_BACKGROUND|SS_NO_TICK_CHECK|SS_NO_INIT
wait = 3 MINUTES
flags = SS_BACKGROUND|SS_NO_INIT
runlevels = RUNLEVEL_GAME
// THINGS
var/overdue_time = 15 MINUTES
var/core_dumped = FALSE // Core has been dumped! Also set can_fire = 0 when you set this.
var/current_step = SSTRANSCORE_IMPLANTS
var/cost_backups = 0
var/cost_implants = 0
var/datum/transhuman/mind_record/list/backed_up = list() // All known mind records, indexed by MR.mindname/mind.name
var/datum/transhuman/mind_record/list/has_left = list() // Why do we even have this?
var/datum/transhuman/body_record/list/body_scans = list() // All known body records, indexed by BR.mydna.name
var/obj/item/weapon/implant/backup/list/implants = list() // All OPERATING implants that are being ticked
/datum/controller/subsystem/transcore/fire()
for(var/N in backed_up)
var/datum/transhuman/mind_record/curr_MR = backed_up[N]
if(!curr_MR)
log_debug("Tried to process [N] in transcore w/o a record!")
var/list/current_run = list()
/datum/controller/subsystem/transcore/fire(resumed = 0)
var/timer = TICK_USAGE
INTERNAL_PROCESS_STEP(SSTRANSCORE_IMPLANTS,TRUE,process_implants,cost_implants,SSTRANSCORE_BACKUPS)
INTERNAL_PROCESS_STEP(SSTRANSCORE_BACKUPS,FALSE,process_backups,cost_backups,SSTRANSCORE_IMPLANTS)
/datum/controller/subsystem/transcore/proc/process_implants(resumed = 0)
if (!resumed)
src.current_run = implants.Copy()
var/list/current_run = src.current_run
while(current_run.len)
var/obj/item/weapon/implant/backup/imp = current_run[current_run.len]
current_run.len--
//Remove if not in a human anymore.
if(!imp || !ishuman(imp.loc))
implants -= imp
continue
//We're in a human, at least.
var/mob/living/carbon/human/H = imp.loc
BITSET(H.hud_updateflag, BACKUP_HUD)
if(H == imp.imp_in && H.mind && H.stat < DEAD)
SStranscore.m_backup(H.mind,H.nif)
persist_nif_data(H)
if(MC_TICK_CHECK)
return
/datum/controller/subsystem/transcore/proc/process_backups(resumed = 0)
if (!resumed)
src.current_run = backed_up.Copy()
var/list/current_run = src.current_run
while(current_run.len)
var/name = current_run[current_run.len]
var/datum/transhuman/mind_record/curr_MR = current_run[name]
current_run -= name
//Invalid record
if(!curr_MR)
log_debug("Tried to process [name] in transcore w/o a record!")
backed_up -= name
continue
//Onetimes do not get processing or notifications
if(curr_MR.one_time)
continue
//Timing check
var/since_backup = world.time - curr_MR.last_update
if(since_backup < overdue_time)
curr_MR.dead_state = MR_NORMAL
else
if(curr_MR.dead_state != MR_DEAD) //First time switching to dead
notify(N)
notify(name)
curr_MR.dead_state = MR_DEAD
/datum/controller/subsystem/transcore/stat_entry(msg)
if(MC_TICK_CHECK)
return
/datum/controller/subsystem/transcore/stat_entry()
var/msg = list()
if(core_dumped)
msg += "CORE DUMPED | "
msg += "MR: [backed_up.len] | BR: [body_scans.len]"
..(msg)
msg += "$:{"
msg += "IM:[round(cost_implants,1)]|"
msg += "BK:[round(cost_backups,1)]"
msg += "} "
msg += "#:{"
msg += "IM:[implants.len]|"
msg += "BK:[backed_up.len]"
msg += "} "
..(jointext(msg, null))
/datum/controller/subsystem/transcore/Recover()
if (istype(SStranscore.body_scans))
@@ -131,3 +197,6 @@ SUBSYSTEM_DEF(transcore)
core_dumped = TRUE
can_fire = FALSE
return disk.stored.len
#undef SSTRANSCORE_BACKUPS
#undef SSTRANSCORE_IMPLANTS
+4
View File
@@ -40,6 +40,10 @@ var/global/list/all_exonet_connections = list()
src.holder = holder
..()
/datum/exonet_protocol/Destroy()
remove_address()
holder = null
return ..()
// Proc: make_address()
// Parameters: 1 (string - used to make into a hash that will be part of the new address)
+1 -2
View File
@@ -34,8 +34,7 @@
data_core.medical -= src
data_core.general -= src
data_core.security -= src
..()
return QDEL_HINT_FINDREFERENCE // If we must, we can resort to QDEL_HINT_HARDDEL. But lets see how this works in practice ~Leshana
. = ..()
/datum/data/text
name = "text"
+4 -2
View File
@@ -22,8 +22,10 @@
/datum/progressbar/Destroy()
if (client)
client.images -= bar
qdel(bar)
. = ..()
qdel_null(bar)
user = null
client = null
return ..()
/datum/progressbar/proc/update(progress)
//world << "Update [progress] - [goal] - [(progress / goal)] - [((progress / goal) * 100)] - [round(((progress / goal) * 100), 5)]"
@@ -287,17 +287,20 @@ var/global/list/obj/item/device/communicator/all_communicators = list()
to_chat(voice, "<span class='danger'>\icon[src] Connection timed out with remote host.</span>")
qdel(voice)
close_connection(reason = "Connection timed out")
//Clean up all references we might have to others
communicating.Cut()
voice_requests.Cut()
voice_invites.Cut()
node = null
//Clean up references that might point at us
all_communicators -= src
processing_objects -= src
listening_objects.Remove(src)
qdel(camera)
camera = null
if(exonet)
exonet.remove_address()
exonet = null
qdel_null(camera)
qdel_null(exonet)
return ..()
// Proc: update_icon()
@@ -52,7 +52,9 @@
/obj/item/weapon/implant/Destroy()
if(part)
part.implants.Remove(src)
listening_objects.Remove(src)
part = null
imp_in = null
return ..()
/obj/item/weapon/implant/attackby(obj/item/I, mob/user)
@@ -82,7 +84,6 @@
/obj/item/weapon/implant/tracking/implanted(var/mob/source)
processing_objects.Add(src)
listening_objects |= src
return 1
/obj/item/weapon/implant/tracking/Destroy()
+3
View File
@@ -4,3 +4,6 @@
if(viewing_alternate_appearances && viewing_alternate_appearances.len)
for(var/datum/alternate_appearance/AA in viewing_alternate_appearances)
AA.display_to(list(src))
var/obj/screen/plane_master/augmented/aug = plane_holder.plane_masters[VIS_AUGMENTED]
aug.apply()
+3
View File
@@ -94,6 +94,9 @@
var/invis_toggle = FALSE
var/list/sub_planes
/obj/screen/plane_master/New()
..(null) //Never be in anything ever.
/obj/screen/plane_master/proc/set_desired_alpha(var/new_alpha)
if(new_alpha != alpha && new_alpha > 0 && new_alpha <= 255)
desired_alpha = new_alpha
+3 -5
View File
@@ -5,7 +5,7 @@
plane_masters[VIS_CH_BACKUP] = new /obj/screen/plane_master{plane = PLANE_CH_BACKUP} //Backup implant status
plane_masters[VIS_CH_VANTAG] = new /obj/screen/plane_master{plane = PLANE_CH_VANTAG} //Vore Antags
plane_masters[VIS_AUGMENTED] = new /obj/screen/plane_master/augmented(null,my_mob) //Augmented reality
plane_masters[VIS_AUGMENTED] = new /obj/screen/plane_master/augmented(my_mob) //Augmented reality
/////////////////
//AR planemaster does some special image handling
@@ -14,13 +14,11 @@
var/state = FALSE //Saves cost with the lists
var/mob/my_mob
/obj/screen/plane_master/augmented/New(var/newloc, var/mob/M)
..(newloc)
/obj/screen/plane_master/augmented/New(var/mob/M)
..()
my_mob = M
logged_in_event.register(my_mob,src,/obj/screen/plane_master/augmented/proc/apply)
/obj/screen/plane_master/augmented/Destroy()
logged_in_event.unregister(my_mob,src)
my_mob = null
return ..()
+4
View File
@@ -5,6 +5,10 @@
/datum/nano_module/New(var/host)
src.host = host
/datum/nano_module/Destroy()
host = null
return ..()
/datum/nano_module/nano_host()
return host ? host : src
@@ -13,6 +13,10 @@
if((. = ..()))
nif.comm = new(nif,src)
uninstall()
if((. = ..()))
qdel_null(nif.comm)
activate()
if((. = ..()))
nif.comm.initialize_exonet(nif.human)
+5 -22
View File
@@ -9,8 +9,6 @@
desc = "A mindstate backup implant that occasionally stores a copy of one's mind on a central server for backup purposes."
icon = 'icons/vore/custom_items_vr.dmi'
icon_state = "backup_implant"
var/last_attempt
var/attempt_delay = 5 MINUTES
/obj/item/weapon/implant/backup/get_data()
var/dat = {"
@@ -25,6 +23,10 @@
<b>Integrity:</b> Generally very survivable. Susceptible to being destroyed by acid."}
return dat
/obj/item/weapon/implant/backup/Destroy()
SStranscore.implants -= src
return ..()
/obj/item/weapon/implant/backup/implanted(var/mob/living/carbon/human/H)
..()
if(istype(H))
@@ -32,29 +34,10 @@
if(other_imp && other_imp.imp_in == H)
qdel(other_imp) //implant fight
if(H.mind && H.stat < DEAD) //One right now, on implanting.
SStranscore.m_backup(H.mind)
last_attempt = world.time
backup()
SStranscore.implants |= src
return 1
/obj/item/weapon/implant/backup/proc/backup()
last_attempt = world.time
var/mob/living/carbon/human/H = loc
//We're in a human, at least.
if(istype(H))
BITSET(H.hud_updateflag, BACKUP_HUD)
//Okay we've got a mind at least
if(H == imp_in && H.mind && H.stat < DEAD)
SStranscore.m_backup(H.mind,H.nif)
persist_nif_data(H)
spawn(attempt_delay)
backup()
//New, modern implanter instead of old style implanter.
/obj/item/weapon/backup_implanter
name = "backup implanter"