From 74708b505e4bb2ec83460c300c4ecf85c44fde7f Mon Sep 17 00:00:00 2001 From: liyi Date: Mon, 16 Dec 2024 13:59:21 +0800 Subject: [PATCH] =?UTF-8?q?fix:=E5=A4=84=E7=90=86=E5=BF=83=E8=B7=B3?= =?UTF-8?q?=E5=93=8D=E5=BA=94=E5=A4=B1=E8=B4=A5=E5=90=8E=EF=BC=9A=E5=81=9C?= =?UTF-8?q?=E6=AD=A2=E5=8F=91=E9=80=81=E5=BF=83=E8=B7=B3=E6=B6=88=E6=81=AF?= =?UTF-8?q?=EF=BC=8C=E5=B9=B6=E5=90=AF=E5=8A=A8=E9=87=8D=E6=96=B0=E4=B8=8A?= =?UTF-8?q?=E7=BA=BF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handle/impl/udp_heart_beat_handler.dart | 13 +++++++------ 1 file changed, 7 insertions(+), 6 deletions(-) diff --git a/lib/talk/startChart/handle/impl/udp_heart_beat_handler.dart b/lib/talk/startChart/handle/impl/udp_heart_beat_handler.dart index 75fe9103..82b8843b 100644 --- a/lib/talk/startChart/handle/impl/udp_heart_beat_handler.dart +++ b/lib/talk/startChart/handle/impl/udp_heart_beat_handler.dart @@ -16,21 +16,22 @@ class UdpHeartBeatHandler extends ScpMessageBaseHandle @override void handleResp(ScpMessage scpMessage) { - // TODO: 收到心跳消息回复 final HeartbeatResponse heartbeatResponse = scpMessage.Payload; final statusCode = heartbeatResponse.statusCode; if (statusCode != null && statusCode != PayloadTypeConstant.heartHeatSuccessResponse) { - // 停止发送心跳 + // 心跳回复失败,停止发送心跳 startChartManage.stopHeartbeat(); // 心跳响应失败,重新上线 startChartManage.isOnlineStartChartServer = false; startChartManage.reStartOnlineStartChartServer(); + } else { + // 修改间隔为返回的心跳间隔 + startChartManage.heartbeatIntervalTime = + heartbeatResponse.nextPingTime ?? 1; + // 修改完间隔之后重新启动发送心跳 + startChartManage.reStartHeartBeat(); } - startChartManage.heartbeatIntervalTime = - heartbeatResponse.nextPingTime ?? 1; - // 修改完间隔之后重新启动发送心跳 - startChartManage.reStartHeartBeat(); } @override