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

fix device

Browse Source
This commit is contained in:
anlicheng 2023-08-15 23:20:02 +08:00
parent 30c0d6c198
commit 5cc6665a3d
1 changed files with 16 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
apps/iot/src/iot_host.erl
View File

@ -415,16 +415,22 @@ handle_event(info, {'EXIT', Pid, Reason}, StateName, State = #state{uuid = UUID,
false -> false ->
{keep_state, State}; {keep_state, State};
{value, {DeviceUUID, _}} -> {value, {DeviceUUID, _}} ->
%% 避免数据异常，导致一直重启
erlang:start_timer(5000, self(), {restart_device, DeviceUUID}),
{keep_state, State#state{device_map = maps:remove(DeviceUUID, DeviceMap)}}
end;
handle_event(info, {timeout, _, {restart_device, DeviceUUID}}, _, State = #state{uuid = UUID, device_map = DeviceMap}) ->
%% 重启device进程不一定能成功，可能重启时，数据库已经删除了 %% 重启device进程不一定能成功，可能重启时，数据库已经删除了
case iot_device:start_link(self(), DeviceUUID) of case catch iot_device:start_link(self(), DeviceUUID) of
{ok, DevicePid} -> {ok, DevicePid} ->
lager:debug("[iot_host] uuid: ~p, restart device: ~p, success", [UUID, DeviceUUID]),
%% 采用的是同样的DeviceUUID，因此老的值会被覆盖 %% 采用的是同样的DeviceUUID，因此老的值会被覆盖
NDeviceMap = maps:put(DeviceUUID, DevicePid, DeviceMap), NDeviceMap = maps:put(DeviceUUID, DevicePid, DeviceMap),
{keep_state, State#state{device_map = NDeviceMap}}; {keep_state, State#state{device_map = NDeviceMap}};
Error -> Error ->
lager:warning("[iot_host] uuid: ~p, restart device: ~p, get error: ~p", [UUID, DeviceUUID, Error]), lager:warning("[iot_host] uuid: ~p, restart device: ~p, get error: ~p", [UUID, DeviceUUID, Error]),
{keep_state, State} {keep_state, State}
end
end; end;
handle_event(EventType, EventContent, StateName, State) -> handle_event(EventType, EventContent, StateName, State) ->