starting with Environ cell registry
This commit is contained in:
parent
ea03dccf53
commit
3aafb36bd3
5 changed files with 18 additions and 13 deletions
|
|
@ -11,11 +11,9 @@ defmodule Scopes.CSys.Application do
|
||||||
def start(type, args) do
|
def start(type, args) do
|
||||||
IO.puts("Hello CSys")
|
IO.puts("Hello CSys")
|
||||||
Logger.info(Util.show [type, args])
|
Logger.info(Util.show [type, args])
|
||||||
# input_neurons = Environ.create_input
|
|
||||||
IO.inspect Scopes.CSys.Server.Endpoint.child_spec(input: %{[:csys, :s01] => "dummy"})
|
|
||||||
children = [
|
children = [
|
||||||
#Scopes.CSys.Server.Endpoint
|
Scopes.Core.Environ,
|
||||||
{Scopes.CSys.Server.Endpoint, input: %{[:csys, :s01] => "dummy"}}
|
Scopes.CSys.Server.Endpoint
|
||||||
]
|
]
|
||||||
opts = [strategy: :one_for_one, name: Scopes.CSys.Supervisor]
|
opts = [strategy: :one_for_one, name: Scopes.CSys.Supervisor]
|
||||||
Supervisor.start_link(children, opts)
|
Supervisor.start_link(children, opts)
|
||||||
|
|
|
||||||
|
|
@ -1,12 +1,6 @@
|
||||||
defmodule Scopes.CSys.Server.Endpoint do
|
defmodule Scopes.CSys.Server.Endpoint do
|
||||||
use Phoenix.Endpoint, otp_app: :scopes_csys
|
use Phoenix.Endpoint, otp_app: :scopes_csys
|
||||||
|
|
||||||
def init(arg) do
|
|
||||||
IO.inspect(arg)
|
|
||||||
IO.inspect(Process.get())
|
|
||||||
:ignore
|
|
||||||
end
|
|
||||||
|
|
||||||
plug Plug.Static,
|
plug Plug.Static,
|
||||||
at: "/",
|
at: "/",
|
||||||
from: :scopes_csys,
|
from: :scopes_csys,
|
||||||
|
|
@ -22,5 +16,4 @@ defmodule Scopes.CSys.Server.Endpoint do
|
||||||
json_decoder: Phoenix.json_library()
|
json_decoder: Phoenix.json_library()
|
||||||
|
|
||||||
plug Scopes.CSys.Server.Router
|
plug Scopes.CSys.Server.Router
|
||||||
#input_neurons: @input
|
|
||||||
end
|
end
|
||||||
|
|
|
||||||
|
|
@ -12,7 +12,7 @@ defmodule Scopes.Application do
|
||||||
|
|
||||||
@impl true
|
@impl true
|
||||||
def start(type, args) do
|
def start(type, args) do
|
||||||
IO.puts("Hello World")
|
IO.puts("Hello Scopes!")
|
||||||
Logger.info(Util.show [type, args])
|
Logger.info(Util.show [type, args])
|
||||||
children = [
|
children = [
|
||||||
#Scopes.Web.Server.Telemetry,
|
#Scopes.Web.Server.Telemetry,
|
||||||
|
|
@ -28,7 +28,7 @@ defmodule Scopes.Application do
|
||||||
|
|
||||||
# See https://hexdocs.pm/elixir/Supervisor.html
|
# See https://hexdocs.pm/elixir/Supervisor.html
|
||||||
# for other strategies and supported options
|
# for other strategies and supported options
|
||||||
opts = [strategy: :one_for_one, name: ScopesApi.Supervisor]
|
opts = [strategy: :one_for_one, name: Scopes.Supervisor]
|
||||||
Supervisor.start_link(children, opts)
|
Supervisor.start_link(children, opts)
|
||||||
end
|
end
|
||||||
|
|
||||||
|
|
|
||||||
|
|
@ -1,4 +1,5 @@
|
||||||
defmodule Scopes.Core.Environ do
|
defmodule Scopes.Core.Environ do
|
||||||
|
@cell_registry __MODULE__.Cells
|
||||||
|
|
||||||
alias Scopes.Core
|
alias Scopes.Core
|
||||||
alias Scopes.Core.Shape
|
alias Scopes.Core.Shape
|
||||||
|
|
@ -7,6 +8,17 @@ defmodule Scopes.Core.Environ do
|
||||||
defstruct [cells: %{}, init_seq: []]
|
defstruct [cells: %{}, init_seq: []]
|
||||||
end
|
end
|
||||||
|
|
||||||
|
def child_spec(opts) do
|
||||||
|
%{id: __MODULE__,
|
||||||
|
start: {__MODULE__, :start_link, opts}}
|
||||||
|
end
|
||||||
|
|
||||||
|
def start_link() do
|
||||||
|
Registry.start_link(keys: :unique, name: @cell_registry)
|
||||||
|
end
|
||||||
|
|
||||||
|
def cells(), do: @cell_registry
|
||||||
|
|
||||||
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)
|
||||||
|
|
|
||||||
|
|
@ -17,6 +17,7 @@ defmodule Scopes.CoreTest do
|
||||||
|
|
||||||
describe "core-basic:" do
|
describe "core-basic:" do
|
||||||
test "minimal-b1" do
|
test "minimal-b1" do
|
||||||
|
Environ.start_link()
|
||||||
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)
|
||||||
|
|
@ -31,6 +32,7 @@ defmodule Scopes.CoreTest do
|
||||||
end
|
end
|
||||||
|
|
||||||
test "recursive-1" do
|
test "recursive-1" do
|
||||||
|
Environ.start_link()
|
||||||
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)
|
||||||
|
|
|
||||||
Loading…
Add table
Reference in a new issue