diff options
author | juhlig <[email protected]> | 2019-05-14 11:27:04 +0200 |
---|---|---|
committer | Loïc Hoguin <[email protected]> | 2019-05-18 21:50:44 +0200 |
commit | b1e6406e4f0871c656f92fdd0755c8ef82be2818 (patch) | |
tree | b628d0e65859384d8cbc7315d96cfdbb22f8b742 /src/ranch_acceptors_sup.erl | |
parent | c7dcc9cb1362e397d8d3d184b0643f2ca50c032e (diff) | |
download | ranch-b1e6406e4f0871c656f92fdd0755c8ef82be2818.tar.gz ranch-b1e6406e4f0871c656f92fdd0755c8ef82be2818.tar.bz2 ranch-b1e6406e4f0871c656f92fdd0755c8ef82be2818.zip |
Add support for UNIX domain sockets
It was working already but the types were wrong and some small
details needed to be corrected.
Diffstat (limited to 'src/ranch_acceptors_sup.erl')
-rw-r--r-- | src/ranch_acceptors_sup.erl | 26 |
1 files changed, 17 insertions, 9 deletions
diff --git a/src/ranch_acceptors_sup.erl b/src/ranch_acceptors_sup.erl index 6a89d5a..c062645 100644 --- a/src/ranch_acceptors_sup.erl +++ b/src/ranch_acceptors_sup.erl @@ -50,16 +50,22 @@ init([Ref, NumAcceptors, Transport]) -> -> [{pos_integer(), inet:socket()}]. start_listen_sockets(Ref, NumListenSockets, Transport, SocketOpts0, Logger) when NumListenSockets > 0 -> BaseSocket = start_listen_socket(Ref, Transport, SocketOpts0, Logger), - {ok, Addr={_, Port}} = Transport:sockname(BaseSocket), - SocketOpts = case lists:keyfind(port, 1, SocketOpts0) of - {port, Port} -> - SocketOpts0; - _ -> - [{port, Port}|lists:keydelete(port, 1, SocketOpts0)] + {ok, Addr} = Transport:sockname(BaseSocket), + ExtraSockets = case Addr of + {local, _} when NumListenSockets > 1 -> + listen_error(Ref, Transport, SocketOpts0, reuseport_local, Logger); + {local, _} -> + []; + {_, Port} -> + SocketOpts = case lists:keyfind(port, 1, SocketOpts0) of + {port, Port} -> + SocketOpts0; + _ -> + [{port, Port}|lists:keydelete(port, 1, SocketOpts0)] + end, + [{N, start_listen_socket(Ref, Transport, SocketOpts, Logger)} + || N <- lists:seq(2, NumListenSockets)] end, - ExtraSockets = [ - {N, start_listen_socket(Ref, Transport, SocketOpts, Logger)} - || N <- lists:seq(2, NumListenSockets)], ranch_server:set_addr(Ref, Addr), [{1, BaseSocket}|ExtraSockets]. @@ -84,5 +90,7 @@ listen_error(Ref, Transport, SocketOpts0, Reason, Logger) -> format_error(no_cert) -> "no certificate provided; see cert, certfile, sni_fun or sni_hosts options"; +format_error(reuseport_local) -> + "num_listen_sockets must be set to 1 for local sockets"; format_error(Reason) -> inet:format_error(Reason). |