集群增加自动同步时钟选项

2025-12-28 00:06:36 +08:00 · 2022-09-15 15:56:50 +08:00
parent 86499eaee4
commit 49ac8442b0
5 changed files with 79 additions and 35 deletions
--- a/internal/db/models/node_dao.go
+++ b/internal/db/models/node_dao.go
@@ -1085,6 +1085,11 @@ func (this *NodeDAO) ComposeNodeConfig(tx *dbs.Tx, nodeId int64, cacheMap *utils
 			}
 		}

+		// 时钟
+		if config.Clock == nil {
+			config.Clock = nodeCluster.DecodeClock()
+		}
+
 		// 最大线程数、TCP连接数
 		if clusterIndex == 0 {
 			config.MaxThreads = int(nodeCluster.NodeMaxThreads)