mirror of
https://github.com/duanhf2012/origin.git
synced 2026-02-04 06:54:45 +08:00
TCP服务与Gate服务加载顺序问题
This commit is contained in:
@@ -2,15 +2,17 @@ package service
|
|||||||
|
|
||||||
//本地所有的service
|
//本地所有的service
|
||||||
var mapServiceName map[string]IService
|
var mapServiceName map[string]IService
|
||||||
|
var setupServiceList []IService
|
||||||
|
|
||||||
func init(){
|
func init(){
|
||||||
mapServiceName = map[string]IService{}
|
mapServiceName = map[string]IService{}
|
||||||
|
setupServiceList = []IService{}
|
||||||
}
|
}
|
||||||
|
|
||||||
func Init(chanCloseSig chan bool) {
|
func Init(chanCloseSig chan bool) {
|
||||||
closeSig=chanCloseSig
|
closeSig=chanCloseSig
|
||||||
|
|
||||||
for _,s := range mapServiceName {
|
for _,s := range setupServiceList {
|
||||||
err := s.OnInit()
|
err := s.OnInit()
|
||||||
if err != nil {
|
if err != nil {
|
||||||
panic(err)
|
panic(err)
|
||||||
@@ -25,6 +27,7 @@ func Setup(s IService) bool {
|
|||||||
}
|
}
|
||||||
|
|
||||||
mapServiceName[s.GetName()] = s
|
mapServiceName[s.GetName()] = s
|
||||||
|
setupServiceList = append(setupServiceList, s)
|
||||||
return true
|
return true
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -38,13 +41,13 @@ func GetService(serviceName string) IService {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func Start(){
|
func Start(){
|
||||||
for _,s := range mapServiceName {
|
for _,s := range setupServiceList {
|
||||||
s.Start()
|
s.Start()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
func WaitStop(){
|
func WaitStop(){
|
||||||
for _,s := range mapServiceName {
|
for i := len(setupServiceList) - 1; i >= 0; i-- {
|
||||||
s.Wait()
|
setupServiceList[i].Wait()
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|||||||
Reference in New Issue
Block a user