diff --git a/internal/iplibrary/manager_country.go b/internal/iplibrary/manager_country.go index 6411bef..1b4eada 100644 --- a/internal/iplibrary/manager_country.go +++ b/internal/iplibrary/manager_country.go @@ -20,12 +20,12 @@ import ( var SharedCountryManager = NewCountryManager() func init() { - events.On(events.EventStart, func() { + events.On(events.EventLoaded, func() { go SharedCountryManager.Start() }) } -// 国家信息管理 +// CountryManager 国家/地区信息管理 type CountryManager struct { cacheFile string diff --git a/internal/iplibrary/manager_ip_list.go b/internal/iplibrary/manager_ip_list.go index e3f97b0..2875126 100644 --- a/internal/iplibrary/manager_ip_list.go +++ b/internal/iplibrary/manager_ip_list.go @@ -15,12 +15,12 @@ var SharedIPListManager = NewIPListManager() var IPListUpdateNotify = make(chan bool, 1) func init() { - events.On(events.EventStart, func() { + events.On(events.EventLoaded, func() { go SharedIPListManager.Start() }) } -// IP名单管理 +// IPListManager IP名单管理 type IPListManager struct { // 缓存文件 // 每行一个数据:id|from|to|expiredAt diff --git a/internal/iplibrary/manager_province.go b/internal/iplibrary/manager_province.go index fae475b..df0410a 100644 --- a/internal/iplibrary/manager_province.go +++ b/internal/iplibrary/manager_province.go @@ -24,12 +24,12 @@ const ( var SharedProvinceManager = NewProvinceManager() func init() { - events.On(events.EventStart, func() { + events.On(events.EventLoaded, func() { go SharedProvinceManager.Start() }) } -// 国家信息管理 +// ProvinceManager 中国省份信息管理 type ProvinceManager struct { cacheFile string diff --git a/internal/monitor/value_queue.go b/internal/monitor/value_queue.go index d4a6d07..3f1b4c1 100644 --- a/internal/monitor/value_queue.go +++ b/internal/monitor/value_queue.go @@ -15,7 +15,7 @@ import ( var SharedValueQueue = NewValueQueue() func init() { - events.On(events.EventStart, func() { + events.On(events.EventLoaded, func() { go SharedValueQueue.Start() }) } diff --git a/internal/nodes/node.go b/internal/nodes/node.go index b36b095..ba84065 100644 --- a/internal/nodes/node.go +++ b/internal/nodes/node.go @@ -290,7 +290,7 @@ func (this *Node) syncConfig() error { if os.IsNotExist(clusterErr) { return err } - return clusterErr + return errors.New("check cluster config failed: " + clusterErr.Error()) } } else { return err @@ -347,7 +347,7 @@ func (this *Node) syncConfig() error { } else { remotelogs.Println("NODE", "loading config ...") } - + nodeconfigs.ResetNodeConfig(nodeConfig) caches.SharedManager.MaxDiskCapacity = nodeConfig.MaxCacheDiskCapacity caches.SharedManager.MaxMemoryCapacity = nodeConfig.MaxCacheMemoryCapacity @@ -425,7 +425,7 @@ func (this *Node) checkClusterConfig() error { return err } - logs.Println("[NODE]registering node ...") + logs.Println("[NODE]registering node to cluster ...") resp, err := rpcClient.NodeRPC().RegisterClusterNode(rpcClient.ClusterContext(config.ClusterId, config.Secret), &pb.RegisterClusterNodeRequest{Name: HOSTNAME}) if err != nil { return err