From c74abe79d072bb1a9309e6c812434a21cbab86b1 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Tue, 15 Aug 2023 16:07:30 -0300 Subject: [PATCH] refactor: reduce arity --- apps/emqx/src/emqx_cm.erl | 3 +-- apps/emqx/src/emqx_session.erl | 7 ++++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/apps/emqx/src/emqx_cm.erl b/apps/emqx/src/emqx_cm.erl index ae6efb89c..2cc2b72b4 100644 --- a/apps/emqx/src/emqx_cm.erl +++ b/apps/emqx/src/emqx_cm.erl @@ -301,9 +301,8 @@ open_session(false, ClientInfo = #{clientid := ClientId}, ConnInfo) -> emqx_cm_locker:trans(ClientId, ResumeStart). create_session(ClientInfo, ConnInfo) -> - #{clientid := ClientId} = ClientInfo, Options = get_session_confs(ClientInfo, ConnInfo), - Session = emqx_session:init_and_open(ClientId, Options), + Session = emqx_session:init_and_open(Options), ok = emqx_metrics:inc('session.created'), ok = emqx_hooks:run('session.created', [ClientInfo, emqx_session:info(Session)]), Session. diff --git a/apps/emqx/src/emqx_session.erl b/apps/emqx/src/emqx_session.erl index 32c98290a..0c051f002 100644 --- a/apps/emqx/src/emqx_session.erl +++ b/apps/emqx/src/emqx_session.erl @@ -60,7 +60,7 @@ unpersist/1 ]). --export([init/1, init_and_open/2]). +-export([init/1, init_and_open/1]). -export([ info/1, @@ -166,8 +166,9 @@ %% Init a Session %%-------------------------------------------------------------------- --spec init_and_open(emqx_types:clientid(), options()) -> session(). -init_and_open(ClientID, Options) -> +-spec init_and_open(options()) -> session(). +init_and_open(Options) -> + #{clientid := ClientID} = Options, Session0 = emqx_session:init(Options), _ = emqx_persistent_session_ds:open_session(ClientID), Session0.