X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fhandlers%2Fhttpmsghandlers%2Fdelete_all_request_handler.go;h=975640a613bc8bb65ed0d8e02ab928b5ad3e10b1;hb=5c9533257e79cc65d506df54105933bf5844e7ab;hp=fc6b3c480df627d110e401865f92e8ffc5f92acf;hpb=de19068aaa1f3d2b415cd960106121ceb167aaa9;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/handlers/httpmsghandlers/delete_all_request_handler.go b/E2Manager/handlers/httpmsghandlers/delete_all_request_handler.go index fc6b3c4..975640a 100644 --- a/E2Manager/handlers/httpmsghandlers/delete_all_request_handler.go +++ b/E2Manager/handlers/httpmsghandlers/delete_all_request_handler.go @@ -13,162 +13,212 @@ // 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 httpmsghandlers import "C" import ( + "e2mgr/clients" "e2mgr/configuration" "e2mgr/e2managererrors" "e2mgr/logger" + "e2mgr/managers" "e2mgr/models" "e2mgr/rmrCgo" "e2mgr/services" "e2mgr/services/rmrsender" - "e2mgr/stateMachine" + "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common" "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities" "time" ) type DeleteAllRequestHandler struct { - rnibDataService services.RNibDataService - rmrSender *rmrsender.RmrSender - config *configuration.Configuration - logger *logger.Logger + rnibDataService services.RNibDataService + rmrSender *rmrsender.RmrSender + config *configuration.Configuration + logger *logger.Logger + e2tInstancesManager managers.IE2TInstancesManager + rmClient clients.IRoutingManagerClient } -func NewDeleteAllRequestHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, config *configuration.Configuration, rnibDataService services.RNibDataService) *DeleteAllRequestHandler { +const PartialSuccessDueToRmErrorMessage = "Operation succeeded except for routing manager outbound call" + +func NewDeleteAllRequestHandler(logger *logger.Logger, rmrSender *rmrsender.RmrSender, config *configuration.Configuration, rnibDataService services.RNibDataService, e2tInstancesManager managers.IE2TInstancesManager, rmClient clients.IRoutingManagerClient) *DeleteAllRequestHandler { return &DeleteAllRequestHandler{ - logger: logger, - rnibDataService: rnibDataService, - rmrSender: rmrSender, - config: config, + logger: logger, + rnibDataService: rnibDataService, + rmrSender: rmrSender, + config: config, + e2tInstancesManager: e2tInstancesManager, + rmClient: rmClient, } } -func (handler *DeleteAllRequestHandler) Handle(request models.Request) (models.IResponse, error) { +func (h *DeleteAllRequestHandler) Handle(request models.Request) (models.IResponse, error) { + h.logger.Infof("#DeleteAllRequestHandler.Handle - handling shutdown request") + + e2tAddresses, err := h.e2tInstancesManager.GetE2TAddresses() - err, continueFlow := handler.updateNodebStates(false) if err != nil { return nil, err } - if continueFlow == false { - return nil, nil + if len(e2tAddresses) == 0 { + err, _ = h.updateNodebs(h.updateNodebInfoForceShutdown) + return nil, err + } + + dissocErr := h.rmClient.DissociateAllRans(e2tAddresses) + + if dissocErr != nil { + h.logger.Warnf("#DeleteAllRequestHandler.Handle - routing manager failure. continue flow.") } - response := models.RmrMessage{MsgType: rmrCgo.RIC_SCTP_CLEAR_ALL} - if err := handler.rmrSender.Send(&response); err != nil { - handler.logger.Errorf("#DeleteAllRequestHandler.Handle - failed to send sctp clear all message to RMR: %s", err) + err, updatedAtLeastOnce := h.updateNodebs(h.updateNodebInfoShuttingDown) + + if err != nil { + return nil, err + } + + err = h.e2tInstancesManager.ClearRansOfAllE2TInstances() + + if err != nil { + return nil, err + } + + rmrMessage := models.RmrMessage{MsgType: rmrCgo.RIC_SCTP_CLEAR_ALL} + + err = h.rmrSender.Send(&rmrMessage) + + if err != nil { + h.logger.Errorf("#DeleteAllRequestHandler.Handle - failed to send sctp clear all message to RMR: %s", err) return nil, e2managererrors.NewRmrError() } - time.Sleep(time.Duration(handler.config.BigRedButtonTimeoutSec) * time.Second) - handler.logger.Infof("#DeleteAllRequestHandler.Handle - timer expired") + if !updatedAtLeastOnce { + h.logger.Infof("#DeleteAllRequestHandler.Handle - DB wasn't updated, not activating timer") + + if dissocErr != nil { + return models.NewRedButtonPartialSuccessResponseModel(PartialSuccessDueToRmErrorMessage), nil + } + + return nil, nil + } + + time.Sleep(time.Duration(h.config.BigRedButtonTimeoutSec) * time.Second) + h.logger.Infof("#DeleteAllRequestHandler.Handle - timer expired") + + err, _ = h.updateNodebs(h.updateNodebInfoShutDown) - err, _ = handler.updateNodebStates(true) if err != nil { return nil, err } + if dissocErr != nil { + return models.NewRedButtonPartialSuccessResponseModel(PartialSuccessDueToRmErrorMessage), nil + } + return nil, nil } -func (handler *DeleteAllRequestHandler) updateNodebStates(timeoutExpired bool) (error, bool) { - nbIdentityList, err := handler.rnibDataService.GetListNodebIds() +func (h *DeleteAllRequestHandler) updateNodebs(updateCb func(node *entities.NodebInfo) (error, bool)) (error, bool) { + nbIdentityList, err := h.rnibDataService.GetListNodebIds() if err != nil { - handler.logger.Errorf("#DeleteAllRequestHandler.updateNodebStates - failed to get nodes list from RNIB. Error: %s", err.Error()) + h.logger.Errorf("#DeleteAllRequestHandler.updateNodebs - failed to get nodes list from rNib. Error: %s", err) return e2managererrors.NewRnibDbError(), false } - if len(nbIdentityList) == 0 { - return nil, false - } + updatedAtLeastOnce := false - numOfRanToShutDown := 0 for _, nbIdentity := range nbIdentityList { - - node, err := handler.rnibDataService.GetNodeb((*nbIdentity).GetInventoryName()) + node, err := h.rnibDataService.GetNodeb(nbIdentity.InventoryName) if err != nil { - handler.logger.Errorf("#DeleteAllRequestHandler.updateNodebStates - failed to get nodeB entity for ran name: %v from RNIB. Error: %s", - (*nbIdentity).GetInventoryName(), err.Error()) - continue - } + _, ok := err.(*common.ResourceNotFoundError) - if timeoutExpired { - - if handler.saveNodebShutDownState(nbIdentity, node) { - numOfRanToShutDown++ + if !ok { + h.logger.Errorf("#DeleteAllRequestHandler.updateNodebs - failed to get nodeB entity for ran name: %s from rNib. error: %s", nbIdentity.InventoryName, err) + return e2managererrors.NewRnibDbError(), false } continue } - if handler.saveNodebNextState(nbIdentity, node) { - numOfRanToShutDown++ + + err, updated := updateCb(node) + + if err != nil { + return err, false } - } - if numOfRanToShutDown > 0 { - handler.logger.Infof("#DeleteAllRequestHandler.updateNodebStates - update nodebs states in RNIB completed") - } else { - handler.logger.Infof("#DeleteAllRequestHandler.updateNodebStates - nodebs states are not updated ") - return nil, false + if updated { + updatedAtLeastOnce = true + } } - return nil, true + return nil, updatedAtLeastOnce } -func (handler *DeleteAllRequestHandler) saveNodebNextState(nbIdentity *entities.NbIdentity, node *entities.NodebInfo) bool { +func (h *DeleteAllRequestHandler) updateNodebInfoForceShutdown(node *entities.NodebInfo) (error, bool) { + err := h.updateNodebInfo(node, entities.ConnectionStatus_SHUT_DOWN, true) - if node.ConnectionStatus == entities.ConnectionStatus_SHUTTING_DOWN { - return true + if err != nil { + return err, false } - nextStatus, res := stateMachine.NodeNextStateDeleteAll(node.ConnectionStatus) - if res == false { - return false - } + return nil, true +} - node.ConnectionStatus = nextStatus +func (h *DeleteAllRequestHandler) updateNodebInfoShuttingDown(node *entities.NodebInfo) (error, bool) { + if node.ConnectionStatus == entities.ConnectionStatus_SHUT_DOWN { + return nil, false + } - err := handler.rnibDataService.SaveNodeb(nbIdentity, node) + err := h.updateNodebInfo(node, entities.ConnectionStatus_SHUTTING_DOWN, true) if err != nil { - handler.logger.Errorf("#DeleteAllRequestHandler.saveNodebNextState - failed to save nodeB entity for inventory name: %v to RNIB. Error: %s", - (*nbIdentity).GetInventoryName(), err.Error()) - return false + return err, false } - if handler.logger.DebugEnabled() { - handler.logger.Debugf("#DeleteAllRequestHandler.saveNodebNextState - connection status of inventory name: %v changed to %v", - (*nbIdentity).GetInventoryName(), nextStatus.String()) - } - return true + return nil, true } -func (handler *DeleteAllRequestHandler) saveNodebShutDownState(nbIdentity *entities.NbIdentity, node *entities.NodebInfo) bool { - +func (h *DeleteAllRequestHandler) updateNodebInfoShutDown(node *entities.NodebInfo) (error, bool) { if node.ConnectionStatus == entities.ConnectionStatus_SHUT_DOWN { - return false + return nil, false } if node.ConnectionStatus != entities.ConnectionStatus_SHUTTING_DOWN { - handler.logger.Errorf("#DeleteAllRequestHandler.saveNodebShutDownState - ignore, status is not Shutting Down, inventory name: %v ", (*nbIdentity).GetInventoryName()) - return false + h.logger.Warnf("#DeleteAllRequestHandler.updateNodebInfoShutDown - RAN name: %s - ignore, status is not Shutting Down", node.RanName) + return nil, false + } + + err := h.updateNodebInfo(node, entities.ConnectionStatus_SHUT_DOWN, false) + + if err != nil { + return err, false } - node.ConnectionStatus = entities.ConnectionStatus_SHUT_DOWN + return nil, true +} + +func (h *DeleteAllRequestHandler) updateNodebInfo(node *entities.NodebInfo, connectionStatus entities.ConnectionStatus, resetAssociatedE2TAddress bool) error { + node.ConnectionStatus = connectionStatus + + if resetAssociatedE2TAddress { + node.AssociatedE2TInstanceAddress = "" + } - err := handler.rnibDataService.SaveNodeb(nbIdentity, node) + err := h.rnibDataService.UpdateNodebInfo(node) if err != nil { - handler.logger.Errorf("#DeleteAllRequestHandler.saveNodebShutDownState - failed to save nodeB entity for inventory name: %v to RNIB. Error: %s", - (*nbIdentity).GetInventoryName(), err.Error()) - return false + h.logger.Errorf("#DeleteAllRequestHandler.updateNodebInfo - RAN name: %s - failed updating nodeB entity in rNib. error: %s", node.RanName, err) + return e2managererrors.NewRnibDbError() } - handler.logger.Errorf("#DeleteAllRequestHandler.saveNodebShutDownState - Shut Down , inventory name: %v ", (*nbIdentity).GetInventoryName()) - return true + h.logger.Infof("#DeleteAllRequestHandler.updateNodebInfo - RAN name: %s, connection status: %s", node.RanName, connectionStatus) + return nil + }