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

diff --git a/pkg/rpe/rpe.go b/pkg/rpe/rpe.go
index b5c6961..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
@@ -244,6 +272,8 @@ func (r *Rpe) generatePlatformRoutes(e2TermEp []rtmgr.Endpoint, subManEp *rtmgr.
 	if len(e2TermEp) > 0 {
 		r.addRoute_rx_list("RIC_SCTP_CLEAR_ALL", e2ManEp, e2TermEp, routeTable, -1, "")
 		r.addRoute_rx_list("E2_TERM_KEEP_ALIVE_REQ", e2ManEp, e2TermEp, routeTable, -1, "")
+		r.addRoute_rx_list("RIC_E2_SETUP_RESP", e2ManEp, e2TermEp, routeTable, -1, "")
+		r.addRoute_rx_list("RIC_E2_SETUP_FAILURE", e2ManEp, e2TermEp, routeTable, -1, "")
 	}
 }
 
@@ -294,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