core: use strings as neuron addresses
This commit is contained in:
parent
244c61ddd1
commit
ec3c311539
5 changed files with 17 additions and 14 deletions
3
.gitignore
vendored
3
.gitignore
vendored
|
|
@ -6,6 +6,9 @@ erl_crash.dump
|
||||||
*.ez
|
*.ez
|
||||||
scopes-*.tar
|
scopes-*.tar
|
||||||
tmp/
|
tmp/
|
||||||
|
/priv/static/assets/
|
||||||
|
/priv/static/cache_manifest.json
|
||||||
|
/priv/static/docs
|
||||||
|
|
||||||
log/
|
log/
|
||||||
.env
|
.env
|
||||||
|
|
|
||||||
|
|
@ -10,7 +10,7 @@ defmodule Scopes.Core.Environ do
|
||||||
def setup({state, proc}, init_seq, proc_env \\ &proc_env/2) do
|
def setup({state, proc}, init_seq, proc_env \\ &proc_env/2) do
|
||||||
env_scope = {%State{init_seq: init_seq}, proc_env, [], self()}
|
env_scope = {%State{init_seq: init_seq}, proc_env, [], self()}
|
||||||
env = Core.neuron(env_scope)
|
env = Core.neuron(env_scope)
|
||||||
msg = Shape.create([:csys, :zero], data: %{addr: [:csys, :c00, {0, 0}]})
|
msg = Shape.create([:csys, :zero], data: %{addr: [:csys, :c00, "0-0"]})
|
||||||
proc = {state, proc, [], env}
|
proc = {state, proc, [], env}
|
||||||
Core.create(msg, proc)
|
Core.create(msg, proc)
|
||||||
env
|
env
|
||||||
|
|
|
||||||
|
|
@ -124,10 +124,10 @@ defmodule Scopes.Core.Program do
|
||||||
# demo init sequences
|
# demo init sequences
|
||||||
|
|
||||||
def init_seq_b1() do
|
def init_seq_b1() do
|
||||||
zero = [:csys, :c00, {0, 0}]
|
zero = [:csys, :c00, "0-0"]
|
||||||
one = [:csys, :s01, {1, 0}]
|
one = [:csys, :s01, "1-0"]
|
||||||
two = [:csys, :c00, {1, 1}]
|
two = [:csys, :c00, "1-1"]
|
||||||
three = [:csys, :s01, {1, 1}]
|
three = [:csys, :s01, "1-1"]
|
||||||
[
|
[
|
||||||
fn state ->
|
fn state ->
|
||||||
Environ.send_message(state, zero, ~w(csys create pred)a,
|
Environ.send_message(state, zero, ~w(csys create pred)a,
|
||||||
|
|
@ -145,16 +145,16 @@ defmodule Scopes.Core.Program do
|
||||||
end
|
end
|
||||||
|
|
||||||
def init_recursive_1() do
|
def init_recursive_1() do
|
||||||
zero = [:csys, :c00, {0, 0}]
|
zero = [:csys, :c00, "0-0"]
|
||||||
[
|
[
|
||||||
fn state ->
|
fn state ->
|
||||||
Environ.connect(state, zero, zero, negate())
|
Environ.connect(state, zero, zero, negate())
|
||||||
Environ.send_message(state, zero, ~w(csys create succ)a,
|
Environ.send_message(state, zero, ~w(csys create succ)a,
|
||||||
%{addr: [:csys, :e01, {1, 1}]})
|
%{addr: [:csys, :e01, "1-1"]})
|
||||||
end,
|
end,
|
||||||
fn state ->
|
fn state ->
|
||||||
Environ.send_message(state, zero, ~w(csys create pred)a,
|
Environ.send_message(state, zero, ~w(csys create pred)a,
|
||||||
%{addr: [:csys, :s01, {1, 1}]})
|
%{addr: [:csys, :s01, "1-1"]})
|
||||||
end
|
end
|
||||||
]
|
]
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -1,6 +1,6 @@
|
||||||
defmodule Scopes.Web.Server do
|
defmodule Scopes.Web.Server do
|
||||||
|
|
||||||
def static_paths, do: ~w(assets fonts images favicon.ico robots.txt)
|
def static_paths, do: ~w(assets fonts images favicon.ico robots.txt docs)
|
||||||
|
|
||||||
def router do
|
def router do
|
||||||
quote do
|
quote do
|
||||||
|
|
|
||||||
|
|
@ -19,12 +19,12 @@ defmodule Scopes.CoreTest do
|
||||||
test "minimal-b1" do
|
test "minimal-b1" do
|
||||||
env = Environ.setup(Program.prepare_basic(), Program.init_seq_b1())
|
env = Environ.setup(Program.prepare_basic(), Program.init_seq_b1())
|
||||||
Process.sleep(50)
|
Process.sleep(50)
|
||||||
Environ.forward_value(env, [:csys, :c00, {0, 0}], 0)
|
Environ.forward_value(env, [:csys, :c00, "0-0"], 0)
|
||||||
assert 0 = receive_data().value
|
assert 0 = receive_data().value
|
||||||
Environ.forward_value(env, [:csys, :s01, {1, 0}], 1)
|
Environ.forward_value(env, [:csys, :s01, "1-0"], 1)
|
||||||
assert receive_data().value == 1
|
assert receive_data().value == 1
|
||||||
#assert receive_data().value in [-1, 1]
|
#assert receive_data().value in [-1, 1]
|
||||||
Environ.forward_value(env, [:csys, :s01, {1, 1}], 3)
|
Environ.forward_value(env, [:csys, :s01, "1-1"], 3)
|
||||||
assert receive_data().value in [2, 3]
|
assert receive_data().value in [2, 3]
|
||||||
assert receive_data().value in [2, 3]
|
assert receive_data().value in [2, 3]
|
||||||
refute_receive msg, 30, "unhandled message(s): #{inspect(msg)}"
|
refute_receive msg, 30, "unhandled message(s): #{inspect(msg)}"
|
||||||
|
|
@ -33,9 +33,9 @@ defmodule Scopes.CoreTest do
|
||||||
test "recursive-1" do
|
test "recursive-1" do
|
||||||
env = Environ.setup(Program.prepare_basic(), Program.init_recursive_1())
|
env = Environ.setup(Program.prepare_basic(), Program.init_recursive_1())
|
||||||
Process.sleep(50)
|
Process.sleep(50)
|
||||||
Environ.forward_value(env, [:csys, :s01, {1, 1}], 42)
|
Environ.forward_value(env, [:csys, :s01, "1-1"], 42)
|
||||||
assert receive_data().value == 42
|
assert receive_data().value == 42
|
||||||
Environ.forward_value(env, [:csys, :s01, {1, 1}], 47)
|
Environ.forward_value(env, [:csys, :s01, "1-1"], 47)
|
||||||
assert receive_data().value == 5
|
assert receive_data().value == 5
|
||||||
refute_receive msg, 30, "unhandled message(s): #{inspect(msg)}"
|
refute_receive msg, 30, "unhandled message(s): #{inspect(msg)}"
|
||||||
end
|
end
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue