2 ==================================================================================
3 Copyright (c) 2019 AT&T Intellectual Property.
4 Copyright (c) 2019 Nokia
6 Licensed under the Apache License, Version 2.0 (the "License");
7 you may not use this file except in compliance with the License.
8 You may obtain a copy of the License at
10 http://www.apache.org/licenses/LICENSE-2.0
12 Unless required by applicable law or agreed to in writing, software
13 distributed under the License is distributed on an "AS IS" BASIS,
14 WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 See the License for the specific language governing permissions and
16 limitations under the License.
19 This source code is part of the near-RT RIC (RAN Intelligent Controller)
20 platform project (RICP).
22 ==================================================================================
26 Abstract: RMR Route Policy implementation
27 Produces RMR (RIC Management Routing) formatted route messages
34 "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
35 "routing-manager/pkg/models"
36 "routing-manager/pkg/rtmgr"
49 func NewRmrPush() *RmrPush {
50 instance := new(RmrPush)
55 Produces the raw route message consumable by RMR
57 func (r *Rmr) generateRMRPolicies(eps rtmgr.Endpoints, rcs *rtmgr.RicComponents, key string) *[]string {
58 rawrt := []string{key + "newrt|start\n"}
59 rt := r.generateRouteTable(eps)
60 for _, rte := range *rt {
61 rawrte := key + "mse|" + rte.MessageType
62 for _, tx := range rte.TxList {
63 rawrte += "," + tx.Ip + ":" + strconv.Itoa(int(tx.Port))
65 rawrte += "|" + strconv.Itoa(int(rte.SubID)) + "|"
67 for _, rxg := range rte.RxGroups {
69 for _, rx := range rxg {
71 member += rx.Ip + ":" + strconv.Itoa(int(rx.Port))
73 member += "," + rx.Ip + ":" + strconv.Itoa(int(rx.Port))
83 if rte.RouteType == "%meid" {
84 rawrte += "%" + "meid"
89 rawrt = append(rawrt, rawrte+"\n")
91 for _, val := range rtmgr.DynamicRouteList {
92 rawrt = append(rawrt, val)
95 rawrt = append(rawrt, key+"newrt|end\n")
98 rawrt = append(rawrt, key+"meid_map|start\n")
99 keys := make(map[string]RouteIndex)
100 for _, value := range rcs.MeidMap {
101 if _, v := keys[key+value+"\n"]; !v {
102 rawrt = append(rawrt, key+value+"\n")
103 appendedindex := uint16(len(rawrt) - 1)
104 keys[key+value+"\n"] = RouteIndex{true, appendedindex}
107 if strings.Contains(value, "mme_ar") {
108 tmpstr := strings.Split(value, "|")
110 //MEID entry for mme_ar must always contain 3 strings speartred by | i.e "mme_ar|<string1>|<string2>"
111 MEID := strings.TrimSuffix(tmpstr[2], "\n")
113 mapindex := "mme_del|" + MEID + "\n"
114 i := keys[mapindex].index
115 if keys[mapindex].flag {
116 copy(rawrt[i:], rawrt[i+1:])
117 rawrt[len(rawrt)-1] = ""
118 rawrt = rawrt[:len(rawrt)-1]
119 delete(keys, mapindex)
124 rawrt = append(rawrt, key+"meid_map|end|"+strconv.Itoa(count)+"\n")
126 xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rawrt)
127 xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rcs)
132 Produces the raw route message consumable by RMR
134 func (r *Rmr) generatePartialRMRPolicies(eps rtmgr.Endpoints, xappSubData *models.XappSubscriptionData, key string, updatetype rtmgr.RMRUpdateType) *[]string {
135 rawrt := []string{key + "updatert|start\n"}
136 rt := r.generatePartialRouteTable(eps, xappSubData, updatetype)
137 for _, rte := range *rt {
138 rawrte := key + "mse|" + rte.MessageType
139 for _, tx := range rte.TxList {
140 rawrte += "," + tx.Ip + ":" + strconv.Itoa(int(tx.Port))
142 rawrte += "|" + strconv.Itoa(int(rte.SubID)) + "|"
144 for _, rxg := range rte.RxGroups {
146 for _, rx := range rxg {
148 member += rx.Ip + ":" + strconv.Itoa(int(rx.Port))
150 member += "," + rx.Ip + ":" + strconv.Itoa(int(rx.Port))
156 group += ";" + member
160 if rte.RouteType == "%meid" {
161 rawrte += "%" + "meid"
166 rawrt = append(rawrt, rawrte+"\n")
169 rawrt = append(rawrt, key+"updatert|end\n")
172 xapp.Logger.Debug("rmr.GeneratePolicies returns: %v", rawrt)
175 func (r *RmrPush) GeneratePolicies(eps rtmgr.Endpoints, rcs *rtmgr.RicComponents) *[]string {
176 xapp.Logger.Debug("Invoked rmr.GeneratePolicies, args: %v: ", eps)
177 return r.generateRMRPolicies(eps, rcs, "")
180 func (r *RmrPush) GenerateRouteTable(eps rtmgr.Endpoints) *rtmgr.RouteTable {
181 return r.generateRouteTable(eps)
184 func (r *RmrPush) GeneratePartialPolicies(eps rtmgr.Endpoints, xappSubData *models.XappSubscriptionData, updatetype rtmgr.RMRUpdateType) *[]string {
185 xapp.Logger.Debug("Invoked rmr.GeneratePartialPolicies, args: %v: ", eps)
186 return r.generatePartialRMRPolicies(eps, xappSubData, "", updatetype)