mtcontrib/colddb
1
0
Fork 1
Code Issues Pull Requests Releases Wiki Activity

Move: desc and depends into conf file

Browse Source
This commit is contained in:
Coder12a 2019-05-13 14:32:42 -05:00
parent 8ca43c745a
commit 2943e0ddfb
6 changed files with 4 additions and 211 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

206
async.lua
View File

@ -1,206 +0,0 @@
if not extended_api then
extended_api = {}
end
if not extended_api.Async then
extended_api.Async = {}
end
function extended_api.Async()
local self = {}
self.task_queue = {}
self.resting = 200
self.maxtime = 200
self.queue_threads = 8
self.state = "suspended"
self.create_worker = function(func)
local thread = coroutine.create(func)
if not thread or coroutine.status(thread) == "dead" then
minetest.after(0.3, self.create_worker, func)
return
end
self.run_worker(thread)
end
self.create_globalstep_worker = function(func)
local thread = coroutine.create(func)
if not thread or coroutine.status(thread) == "dead" then
minetest.after(0.3, self.create_globalstep_worker, func)
return
end
self.run_globalstep_worker(thread)
end
self.run_worker = function(thread)
if not thread or coroutine.status(thread) == "dead" then
return false
else
coroutine.resume(thread)
minetest.after(self.resting / 1000, self.run_worker, thread)
return true
end
end
self.run_globalstep_worker = function(thread)
if not thread or coroutine.status(thread) == "dead" then
return false
else
coroutine.resume(thread)
minetest.after(0, self.run_globalstep_worker, thread)
return true
end
end
self.priority = function(resting, maxtime)
self.resting = resting
self.maxtime = maxtime
end
self.iterate = function(from, to, func, callback)
self.create_worker(function()
local last_time = minetest.get_us_time() / 1000
local maxtime = self.maxtime
for i = from, to do
local b = func(i)
if b ~= nil and b == false then
break
end
if minetest.get_us_time() / 1000 > last_time + maxtime then
coroutine.yield()
last_time = minetest.get_us_time() / 1000
end
end
if callback then
callback()
end
return
end)
end
self.foreach = function(array, func, callback)
self.create_worker(function()
local last_time = minetest.get_us_time() / 1000
local maxtime = self.maxtime
for k,v in ipairs(array) do
local b = func(k,v)
if b ~= nil and b == false then
break
end
if minetest.get_us_time() / 1000 > last_time + maxtime then
coroutine.yield()
last_time = minetest.get_us_time() / 1000
end
end
if callback then
callback()
end
return
end)
end
self.do_while = function(condition_func, func, callback)
self.create_worker(function()
local last_time = minetest.get_us_time() / 1000
local maxtime = self.maxtime
while(condition_func()) do
local c = func()
if c ~= nil and c ~= condition_func() then
break
end
if minetest.get_us_time() / 1000 > last_time + maxtime then
coroutine.yield()
last_time = minetest.get_us_time() / 1000
end
end
if callback then
callback()
end
return
end)
end
self.register_globalstep = function(func)
self.create_globalstep_worker(function()
local last_time = minetest.get_us_time() / 1000000
local dtime = last_time
while(true) do
dtime = (minetest.get_us_time() / 1000000) - last_time
func(dtime)
-- 0.05 seconds
if minetest.get_us_time() / 1000000 > last_time + 0.05 then
coroutine.yield()
last_time = minetest.get_us_time() / 1000000
end
end
end)
end
self.chain_task = function(tasks, callback)
self.create_worker(function()
local pass_arg = nil
local last_time = minetest.get_us_time() / 1000
local maxtime = self.maxtime
for index, task_func in pairs(tasks) do
local p = task_func(pass_arg)
if p ~= nil then
pass_arg = p
end
if minetest.get_us_time() / 1000 > last_time + maxtime then
coroutine.yield()
last_time = minetest.get_us_time() / 1000
end
end
if callback then
callback(pass_arg)
end
return
end)
end
self.queue_task = function(func, callback)
table.insert(self.task_queue, {func = func,callback = callback})
if self.queue_threads > 0 then
self.queue_threads = self.queue_threads - 1
self.create_worker(function()
local pass_arg = nil
local last_time = minetest.get_us_time() / 1000
local maxtime = self.maxtime
while(true) do
local task_func = self.task_queue[1]
table.remove(self.task_queue, 1)
if task_func and task_func.func then
pass_arg = nil
local p = task_func.func()
if p ~= nil then
pass_arg = p
end
if task_func.callback then
task_func.callback(pass_arg)
end
if minetest.get_us_time() / 1000 > last_time + maxtime then
coroutine.yield()
last_time = minetest.get_us_time() / 1000
end
else
self.queue_threads = self.queue_threads + 1
return
end
end
end)
end
end
self.single_task = function(func, callback)
self.create_worker(function()
local pass_arg = func()
if p ~= nil then
pass_arg = p
end
if task_func.callback then
task_func.callback(pass_arg)
end
return
end)
end
return self
end

2
colddb.lua
View File

@ -11,7 +11,7 @@ function colddb.Colddb(dir)
local mem_pool = {} local mem_pool = {}
local mem_pool_del = {} local mem_pool_del = {}
local add_to_mem_pool = true local add_to_mem_pool = true
local async = extended_api.Async() local async = async.Async()
async.priority(150, 250) async.priority(150, 250)

1
depends.txt
View File

@ -1 +0,0 @@
extended_api?

1
description.txt
View File

@ -1 +0,0 @@
pure lua No-sql Asynchronous database mod.

1
init.lua
View File

@ -1,4 +1,3 @@
modpath = minetest.get_modpath("colddb") modpath = minetest.get_modpath("colddb")
dofile(string.format("%s/async.lua", modpath))
dofile(string.format("%s/colddb.lua", modpath)) dofile(string.format("%s/colddb.lua", modpath))

4
mod.conf
View File

@ -1 +1,3 @@
name = colddb name = colddb
description = pure lua No-sql Asynchronous database mod.
depends = async