Bläddra i källkod

Configurable rpc client number

terry-xiaoyu 6 år sedan
förälder
incheckning
11fdf101f0
1 ändrade filer med 2 tillägg och 1 borttagningar
  1. 2 1
      src/emqx_rpc.erl

+ 2 - 1
src/emqx_rpc.erl

@@ -32,7 +32,8 @@ cast(Node, Mod, Fun, Args) ->
     filter_result(?RPC:cast(rpc_node(Node), Mod, Fun, Args)).
     filter_result(?RPC:cast(rpc_node(Node), Mod, Fun, Args)).
 
 
 rpc_node(Node) ->
 rpc_node(Node) ->
-    {Node, erlang:system_info(scheduler_id)}.
+    {ok, ClientNum} = application:get_env(gen_rpc, tcp_client_num),
+    {Node, rand:uniform(ClientNum)}.
 
 
 rpc_nodes(Nodes) ->
 rpc_nodes(Nodes) ->
     rpc_nodes(Nodes, []).
     rpc_nodes(Nodes, []).