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

feat(quic): stream use active_n 10

This commit is contained in:
William Yang 2023-01-05 15:15:34 +01:00
parent 0173121a30
commit 71d3148544
2 changed files with 5 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/emqx/src/emqx_quic_data_stream.erl
View File

@ -182,7 +182,8 @@ handle_stream_data(
%% {ok, State} %% {ok, State}
%% end. %% end.
passive(_Stream, undefined, S) -> passive(Stream, undefined, S) ->
quicer:setopt(Stream, active, 10),
{ok, S}. {ok, S}.
stream_closed( stream_closed(

5
apps/emqx/src/emqx_quic_stream.erl
View File

@ -270,8 +270,9 @@ start_completed(_Stream, #{status := Other} = Prop, S) ->
%% {stop, unimpl}. %% {stop, unimpl}.
-spec passive(stream_handle(), undefined, cb_data()) -> cb_ret(). -spec passive(stream_handle(), undefined, cb_data()) -> cb_ret().
passive(_Stream, undefined, _S) -> passive(Stream, undefined, S) ->
{stop, unimpl}. quicer:setopt(Stream, active, 10),
{ok, S}.
-spec stream_closed(stream_handle(), quicer:stream_closed_props(), cb_data()) -> cb_ret(). -spec stream_closed(stream_handle(), quicer:stream_closed_props(), cb_data()) -> cb_ret().
stream_closed( stream_closed(