diff options
| author | Simon MacMullen <simon@lshift.net> | 2010-04-22 13:10:16 +0100 |
|---|---|---|
| committer | Simon MacMullen <simon@lshift.net> | 2010-04-22 13:10:16 +0100 |
| commit | 0e6225f1195594225ccb3a834c110e7911aeae5a (patch) | |
| tree | 89571e4b3985b84cf704b440ca422c6435eb0c26 | |
| parent | 26dc835803fc00b3305745e06f989432538b447b (diff) | |
| download | rabbitmq-server-git-0e6225f1195594225ccb3a834c110e7911aeae5a.tar.gz | |
Use phash2/2, remove string:concat.
| -rw-r--r-- | src/delegate.erl | 4 | ||||
| -rw-r--r-- | src/delegate_sup.erl | 2 |
2 files changed, 3 insertions, 3 deletions
diff --git a/src/delegate.erl b/src/delegate.erl index 5a2a011af6..2724736e5b 100644 --- a/src/delegate.erl +++ b/src/delegate.erl @@ -121,10 +121,10 @@ delegate_per_node(NodePids, FPid, DelegateFun) -> || {Node, Pids} <- NodePids]). server() -> - server(erlang:phash(self(), ?DELEGATE_PROCESSES)). + server(erlang:phash2(self(), ?DELEGATE_PROCESSES)). server(Hash) -> - list_to_atom(string:concat("delegate_process_", integer_to_list(Hash))). + list_to_atom("delegate_process_" ++ integer_to_list(Hash)). safe_invoke(FPid, Pid) -> case catch FPid(Pid) of diff --git a/src/delegate_sup.erl b/src/delegate_sup.erl index d9722a11f3..99a5e4d3f3 100644 --- a/src/delegate_sup.erl +++ b/src/delegate_sup.erl @@ -51,6 +51,6 @@ init(_Args) -> {ok, {{one_for_one, 10, 10}, [{delegate:server(Hash), {delegate, start_link, [Hash]}, transient, 16#ffffffff, worker, [delegate]} || - Hash <- lists:seq(1, ?DELEGATE_PROCESSES)]}}. + Hash <- lists:seq(0, ?DELEGATE_PROCESSES - 1)]}}. %%-------------------------------------------------------------------- |