From 14614fbe33ee27a26e705945261994f8534374b9 Mon Sep 17 00:00:00 2001 From: William Yang Date: Tue, 11 May 2021 22:52:25 +0200 Subject: [PATCH] feat(quic): adapt to new quicer API. --- apps/emqx/src/emqx_listeners.erl | 2 ++ apps/emqx/src/emqx_quic_stream.erl | 2 +- 2 files changed, 3 insertions(+), 1 deletion(-) 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) ->