summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorJeija <jeija@mesecons.net>2014-11-22 14:47:18 +0100
committerJeija <jeija@mesecons.net>2014-11-22 14:47:18 +0100
commitffacbfde5a956da910479139f490f8ffa3ae5a85 (patch)
tree0698c4bd63bf1538ca60b1f406c8c708e272a2cb
parentb5cc933287b9dcd1d2e9b999398f93023e89fccc (diff)
downloadmesecons-ffacbfde5a956da910479139f490f8ffa3ae5a85.tar
mesecons-ffacbfde5a956da910479139f490f8ffa3ae5a85.tar.gz
mesecons-ffacbfde5a956da910479139f490f8ffa3ae5a85.tar.bz2
mesecons-ffacbfde5a956da910479139f490f8ffa3ae5a85.tar.xz
mesecons-ffacbfde5a956da910479139f490f8ffa3ae5a85.zip
Use an iterative algorithm for turnon() and turnoff(), fixes #160
This may also bring some performance benefit.
-rw-r--r--mesecons/internal.lua161
-rw-r--r--mesecons_luacontroller/init.lua5
2 files changed, 84 insertions, 82 deletions
diff --git a/mesecons/internal.lua b/mesecons/internal.lua
index edf361f..75d7785 100644
--- a/mesecons/internal.lua
+++ b/mesecons/internal.lua
@@ -22,9 +22,9 @@
-- mesecon:effector_get_rules(node) --> Returns the input rules of the effector (mesecon.rules.default if none specified)
-- SIGNALS
--- mesecon:activate(pos, node, recdepth) --> Activates the effector node at the specific pos (calls nodedef.mesecons.effector.action_on), higher recdepths are executed later
--- mesecon:deactivate(pos, node, recdepth) --> Deactivates the effector node at the specific pos (calls nodedef.mesecons.effector.action_off), "
--- mesecon:changesignal(pos, node, rulename, newstate) --> Changes the effector node at the specific pos (calls nodedef.mesecons.effector.action_change), "
+-- mesecon:activate(pos, node, depth) --> Activates the effector node at the specific pos (calls nodedef.mesecons.effector.action_on), higher depths are executed later
+-- mesecon:deactivate(pos, node, depth) --> Deactivates the effector node at the specific pos (calls nodedef.mesecons.effector.action_off), higher depths are executed later
+-- mesecon:changesignal(pos, node, rulename, newstate, depth) --> Changes the effector node at the specific pos (calls nodedef.mesecons.effector.action_change), higher depths are executed later
-- CONDUCTORS
-- mesecon:is_conductor(nodename) --> Returns true if nodename is a conductor
@@ -187,14 +187,14 @@ mesecon.queue:add_function("activate", function (pos, rulename)
end
end)
-function mesecon:activate(pos, node, rulename, recdepth)
+function mesecon:activate(pos, node, rulename, depth)
if rulename == nil then
for _,rule in ipairs(mesecon:effector_get_rules(node)) do
- mesecon:activate(pos, node, rule, recdepth + 1)
+ mesecon:activate(pos, node, rule, depth + 1)
end
return
end
- mesecon.queue:add_action(pos, "activate", {rulename}, nil, rulename, 1 / recdepth)
+ mesecon.queue:add_action(pos, "activate", {rulename}, nil, rulename, 1 / depth)
end
@@ -208,36 +208,36 @@ mesecon.queue:add_function("deactivate", function (pos, rulename)
end
end)
-function mesecon:deactivate(pos, node, rulename, recdepth)
+function mesecon:deactivate(pos, node, rulename, depth)
if rulename == nil then
for _,rule in ipairs(mesecon:effector_get_rules(node)) do
- mesecon:deactivate(pos, node, rule, recdepth + 1)
+ mesecon:deactivate(pos, node, rule, depth + 1)
end
return
end
- mesecon.queue:add_action(pos, "deactivate", {rulename}, nil, rulename, 1 / recdepth)
+ mesecon.queue:add_action(pos, "deactivate", {rulename}, nil, rulename, 1 / depth)
end
-- Change
mesecon.queue:add_function("change", function (pos, rulename, changetype)
- node = minetest.get_node(pos)
- effector = mesecon:get_effector(node.name)
+ local node = minetest.get_node(pos)
+ local effector = mesecon:get_effector(node.name)
if effector and effector.action_change then
effector.action_change(pos, node, rulename, changetype)
end
end)
-function mesecon:changesignal(pos, node, rulename, newstate, recdepth)
+function mesecon:changesignal(pos, node, rulename, newstate, depth)
if rulename == nil then
for _,rule in ipairs(mesecon:effector_get_rules(node)) do
- mesecon:changesignal(pos, node, rule, newstate, recdepth + 1)
+ mesecon:changesignal(pos, node, rule, newstate, depth + 1)
end
return
end
- mesecon.queue:add_action(pos, "change", {rulename, newstate}, nil, rulename, 1 / recdepth)
+ mesecon.queue:add_action(pos, "change", {rulename, newstate}, nil, rulename, 1 / depth)
end
-- Conductors
@@ -349,50 +349,47 @@ function mesecon:is_power_off(pos, rulename)
return false
end
-function mesecon:turnon(pos, rulename, recdepth)
- recdepth = recdepth or 2
- if (recdepth > STACK_SIZE) then return end
- local node = minetest.get_node(pos)
+function mesecon:turnon(pos, link)
+ local frontiers = {{pos = pos, link = link}}
- if(node.name == "ignore") then
- -- try turning on later again
- mesecon.queue:add_action(
- pos, "turnon", {rulename, recdepth + 1}, nil, true)
- end
-
- if mesecon:is_conductor_off(node, rulename) then
- local rules = mesecon:conductor_get_rules(node)
+ local depth = 1
+ while frontiers[depth] do
+ local f = frontiers[depth]
+ local node = minetest.get_node_or_nil(f.pos)
- if not rulename then
- for _, rule in ipairs(mesecon:flattenrules(rules)) do
- if mesecon:connected_to_receptor(pos, rule) then
- mesecon:turnon(pos, rule, recdepth + 1)
- end
- end
- return
+ -- area not loaded, postpone action
+ if not node then
+ mesecon.queue:add_action(f.pos, "turnon", {link}, nil, true)
end
- minetest.swap_node(pos, {name = mesecon:get_conductor_on(node, rulename), param2 = node.param2})
+ if mesecon:is_conductor_off(node, f.link) then
+ local rules = mesecon:conductor_get_rules(node)
- for _, rule in ipairs(mesecon:rule2meta(rulename, rules)) do
- local np = mesecon:addPosRule(pos, rule)
- if(minetest.get_node(np).name == "ignore") then
- -- try turning on later again
- mesecon.queue:add_action(
- np, "turnon", {rulename, recdepth + 1}, nil, true)
- else
- local rulenames = mesecon:rules_link_rule_all(pos, rule)
-
- for _, rulename in ipairs(rulenames) do
- mesecon:turnon(np, rulename, recdepth + 1)
+ minetest.swap_node(f.pos, {name = mesecon:get_conductor_on(node, f.link),
+ param2 = node.param2})
+
+ -- call turnon on neighbors: normal rules
+ for _, r in ipairs(mesecon:rule2meta(f.link, rules)) do
+ local np = mesecon:addPosRule(f.pos, r)
+
+ -- area not loaded, postpone action
+ if not minetest.get_node_or_nil(np) then
+ mesecon.queue:add_action(np, "turnon", {rulename},
+ nil, true)
+ else
+ local links = mesecon:rules_link_rule_all(f.pos, r)
+ for _, l in ipairs(links) do
+ table.insert(frontiers, {pos = np, link = l})
+ end
end
end
+ elseif mesecon:is_effector(node.name) then
+ mesecon:changesignal(f.pos, node, f.link, mesecon.state.on, depth)
+ if mesecon:is_effector_off(node.name) then
+ mesecon:activate(f.pos, node, f.link, depth)
+ end
end
- elseif mesecon:is_effector(node.name) then
- mesecon:changesignal(pos, node, rulename, mesecon.state.on, recdepth)
- if mesecon:is_effector_off(node.name) then
- mesecon:activate(pos, node, rulename, recdepth)
- end
+ depth = depth + 1
end
end
@@ -400,41 +397,47 @@ mesecon.queue:add_function("turnon", function (pos, rulename, recdepth)
mesecon:turnon(pos, rulename, recdepth)
end)
-function mesecon:turnoff(pos, rulename, recdepth)
- recdepth = recdepth or 2
- if (recdepth > STACK_SIZE) then return end
- local node = minetest.get_node(pos)
+function mesecon:turnoff(pos, link)
+ local frontiers = {{pos = pos, link = link}}
- if(node.name == "ignore") then
- -- try turning on later again
- mesecon.queue:add_action(
- pos, "turnoff", {rulename, recdepth + 1}, nil, true)
- end
+ local depth = 1
+ while frontiers[depth] do
+ local f = frontiers[depth]
+ local node = minetest.get_node_or_nil(f.pos)
- if mesecon:is_conductor_on(node, rulename) then
- local rules = mesecon:conductor_get_rules(node)
- minetest.swap_node(pos, {name = mesecon:get_conductor_off(node, rulename), param2 = node.param2})
+ -- area not loaded, postpone action
+ if not node then
+ mesecon.queue:add_action(f.pos, "turnoff", {link}, nil, true)
+ end
- for _, rule in ipairs(mesecon:rule2meta(rulename, rules)) do
- local np = mesecon:addPosRule(pos, rule)
- if(minetest.get_node(np).name == "ignore") then
- -- try turning on later again
- mesecon.queue:add_action(
- np, "turnoff", {rulename, recdepth + 1}, nil, true)
- else
- local rulenames = mesecon:rules_link_rule_all(pos, rule)
-
- for _, rulename in ipairs(rulenames) do
- mesecon:turnoff(np, rulename, recdepth + 1)
+ if mesecon:is_conductor_on(node, f.link) then
+ local rules = mesecon:conductor_get_rules(node)
+
+ minetest.swap_node(f.pos, {name = mesecon:get_conductor_off(node, f.link),
+ param2 = node.param2})
+
+ -- call turnoff on neighbors: normal rules
+ for _, r in ipairs(mesecon:rule2meta(f.link, rules)) do
+ local np = mesecon:addPosRule(f.pos, r)
+
+ -- area not loaded, postpone action
+ if not minetest.get_node_or_nil(np) then
+ mesecon.queue:add_action(np, "turnoff", {rulename},
+ nil, true)
+ else
+ local links = mesecon:rules_link_rule_all(f.pos, r)
+ for _, l in ipairs(links) do
+ table.insert(frontiers, {pos = np, link = l})
+ end
end
end
+ elseif mesecon:is_effector(node.name) then
+ mesecon:changesignal(f.pos, node, f.link, mesecon.state.off, depth)
+ if mesecon:is_effector_on(node.name) and not mesecon:is_powered(f.pos) then
+ mesecon:deactivate(f.pos, node, f.link, depth)
+ end
end
- elseif mesecon:is_effector(node.name) then
- mesecon:changesignal(pos, node, rulename, mesecon.state.off, recdepth)
- if mesecon:is_effector_on(node.name)
- and not mesecon:is_powered(pos) then
- mesecon:deactivate(pos, node, rulename, recdepth + 1)
- end
+ depth = depth + 1
end
end
diff --git a/mesecons_luacontroller/init.lua b/mesecons_luacontroller/init.lua
index 6fb5d03..e4faaad 100644
--- a/mesecons_luacontroller/init.lua
+++ b/mesecons_luacontroller/init.lua
@@ -83,7 +83,6 @@ local merge_portstates = function (ports, vports)
end
local generate_name = function (ports)
- local overwrite = overwrite or {}
local d = ports.d and 1 or 0
local c = ports.c and 1 or 0
local b = ports.b and 1 or 0
@@ -271,7 +270,7 @@ local create_sandbox = function (code, env)
if code:byte(1) == 27 then
return _, "You Hacker You! Don't use binary code!"
end
- f, msg = loadstring(code)
+ local f, msg = loadstring(code)
if not f then return _, msg end
setfenv(f, env)
return f
@@ -321,7 +320,7 @@ lc_update = function (pos, event)
-- create the sandbox and execute code
local chunk, msg = create_sandbox (code, env)
if not chunk then return msg end
- local success, msg = pcall(f)
+ local success, msg = pcall(chunk)
if not success then return msg end
if ports_invalid(env.port) then return ports_invalid(env.port) end