yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

chore: clear dialyzer warning.

This commit is contained in:
Zhongwen Deng 2022-10-27 09:39:45 +08:00
parent 3066d6662b
commit af79e652da
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqx/src/emqx_rpc.erl
View File

@ -124,7 +124,7 @@ filter_result(Delivery) ->
max_client_num() -> max_client_num() ->
emqx:get_config([rpc, tcp_client_num], ?DefaultClientNum). emqx:get_config([rpc, tcp_client_num], ?DefaultClientNum).
-spec unwrap_erpc(emqx_rpc:erpc(A)) -> A | {error, _Err}. -spec unwrap_erpc(emqx_rpc:erpc(A) | [emqx_rpc:erpc(A)]) -> A | {error, _Err} | list().
unwrap_erpc(Res) when is_list(Res) -> unwrap_erpc(Res) when is_list(Res) ->
[unwrap_erpc(R) || R <- Res]; [unwrap_erpc(R) || R <- Res];

4
apps/emqx_management/src/proto/emqx_management_proto_v3.erl
View File

@ -45,11 +45,11 @@ introduced_in() ->
unsubscribe_batch(Node, ClientId, Topics) -> unsubscribe_batch(Node, ClientId, Topics) ->
rpc:call(Node, emqx_mgmt, do_unsubscribe_batch, [ClientId, Topics]). rpc:call(Node, emqx_mgmt, do_unsubscribe_batch, [ClientId, Topics]).
-spec node_info([node()]) -> emqx_rpc:multicall_result(). -spec node_info([node()]) -> emqx_rpc:erpc_multicall(map()).
node_info(Nodes) -> node_info(Nodes) ->
erpc:multicall(Nodes, emqx_mgmt, node_info, [], 30000). erpc:multicall(Nodes, emqx_mgmt, node_info, [], 30000).
-spec broker_info([node()]) -> emqx_rpc:multicall_result(). -spec broker_info([node()]) -> emqx_rpc:erpc_multicall(map()).
broker_info(Nodes) -> broker_info(Nodes) ->
erpc:multicall(Nodes, emqx_mgmt, broker_info, [], 30000). erpc:multicall(Nodes, emqx_mgmt, broker_info, [], 30000).