Skip to content

Commit 7db7f16

Browse files
committed
fix
1 parent 5725862 commit 7db7f16

1 file changed

Lines changed: 3 additions & 3 deletions

File tree

Cyaim.WebSocketServer/Cluster/Cyaim.WebSocketServer.Cluster.Hybrid/HybridClusterTransport.cs

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -782,11 +782,11 @@ private void OnNodeDiscovered(object sender, NodeInfo nodeInfo)
782782
_logger.LogWarning($"[HybridClusterTransport] OnNodeDiscovered: 节点心跳时间未设置,使用当前时间 - NodeId: {nodeInfo.NodeId}, CurrentNodeId: {_nodeId}");
783783
}
784784

785-
// 确保 Status 已设置
786-
if (nodeInfo.Status == NodeStatus.Unknown)
785+
// 确保 Status 已设置(枚举默认值为 Active,但为了安全起见,如果状态不是 Active/Draining/Offline,设置为 Active)
786+
if (nodeInfo.Status != NodeStatus.Active && nodeInfo.Status != NodeStatus.Draining && nodeInfo.Status != NodeStatus.Offline)
787787
{
788788
nodeInfo.Status = NodeStatus.Active;
789-
_logger.LogWarning($"[HybridClusterTransport] OnNodeDiscovered: 节点状态未设置,设置为 Active - NodeId: {nodeInfo.NodeId}, CurrentNodeId: {_nodeId}");
789+
_logger.LogWarning($"[HybridClusterTransport] OnNodeDiscovered: 节点状态无效,设置为 Active - NodeId: {nodeInfo.NodeId}, InvalidStatus: {nodeInfo.Status}, CurrentNodeId: {_nodeId}");
790790
}
791791

792792
var wasNew = _knownNodes.TryAdd(nodeInfo.NodeId, nodeInfo);

0 commit comments

Comments
 (0)