Chapril/xmpp.chapril.org-ejabberd
25
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-11-22 16:20:52 +01:00
Code Releases Activity

Add call/5 and multicall/5 to ejabberd_cluster

Browse Source
This commit is contained in:
Evgeny Khramtsov 2019-07-12 13:58:46 +03:00
parent 53dacb3825
commit 696c64064b
1 changed files with 12 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
src/ejabberd_cluster.erl
View File

@ -24,8 +24,8 @@
-behaviour(gen_server). -behaviour(gen_server).
%% API %% API
-export([start_link/0, call/4, multicall/3, multicall/4, eval_everywhere/3, -export([start_link/0, call/4, call/5, multicall/3, multicall/4, multicall/5,
eval_everywhere/4]). eval_everywhere/3, eval_everywhere/4]).
%% Backend dependent API %% Backend dependent API
-export([get_nodes/0, get_known_nodes/0, join/1, leave/1, subscribe/0, -export([get_nodes/0, get_known_nodes/0, join/1, leave/1, subscribe/0,
subscribe/1, node_id/0, get_node_by_id/1, send/2, wait_for_sync/1]). subscribe/1, node_id/0, get_node_by_id/1, send/2, wait_for_sync/1]).
@ -58,7 +58,11 @@ start_link() ->
-spec call(node(), module(), atom(), [any()]) -> any(). -spec call(node(), module(), atom(), [any()]) -> any().
call(Node, Module, Function, Args) -> call(Node, Module, Function, Args) ->
rpc:call(Node, Module, Function, Args, rpc_timeout()). call(Node, Module, Function, Args, rpc_timeout()).
-spec call(node(), module(), atom(), [any()], timeout()) -> any().
call(Node, Module, Function, Args, Timeout) ->
call(Node, Module, Function, Args, Timeout).
-spec multicall(module(), atom(), [any()]) -> {list(), [node()]}. -spec multicall(module(), atom(), [any()]) -> {list(), [node()]}.
multicall(Module, Function, Args) -> multicall(Module, Function, Args) ->
@ -66,7 +70,11 @@ multicall(Module, Function, Args) ->
-spec multicall([node()], module(), atom(), list()) -> {list(), [node()]}. -spec multicall([node()], module(), atom(), list()) -> {list(), [node()]}.
multicall(Nodes, Module, Function, Args) -> multicall(Nodes, Module, Function, Args) ->
rpc:multicall(Nodes, Module, Function, Args, rpc_timeout()). multicall(Nodes, Module, Function, Args, rpc_timeout()).
-spec multicall([node()], module(), atom(), list(), timeout()) -> {list(), [node()]}.
multicall(Nodes, Module, Function, Args, Timeout) ->
rpc:multicall(Nodes, Module, Function, Args, Timeout).
-spec eval_everywhere(module(), atom(), [any()]) -> ok. -spec eval_everywhere(module(), atom(), [any()]) -> ok.
eval_everywhere(Module, Function, Args) -> eval_everywhere(Module, Function, Args) ->