aboutsummaryrefslogtreecommitdiffstats
path: root/test/trap_exit_protocol.erl
diff options
context:
space:
mode:
authorLoïc Hoguin <[email protected]>2013-12-07 13:40:37 +0100
committerLoïc Hoguin <[email protected]>2013-12-07 13:40:37 +0100
commit7194df4568e66c1f2fee86816ace3308ec9eb302 (patch)
treea0846353b35d02b536ecf72b88163ad6a968daad /test/trap_exit_protocol.erl
parent6a5015fedd0f85388144de7b8a6ed7d883da5e1a (diff)
downloadranch-7194df4568e66c1f2fee86816ace3308ec9eb302.tar.gz
ranch-7194df4568e66c1f2fee86816ace3308ec9eb302.tar.bz2
ranch-7194df4568e66c1f2fee86816ace3308ec9eb302.zip
Gracefully shutdown when stop_listener/1 is called
Implements the `shutdown` option as documented previously.
Diffstat (limited to 'test/trap_exit_protocol.erl')
-rw-r--r--test/trap_exit_protocol.erl23
1 files changed, 23 insertions, 0 deletions
diff --git a/test/trap_exit_protocol.erl b/test/trap_exit_protocol.erl
new file mode 100644
index 0000000..a0c4329
--- /dev/null
+++ b/test/trap_exit_protocol.erl
@@ -0,0 +1,23 @@
+-module(trap_exit_protocol).
+-behaviour(ranch_protocol).
+
+-export([start_link/4]).
+-export([init/4]).
+
+start_link(Ref, Socket, Transport, Opts) ->
+ Pid = spawn_link(?MODULE, init, [Ref, Socket, Transport, Opts]),
+ {ok, Pid}.
+
+init(Ref, Socket, Transport, _Opts = []) ->
+ process_flag(trap_exit, true),
+ ok = ranch:accept_ack(Ref),
+ loop(Socket, Transport).
+
+loop(Socket, Transport) ->
+ case Transport:recv(Socket, 0, infinity) of
+ {ok, Data} ->
+ Transport:send(Socket, Data),
+ loop(Socket, Transport);
+ _ ->
+ ok = Transport:close(Socket)
+ end.