if not modules then modules = { } end modules ['core-uti'] = {
version = 1.001,
comment = "companion to core-uti.mkiv",
author = "Hans Hagen, PRAGMA-ADE, Hasselt NL",
copyright = "PRAGMA ADE / ConTeXt Development Team",
license = "see context related readme files"
}
-- todo: keep track of changes here (hm, track access, and only true when
-- accessed and changed)
--[[ldx--
A utility file has always been part of and with
the move to we also moved a lot of multi-pass info
to a table. Instead of loading a based
utility file under different setups, we now load a table once. This
saves much runtime but at the cost of more memory usage.
--ldx]]--
local format, match = string.format, string.match
local next, type, tostring = next, type, tostring
local concat = table.concat
local texcount = tex.count
local definetable = utilities.tables.definetable
local accesstable = utilities.tables.accesstable
local migratetable = utilities.tables.migratetable
local serialize = table.serialize
local packers = utilities.packers
local allocate = utilities.storage.allocate
local mark = utilities.storage.mark
local report_passes = logs.reporter("job","passes")
job = job or { }
local job = job
job.version = 1.22 -- make sure we don't have old lua 5.1 hash leftovers
job.packversion = 1.02 -- make sure we don't have old lua 5.1 hash leftovers
-- some day we will implement loading of other jobs and then we need
-- job.jobs
--[[ldx--
Variables are saved using in the previously defined table and passed
onto using the following method. Of course one can also
directly access the variable using a call.
--ldx]]--
local savelist, comment = { }, { }
function job.comment(key,value)
comment[key] = value
end
job.comment("version",job.version)
local enabled = true
directives.register("job.save",function(v) enabled = v end)
function job.disablesave() -- can be command
enabled = false
end
function job.initialize(loadname,savename)
job.load(loadname) -- has to come after structure is defined !
luatex.registerstopactions(function()
if enabled and not status.lasterrorstring or status.lasterrorstring == "" then
job.save(savename)
end
end)
end
function job.register(collected, tobesaved, initializer, finalizer)
savelist[#savelist+1] = { collected, tobesaved, initializer, finalizer }
end
-- as an example we implement variables
local tobesaved, collected, checksums = allocate(), allocate(), allocate()
local jobvariables = {
collected = collected,
tobesaved = tobesaved,
checksums = checksums,
}
job.variables = jobvariables
if not checksums.old then checksums.old = md5.HEX("old") end -- used in experiment
if not checksums.new then checksums.new = md5.HEX("new") end -- used in experiment
job.register('job.variables.checksums', checksums)
local rmethod, rvalue
local function initializer()
tobesaved = jobvariables.tobesaved
collected = jobvariables.collected
checksums = jobvariables.checksums
rvalue = collected.randomseed
if not rvalue then
rvalue = math.random()
math.setrandomseedi(rvalue,"initialize")
rmethod = "initialized"
else
math.setrandomseedi(rvalue,"previous run")
rmethod = "resumed"
end
tobesaved.randomseed = rvalue
for cs, value in next, collected do
context.setxvalue(cs,value)
end
end
job.register('job.variables.collected', tobesaved, initializer)
function jobvariables.save(cs,value)
tobesaved[cs] = value
end
local packlist = {
"numbers",
"metadata",
"sectiondata",
"prefixdata",
"numberdata",
"pagedata",
"directives",
"specification",
"processors", -- might become key under directives or metadata
-- "references", -- we need to rename of them as only one packs (not structures.lists.references)
}
local jobpacker = packers.new(packlist,job.packversion) -- jump number when changs in hash
job.pack = true
-- job.pack = false
directives.register("job.pack",function(v) pack = v end)
local _save_, _load_, _others_ = { }, { }, { } -- registers timing
function job.save(filename) -- we could return a table but it can get pretty large
statistics.starttiming(_save_)
local f = io.open(filename,'w')
if f then
f:write("local utilitydata = { }\n\n")
f:write(serialize(comment,"utilitydata.comment",true,true),"\n\n")
for l=1,#savelist do
local list = savelist[l]
local target = format("utilitydata.%s",list[1])
local data = list[2]
local finalizer = list[4]
if type(finalizer) == "function" then
finalizer()
end
if job.pack then
packers.pack(data,jobpacker,true)
end
local definer, name = definetable(target,true,true) -- no first and no last
f:write(definer,"\n\n",serialize(data,name,true,true),"\n\n")
end
if job.pack then
packers.strip(jobpacker)
f:write(serialize(jobpacker,"utilitydata.job.packed",true,true),"\n\n")
end
f:write("return utilitydata")
f:close()
end
statistics.stoptiming(_save_)
end
local function load(filename)
if lfs.isfile(filename) then
local okay, data = pcall(dofile,filename)
if okay and type(data) == "table" then
local jobversion = job.version
local datacomment = data.comment
local dataversion = datacomment and datacomment.version or "?"
if dataversion ~= jobversion then
report_passes("version mismatch: %s <> %s",dataversion,jobversion)
else
return data
end
else
os.remove(filename) -- probably a bad file
report_passes("removing stale job data file %a, restart job",filename)
os.exit(true) -- trigger second run
end
end
end
function job.load(filename)
statistics.starttiming(_load_)
local utilitydata = load(filename)
if utilitydata then
local jobpacker = utilitydata.job.packed
for l=1,#savelist do
local list = savelist[l]
local target = list[1]
local initializer = list[3]
local result = accesstable(target,utilitydata)
local done = packers.unpack(result,jobpacker,true)
if done then
migratetable(target,mark(result))
if type(initializer) == "function" then
initializer(result)
end
else
report_passes("pack version mismatch")
end
end
end
statistics.stoptiming(_load_)
end
function job.loadother(filename)
statistics.starttiming(_load_)
_others_[#_others_+1] = file.nameonly(filename)
local utilitydata = load(filename)
if utilitydata then
local jobpacker = utilitydata.job.packed
local unpacked = { }
for l=1,#savelist do
local list = savelist[l]
local target = list[1]
local result = accesstable(target,utilitydata)
local done = packers.unpack(result,jobpacker,true)
if done then
migratetable(target,result,unpacked)
end
end
unpacked.job.packed = nil -- nicer in inspecting
return unpacked
end
statistics.stoptiming(_load_)
end
-- eventually this will end up in strc-ini
statistics.register("startup time", function()
return statistics.elapsedseconds(statistics,"including runtime option file processing")
end)
statistics.register("jobdata time",function()
if enabled then
if #_others_ > 0 then
return format("%s seconds saving, %s seconds loading, other files: %s",statistics.elapsedtime(_save_),statistics.elapsedtime(_load_),concat(_others_," "))
else
return format("%s seconds saving, %s seconds loading",statistics.elapsedtime(_save_),statistics.elapsedtime(_load_))
end
else
if #_others_ > 0 then
return format("nothing saved, %s seconds loading, other files: %s",statistics.elapsedtime(_load_),concat(_others_," "))
else
return format("nothing saved, %s seconds loading",statistics.elapsedtime(_load_))
end
end
end)
statistics.register("callbacks", function()
local total, indirect = status.callbacks or 0, status.indirect_callbacks or 0
local pages = texcount['realpageno'] - 1
if pages > 1 then
return format("direct: %s, indirect: %s, total: %s (%i per page)", total-indirect, indirect, total, total/pages)
else
return format("direct: %s, indirect: %s, total: %s", total-indirect, indirect, total)
end
end)
statistics.register("randomizer", function()
if rmethod and rvalue then
return format("%s with value %s",rmethod,rvalue)
end
end)
function statistics.formatruntime(runtime)
if not environment.initex then -- else error when testing as not counters yet
local shipped = texcount['nofshipouts']
local pages = texcount['realpageno']
if pages > shipped then
pages = shipped
end
if shipped > 0 or pages > 0 then
local persecond = shipped / runtime
if pages == 0 then pages = shipped end
return format("%s seconds, %i processed pages, %i shipped pages, %.3f pages/second",runtime,pages,shipped,persecond)
else
return format("%s seconds",runtime)
end
end
end