Function InitController

controller/controller.go:26–51

()

}

func InitController() error {
	protocol := &tcp.DefaultProtocol{}
	protocol.SetMaxPacketSize(uint32(GlobalConfig.MAX_PACKET_SIZE))
	server := tcp.NewAsyncTCPServer(GlobalConfig.TCP_BIND, &callback{}, protocol)
	if err := server.ListenAndServe(); err != nil {
		return err
	}
	lg.Info("Start listen: %v", GlobalConfig.TCP_BIND)

	controller = &Controller{server,
		NewTaskPool(GlobalConfig.TASK_POOL_SIZE),
		NewResultPool(GlobalConfig.RESULT_POOL_SIZE),
		NewNodePool(),
		make(map[int]*EventPool),
		new(sync.RWMutex),
		cache.New(time.Duration(GlobalConfig.LOAD_STRATEGIES_INTERVAL)*time.Second, 30*time.Second),
		cache.New(10*time.Minute, 10*time.Minute)}

	go controller.processStrategyResultForever()
	go controller.processStrategyEventForever()
	go controller.checkNodesForever()
	go controller.startHttpServer()
	go controller.loadStrategiesForever()

	return nil
}

//checkNodesForever 持续运行检查节点函数，并维护节点数组
func (c *Controller) checkNodesForever() {