2 files changed, 36 insertions, 0 deletions
diff --git a/step-05/echo_client.erl b/step-05/echo_client.erl
new file mode 100644
index 0000000..92785be
--- /dev/null
+++ b/step-05/echo_client.erl
@@ -0,0 +1,14 @@
+-module(echo_client).
+
+-export([send_ping/1]).
+
+send_ping(Echo_Node) ->
+  io:format("Sending echo to ~s~n", [Echo_Node]),
+  io:format("self=~p~n", [self()]),
+  {echo, Echo_Node} ! {ping, self()},
+  receive
+    {pong, Server} -> io:format("got pong from ~w~n", [Server]);
+    X -> io:format("Unexpected reply: ~w~n", [X])
+  after 1000 -> io:format("timeout~n")
+  end,
+  io:format("done~n").
diff --git a/step-05/echo_server.erl b/step-05/echo_server.erl
new file mode 100644
index 0000000..3f531e5
--- /dev/null
+++ b/step-05/echo_server.erl
@@ -0,0 +1,22 @@
+-module(echo_server).
+
+-export([start/0, loop/1]).
+
+loop(0) ->
+  io:format("ping finished~n", []);
+
+loop(N) ->
+  receive
+    {ping, Node} ->
+      io:format("~w: Got ping req from: ~w~n", [self(), Node]),
+      Node ! {pong, self()};
+    X ->
+      io:format("Unexpected message: ~w~n", [X])
+  end,
+  echo_server:loop(N - 1).
+
+start() ->
+  Pid = spawn(echo_server, loop, [10]),
+  io:format("Starting server, pid=~w~n", [Pid]),
+  io:format("Starting server, pid=~w~n", [Pid]),
+  register(echo, Pid).