feat(quic): adapt to new quicer API.
This commit is contained in:
parent
5356668eac
commit
14614fbe33
|
@ -150,6 +150,8 @@ start_listener(quic, ListenOn, Options) ->
|
||||||
ListenOpts = [ {cert, proplists:get_value(certfile, SSLOpts)}
|
ListenOpts = [ {cert, proplists:get_value(certfile, SSLOpts)}
|
||||||
, {key, proplists:get_value(keyfile, SSLOpts)}
|
, {key, proplists:get_value(keyfile, SSLOpts)}
|
||||||
, {alpn, ["mqtt"]}
|
, {alpn, ["mqtt"]}
|
||||||
|
, {peer_unidi_stream_count, 1}
|
||||||
|
, {peer_bidi_stream_count, 10}
|
||||||
, {conn_acceptors, 32}
|
, {conn_acceptors, 32}
|
||||||
],
|
],
|
||||||
ConnectionOpts = [ {conn_callback, emqx_quic_connection}
|
ConnectionOpts = [ {conn_callback, emqx_quic_connection}
|
||||||
|
|
|
@ -49,7 +49,7 @@ peercert(_S) ->
|
||||||
getstat(Socket, Stats) ->
|
getstat(Socket, Stats) ->
|
||||||
case quicer:getstat(Socket, Stats) of
|
case quicer:getstat(Socket, Stats) of
|
||||||
{error, _} -> {error, closed};
|
{error, _} -> {error, closed};
|
||||||
Res -> {ok, Res}
|
Res -> Res
|
||||||
end.
|
end.
|
||||||
|
|
||||||
setopts(_Socket, _Opts) ->
|
setopts(_Socket, _Opts) ->
|
||||||
|
|
Loading…
Reference in New Issue