Method mainLoop

tars/application.go:582–623

()

}

func (a *application) mainLoop() {
	ha := new(NodeFHelper)
	comm := a.Communicator()
	node := a.svrCfg.Node
	app := a.svrCfg.App
	server := a.svrCfg.Server
	container := a.svrCfg.Container
	ha.SetNodeInfo(comm, node, app, server, container)

	svrCfg := a.ServerConfig()
	go ha.ReportVersion(svrCfg.Version)
	go ha.KeepAlive("") //first start
	go a.handleSignal()
	// registrar service
	ctx := context.Background()
	go a.registryAdapters(ctx)

	loop := time.NewTicker(svrCfg.MainLoopTicker)
	for {
		select {
		case <-a.shutdown:
			ReportNotifyInfo(NotifyNormal, "stop")
			return
		case <-loop.C:
			if atomic.LoadInt32(&a.isShutdowning) == 1 {
				continue
			}
			for name, adapter := range a.svrCfg.Adapters {
				if adapter.Protocol == "not_tars" {
					// TODO not_tars support
					ha.KeepAlive(name)
					continue
				}
				if s, ok := a.goSvrs[adapter.Obj]; ok {
					if !s.IsZombie(svrCfg.ZombieTimeout) {
						ha.KeepAlive(name)
					}
				}
			}
		}
	}
}