anyproto/any-sync
1
0
Fork 0
mirror of https://github.com/anyproto/any-sync.git synced 2025-06-08 05:57:03 +09:00
Code Activity

save addrs; use coordinator type

Browse source
This commit is contained in:
Anatolii Smolianinov 2024-09-16 12:23:20 +02:00
parent f4a05bc4f0
commit 5a691f42d9
No known key found for this signature in database
GPG key ID: 5E259D1D468B99F4
1 changed files with 12 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

14
nodeconf/service.go
View file

@ -68,7 +68,7 @@ func mergedTreeNodes(configNodes []Node, lastStoredNodes []Node) (mergedAddrs []
mustRewriteNods := false
for _, node := range lastStoredNodes {
if node.HasType(NodeTypeTree) {
if node.HasType(NodeTypeCoordinator) {
for _, addr := range node.Addresses {
treeNodes[addr] = 1
}
@ -76,7 +76,7 @@ func mergedTreeNodes(configNodes []Node, lastStoredNodes []Node) (mergedAddrs []
}
for _, node := range configNodes {
if node.HasType(NodeTypeTree) {
if node.HasType(NodeTypeCoordinator) {
for _, addr := range node.Addresses {
if _, found := treeNodes[addr]; !found {
mustRewriteNods = true
@ -108,6 +108,16 @@ func (s *service) Init(a *app.App) (err error) {
lastStored = s.config
err = nil
}
if mergedAddrs := mergedTreeNodes(s.config.Nodes, lastStored.Nodes); mergedAddrs != nil {
for _, node := range lastStored.Nodes {
if node.HasType(NodeTypeCoordinator) {
node.Addresses = mergedAddrs
break // can we break here? node structure in yaml allows to have multiple sections with the same nodeType
}
}
}
var updatePeriodSec = 600
if confUpd, ok := a.MustComponent("config").(ConfigUpdateGetter); ok && confUpd.GetNodeConfUpdateInterval() > 0 {
updatePeriodSec = confUpd.GetNodeConfUpdateInterval()