import (\r
"e2mgr/configuration"\r
"e2mgr/logger"\r
+ "e2mgr/managers"\r
"e2mgr/models"\r
"e2mgr/rmrCgo"\r
"e2mgr/services"\r
rnibDataService services.RNibDataService\r
config *configuration.Configuration\r
rmrSender *rmrsender.RmrSender\r
+ ranResetManager *managers.RanResetManager\r
}\r
\r
-func NewE2ResetRequestNotificationHandler(logger *logger.Logger, rnibDataService services.RNibDataService, config *configuration.Configuration, rmrSender *rmrsender.RmrSender) *E2ResetRequestNotificationHandler {\r
+func NewE2ResetRequestNotificationHandler(logger *logger.Logger, rnibDataService services.RNibDataService, config *configuration.Configuration, rmrSender *rmrsender.RmrSender, ranResetManager *managers.RanResetManager) *E2ResetRequestNotificationHandler {\r
return &E2ResetRequestNotificationHandler{\r
logger: logger,\r
rnibDataService: rnibDataService,\r
config: config,\r
rmrSender: rmrSender,\r
+ ranResetManager: ranResetManager,\r
}\r
}\r
\r
\r
nodebInfo.ConnectionStatus = entities.ConnectionStatus_UNDER_RESET\r
\r
- err = e.rnibDataService.UpdateNodebInfoAndPublish(nodebInfo)\r
+ ranName := request.RanName\r
+ isResetDone, err := e.ranResetManager.ResetRan(ranName)\r
+ if err != nil {\r
+ e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to update and notify connection status of nodeB entity. RanName: %s. Error: %s", request.RanName, err.Error())\r
+ } else {\r
+ if isResetDone {\r
+ nodebInfoupdated, err1 := e.getNodebInfo(request.RanName)\r
+ if err1 != nil {\r
+ e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to get updated nodeB entity. RanName: %s. Error: %s", request.RanName, err1.Error())\r
+ }\r
+ e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - Reset Done Successfully ran: %s , Connection status updated : %s", ranName, nodebInfoupdated.ConnectionStatus)\r
+ } else {\r
+ e.logger.Debugf("#E2ResetRequestNotificationHandler.Handle - Reset Failed")\r
+ }\r
+ }\r
\r
if err != nil {\r
e.logger.Errorf("#E2ResetRequestNotificationHandler.Handle - failed to update connection status of nodeB entity. RanName: %s. Error: %s", request.RanName, err.Error())\r
\r
e.waitfortimertimeout(request)\r
\r
- ranName := request.RanName\r
resetRequest, err := e.parseE2ResetMessage(request.Payload)\r
if err != nil {\r
e.logger.Errorf(err.Error())\r