refactor(loader): remove Loader table and use locals

This commit is contained in:
Lewis Russell
2024-10-31 14:48:28 +00:00
parent 4a0010e267
commit 8d68d883a9

View File

@@ -4,6 +4,9 @@ local uri_encode = vim.uri_encode --- @type function
--- @type (fun(modename: string): fun()|string)[] --- @type (fun(modename: string): fun()|string)[]
local loaders = package.loaders local loaders = package.loaders
local _loadfile = loadfile
local VERSION = 4
local M = {} local M = {}
@@ -42,7 +45,7 @@ local M = {}
--- The fs_stat of the module path. Won't be returned for `modname="*"` --- The fs_stat of the module path. Won't be returned for `modname="*"`
--- @field stat? uv.uv_fs_t --- @field stat? uv.uv_fs_t
---@alias LoaderStats table<string, {total:number, time:number, [string]:number?}?> ---@alias vim.loader.Stats table<string, {total:number, time:number, [string]:number?}?>
---@nodoc ---@nodoc
M.path = vim.fn.stdpath('cache') .. '/luac' M.path = vim.fn.stdpath('cache') .. '/luac'
@@ -50,76 +53,69 @@ M.path = vim.fn.stdpath('cache') .. '/luac'
---@nodoc ---@nodoc
M.enabled = false M.enabled = false
---@class (private) Loader ---@type vim.loader.Stats
---@field private _rtp string[] local stats = { find = { total = 0, time = 0, not_found = 0 } }
---@field private _rtp_pure string[]
---@field private _rtp_key string --- @type table<string, vim.loader.CacheHash>?
---@field private _hashes? table<string, vim.loader.CacheHash> local hashes
local Loader = {
VERSION = 4,
---@type table<string, table<string,vim.loader.ModuleInfo>> ---@type table<string, table<string,vim.loader.ModuleInfo>>
_indexed = {}, local indexed = {}
_loadfile = loadfile,
---@type LoaderStats
_stats = {
find = { total = 0, time = 0, not_found = 0 },
},
}
--- @param path string --- @param path string
--- @return vim.loader.CacheHash --- @return vim.loader.CacheHash
--- @private local function get_hash(path)
function Loader.get_hash(path) if not hashes then
if not Loader._hashes then
return uv.fs_stat(path) --[[@as vim.loader.CacheHash]] return uv.fs_stat(path) --[[@as vim.loader.CacheHash]]
end end
if not Loader._hashes[path] then if not hashes[path] then
-- Note we must never save a stat for a non-existent path. -- Note we must never save a stat for a non-existent path.
-- For non-existent paths fs_stat() will return nil. -- For non-existent paths fs_stat() will return nil.
Loader._hashes[path] = uv.fs_stat(path) hashes[path] = uv.fs_stat(path)
end end
return Loader._hashes[path] return hashes[path]
end end
local function normalize(path) local function normalize(path)
return fs.normalize(path, { expand_env = false, _fast = true }) return fs.normalize(path, { expand_env = false, _fast = true })
end end
local rtp_cached = {} --- @type string[]
local rtp_cache_key --- @type string?
--- Gets the rtp excluding after directories. --- Gets the rtp excluding after directories.
--- The result is cached, and will be updated if the runtime path changes. --- The result is cached, and will be updated if the runtime path changes.
--- When called from a fast event, the cached value will be returned. --- When called from a fast event, the cached value will be returned.
--- @return string[] rtp, boolean updated --- @return string[] rtp, boolean updated
---@private local function get_rtp()
function Loader.get_rtp()
if vim.in_fast_event() then if vim.in_fast_event() then
return (Loader._rtp or {}), false return (rtp_cached or {}), false
end end
local updated = false local updated = false
local key = vim.go.rtp local key = vim.go.rtp
if key ~= Loader._rtp_key then if key ~= rtp_cache_key then
Loader._rtp = {} rtp_cached = {}
for _, path in ipairs(vim.api.nvim_get_runtime_file('', true)) do for _, path in ipairs(vim.api.nvim_get_runtime_file('', true)) do
path = normalize(path) path = normalize(path)
-- skip after directories -- skip after directories
if if
path:sub(-6, -1) ~= '/after' path:sub(-6, -1) ~= '/after'
and not (Loader._indexed[path] and vim.tbl_isempty(Loader._indexed[path])) and not (indexed[path] and vim.tbl_isempty(indexed[path]))
then then
Loader._rtp[#Loader._rtp + 1] = path rtp_cached[#rtp_cached + 1] = path
end end
end end
updated = true updated = true
Loader._rtp_key = key rtp_cache_key = key
end end
return Loader._rtp, updated return rtp_cached, updated
end end
--- Returns the cache file name --- Returns the cache file name
---@param name string can be a module name, or a file name ---@param name string can be a module name, or a file name
---@return string file_name ---@return string file_name
---@private local function cache_filename(name)
function Loader.cache_file(name)
local ret = ('%s/%s'):format(M.path, uri_encode(name, 'rfc2396')) local ret = ('%s/%s'):format(M.path, uri_encode(name, 'rfc2396'))
return ret:sub(-4) == '.lua' and (ret .. 'c') or (ret .. '.luac') return ret:sub(-4) == '.lua' and (ret .. 'c') or (ret .. '.luac')
end end
@@ -128,11 +124,10 @@ end
---@param cname string cache filename ---@param cname string cache filename
---@param hash vim.loader.CacheHash ---@param hash vim.loader.CacheHash
---@param chunk function ---@param chunk function
---@private local function write_cachefile(cname, hash, chunk)
function Loader.write(cname, hash, chunk)
local f = assert(uv.fs_open(cname, 'w', 438)) local f = assert(uv.fs_open(cname, 'w', 438))
local header = { local header = {
Loader.VERSION, VERSION,
hash.size, hash.size,
hash.mtime.sec, hash.mtime.sec,
hash.mtime.nsec, hash.mtime.nsec,
@@ -159,8 +154,7 @@ end
---@param cname string cache filename ---@param cname string cache filename
---@return vim.loader.CacheHash? hash ---@return vim.loader.CacheHash? hash
---@return string? chunk ---@return string? chunk
---@private local function read_cachefile(cname)
function Loader.read(cname)
local data = readfile(cname, 438) local data = readfile(cname, 438)
if not data then if not data then
return return
@@ -173,7 +167,7 @@ function Loader.read(cname)
---@type integer[]|{[0]:integer} ---@type integer[]|{[0]:integer}
local header = vim.split(data:sub(1, zero - 1), ',') local header = vim.split(data:sub(1, zero - 1), ',')
if tonumber(header[1]) ~= Loader.VERSION then if tonumber(header[1]) ~= VERSION then
return return
end end
@@ -190,18 +184,17 @@ end
--- The `package.loaders` loader for Lua files using the cache. --- The `package.loaders` loader for Lua files using the cache.
---@param modname string module name ---@param modname string module name
---@return string|function ---@return string|function
---@private local function loader_cached(modname)
function Loader.loader(modname) hashes = {}
Loader._hashes = {}
local ret = M.find(modname)[1] local ret = M.find(modname)[1]
if ret then if ret then
-- Make sure to call the global loadfile so we respect any augmentations done elsewhere. -- Make sure to call the global loadfile so we respect any augmentations done elsewhere.
-- E.g. profiling -- E.g. profiling
local chunk, err = loadfile(ret.modpath) local chunk, err = loadfile(ret.modpath)
Loader._hashes = nil hashes = nil
return chunk or error(err) return chunk or error(err)
end end
Loader._hashes = nil hashes = nil
return ("\n\tcache_loader: module '%s' not found"):format(modname) return ("\n\tcache_loader: module '%s' not found"):format(modname)
end end
@@ -210,8 +203,7 @@ local is_win = vim.fn.has('win32') == 1
--- The `package.loaders` loader for libs --- The `package.loaders` loader for libs
---@param modname string module name ---@param modname string module name
---@return string|function ---@return string|function
---@private local function loader_lib_cached(modname)
function Loader.loader_lib(modname)
local ret = M.find(modname, { patterns = { is_win and '.dll' or '.so' } })[1] local ret = M.find(modname, { patterns = { is_win and '.dll' or '.so' } })[1]
if not ret then if not ret then
return ("\n\tcache_loader_lib: module '%s' not found"):format(modname) return ("\n\tcache_loader_lib: module '%s' not found"):format(modname)
@@ -228,20 +220,33 @@ function Loader.loader_lib(modname)
return chunk or error(err) return chunk or error(err)
end end
--- Checks whether two cache hashes are the same based on:
--- * file size
--- * mtime in seconds
--- * mtime in nanoseconds
---@param a? vim.loader.CacheHash
---@param b? vim.loader.CacheHash
local function hash_eq(a, b)
return a
and b
and a.size == b.size
and a.mtime.sec == b.mtime.sec
and a.mtime.nsec == b.mtime.nsec
end
--- `loadfile` using the cache --- `loadfile` using the cache
--- Note this has the mode and env arguments which is supported by LuaJIT and is 5.1 compatible. --- Note this has the mode and env arguments which is supported by LuaJIT and is 5.1 compatible.
---@param filename? string ---@param filename? string
---@param mode? "b"|"t"|"bt" ---@param mode? "b"|"t"|"bt"
---@param env? table ---@param env? table
---@return function?, string? error_message ---@return function?, string? error_message
---@private local function loadfile_cached(filename, mode, env)
function Loader.loadfile(filename, mode, env)
local modpath = normalize(filename) local modpath = normalize(filename)
local hash = Loader.get_hash(modpath) local hash = get_hash(modpath)
local cname = Loader.cache_file(modpath) local cname = cache_filename(modpath)
if hash then if hash then
local e_hash, e_chunk = Loader.read(cname) local e_hash, e_chunk = read_cachefile(cname)
if Loader.eq(e_hash, hash) and e_chunk then if hash_eq(e_hash, hash) and e_chunk then
-- found in cache and up to date -- found in cache and up to date
local chunk, err = load(e_chunk, '@' .. modpath, mode, env) local chunk, err = load(e_chunk, '@' .. modpath, mode, env)
if not (err and err:find('cannot load incompatible bytecode', 1, true)) then if not (err and err:find('cannot load incompatible bytecode', 1, true)) then
@@ -250,26 +255,38 @@ function Loader.loadfile(filename, mode, env)
end end
end end
local chunk, err = Loader._loadfile(modpath, mode, env) local chunk, err = _loadfile(modpath, mode, env)
if chunk then if chunk then
Loader.write(cname, hash, chunk) write_cachefile(cname, hash, chunk)
end end
return chunk, err return chunk, err
end end
--- Checks whether two cache hashes are the same based on: --- Return the top-level \`/lua/*` modules for this path
--- * file size ---@param path string path to check for top-level Lua modules
--- * mtime in seconds local function lsmod(path)
--- * mtime in nanoseconds if not indexed[path] then
---@param a? vim.loader.CacheHash indexed[path] = {}
---@param b? vim.loader.CacheHash for name, t in fs.dir(path .. '/lua') do
---@private local modpath = path .. '/lua/' .. name
function Loader.eq(a, b) -- HACK: type is not always returned due to a bug in luv
return a t = t or get_hash(modpath).type
and b ---@type string
and a.size == b.size local topname
and a.mtime.sec == b.mtime.sec local ext = name:sub(-4)
and a.mtime.nsec == b.mtime.nsec if ext == '.lua' or ext == '.dll' then
topname = name:sub(1, -5)
elseif name:sub(-3) == '.so' then
topname = name:sub(1, -4)
elseif t == 'link' or t == 'directory' then
topname = name
end
if topname then
indexed[path][topname] = { modpath = modpath, modname = topname }
end
end
end
return indexed[path]
end end
--- Finds Lua modules for the given module name. --- Finds Lua modules for the given module name.
@@ -318,17 +335,17 @@ function M.find(modname, opts)
local function _find(paths) local function _find(paths)
for _, path in ipairs(paths) do for _, path in ipairs(paths) do
if topmod == '*' then if topmod == '*' then
for _, r in pairs(Loader.lsmod(path)) do for _, r in pairs(lsmod(path)) do
results[#results + 1] = r results[#results + 1] = r
if not continue() then if not continue() then
return return
end end
end end
elseif Loader.lsmod(path)[topmod] then elseif lsmod(path)[topmod] then
for _, pattern in ipairs(patterns) do for _, pattern in ipairs(patterns) do
local modpath = path .. pattern local modpath = path .. pattern
Loader._stats.find.stat = (Loader._stats.find.stat or 0) + 1 stats.find.stat = (stats.find.stat or 0) + 1
local hash = Loader.get_hash(modpath) local hash = get_hash(modpath)
if hash then if hash then
results[#results + 1] = { modpath = modpath, stat = hash, modname = modname } results[#results + 1] = { modpath = modpath, stat = hash, modname = modname }
if not continue() then if not continue() then
@@ -342,9 +359,9 @@ function M.find(modname, opts)
-- always check the rtp first -- always check the rtp first
if opts.rtp ~= false then if opts.rtp ~= false then
_find(Loader._rtp or {}) _find(rtp_cached or {})
if continue() then if continue() then
local rtp, updated = Loader.get_rtp() local rtp, updated = get_rtp()
if updated then if updated then
_find(rtp) _find(rtp)
end end
@@ -358,7 +375,7 @@ function M.find(modname, opts)
if #results == 0 then if #results == 0 then
-- module not found -- module not found
Loader._stats.find.not_found = Loader._stats.find.not_found + 1 stats.find.not_found = stats.find.not_found + 1
end end
return results return results
@@ -371,14 +388,14 @@ end
---@param path string? path to reset ---@param path string? path to reset
function M.reset(path) function M.reset(path)
if path then if path then
Loader._indexed[normalize(path)] = nil indexed[normalize(path)] = nil
else else
Loader._indexed = {} indexed = {}
end end
-- Path could be a directory so just clear all the hashes. -- Path could be a directory so just clear all the hashes.
if Loader._hashes then if hashes then
Loader._hashes = {} hashes = {}
end end
end end
@@ -395,11 +412,11 @@ function M.enable()
end end
M.enabled = true M.enabled = true
vim.fn.mkdir(vim.fn.fnamemodify(M.path, ':p'), 'p') vim.fn.mkdir(vim.fn.fnamemodify(M.path, ':p'), 'p')
_G.loadfile = Loader.loadfile _G.loadfile = loadfile_cached
-- add Lua loader -- add Lua loader
table.insert(loaders, 2, Loader.loader) table.insert(loaders, 2, loader_cached)
-- add libs loader -- add libs loader
table.insert(loaders, 3, Loader.loader_lib) table.insert(loaders, 3, loader_lib_cached)
-- remove Nvim loader -- remove Nvim loader
for l, loader in ipairs(loaders) do for l, loader in ipairs(loaders) do
if loader == vim._load_package then if loader == vim._load_package then
@@ -419,55 +436,26 @@ function M.disable()
return return
end end
M.enabled = false M.enabled = false
_G.loadfile = Loader._loadfile _G.loadfile = _loadfile
for l, loader in ipairs(loaders) do for l, loader in ipairs(loaders) do
if loader == Loader.loader or loader == Loader.loader_lib then if loader == loader_cached or loader == loader_lib_cached then
table.remove(loaders, l) table.remove(loaders, l)
end end
end end
table.insert(loaders, 2, vim._load_package) table.insert(loaders, 2, vim._load_package)
end end
--- Return the top-level \`/lua/*` modules for this path
---@param path string path to check for top-level Lua modules
---@private
function Loader.lsmod(path)
if not Loader._indexed[path] then
Loader._indexed[path] = {}
for name, t in fs.dir(path .. '/lua') do
local modpath = path .. '/lua/' .. name
-- HACK: type is not always returned due to a bug in luv
t = t or Loader.get_hash(modpath).type
---@type string
local topname
local ext = name:sub(-4)
if ext == '.lua' or ext == '.dll' then
topname = name:sub(1, -5)
elseif name:sub(-3) == '.so' then
topname = name:sub(1, -4)
elseif t == 'link' or t == 'directory' then
topname = name
end
if topname then
Loader._indexed[path][topname] = { modpath = modpath, modname = topname }
end
end
end
return Loader._indexed[path]
end
--- Tracks the time spent in a function --- Tracks the time spent in a function
--- @generic F: function --- @generic F: function
--- @param f F --- @param f F
--- @return F --- @return F
--- @private local function track(stat, f)
function Loader.track(stat, f)
return function(...) return function(...)
local start = vim.uv.hrtime() local start = vim.uv.hrtime()
local r = { f(...) } local r = { f(...) }
Loader._stats[stat] = Loader._stats[stat] or { total = 0, time = 0 } stats[stat] = stats[stat] or { total = 0, time = 0 }
Loader._stats[stat].total = Loader._stats[stat].total + 1 stats[stat].total = stats[stat].total + 1
Loader._stats[stat].time = Loader._stats[stat].time + uv.hrtime() - start stats[stat].time = stats[stat].time + uv.hrtime() - start
return unpack(r, 1, table.maxn(r)) return unpack(r, 1, table.maxn(r))
end end
end end
@@ -476,28 +464,29 @@ end
---@field loaders? boolean Add profiling to the loaders ---@field loaders? boolean Add profiling to the loaders
--- Debug function that wraps all loaders and tracks stats --- Debug function that wraps all loaders and tracks stats
--- Must be called before vim.loader.enable()
---@private ---@private
---@param opts vim.loader._profile.Opts? ---@param opts vim.loader._profile.Opts?
function M._profile(opts) function M._profile(opts)
Loader.get_rtp = Loader.track('get_rtp', Loader.get_rtp) get_rtp = track('get_rtp', get_rtp)
Loader.read = Loader.track('read', Loader.read) read_cachefile = track('read', read_cachefile)
Loader.loader = Loader.track('loader', Loader.loader) loader_cached = track('loader', loader_cached)
Loader.loader_lib = Loader.track('loader_lib', Loader.loader_lib) loader_lib_cached = track('loader_lib', loader_lib_cached)
Loader.loadfile = Loader.track('loadfile', Loader.loadfile) loadfile_cached = track('loadfile', loadfile_cached)
M.find = Loader.track('find', M.find) M.find = track('find', M.find)
Loader.lsmod = Loader.track('lsmod', Loader.lsmod) lsmod = track('lsmod', lsmod)
if opts and opts.loaders then if opts and opts.loaders then
for l, loader in pairs(loaders) do for l, loader in pairs(loaders) do
local loc = debug.getinfo(loader, 'Sn').source:sub(2) local loc = debug.getinfo(loader, 'Sn').source:sub(2)
loaders[l] = Loader.track('loader ' .. l .. ': ' .. loc, loader) loaders[l] = track('loader ' .. l .. ': ' .. loc, loader)
end end
end end
end end
--- Prints all cache stats --- Prints all cache stats
---@param opts? {print?:boolean} ---@param opts? {print?:boolean}
---@return LoaderStats ---@return vim.loader.Stats
---@private ---@private
function M._inspect(opts) function M._inspect(opts)
if opts and opts.print then if opts and opts.print then
@@ -505,20 +494,17 @@ function M._inspect(opts)
return math.floor(nsec / 1e6 * 1000 + 0.5) / 1000 .. 'ms' return math.floor(nsec / 1e6 * 1000 + 0.5) / 1000 .. 'ms'
end end
local chunks = {} ---@type string[][] local chunks = {} ---@type string[][]
---@type string[] for _, stat in vim.spairs(stats) do
local stats = vim.tbl_keys(Loader._stats)
table.sort(stats)
for _, stat in ipairs(stats) do
vim.list_extend(chunks, { vim.list_extend(chunks, {
{ '\n' .. stat .. '\n', 'Title' }, { '\n' .. stat .. '\n', 'Title' },
{ '* total: ' }, { '* total: ' },
{ tostring(Loader._stats[stat].total) .. '\n', 'Number' }, { tostring(stat.total) .. '\n', 'Number' },
{ '* time: ' }, { '* time: ' },
{ ms(Loader._stats[stat].time) .. '\n', 'Bold' }, { ms(stat.time) .. '\n', 'Bold' },
{ '* avg time: ' }, { '* avg time: ' },
{ ms(Loader._stats[stat].time / Loader._stats[stat].total) .. '\n', 'Bold' }, { ms(stat.time / stat.total) .. '\n', 'Bold' },
}) })
for k, v in pairs(Loader._stats[stat]) do for k, v in pairs(stat) do
if not vim.list_contains({ 'time', 'total' }, k) then if not vim.list_contains({ 'time', 'total' }, k) then
chunks[#chunks + 1] = { '* ' .. k .. ':' .. string.rep(' ', 9 - #k) } chunks[#chunks + 1] = { '* ' .. k .. ':' .. string.rep(' ', 9 - #k) }
chunks[#chunks + 1] = { tostring(v) .. '\n', 'Number' } chunks[#chunks + 1] = { tostring(v) .. '\n', 'Number' }
@@ -527,7 +513,7 @@ function M._inspect(opts)
end end
vim.api.nvim_echo(chunks, true, {}) vim.api.nvim_echo(chunks, true, {})
end end
return Loader._stats return stats
end end
return M return M