X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fx2_reset_request_notification_handler.go;h=622a3387de052e44055a285ae68dcb9802ffb63d;hb=refs%2Fchanges%2F43%2F943%2F1;hp=367b9361c9df838004185f520dcfaa92d0356aec;hpb=1ec13d4076e7c7abefac6176462c1fee31229213;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/handlers/rmrmsghandlers/x2_reset_request_notification_handler.go b/E2Manager/handlers/rmrmsghandlers/x2_reset_request_notification_handler.go index 367b936..622a338 100644 --- a/E2Manager/handlers/rmrmsghandlers/x2_reset_request_notification_handler.go +++ b/E2Manager/handlers/rmrmsghandlers/x2_reset_request_notification_handler.go @@ -27,27 +27,26 @@ import ( "e2mgr/logger" "e2mgr/models" "e2mgr/rmrCgo" - "e2mgr/sessions" + "e2mgr/services" "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities" - "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/reader" "unsafe" ) type X2ResetRequestNotificationHandler struct { - rnibReaderProvider func() reader.RNibReader + rnibDataService services.RNibDataService } -func NewX2ResetRequestNotificationHandler(rnibReaderProvider func() reader.RNibReader) X2ResetRequestNotificationHandler { +func NewX2ResetRequestNotificationHandler(rnibDataService services.RNibDataService) X2ResetRequestNotificationHandler { return X2ResetRequestNotificationHandler{ - rnibReaderProvider: rnibReaderProvider, + rnibDataService: rnibDataService, } } -func (src X2ResetRequestNotificationHandler) Handle(logger *logger.Logger, e2Sessions sessions.E2Sessions, request *models.NotificationRequest, messageChannel chan<- *models.NotificationResponse) { +func (src X2ResetRequestNotificationHandler) Handle(logger *logger.Logger, request *models.NotificationRequest, messageChannel chan<- *models.NotificationResponse) { logger.Debugf("#X2ResetRequestNotificationHandler.Handle - Ran name: %s", request.RanName) - nb, rNibErr := src.rnibReaderProvider().GetNodeb(request.RanName) + nb, rNibErr := src.rnibDataService.GetNodeb(request.RanName) if rNibErr != nil { logger.Errorf("#X2ResetRequestNotificationHandler.Handle - failed to retrieve nodeB entity. RanName: %s. Error: %s", request.RanName, rNibErr.Error()) printHandlingSetupResponseElapsedTimeInMs(logger, "#X2ResetRequestNotificationHandler.Handle - Summary: Elapsed time for receiving and handling reset request message from E2 terminator", request.StartTime)