Passive Update mode supported

tools/dpvs-agent/cmd/ipvs/post_vs_vip_port_rs.go

@@ -15,6 +15,7 @@
 package ipvs
 
 import (
+	"sort"
 	"strings"
 
 	"github.com/dpvs-agent/models"
@@ -73,11 +74,57 @@ func (h *postVsRs) Handle(params apiVs.PostVsVipPortRsParams) middleware.Respond
 		rss[i].SetInhibited(&inhibited)
 	}
 
+	update := !*params.PassiveUpdate
+
 	shareSnapshot := settings.ShareSnapshot()
 	if shareSnapshot.ServiceLock(params.VipPort) {
 		defer shareSnapshot.ServiceUnlock(params.VipPort)
 	}
 
+	// default passiveUpdate == false
+	if *params.PassiveUpdate {
+		// passiveUpdate == true
+		vsModel := shareSnapshot.ServiceGet(params.VipPort)
+		if vsModel == nil {
+			h.logger.Info("Try update update. vs not found in snapshot.", "VipPort", params.VipPort)
+			update = true
+		}
+
+		if vsModel != nil {
+			if len(vsModel.RSs.Items) != len(rss) {
+				h.logger.Info("Try update update. vs rss len has changed.", "VipPort", params.VipPort)
+				update = true
+			}
+
+			if len(vsModel.RSs.Items) == len(rss) {
+				cacheRSs := (types.SliceRealServerSpecExpandModel)(vsModel.RSs.Items)
+				sort.Sort(cacheRSs)
+
+				newRSs := (types.SliceRealServerSpec)(rss)
+				sort.Sort(newRSs)
+
+				for i, newRs := range newRSs {
+					cacheRs := cacheRSs[i]
+					if int(cacheRs.Spec.Weight) != int(newRs.GetWeight()) {
+						h.logger.Info("Try update update. rs weight has changed.", "VipPort", params.VipPort, "rs", newRs.ID(), "cache weight", cacheRs.Spec.Weight, "update weight", newRs.GetWeight())
+						update = true
+						break
+					}
+
+					if !strings.EqualFold(strings.ToUpper(cacheRs.Spec.Mode), strings.ToUpper(newRs.GetFwdModeString())) {
+						h.logger.Info("Try update update. rs nat mode has changed.", "VipPort", params.VipPort, "rs", newRs.ID(), "cache nat mode", cacheRs.Spec.Mode, "update nat mode", newRs.GetFwdModeString())
+						update = true
+						break
+					}
+				}
+			}
+		}
+	}
+
+	if !update {
+		return apiVs.NewPostVsVipPortRsOK().WithPayload("PassiveUpdate")
+	}
+
 	result := front.Update(rss, h.connPool, h.logger)
 	switch result {
 	case types.EDPVS_EXIST, types.EDPVS_OK:

tools/dpvs-agent/cmd/ipvs/put_vs_vip_port.go

@@ -90,7 +90,54 @@ func (h *putVsItem) Handle(params apiVs.PutVsVipPortParams) middleware.Responder
 		}
 	}
 
+	update := !*params.PassiveUpdate
+
 	shareSnapshot := settings.ShareSnapshot()
+	if shareSnapshot.ServiceRLock(vs.ID()) {
+		vsModel := shareSnapshot.ServiceGet(vs.ID())
+		if vsModel == nil {
+			shareSnapshot.ServiceRUnlock(vs.ID())
+			return apiVs.NewPutVsVipPortInvalidBackend()
+		}
+
+		if *params.PassiveUpdate {
+			// bypass  VIP, Port, Protocol, Af, netmask
+			if vsModel.Fwmark != vs.GetFwmark() ||
+				vsModel.ConnTimeout != vs.GetConnTimeout() ||
+				vsModel.Bps != vs.GetBps() ||
+				vsModel.LimitProportion != vs.GetLimitProportion() {
+
+				h.logger.Info("Try to update !!! Fwmark | ConnTimeout | Bps | LimitProportion has Changed.", "VipPort", params.VipPort)
+
+				update = true
+			}
+
+			// ExpireQuiescent | SynProxy | Quic | Persistence
+			newFlags := vs.GetFlags()
+			newFlagsNOT := ^newFlags
+			tmpFlags := vsModel.RAMFlags ^ newFlagsNOT
+			if (tmpFlags & vsModel.RAMFlags) != newFlags {
+
+				h.logger.Info("Try to update !!! the flags has changed.", "VipPort", params.VipPort)
+
+				update = true
+			}
+
+			if !strings.EqualFold(vs.GetSchedName(), vsModel.SchedName) {
+
+				h.logger.Info("Try to update !!! the SchedName has changed.", "VipPort", params.VipPort)
+
+				update = true
+			}
+		}
+
+		shareSnapshot.ServiceRUnlock(vs.ID())
+	}
+
+	if !update {
+		return apiVs.NewPutVsVipPortOK().WithPayload("PassiveUpdate")
+	}
+
 	result := vs.Add(h.connPool, h.logger)
 	h.logger.Info("Add virtual server done.", "vs", vs, "result", result.String())
 	switch result {

tools/dpvs-agent/dpvs-agent-api.yaml

@@ -156,6 +156,12 @@ parameters:
       - off
     default: unset
     required: false
+  passive-update:
+    name: passiveUpdate
+    in: query
+    type: boolean
+    default: false
+    required: false
   version:
     name: version
     in: query
@@ -561,6 +567,9 @@ definitions:
         format: "uint32"
       Flags:
         type: "string"
+      RamFlags:
+        type: "integer"
+        format: "uint32"
       SynProxy:
         type: "string"
         enum:
@@ -1164,6 +1173,7 @@ paths:
       tags:
         - "virtualserver"
       parameters:
+        - "$ref": "#/parameters/passive-update"
         - "$ref": "#/parameters/snapshot"
         - "$ref": "#/parameters/service-id"
         - "$ref": "#/parameters/vs-config"
@@ -1381,6 +1391,7 @@ paths:
       tags:
         - "virtualserver"
       parameters:
+        - "$ref": "#/parameters/passive-update"
         - "$ref": "#/parameters/snapshot"
         - "$ref": "#/parameters/service-id"
         - "$ref": "#/parameters/rss-config"

tools/dpvs-agent/pkg/ipc/types/getmodel.go

@@ -37,6 +37,7 @@ func (vs *VirtualServerSpec) GetModel() *models.VirtualServerSpecExpand {
 		Match:           vs.match.GetModel(),
 		Stats:           vs.stats.GetModel(),
 		DestCheck:       vs.GetDestCheck(),
+		RAMFlags:        vs.GetFlags(),
 	}
 
 	flags := ""

tools/dpvs-agent/pkg/ipc/types/realserver.go

@@ -31,6 +31,20 @@ import (
 	"github.com/dpvs-agent/pkg/ipc/pool"
 )
 
+type SliceRealServerSpec []*RealServerSpec
+
+func (rss SliceRealServerSpec) Len() int {
+	return len(rss)
+}
+
+func (rss SliceRealServerSpec) Swap(i, j int) {
+	rss[i], rss[j] = rss[j], rss[i]
+}
+
+func (rss SliceRealServerSpec) Less(i, j int) bool {
+	return rss[i].ID() < rss[j].ID()
+}
+
 type RealServerSpec struct {
 	af           uint32
 	port         uint16

tools/dpvs-agent/pkg/ipc/types/snapshot.go

@@ -207,6 +207,22 @@ func (spec *VirtualServerSpecExpandModel) ID() string {
 	return fmt.Sprintf("%s-%d-%s", net.ParseIP(spec.Addr).String(), spec.Port, proto)
 }
 
+type SliceRealServerSpecExpandModel []*models.RealServerSpecExpand
+
+func (rss SliceRealServerSpecExpandModel) Len() int {
+	return len(rss)
+}
+
+func (rss SliceRealServerSpecExpandModel) Swap(i, j int) {
+	rss[i], rss[j] = rss[j], rss[i]
+}
+
+func (rss SliceRealServerSpecExpandModel) Less(i, j int) bool {
+	rs1 := (*RealServerSpecExpandModel)(rss[i])
+	rs2 := (*RealServerSpecExpandModel)(rss[j])
+	return rs1.ID() < rs2.ID()
+}
+
 func (node *NodeSnapshot) LoadFrom(cacheFile string, logger hclog.Logger) error {
 	content, err := os.ReadFile(cacheFile)
 	if err != nil {