From 8516524d021d85007cdcdebb9aa909efecc171f4 Mon Sep 17 00:00:00 2001 From: 0xdcarns Date: Tue, 22 Feb 2022 16:14:23 -0500 Subject: [PATCH] sync hotfix --- mq/publishers.go | 2 ++ serverctl/serverctl.go | 2 ++ 2 files changed, 4 insertions(+) diff --git a/mq/publishers.go b/mq/publishers.go index 52735621..2bec7e22 100644 --- a/mq/publishers.go +++ b/mq/publishers.go @@ -8,6 +8,7 @@ import ( "github.com/gravitl/netmaker/logic" "github.com/gravitl/netmaker/models" "github.com/gravitl/netmaker/servercfg" + "github.com/gravitl/netmaker/serverctl" ) // PublishPeerUpdate --- deterines and publishes a peer update to all the peers of a node @@ -126,6 +127,7 @@ func sendPeers() { } } else { logger.Log(1, "unable to retrieve leader for network ", network.NetID) + serverctl.SyncServerNetwork(network.NetID) logger.Log(1, errN.Error()) continue } diff --git a/serverctl/serverctl.go b/serverctl/serverctl.go index 5b5d6087..5b96390a 100644 --- a/serverctl/serverctl.go +++ b/serverctl/serverctl.go @@ -5,6 +5,7 @@ import ( "net" "os" "strings" + "time" "github.com/gravitl/netmaker/database" "github.com/gravitl/netmaker/logger" @@ -38,6 +39,7 @@ func InitializeCommsNetwork() error { logger.Log(1, "comms net does not exist, creating with ID,", network.NetID, "and CIDR,", network.AddressRange) return logic.CreateNetwork(network) } + time.Sleep(time.Second << 1) SyncServerNetwork(COMMS_NETID) return nil