TRKJ/EdgeAPI
2
0
Fork 0
mirror of https://github.com/TeaOSLab/EdgeAPI.git synced 2025-11-05 01:20:25 +08:00
Code Issues Packages Projects Releases Wiki Activity

优化节点活跃检测机制

Browse Source
This commit is contained in:
GoEdgeLab
2022-09-03 12:43:06 +08:00
parent 89f078cfe0
commit 160ea5a5b2
1 changed files with 7 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
internal/rpc/services/service_node_stream.go
View File

@@ -124,6 +124,7 @@ func (this *NodeService) NodeStream(server pb.NodeService_NodeStreamServer) erro
return err return err
} }
if inactiveNotifiedAt > 0 { if inactiveNotifiedAt > 0 {
// 设置为活跃
err = models.SharedNodeDAO.UpdateNodeActive(tx, nodeId, true) err = models.SharedNodeDAO.UpdateNodeActive(tx, nodeId, true)
if err != nil { if err != nil {
return err return err
@@ -144,6 +145,12 @@ func (this *NodeService) NodeStream(server pb.NodeService_NodeStreamServer) erro
if err != nil { if err != nil {
return err return err
} }
} else {
// 设置为活跃
err = models.SharedNodeDAO.UpdateNodeActive(tx, nodeId, true)
if err != nil {
return err
}
} }
} }