yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

Hiberate after subscribe, unsubscribe and resume

This commit is contained in:
Feng Lee 2017-02-20 16:45:53 +08:00
parent 44ea90fa20
commit cabd1af23a
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
src/emqttd_session.erl
View File

@ -391,7 +391,7 @@ handle_cast({subscribe, _From, TopicTable, AckFun},
{[NewQos|QosAcc], SubMap1} {[NewQos|QosAcc], SubMap1}
end, {[], Subscriptions}, TopicTable), end, {[], Subscriptions}, TopicTable),
AckFun(lists:reverse(GrantedQos)), AckFun(lists:reverse(GrantedQos)),
noreply(emit_stats(State#state{subscriptions = Subscriptions1})); hibernate(emit_stats(State#state{subscriptions = Subscriptions1}));
handle_cast({unsubscribe, _From, TopicTable}, handle_cast({unsubscribe, _From, TopicTable},
State = #state{client_id = ClientId, State = #state{client_id = ClientId,
@ -409,7 +409,7 @@ handle_cast({unsubscribe, _From, TopicTable},
SubMap SubMap
end end
end, Subscriptions, TopicTable), end, Subscriptions, TopicTable),
noreply(emit_stats(State#state{subscriptions = Subscriptions1})); hibernate(emit_stats(State#state{subscriptions = Subscriptions1}));
%% PUBACK: %% PUBACK:
handle_cast({puback, PacketId}, State = #state{inflight = Inflight}) -> handle_cast({puback, PacketId}, State = #state{inflight = Inflight}) ->
@ -501,7 +501,7 @@ handle_cast({resume, ClientId, ClientPid},
end, end,
%% Replay delivery and Dequeue pending messages %% Replay delivery and Dequeue pending messages
noreply(emit_stats(dequeue(retry_delivery(true, State1)))); hibernate(emit_stats(dequeue(retry_delivery(true, State1))));
handle_cast({destroy, ClientId}, State = #state{client_id = ClientId, handle_cast({destroy, ClientId}, State = #state{client_id = ClientId,
client_pid = undefined}) -> client_pid = undefined}) ->