Parallelize (ish; CC can't do much of that) indexing
This commit is contained in:
parent
7b6c2f5332
commit
94743e9633
@ -108,12 +108,18 @@ local function server(command)
|
|||||||
if command.type == "buffers" then -- Sends the external address of the buffer
|
if command.type == "buffers" then -- Sends the external address of the buffer
|
||||||
return conf.buffer_external
|
return conf.buffer_external
|
||||||
elseif command.type == "reindex" then
|
elseif command.type == "reindex" then
|
||||||
update_index()
|
os.queueEvent "reindex"
|
||||||
elseif command.type == "extract" then
|
elseif command.type == "extract" then
|
||||||
local result = find_by_ID_meta(command.ID, command.meta)
|
local result = find_by_ID_meta(command.ID, command.meta)
|
||||||
end
|
end
|
||||||
end
|
end
|
||||||
|
|
||||||
update_index()
|
local function indexer_thread()
|
||||||
|
while true do
|
||||||
|
update_index()
|
||||||
|
os.pullEvent "reindex"
|
||||||
|
end
|
||||||
|
end
|
||||||
|
|
||||||
w.init()
|
w.init()
|
||||||
w.serve(server, "storage")
|
parallel.waitForAll(function() w.serve(server, "storage") end, indexer_thread)
|
Loading…
Reference in New Issue
Block a user