diff options
| author | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2015-07-30 17:49:13 +0200 |
|---|---|---|
| committer | Jean-Sébastien Pédron <jean-sebastien@rabbitmq.com> | 2015-08-05 16:16:38 +0200 |
| commit | ae53a636074e19b371be04ebdb80c659720df9d7 (patch) | |
| tree | 04424ba4df3f9e382d889a9b6e0209003839d3a1 | |
| parent | 26637302123dc6196dff436d1ed4d695f1cf44cd (diff) | |
| download | rabbitmq-server-git-ae53a636074e19b371be04ebdb80c659720df9d7.tar.gz | |
pg2_fixed: Use erlang:system_time(micro_seconds) to pick a "random" node
References #233.
| -rw-r--r-- | src/pg2_fixed.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/pg2_fixed.erl b/src/pg2_fixed.erl index 8926b83b77..d6f756ce68 100644 --- a/src/pg2_fixed.erl +++ b/src/pg2_fixed.erl @@ -146,14 +146,14 @@ get_closest_pid(Name) -> [Pid] -> Pid; [] -> - {_,_,X} = erlang:now(), case get_members(Name) of [] -> {error, {no_process, Name}}; Members -> + X = time_compat:erlang_system_time(micro_seconds), lists:nth((X rem length(Members))+1, Members) end; Members when is_list(Members) -> - {_,_,X} = erlang:now(), + X = time_compat:erlang_system_time(micro_seconds), lists:nth((X rem length(Members))+1, Members); Else -> Else |