yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix: quic listener spec

This commit is contained in:
William Yang 2021-08-25 17:04:04 +02:00
parent 2ef2acc850
commit eb7625a595
2 changed files with 5 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/emqx/src/emqx_connection.erl
View File

@ -135,7 +135,9 @@
, system_code_change/4 , system_code_change/4
]}). ]}).
-spec(start_link(esockd:transport(), esockd:socket(), emqx_channel:opts()) -spec(start_link(esockd:transport(),
esockd:socket() | {pid(), quicer:connection_handler()},
emqx_channel:opts())
-> {ok, pid()}). -> {ok, pid()}).
start_link(Transport, Socket, Options) -> start_link(Transport, Socket, Options) ->
Args = [self(), Transport, Socket, Options], Args = [self(), Transport, Socket, Options],

6
apps/emqx/src/emqx_quic_connection.erl
View File

@ -50,12 +50,8 @@ new_conn(Conn, S) ->
-spec connected(quicer:connection_handler(), cb_state()) -> {ok, cb_state()} | {error, any()}. -spec connected(quicer:connection_handler(), cb_state()) -> {ok, cb_state()} | {error, any()}.
connected(Conn, #{slow_start := false} = S) -> connected(Conn, #{slow_start := false} = S) ->
case emqx_connection:start_link(emqx_quic_stream, Conn, S) of {ok, _Pid} = emqx_connection:start_link(emqx_quic_stream, Conn, S),
{ok, _Pid} ->
{ok, S}; {ok, S};
Other ->
{error, Other}
end;
connected(_Conn, S) -> connected(_Conn, S) ->
{ok, S}. {ok, S}.