diff --git a/apps/emqx/src/emqx_quic_connection.erl b/apps/emqx/src/emqx_quic_connection.erl index e081dc5cf..b75137e05 100644 --- a/apps/emqx/src/emqx_quic_connection.erl +++ b/apps/emqx/src/emqx_quic_connection.erl @@ -47,13 +47,15 @@ handle_info/2 ]). +-export_type([cb_state/0, cb_ret/0]). + -type cb_state() :: #{ %% connecion owner pid conn_pid := pid(), %% Pid of ctrl stream ctrl_pid := undefined | pid(), %% quic connecion handle - conn := undefined | quicer:conneciton_handle(), + conn := undefined | quicer:connection_handle(), %% Data streams that handoff from this process %% these streams could die/close without effecting the connecion/session. %@TODO type? @@ -85,7 +87,7 @@ init(#{stream_opts := SOpts} = S) when is_list(SOpts) -> init(ConnOpts) when is_map(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()}. closed(_Conn, #{is_peer_acked := _} = Prop, S) -> ?SLOG(debug, Prop), diff --git a/apps/emqx/src/emqx_quic_data_stream.erl b/apps/emqx/src/emqx_quic_data_stream.erl index 254e6e2a3..48d8ddd2e 100644 --- a/apps/emqx/src/emqx_quic_data_stream.erl +++ b/apps/emqx/src/emqx_quic_data_stream.erl @@ -124,7 +124,7 @@ send_complete(_Stream, false, S) -> send_complete(_Stream, true = _IsCanceled, 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) -> {ok, S}. @@ -321,7 +321,7 @@ serialize_packet(Packet, Serialize) -> -spec init_state( quicer:stream_handle(), quicer:connection_handle(), - quicer:new_stream_props() + non_neg_integer() ) -> % @TODO map().