cicv_data_closed_loop/kinglong/master/pkg/cfg/master_tcp_cfg.go

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
	//	}
	//
	//}

}