Chapril/xmpp.chapril.org-ejabberd
25
1
Fork 0
mirror of https://github.com/processone/ejabberd.git synced 2024-12-24 17:29:28 +01:00
Code Releases Activity

pubsub clean now cluster aware

Browse Source
This commit is contained in:
Christophe Romain 2010-09-24 16:11:39 +02:00
parent a894d25b1f
commit db2baa8f84
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/mod_pubsub/pubsub_clean.erl
View File

@ -2,7 +2,7 @@
-define(TIMEOUT, 1000*600). % 1 minute
-export([start/0, loop/0, offline/1]).
-export([start/0, loop/0, purge/0, offline/1]).
start() ->
Pid = spawn(?MODULE, loop, []),
@ -17,7 +17,8 @@ loop() ->
loop().
purge() ->
{Sessions, Subscriptions} = {mnesia:table_info(session,size),mnesia:table_info(pubsub_state,size)},
Sessions = lists:sum([mnesia:table_info(session,size)|[rpc:call(N,mnesia,table_info,[session,size]) || N <- nodes()]]),
Subscriptions = mnesia:table_info(pubsub_state,size),
if Subscriptions > Sessions + 500 ->
lists:foreach(fun(K) ->
[N]=mnesia:dirty_read({pubsub_node, K}),
@ -34,3 +35,4 @@ offline(Jids) ->
lists:filter(fun({U,S,""}) -> ejabberd_sm:get_user_resources(U,S) == [];
({U,S,R}) -> not lists:member(R,ejabberd_sm:get_user_resources(U,S))
end, Jids).
%%ejabberd_cluster:get_node({LUser, LServer})