commit

aarch64/pjisuv/master/main/master.go

@@ -14,8 +14,6 @@ func init() {
 	//runtime.GOMAXPROCS(1)
 	c_log.InitLog("/mnt/media/sda1/cicv-data-closedloop/", "pjisuv-master")
 	commonInit.Init()
-	// 初始化TCP连接，用于发送时间窗口到从节点
-	masterConfig.InitTcpConfig()
 	// 初始化加载触发器插件文件
 	masterConfig.InitTriggerConfig()
 	// 初始化rpc监听

kinglong/master/main/master.go

@@ -14,8 +14,6 @@ func init() {
 	//runtime.GOMAXPROCS(1)
 	log.InitLogConfig("kinglong-master")
 	commonInit.Init()
-	// 初始化TCP连接，用于发送时间窗口到从节点
-	masterConfig.InitTcpConfig()
 	// 初始化加载触发器插件文件
 	masterConfig.InitTriggerConfig()
 	// 初始化rpc监听

kinglong/master/pkg/cfg/master_tcp_cfg.go

@@ -1,28 +0,0 @@
-package cfg
-
-import (
-	"cicv-data-closedloop/kinglong/common/log"
-	"net"
-)
-
-var TcpConnection net.Conn
-
-// InitTcpConfig 初始化TCP连接，用于发送时间窗口到从节点
-func InitTcpConfig() {
-	log.GlobalLogger.Info("主节点初始化TCP长连接 - 开始。")
-	//var err error
-	//socket := commonConfig.CloudConfig.Hosts[1].Ip + ":" + commonConfig.CloudConfig.TcpPort
-	//for {
-	//	time.Sleep(time.Duration(1) * time.Second)
-	//	TcpConnection, err = net.Dial("tcp", socket)
-	//	if err != nil {
-	//		log.GlobalLogger.Error("主节点初始化TCP长连接 - 进行中：", err)
-	//		continue
-	//	} else {
-	//		log.GlobalLogger.Info("主节点初始化TCP长连接 - 成功：", socket)
-	//		break
-	//	}
-	//
-	//}
-
-}