X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fe2_term_init_notification_handler.go;h=4aa403957cd5b7cdcba75e377947aa3e6114d93d;hb=refs%2Fchanges%2F07%2F4007%2F1;hp=0059b2a94248e059db710c123176c9f069afa170;hpb=011bb9161ca8e7ad0d0cf282b818672a88a5dfbf;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/handlers/rmrmsghandlers/e2_term_init_notification_handler.go b/E2Manager/handlers/rmrmsghandlers/e2_term_init_notification_handler.go index 0059b2a..4aa4039 100644 --- a/E2Manager/handlers/rmrmsghandlers/e2_term_init_notification_handler.go +++ b/E2Manager/handlers/rmrmsghandlers/e2_term_init_notification_handler.go @@ -62,7 +62,7 @@ func (h E2TermInitNotificationHandler) Handle(request *models.NotificationReques return } - h.logger.Infof("#E2TermInitNotificationHandler.Handle - E2T address: %s - handling E2_TERM_INIT", e2tAddress) + h.logger.Infof("#E2TermInitNotificationHandler.Handle - E2T payload: %s - handling E2_TERM_INIT", unmarshalledPayload) e2tInstance, err := h.e2tInstancesManager.GetE2TInstance(e2tAddress) @@ -74,7 +74,7 @@ func (h E2TermInitNotificationHandler) Handle(request *models.NotificationReques return } - h.HandleNewE2TInstance(e2tAddress) + h.HandleNewE2TInstance(e2tAddress, unmarshalledPayload.PodName) return } @@ -105,7 +105,7 @@ func (h E2TermInitNotificationHandler) HandleExistingE2TInstance(e2tInstance *en } } -func (h E2TermInitNotificationHandler) HandleNewE2TInstance(e2tAddress string) { +func (h E2TermInitNotificationHandler) HandleNewE2TInstance(e2tAddress string, podName string) { err := h.routingManagerClient.AddE2TInstance(e2tAddress) @@ -114,5 +114,5 @@ func (h E2TermInitNotificationHandler) HandleNewE2TInstance(e2tAddress string) { return } - _ = h.e2tInstancesManager.AddE2TInstance(e2tAddress) + _ = h.e2tInstancesManager.AddE2TInstance(e2tAddress, podName) } \ No newline at end of file