Browse Source

sync hotfix

0xdcarns 3 years ago
parent
commit
8516524d02
2 changed files with 4 additions and 0 deletions
  1. 2 0
      mq/publishers.go
  2. 2 0
      serverctl/serverctl.go

+ 2 - 0
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
 		}

+ 2 - 0
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