diff --git a/ChangeLog b/ChangeLog index 92511bae4..65e29aa14 100644 --- a/ChangeLog +++ b/ChangeLog @@ -2,6 +2,10 @@ * doc/guide.tex: Document the option max_s2s_connections +2008-04-27 Alexey Shchepin + + * src/mod_muc/mod_muc_room.erl: Fixed room shaper processing + 2008-04-26 Badlop * src/mod_shared_roster.erl: Fix for new registered accounts not diff --git a/src/mod_muc/mod_muc_room.erl b/src/mod_muc/mod_muc_room.erl index 30a9fa258..29807ff09 100644 --- a/src/mod_muc/mod_muc_room.erl +++ b/src/mod_muc/mod_muc_room.erl @@ -697,31 +697,27 @@ code_change(_OldVsn, StateName, StateData, _Extra) -> %% {stop, Reason, NewStateData} %%---------------------------------------------------------------------- handle_info({process_user_presence, From}, normal_state = _StateName, StateData) -> - Activity = get_user_activity(From, StateData), - Now = now_to_usec(now()), - {Nick, Packet} = Activity#activity.presence, - NewActivity = Activity#activity{presence_time = Now, - presence = undefined}, - StateData1 = - StateData#state{ - activity = ?DICT:store( - jlib:jid_tolower(From), - NewActivity, - StateData#state.activity)}, - process_presence(From, Nick, Packet, StateData1); + RoomQueueEmpty = queue:is_empty(StateData#state.room_queue), + RoomQueue = queue:in({presence, From}, StateData#state.room_queue), + StateData1 = StateData#state{room_queue = RoomQueue}, + if + RoomQueueEmpty -> + StateData2 = prepare_room_queue(StateData1), + {next_state, normal_state, StateData2}; + true -> + {next_state, normal_state, StateData1} + end; handle_info({process_user_message, From}, normal_state = _StateName, StateData) -> - Activity = get_user_activity(From, StateData), - Now = now_to_usec(now()), - Packet = Activity#activity.message, - NewActivity = Activity#activity{message_time = Now, - message = undefined}, - StateData1 = - StateData#state{ - activity = ?DICT:store( - jlib:jid_tolower(From), - NewActivity, - StateData#state.activity)}, - process_groupchat_message(From, Packet, StateData1); + RoomQueueEmpty = queue:is_empty(StateData#state.room_queue), + RoomQueue = queue:in({message, From}, StateData#state.room_queue), + StateData1 = StateData#state{room_queue = RoomQueue}, + if + RoomQueueEmpty -> + StateData2 = prepare_room_queue(StateData1), + {next_state, normal_state, StateData2}; + true -> + {next_state, normal_state, StateData1} + end; handle_info(process_room_queue, normal_state = StateName, StateData) -> case queue:out(StateData#state.room_queue) of {{value, {message, From}}, RoomQueue} ->