X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Fnbi%2Fhttprestful.go;h=60d65fbc06ad8e68b4b2e6fc6d24fa56b1817d2d;hb=4101d1060980858538c5600af8d9ad7a258db107;hp=5393dc9fa7702be8f362ea529e4fdc52f12a4f8e;hpb=0770de6e47404e68fc9cbb59263648ac54864aef;p=ric-plt%2Frtmgr.git diff --git a/pkg/nbi/httprestful.go b/pkg/nbi/httprestful.go index 5393dc9..60d65fb 100644 --- a/pkg/nbi/httprestful.go +++ b/pkg/nbi/httprestful.go @@ -146,6 +146,7 @@ func provideXappHandleHandlerImpl(data *models.XappCallbackData) error { m.Unlock() updateEp() return sendRoutesToAll() + //return sendPartialRoutesToAll(nil, rtmgr.XappType) } } @@ -227,7 +228,7 @@ func provideXappSubscriptionHandleImpl(data *models.XappSubscriptionData) error addSubscription(&rtmgr.Subs, data) xapp.Logger.Debug("Endpoints: %v", rtmgr.Eps) updateEp() - return sendRoutesToAll() + return sendPartialRoutesToAll(data, rtmgr.SubsType) } func subscriptionExists(data *models.XappSubscriptionData) bool { @@ -295,6 +296,7 @@ func createNewE2tHandleHandlerImpl(data *models.E2tData) error { err, IsDuplicate := validateE2tData(data) if IsDuplicate == true { updateEp() + //return sendPartialRoutesToAll(nil, rtmgr.E2Type) return sendRoutesToAll() } @@ -309,6 +311,7 @@ func createNewE2tHandleHandlerImpl(data *models.E2tData) error { sdlEngine.WriteNewE2TInstance(xapp.Config.GetString("rtfile"), e2data, meiddata) m.Unlock() updateEp() + //sendPartialRoutesToAll(nil, rtmgr.E2Type) sendRoutesToAll() time.Sleep(10 * time.Second) for ep, value := range rtmgr.RMRConnStatus {