Ver Fonte

broadcast egress updates

Abhishek Kondur há 2 anos atrás
pai
commit
b0ed795521
1 ficheiros alterados com 2 adições e 0 exclusões
  1. 2 0
      controllers/node.go

+ 2 - 0
controllers/node.go

@@ -465,6 +465,7 @@ func createEgressGateway(w http.ResponseWriter, r *http.Request) {
 		if err != nil {
 			logger.Log(0, "failed to get egress host: ", err.Error())
 		}
+		mq.BroadcastAddOrUpdatePeer(host, &node, true)
 		f, err := logic.GetFwUpdate(host)
 		if err != nil {
 			logger.Log(0, "failed to get egreess host: ", err.Error())
@@ -512,6 +513,7 @@ func deleteEgressGateway(w http.ResponseWriter, r *http.Request) {
 		if err != nil {
 			logger.Log(0, "failed to get egress host: ", err.Error())
 		}
+		mq.BroadcastAddOrUpdatePeer(host, &node, true)
 		f, err := logic.GetFwUpdate(host)
 		if err != nil {
 			logger.Log(0, "failed to get egreess host: ", err.Error())