Skip to content

Commit

Permalink
fix and change
Browse files Browse the repository at this point in the history
  • Loading branch information
fomfom committed Dec 23, 2024
1 parent dd21229 commit b3695a0
Showing 1 changed file with 4 additions and 6 deletions.
10 changes: 4 additions & 6 deletions lib/giocci_engine_zenoh.ex
Original file line number Diff line number Diff line change
Expand Up @@ -4,13 +4,11 @@ defmodule GiocciEngineZenoh do
use GenServer
require Logger

alias GiocciEngine.ModuleDB

def setup_engine() do
## 最初に指定された数のRelayノードとのZenohコネクションを作成する
relay_number_string = System.get_env("NODE_RELAY_NUMBER")
relay_number = String.to_integer(relay_number_string)
create_session(relay_number)
System.get_env("NODE_RELAY_NUMBER")
|> String.to_integer()
|> create_session()
end

def start_link(relay_name, number) do
Expand All @@ -26,7 +24,7 @@ defmodule GiocciEngineZenoh do
{:ok, publisher} =
Zenohex.Session.declare_publisher(session, "from/" <> engine_name <> "/to/" <> relay_name)

id_string = "Relay2Engine2Relaysession" <> number
id_string = "session" <> number
## 状態として次の状態をもつ
state = %{
publisher: publisher,
Expand Down

0 comments on commit b3695a0

Please sign in to comment.