diff --git a/apps/emqx/src/emqx_listeners.erl b/apps/emqx/src/emqx_listeners.erl index d66606895..6ee07e17b 100644 --- a/apps/emqx/src/emqx_listeners.erl +++ b/apps/emqx/src/emqx_listeners.erl @@ -150,6 +150,8 @@ start_listener(quic, ListenOn, Options) -> ListenOpts = [ {cert, proplists:get_value(certfile, SSLOpts)} , {key, proplists:get_value(keyfile, SSLOpts)} , {alpn, ["mqtt"]} + , {peer_unidi_stream_count, 1} + , {peer_bidi_stream_count, 10} , {conn_acceptors, 32} ], ConnectionOpts = [ {conn_callback, emqx_quic_connection} diff --git a/apps/emqx/src/emqx_quic_stream.erl b/apps/emqx/src/emqx_quic_stream.erl index 22d194632..4fbe2ed65 100644 --- a/apps/emqx/src/emqx_quic_stream.erl +++ b/apps/emqx/src/emqx_quic_stream.erl @@ -49,7 +49,7 @@ peercert(_S) -> getstat(Socket, Stats) -> case quicer:getstat(Socket, Stats) of {error, _} -> {error, closed}; - Res -> {ok, Res} + Res -> Res end. setopts(_Socket, _Opts) ->