X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Frpe%2Frpe.go;h=8f86b4d8aa200d9d83b2937b833f9435b1f85c7b;hb=480359e9bfcc16f20d0814fbc02e1b4b177eabcb;hp=d26a704703f1e8a809613cac33be3f41834fb65f;hpb=41e32c6cd23e3ac33e4b004b0fde57e371d02c81;p=ric-plt%2Frtmgr.git

diff --git a/pkg/rpe/rpe.go b/pkg/rpe/rpe.go
index d26a704..8f86b4d 100644
--- a/pkg/rpe/rpe.go
+++ b/pkg/rpe/rpe.go
@@ -182,6 +182,34 @@ func (r *Rpe) generateXappRoutes(xAppEp *rtmgr.Endpoint, subManEp *rtmgr.Endpoin
 
 }
 
+
+func (r *Rpe) generateXappToXappRoutes(RecvxAppEp *rtmgr.Endpoint, endPointList rtmgr.Endpoints, routeTable *rtmgr.RouteTable) {
+	xapp.Logger.Debug("rpe.generateXappToXappRoutes invoked")
+
+	for _, rxmsg := range RecvxAppEp.RxMessages {
+
+		var src_present bool
+		xapp.Logger.Debug("RecvxAppEp.RxMessages Endpoint: %v, xAppType: %v and rxmsg: %v ", RecvxAppEp.Name, RecvxAppEp.XAppType, rxmsg)
+		if (rxmsg != "RIC_SUB_RESP" && rxmsg != "RIC_SUB_FAILURE" && rxmsg != "RIC_SUB_DEL_RESP" && rxmsg != "RIC_SUB_DEL_FAILURE" && rxmsg != "RIC_INDICATION" && rxmsg != "RIC_CONTROL_ACK" && rxmsg != "RIC_CONTROL_FAILURE" && rxmsg != "A1_POLICY_REQ") {
+			for _, SrcxAppEp := range endPointList {
+				if SrcxAppEp.XAppType != sbi.PlatformType && (len(SrcxAppEp.TxMessages) > 0) && SrcxAppEp.Name != RecvxAppEp.Name {
+					for _, txmsg := range SrcxAppEp.TxMessages {
+							if (rxmsg == txmsg) {
+								r.addRoute(rxmsg, SrcxAppEp, RecvxAppEp, routeTable, -1, "")
+								src_present = true
+								break
+							}
+					}
+				}
+			}
+			if src_present == false {
+				r.addRoute(rxmsg, nil, RecvxAppEp, routeTable, -1, "")
+			}
+		}
+
+	}
+}
+
 func (r *Rpe) generateSubscriptionRoutes(selectedxAppEp *rtmgr.Endpoint, subManEp *rtmgr.Endpoint, routeTable *rtmgr.RouteTable) {
 	xapp.Logger.Debug("rpe.addSubscriptionRoutes invoked")
 	subscriptionList := &rtmgr.Subs
@@ -296,6 +324,8 @@ func (r *Rpe) generateRouteTable(endPointList rtmgr.Endpoints) *rtmgr.RouteTable
 		if endPoint.XAppType != sbi.PlatformType && (len(endPoint.TxMessages) > 0 || len(endPoint.RxMessages) > 0) {
 			r.generateXappRoutes(endPoint, subManEp, routeTable)
 			r.generateSubscriptionRoutes(endPoint, subManEp, routeTable)
+			r.generateXappToXappRoutes(endPoint, endPointList, routeTable)
+
 		}
 	}
 	return routeTable