X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fran_lost_connection_handler.go;h=12d4df1b5a17690eacbe926a54c1806e2cd2206f;hb=011bb9161ca8e7ad0d0cf282b818672a88a5dfbf;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..12d4df1 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 @@ -24,19 +27,21 @@ import ( ) type RanLostConnectionHandler struct { - ranReconnectionManager managers.IRanReconnectionManager + ranDisconnectionManager managers.IRanDisconnectionManager + logger *logger.Logger } -func NewRanLostConnectionHandler(ranReconnectionManager managers.IRanReconnectionManager) RanLostConnectionHandler { +func NewRanLostConnectionHandler(logger *logger.Logger, ranDisconnectionManager managers.IRanDisconnectionManager) RanLostConnectionHandler { return RanLostConnectionHandler{ - ranReconnectionManager: ranReconnectionManager, + logger: logger, + ranDisconnectionManager: ranDisconnectionManager, } } -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.ranDisconnectionManager.DisconnectRan(ranName) }