X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fran_lost_connection_handler.go;h=6c3569f185299d4470ae9b143fef9152668ace66;hb=refs%2Fchanges%2F06%2F2106%2F1;hp=e6ba81e713d3c23cb98949a5e9a231954c41097d;hpb=ffd085dd7f0654b84b163a7bfedd3fa89e7b8a71;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/handlers/rmrmsghandlers/ran_lost_connection_handler.go b/E2Manager/handlers/rmrmsghandlers/ran_lost_connection_handler.go index e6ba81e..6c3569f 100644 --- a/E2Manager/handlers/rmrmsghandlers/ran_lost_connection_handler.go +++ b/E2Manager/handlers/rmrmsghandlers/ran_lost_connection_handler.go @@ -13,7 +13,10 @@ // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. // See the License for the specific language governing permissions and // limitations under the License. -// + +// This source code is part of the near-RT RIC (RAN Intelligent Controller) +// platform project (RICP). + package rmrmsghandlers @@ -25,18 +28,20 @@ import ( type RanLostConnectionHandler struct { ranReconnectionManager managers.IRanReconnectionManager + logger *logger.Logger } -func NewRanLostConnectionHandler(ranReconnectionManager managers.IRanReconnectionManager) RanLostConnectionHandler { +func NewRanLostConnectionHandler(logger *logger.Logger, ranReconnectionManager managers.IRanReconnectionManager) RanLostConnectionHandler { return RanLostConnectionHandler{ + logger: logger, ranReconnectionManager: ranReconnectionManager, } } -func (handler RanLostConnectionHandler) Handle(logger *logger.Logger, request *models.NotificationRequest, messageChannel chan<- *models.NotificationResponse) { +func (h RanLostConnectionHandler) Handle(request *models.NotificationRequest) { ranName := request.RanName - logger.Warnf("#RanLostConnectionHandler.Handle - RAN name: %s - Received lost connection notification", ranName) + h.logger.Warnf("#RanLostConnectionHandler.Handle - RAN name: %s - Received lost connection notification", ranName) - _ = handler.ranReconnectionManager.ReconnectRan(ranName) + _ = h.ranReconnectionManager.ReconnectRan(ranName) }