diff --git a/Makefile b/Makefile index 07fe13cbb..6e01a0450 100644 --- a/Makefile +++ b/Makefile @@ -10,7 +10,7 @@ dep_jsx = git https://github.com/talentdeficit/jsx 2.9.0 dep_gproc = git https://github.com/uwiger/gproc 0.8.0 dep_gen_rpc = git https://github.com/emqx/gen_rpc 2.3.0 dep_esockd = git https://github.com/emqx/esockd v5.4.2 -dep_ekka = git https://github.com/emqx/ekka v0.5.0 +dep_ekka = git https://github.com/emqx/ekka v0.5.1 dep_cowboy = git https://github.com/ninenines/cowboy 2.4.0 dep_clique = git https://github.com/emqx/clique develop diff --git a/rebar.config b/rebar.config index 0af3f6b3e..fa2ab588f 100644 --- a/rebar.config +++ b/rebar.config @@ -6,7 +6,7 @@ %% appended to deps in rebar.config.script {github_emqx_deps, [{gen_rpc, "2.3.0"}, - {ekka, "v0.5.0"}, + {ekka, "v0.5.1"}, {clique, "develop"}, {esockd, "v5.4.2"}, {cuttlefish, "v2.1.0"} diff --git a/src/emqx_sm_locker.erl b/src/emqx_sm_locker.erl index d50d16ccc..29adf3342 100644 --- a/src/emqx_sm_locker.erl +++ b/src/emqx_sm_locker.erl @@ -43,11 +43,11 @@ trans(ClientId, Fun, Piggyback) -> -spec(lock(emqx_types:client_id()) -> ekka_locker:lock_result()). lock(ClientId) -> - ekka_locker:aquire(?MODULE, ClientId, strategy()). + ekka_locker:acquire(?MODULE, ClientId, strategy()). -spec(lock(emqx_types:client_id(), ekka_locker:piggyback()) -> ekka_locker:lock_result()). lock(ClientId, Piggyback) -> - ekka_locker:aquire(?MODULE, ClientId, strategy(), Piggyback). + ekka_locker:acquire(?MODULE, ClientId, strategy(), Piggyback). -spec(unlock(emqx_types:client_id()) -> {boolean(), [node()]}). unlock(ClientId) ->