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

chore(quicer): dialyzer

This commit is contained in:
William Yang 2023-12-07 10:10:04 +01:00
parent 583645d97b
commit 499f4d4bc5
2 changed files with 6 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -47,13 +47,15 @@
handle_info/2 handle_info/2
]). ]).
-export_type([cb_state/0, cb_ret/0]).
-type cb_state() :: #{ -type cb_state() :: #{
%% connecion owner pid %% connecion owner pid
conn_pid := pid(), conn_pid := pid(),
%% Pid of ctrl stream %% Pid of ctrl stream
ctrl_pid := undefined | pid(), ctrl_pid := undefined | pid(),
%% quic connecion handle %% quic connecion handle
conn := undefined | quicer:conneciton_handle(), conn := undefined | quicer:connection_handle(),
%% Data streams that handoff from this process %% Data streams that handoff from this process
%% these streams could die/close without effecting the connecion/session. %% these streams could die/close without effecting the connecion/session.
%@TODO type? %@TODO type?
@ -85,7 +87,7 @@ init(#{stream_opts := SOpts} = S) when is_list(SOpts) ->
init(ConnOpts) when is_map(ConnOpts) -> init(ConnOpts) when is_map(ConnOpts) ->
{ok, init_cb_state(ConnOpts)}. {ok, init_cb_state(ConnOpts)}.
-spec closed(quicer:conneciton_handle(), quicer:conn_closed_props(), cb_state()) -> -spec closed(quicer:connection_handle(), quicer:conn_closed_props(), cb_state()) ->
{stop, normal, cb_state()}. {stop, normal, cb_state()}.
closed(_Conn, #{is_peer_acked := _} = Prop, S) -> closed(_Conn, #{is_peer_acked := _} = Prop, S) ->
?SLOG(debug, Prop), ?SLOG(debug, Prop),

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

@ -124,7 +124,7 @@ send_complete(_Stream, false, S) ->
send_complete(_Stream, true = _IsCanceled, S) -> send_complete(_Stream, true = _IsCanceled, S) ->
{ok, S}. {ok, S}.
-spec send_shutdown_complete(stream_handle(), error_code(), cb_state()) -> cb_ret(). -spec send_shutdown_complete(stream_handle(), IsGraceful :: boolean(), cb_state()) -> cb_ret().
send_shutdown_complete(_Stream, _Flags, S) -> send_shutdown_complete(_Stream, _Flags, S) ->
{ok, S}. {ok, S}.
@ -321,7 +321,7 @@ serialize_packet(Packet, Serialize) ->
-spec init_state( -spec init_state(
quicer:stream_handle(), quicer:stream_handle(),
quicer:connection_handle(), quicer:connection_handle(),
quicer:new_stream_props() non_neg_integer()
) -> ) ->
% @TODO % @TODO
map(). map().