parent
14b8036576
commit
551d5d99d2
2
Makefile
2
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
|
||||
|
||||
|
|
|
@ -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"}
|
||||
|
|
|
@ -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) ->
|
||||
|
|
Loading…
Reference in New Issue