X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Frpe%2Frmr.go;h=544769362658fe34deea99a5f8d0bed95a8e2f58;hb=50ed7b7f9fe26b923f99a96d37ccfa8c19f181e9;hp=c1f126c6d2225b1fa156bcaf37943b2391311bf2;hpb=1433f4d8e1022cdc6ffd505a9b18130c66f1101d;p=ric-plt%2Frtmgr.git diff --git a/pkg/rpe/rmr.go b/pkg/rpe/rmr.go index c1f126c..5447693 100644 --- a/pkg/rpe/rmr.go +++ b/pkg/rpe/rmr.go @@ -79,10 +79,11 @@ func (r *Rmr) generateRMRPolicies(eps rtmgr.Endpoints, rcs *rtmgr.RicComponents, group += ";" + member } } - rawrte += group if rte.RouteType == "%meid" { - rawrte += group + rte.RouteType + rawrte += "%" + "meid" + } else { + rawrte += group } rawrt = append(rawrt, rawrte+"\n") @@ -112,14 +113,16 @@ func (r *Rmr) generateRMRPolicies(eps rtmgr.Endpoints, rcs *rtmgr.RicComponents, mapindex := "mme_del|" + MEID + "\n" i := keys[mapindex].index if keys[mapindex].flag { - copy(rawrt[i:], rawrt[i+1:]) - rawrt[len(rawrt)-1] = "" - rawrt = rawrt[:len(rawrt)-1] + //copy(rawrt[i:], rawrt[i+1:]) + //rawrt[len(rawrt)-1] = "" + //rawrt = rawrt[:len(rawrt)-1] + rawrt[i] = "" delete(keys, mapindex) count-- } } } + rawrt = removeEmptyStrings(rawrt) rawrt = append(rawrt, key+"meid_map|end|"+strconv.Itoa(count)+"\n") xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rawrt) @@ -155,10 +158,11 @@ func (r *Rmr) generatePartialRMRPolicies(eps rtmgr.Endpoints, xappSubData *model group += ";" + member } } - rawrte += group if rte.RouteType == "%meid" { - rawrte += group + rte.RouteType + rawrte += "%" + "meid" + } else { + rawrte += group } rawrt = append(rawrt, rawrte+"\n") @@ -180,6 +184,16 @@ func (r *RmrPush) GenerateRouteTable(eps rtmgr.Endpoints) *rtmgr.RouteTable { } func (r *RmrPush) GeneratePartialPolicies(eps rtmgr.Endpoints, xappSubData *models.XappSubscriptionData, updatetype rtmgr.RMRUpdateType) *[]string { - xapp.Logger.Debug("Invoked rmr.GeneratePartialRMR, args: %v: ", eps) + xapp.Logger.Debug("Invoked rmr.GeneratePartialPolicies, args: %v: ", eps) return r.generatePartialRMRPolicies(eps, xappSubData, "", updatetype) } + +func removeEmptyStrings(s []string) []string { + var r []string + for _, str := range s { + if str != "" { + r = append(r, str) + } + } + return r +}