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

fix heartbeat

Browse Source
This commit is contained in:
anlicheng 2026-05-09 17:19:42 +08:00
parent 7fd82ac61d
commit 7f3775b697
1 changed files with 9 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
src/host/iot_host.erl
View File

@ -311,13 +311,17 @@ handle_event(cast, heartbeat, _, State = #state{uuid = UUID, heartbeat_counter =
maybe_mark_host_online(UUID), maybe_mark_host_online(UUID),
{keep_state, State#state{heartbeat_counter = HeartbeatCounter + 1}}; {keep_state, State#state{heartbeat_counter = HeartbeatCounter + 1}};
%% 没有收到心跳包，主机下线, 设备状态不变 %% UDP 心跳丢失但 SSL channel 仍在时，不能把 host 标记为离线。
handle_event(info, {timeout, _, heartbeat_ticker}, _, State = #state{uuid = UUID, heartbeat_counter = 0, channel_pid = ChannelPid}) -> handle_event(info, {timeout, _, heartbeat_ticker}, _, State = #state{uuid = UUID, heartbeat_counter = 0, channel_pid = ChannelPid}) when is_pid(ChannelPid) ->
logger:warning("[iot_host] uuid: ~p, udp heartbeat lost but ssl channel is alive: ~p", [UUID, ChannelPid]),
maybe_mark_host_online(UUID),
erlang:start_timer(?HEARTBEAT_INTERVAL, self(), heartbeat_ticker),
{keep_state, State#state{heartbeat_counter = 0}};
%% 没有收到 UDP 心跳且没有 SSL channel，主机下线, 设备状态不变
handle_event(info, {timeout, _, heartbeat_ticker}, _, State = #state{uuid = UUID, heartbeat_counter = 0}) ->
logger:warning("[iot_host] uuid: ~p, heartbeat lost, devices will unknown", [UUID]), logger:warning("[iot_host] uuid: ~p, heartbeat lost, devices will unknown", [UUID]),
maybe_mark_host_offline(UUID), maybe_mark_host_offline(UUID),
%% 关闭channel，主机需要重新连接，才能保存状态的一致
is_pid(ChannelPid) andalso ssl_channel:stop(ChannelPid, closed),
erlang:start_timer(?HEARTBEAT_INTERVAL, self(), heartbeat_ticker), erlang:start_timer(?HEARTBEAT_INTERVAL, self(), heartbeat_ticker),
{keep_state, State#state{channel_pid = undefined, has_session = false, heartbeat_counter = 0}}; {keep_state, State#state{channel_pid = undefined, has_session = false, heartbeat_counter = 0}};