clear tempory lindas that helps, but lindas can still block for 10-20 ms which is no good so really needs replacing

Author: xriss

lua/wetgenes/gamecake/mods/console.lua

@@ -325,6 +325,11 @@ font.vbs_idx=1
 			console.lines_display[1]=s
 --			console.display(s)
 
+if oven.times.update.time+oven.times.draw.time > 0.030 then -- slow frame
+
+PRINT("SLOW",s)--, oven.now.now.scene:status())
+end
+
 			console.fps_count=console.fps_count+1
 		end
 

lua/wetgenes/gamecake/oven.lua

@@ -6,10 +6,11 @@ local coroutine,package,string,table,math,io,os,debug,assert,dofile,error,_G,get
 --local log,dump,PRINT=require("wetgenes.logs"):export("log","dump","PRINT")
 local logs=require("wetgenes.logs")
 local global=require("global")
+
 local toaster=require("wetgenes.gamecake.toaster")
 -- help luajit work on android/arm
 toaster.jit_prealloc()
-
+local profile=require("jit.profile")
 
 --[[#lua.wetgenes.gamecake.oven
 
@@ -666,7 +667,6 @@ os.exit()
 
 		function oven.setup()
 			if oven.now and oven.now.setup then
-				toaster.garbage_collect_restart() -- in case of large allocations
 				oven.now.setup() -- this will probably load data and call the preloader
 			end
 --print("setup preloader=off")
@@ -718,6 +718,16 @@ os.exit()
 		function oven.update()
 --print(oven.ticks)
 
+local prof={TOTAL=0}
+if false then
+	local ms=5
+	profile.start("fi"..ms,function(thread, samples, vmstate)
+		prof.TOTAL=prof.TOTAL+samples*ms
+		local s=profile.dumpstack(thread, "l", 1)
+		prof[s]=(prof[s] or 0 ) +samples*ms
+	end)
+end
+
 			if oven.do_backtrace then
 				oven.do_backtrace=false
 				if oven.update_co then
@@ -787,6 +797,25 @@ os.exit()
 			end
 			oven.update_co=nil
 
+if false then
+	profile.stop()
+	if prof.TOTAL >= 10 then
+		local list={}
+		for n,v in pairs(prof) do
+			list[#list+1]=string.format("%4i",v).." : "..n
+		end
+		table.sort(list)
+		local c=0
+		for i=#list,1,-1 do
+			PRINT(list[i])
+			c=c+1
+			if c>=5 then break end
+		end
+		PRINT("")
+	end
+--	DUMP(oven.tasks.linda:dump())
+end
+
 		end
 
 		oven.preloader_enabled=false -- do we need this? we is fast and it is broken

lua/wetgenes/gamecake/toaster.lua

@@ -53,8 +53,8 @@ local M={ modname=(...) } ; package.loaded[M.modname]=M
 -- this will stop gc and take control of it
 M.garbage_collect_step=function()
 	collectgarbage("stop") -- from now on we must explicitly call step as often as we can
-	collectgarbage("setpause",400) -- this number adjusts when collection will start ( still seems to effect us here )
-	collectgarbage("setstepmul",1) -- this number adjusts how much time that each step should take
+	collectgarbage("setpause",500) -- this number adjusts when collection will start ( still seems to effect us here )
+	collectgarbage("setstepmul",10) -- this number adjusts how much time that each step should take
 	collectgarbage("step",0) -- this function may do nothing or may collect some garbage
 end
 

lua/wetgenes/gamecake/upnet.lua

@@ -835,6 +835,9 @@ M.upnet_code=function(linda,task_id,task_idx)
 	local lanes=require("lanes")
 	if lane_threadname then lane_threadname(task_id) end
 
+	local toaster=require("wetgenes.gamecake.toaster")
+	toaster.jit_prealloc()	-- help luajit work on android/arm
+
 	local wtasks=require("wetgenes.tasks")
 	local wwin=require("wetgenes.win")
 	local now=wwin.time -- function to get time now in seconds with ms accuracy, probs
@@ -921,6 +924,7 @@ M.upnet_code=function(linda,task_id,task_idx)
 				end
 			end
 		until not memo
+		toaster.garbage_collect_step() -- try and avoid gc glitching
 	end
 
 end

lua/wetgenes/gamecake/zone/system/all_code.lua

@@ -112,7 +112,9 @@ all.code.db=function(linda,task_id,task_idx)
 	local lanes=require("lanes")
 	if lane_threadname then lane_threadname(task_id) end
 
-	local oven=require("wetgenes.gamecake.toaster").bake({linda=linda})
+	local toaster=require("wetgenes.gamecake.toaster")
+	toaster.jit_prealloc()	-- help luajit work on android/arm
+	local oven=toaster.bake({linda=linda})
 
 	local db=all.db.open({linda=linda,time=oven.time})
 
@@ -163,7 +165,10 @@ all.code.popins=function(linda,task_id,task_idx)
 	local lanes=require("lanes")
 	if lane_threadname then lane_threadname(task_id) end
 
-	local oven=require("wetgenes.gamecake.toaster").bake({linda=linda})
+	local toaster=require("wetgenes.gamecake.toaster")
+	toaster.jit_prealloc()	-- help luajit work on android/arm
+	local oven=toaster.bake({linda=linda})
+
 	oven.upnet=oven.rebake("wetgenes.gamecake.upnet")
 
 	local scene
@@ -231,8 +236,10 @@ all.code.values=function(linda,task_id,task_idx)
 	local lanes=require("lanes")
 	if lane_threadname then lane_threadname(task_id) end
 
-	-- basic oven, nogl etc
-	local oven=require("wetgenes.gamecake.toaster").bake({linda=linda})
+	local toaster=require("wetgenes.gamecake.toaster")
+	toaster.jit_prealloc()	-- help luajit work on android/arm
+	local oven=toaster.bake({linda=linda})
+
 	oven.upnet=oven.rebake("wetgenes.gamecake.upnet")
 
 	local scene
@@ -312,6 +319,7 @@ all.code.values=function(linda,task_id,task_idx)
 			end
 			main() -- probably getting called every 1ms ish
 		until not memo
+		toaster.garbage_collect_step() -- try and avoid gc glitching
 	end
 
 end
@@ -326,8 +334,10 @@ all.code.tweens=function(linda,task_id,task_idx)
 	local lanes=require("lanes")
 	if lane_threadname then lane_threadname(task_id) end
 
-	-- basic oven, nogl etc
-	local oven=require("wetgenes.gamecake.toaster").bake({linda=linda})
+	local toaster=require("wetgenes.gamecake.toaster")
+	toaster.jit_prealloc()	-- help luajit work on android/arm
+	local oven=toaster.bake({linda=linda})
+
 	oven.upnet=oven.rebake("wetgenes.gamecake.upnet")
 
 	local scene
@@ -438,6 +448,7 @@ all.code.tweens=function(linda,task_id,task_idx)
 			end
 			main() -- probably getting called every 1ms ish
 		until not memo
+		toaster.garbage_collect_step() -- try and avoid gc glitching
 	end
 
 end

lua/wetgenes/gamecake/zone/system/all_scene.lua

@@ -117,6 +117,7 @@ all.scene.initialize=function(scene)
 	}
 	scene:sortby_update()
 
+	scene.scrib={}
 	scene.db=db
 	for caste,info in pairs(scene.infos) do -- initialize each system from info
 		local sys={}
@@ -351,21 +352,34 @@ counts.draw=0
 
 --	counts.undo , counts.update = scene:do_update_values()
 
+	if not scene.scrib.tim then
+		scene.scrib.tim=oven.times.create()
+	end
+	scene.scrib.tim.start()
+
+	scene.scrib.tween=0
+	scene.scrib.pull=0
+	scene.scrib.merge=0
 	for memo in oven.tasks:memos("all_draws") do
 		if memo.cmd=="tweens" then
 			scene:values_call( function(it) it.tweens:push() end )
 			scene:load_all_tweens(memo.tweens)
+			scene.scrib.tween=scene.scrib.tween+1
 		end
 	end
 	scene:ticks_sync()
 	-- shrink tweens down to two slots so we may tween between them
 	while #scene.tweens > 2 and scene.tweens:get("tick",2) <= scene.ticks.now do
 		scene:values_call( function(it) it.tweens:pull() end ) -- merge 2 into 1
+		scene.scrib.pull=scene.scrib.pull+1
 	end
 	while #scene.tweens > 2 do
 		scene:values_call( function(it) it.tweens:merge() end ) -- merge 3 into 2
+		scene.scrib.merge=scene.scrib.merge+1
 	end
 
+	scene.scrib.tim.stop()
+
 --if #scene.tweens==2 then
 --print( scene.tweens:get("tick",1) , scene.tweens:get("tick",2) , scene.ticks.time )
 --end
@@ -386,8 +400,17 @@ all.scene.do_draw=function(scene)
 
 	scene:ticks_sync()
 
+	scene.scrib.tim.done()
+--[[
+if scene.scrib.tim.time > 0.01 then
+PRINT("TIM",math.floor(scene.scrib.tim.time*1000))
+end
+]]
+
 --	local upnet=scene.oven.upnet
-	oven.console.lines_display[2]=("now:"..scene.ticks.now.." inp:"..scene.ticks.input.." agr:"..scene.ticks.agreed.." bse:"..scene.ticks.base)
+	oven.console.lines_display[2]=(
+--	"tween:"..scene.scrib.tween.." pull:"..scene.scrib.pull.." merge:"..scene.scrib.merge.." "..
+	"now:"..scene.ticks.now.." inp:"..scene.ticks.input.." agr:"..scene.ticks.agreed.." bse:"..scene.ticks.base)
 
 --	local nowtick=upnet.nowticks()
 --	print("do_draw",scene.ticks.time)

lua/wetgenes/tasks.lua

@@ -66,6 +66,7 @@ M.do_memo=function(linda,memo,timeout)
 	if linda:send( timeout , memo.task , memo ) then -- send on memo.task (a public name of another task)
 		if memo.id then
 			local ok,r=linda:receive( timeout , memo.id ) -- receive the result on memo.id
+			linda:set(memo.id) -- cleanup
 --log("memo",memo.task,memo.id,"done")
 			return r
 		end
@@ -204,6 +205,7 @@ M.tasks_functions.claim_global=function(tasks,name,value)
 	memo.value=value
 	if tasks.linda:send( nil , memo.task , memo ) then -- send on memo.task (a public name of another task)
 		local ok,r=tasks.linda:receive( nil , memo.id ) -- receive the result on memo.id
+		tasks.linda:set(memo.id) -- cleanup
 		return r.result
 	end
 end
@@ -228,6 +230,7 @@ M.tasks_functions.eject_global=function(tasks,name)
 	memo.name=name
 	if tasks.linda:send( nil , memo.task , memo ) then -- send on memo.task (a public name of another task)
 		local ok,r=tasks.linda:receive( nil , memo.id ) -- receive the result on memo.id
+		tasks.linda:set(memo.id) -- cleanup
 		return r.result
 	end
 end
@@ -250,6 +253,7 @@ M.tasks_functions.fetch_global=function(tasks,name)
 	memo.name=name
 	if tasks.linda:send( nil , memo.task , memo ) then -- send on memo.task (a public name of another task)
 		local ok,r=tasks.linda:receive( nil , memo.id ) -- receive the result on memo.id
+		tasks.linda:set(memo.id) -- cleanup
 		return r.result
 	end
 end
@@ -571,7 +575,8 @@ M.tasks_functions.receive=function(tasks,memo,timeout)
 		tasks:send(memo,timeout)
 	end
 	memo.state="receiving"
-	local ok,result=(tasks.main_thread and tasks.colinda or tasks.linda):receive( timeout , memo.id )
+	local ok,result=(tasks.main_thread and tasks.colinda or tasks.linda):receive( timeout , memo.id ) ;
+	(tasks.main_thread and tasks.colinda or tasks.linda):set(memo.id) -- cleanup
 	memo.state="done"
 	tasks:del_memo(memo)
 
@@ -712,11 +717,14 @@ M.colinda_functions.send=function(colinda,...)
 	local timestart
 	if timeout then timestart=os.time() end
 
+--PRINT(timeout)
+--TRACEBACK()
+
 	local ret
 	repeat
-		ret={ colinda.linda:send(0,unpack(aa)) }
+		ret={ colinda.linda:send(1,unpack(aa)) }
 		if ret[1] then break end -- got a result
-		if timeout and os.time() > timestart+timeout then break end
+		if timeout and os.time() >= timestart+timeout then break end
 		coroutine.yield()
 	until false
 
@@ -734,9 +742,9 @@ M.colinda_functions.receive=function(colinda,...)
 
 	local ret
 	repeat
-		ret={ colinda.linda:receive(0,unpack(aa)) }
+		ret={ colinda.linda:receive(1,unpack(aa)) }
 		if ret[1] then break end -- got a result
-		if timeout and os.time() > timestart+timeout then break end
+		if timeout and os.time() >= timestart+timeout then break end
 		coroutine.yield()
 	until false