X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Frmrmsghandlers%2Fran_lost_connection_handler.go;h=e7d3ce5d51028b8ba8c1d0beac2e651f0b4deadd;hb=0249b5fc410b6c6814906b185dfdf25b27621148;hp=7933963857e80ce8e46a2a2a7fbd199f7dc3fa30;hpb=1ec13d4076e7c7abefac6176462c1fee31229213;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 7933963..e7d3ce5 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 @@ -21,23 +24,24 @@ import ( "e2mgr/logger" "e2mgr/managers" "e2mgr/models" - "e2mgr/sessions" ) type RanLostConnectionHandler struct { - ranReconnectionManager managers.IRanReconnectionManager + ranDisconnectionManager managers.IRanDisconnectionManager + logger *logger.Logger } -func NewRanLostConnectionHandler(ranReconnectionManager managers.IRanReconnectionManager) RanLostConnectionHandler { - return RanLostConnectionHandler{ - ranReconnectionManager: ranReconnectionManager, +func NewRanLostConnectionHandler(logger *logger.Logger, ranDisconnectionManager managers.IRanDisconnectionManager) *RanLostConnectionHandler { + return &RanLostConnectionHandler{ + logger: logger, + ranDisconnectionManager: ranDisconnectionManager, } } -func (handler RanLostConnectionHandler) Handle(logger *logger.Logger, e2Sessions sessions.E2Sessions, 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) }