diff --git a/experiments/erlang/src/hop.erl b/experiments/erlang/src/hop.erl index 18b9980..1e7cbc0 100644 --- a/experiments/erlang/src/hop.erl +++ b/experiments/erlang/src/hop.erl @@ -17,7 +17,10 @@ -module(hop). --export([register_idempotent/3, class_of/1, send/2, post/4]). +-export([name/0, register_idempotent/3, class_of/1, send/2, post/4]). + +name() -> + list_to_binary(atom_to_list(node())). register_idempotent(Name, Pid, ClassModule) -> case global:register_name(Name, Pid) of diff --git a/experiments/erlang/src/hop_relay.erl b/experiments/erlang/src/hop_relay.erl index e3ac376..b26eee9 100644 --- a/experiments/erlang/src/hop_relay.erl +++ b/experiments/erlang/src/hop_relay.erl @@ -85,8 +85,7 @@ handle_cast({socket_control_transferred, Sock}, State0 = #state{sock = Sock}) -> inet:setopts(Sock, [binary]), request_data(Sock), State1 = send([<<"hop">>], State0), - State2 = send([<<"subscribe">>, list_to_binary(atom_to_list(node())), <<>>, <<>>, <<>>, <<>>], - State1), + State2 = send([<<"subscribe">>, hop:name(), <<>>, <<>>, <<>>, <<>>], State1), {noreply, State2}; handle_cast(_Request, State) -> {stop, {bad_cast, _Request}, State}.