anlicheng/iot
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix

Browse Source
This commit is contained in:
anlicheng 2023-08-21 16:40:03 +08:00
parent 80b0598985
commit 3a78b7058f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
apps/iot/src/iot_endpoint.erl
View File

@ -180,8 +180,8 @@ handle_event(info, fetch_next, connected, State = #state{tab_name = TabName, cur
%% 收到确认消息
handle_event(info, {ack, Id}, StateName, State = #state{tab_name = TabName, endpoint = #endpoint{name = Name}, timer_map = TimerMap, acc_num = AccNum, flight_num = FlightNum}) ->
lager:debug("[iot_endpoint] endpoint: ~p, get ack: ~p", [Name, Id]),
mnesia_queue:delete(TabName, Id),
ok = mnesia_queue:delete(TabName, Id),
lager:debug("[iot_endpoint] endpoint: ~p, get ack: ~p, delete from mnesia", [Name, Id]),
Actions = case StateName =:= connected of
true -> [{next_event, info, fetch_next}];
false -> []