diff options
| author | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2017-04-23 11:54:56 +0300 |
|---|---|---|
| committer | Evgeniy Khramtsov <ekhramtsov@process-one.net> | 2017-04-23 11:54:56 +0300 |
| commit | 8770fc98e1c3fb42a3341f64107e77df76b2b7ca (patch) | |
| tree | 99e7fcf743dd2b2d3a5fdc0f6e2276d9ee631e34 /src/ejabberd_riak_sup.erl | |
| parent | Add clear_cache admin command (diff) | |
Use round-robin algorithm when selecting worker from DB pool
Diffstat (limited to 'src/ejabberd_riak_sup.erl')
| -rw-r--r-- | src/ejabberd_riak_sup.erl | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/ejabberd_riak_sup.erl b/src/ejabberd_riak_sup.erl index f5c8f7e4..a01f3538 100644 --- a/src/ejabberd_riak_sup.erl +++ b/src/ejabberd_riak_sup.erl @@ -30,7 +30,7 @@ -author('alexey@process-one.net'). -export([start_link/0, init/1, get_pids/0, - transform_options/1, get_random_pid/0, get_random_pid/1, + transform_options/1, get_random_pid/0, host_up/1, config_reloaded/0, opt_type/1]). -include("ejabberd.hrl"). @@ -199,10 +199,7 @@ get_pids() -> [ejabberd_riak:get_proc(I) || I <- lists:seq(1, get_pool_size())]. get_random_pid() -> - get_random_pid(p1_time_compat:system_time()). - -get_random_pid(Term) -> - I = erlang:phash2(Term, get_pool_size()) + 1, + I = randoms:round_robin(get_pool_size()) + 1, ejabberd_riak:get_proc(I). transform_options(Opts) -> |