X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fric_service_update_handler.go;fp=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fric_service_update_handler.go;h=fda411f7325bcf455e5cbef5fbb4f60db098521e;hb=d5fcd9aeaadd7fcfaa7f6cff7bc8b8d10e9e4b81;hp=b8d1c063ae15366f64c2620740c2a1210a0fa01a;hpb=2f26f3da6b2a1cb20024ff191f88baedf63db0d4;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go b/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go index b8d1c06..fda411f 100644 --- a/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go +++ b/E2Manager/handlers/rmrmsghandlers/ric_service_update_handler.go @@ -51,19 +51,19 @@ type functionDetails struct { } type RicServiceUpdateHandler struct { - logger *logger.Logger - rmrSender *rmrsender.RmrSender - rNibDataService services.RNibDataService - ranListManager managers.RanListManager + logger *logger.Logger + rmrSender *rmrsender.RmrSender + rNibDataService services.RNibDataService + ranListManager managers.RanListManager RicServiceUpdateManager managers.IRicServiceUpdateManager } -func NewRicServiceUpdateHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, rNibDataService services.RNibDataService, ranListManager managers.RanListManager,RicServiceUpdateManager managers.IRicServiceUpdateManager) *RicServiceUpdateHandler { +func NewRicServiceUpdateHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, rNibDataService services.RNibDataService, ranListManager managers.RanListManager, RicServiceUpdateManager managers.IRicServiceUpdateManager) *RicServiceUpdateHandler { return &RicServiceUpdateHandler{ - logger: logger, - rmrSender: rmrSender, - rNibDataService: rNibDataService, - ranListManager: ranListManager, + logger: logger, + rmrSender: rmrSender, + rNibDataService: rNibDataService, + ranListManager: ranListManager, RicServiceUpdateManager: RicServiceUpdateManager, } } @@ -92,6 +92,11 @@ func (h *RicServiceUpdateHandler) Handle(request *models.NotificationRequest) { h.RicServiceUpdateManager.StoreExistingRanFunctions(ranName) h.logger.Infof("#RicServiceUpdate.Handle - Getting the ranFunctions before we do the RIC ServiceUpdate handling") + if len(ricServiceUpdate.E2APPDU.InitiatingMessage.Value.RICServiceUpdate.ProtocolIEs.RICServiceUpdateIEs) == 0 { + h.logger.Errorf("#RicServiceUpdateHandler.Handle - RAN name: %s - RICServiceUpdateIEs empty", ranName) + return + } + ackFunctionIds := h.updateFunctions(ricServiceUpdate.E2APPDU.InitiatingMessage.Value.RICServiceUpdate.ProtocolIEs.RICServiceUpdateIEs, nodebInfo) if len(ricServiceUpdate.E2APPDU.InitiatingMessage.Value.RICServiceUpdate.ProtocolIEs.RICServiceUpdateIEs) > 1 { err = h.rNibDataService.UpdateNodebInfoAndPublish(nodebInfo)