Fix previous commit

Fixes #2847
This commit is contained in:
Evgeny Khramtsov 2019-04-02 09:58:12 +03:00
parent ed2abe471a
commit d96ab48c6b
1 changed files with 7 additions and 5 deletions

View File

@ -280,12 +280,14 @@ udp_recv(Socket, Module, Opts) ->
{ok, pid()} | {error, any()} | ignore.
start_connection(Module, Arity, Socket, Opts, Sup) ->
Res = case Sup of
undefined when Arity == 3 ->
Module:start(gen_tcp, Socket, Opts);
undefined ->
case Arity of
3 -> Module:start(gen_tcp, Socket, Opts);
2 -> Module:start({gen_tcp, Socket}, Opts)
end;
_ -> supervisor:start_child(Sup, [{gen_tcp, Socket}, Opts])
Module:start({gen_tcp, Socket}, Opts);
_ when Arity == 3 ->
supervisor:start_child(Sup, [gen_tcp, Socket, Opts]);
_ ->
supervisor:start_child(Sup, [{gen_tcp, Socket}, Opts])
end,
case Res of
{ok, Pid} ->