diff options
| -rw-r--r-- | ChangeLog | 4 | ||||
| -rw-r--r-- | src/ejabberd_router.erl | 6 |
2 files changed, 9 insertions, 1 deletions
@@ -1,3 +1,7 @@ +2004-01-03 Alexey Shchepin <alexey@sevcom.net> + + * src/ejabberd_router.erl (do_route/3): Slightly changed behaviour + 2004-01-01 Alexey Shchepin <alexey@sevcom.net> * src/ejabberd_sm.erl (do_route/3): Minor fix diff --git a/src/ejabberd_router.erl b/src/ejabberd_router.erl index fcc89375..74352254 100644 --- a/src/ejabberd_router.erl +++ b/src/ejabberd_router.erl @@ -80,7 +80,11 @@ do_route(From, To, Packet) -> ?DEBUG("routed to process ~p~n", [Pid]), Pid ! {route, From, To, Packet}; Rs -> - R = lists:nth(erlang:phash(now(), length(Rs)), Rs), + Rs1 = case [R || R <- Rs, node(R#route.pid) == node()] of + [] -> Rs; + LRs -> LRs + end, + R = lists:nth(erlang:phash(now(), length(Rs1)), Rs1), Pid = R#route.pid, ?DEBUG("routed to process ~p~n", [Pid]), Pid ! {route, From, To, Packet} |