X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=E2Manager%2Fservices%2Frnib_data_service.go;h=c1bf97b7d8463efad8bd6724956ec305130d525a;hb=c7018fe32516829bc267efcc5a20818355768762;hp=2ab34d2f1b17add8987dff40f1368346825a256a;hpb=7e2e493acba882641329f867cccb73b3d2a2d2d8;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/services/rnib_data_service.go b/E2Manager/services/rnib_data_service.go index 2ab34d2..c1bf97b 100644 --- a/E2Manager/services/rnib_data_service.go +++ b/E2Manager/services/rnib_data_service.go @@ -53,6 +53,8 @@ type RNibDataService interface { UpdateNodebInfoOnConnectionStatusInversion(nodebInfo *entities.NodebInfo, event string) error SaveGeneralConfiguration(config *entities.GeneralConfiguration) error RemoveEnb(nodebInfo *entities.NodebInfo) error + RemoveServedCells(inventoryName string, servedCells []*entities.ServedCellInfo) error + UpdateEnb(nodebInfo *entities.NodebInfo, servedCells []*entities.ServedCellInfo) error } type rNibDataService struct { @@ -83,6 +85,8 @@ func (w *rNibDataService) RemoveServedNrCells(inventoryName string, servedNrCell } func (w *rNibDataService) RemoveEnb(nodebInfo *entities.NodebInfo) error { + w.logger.Infof("#RnibDataService.RemoveEnb - nodebInfo: %s", nodebInfo) + err := w.retry("RemoveEnb", func() (err error) { err = w.rnibWriter.RemoveEnb(nodebInfo) return @@ -302,6 +306,24 @@ func (w *rNibDataService) SaveGeneralConfiguration(config *entities.GeneralConfi return err } +func (w *rNibDataService) RemoveServedCells(inventoryName string, servedCells []*entities.ServedCellInfo) error { + err := w.retry("RemoveServedCells", func() (err error) { + err = w.rnibWriter.RemoveServedCells(inventoryName, servedCells) + return + }) + + return err +} + +func (w *rNibDataService) UpdateEnb(nodebInfo *entities.NodebInfo, servedCells []*entities.ServedCellInfo) error { + err := w.retry("UpdateEnb", func() (err error) { + err = w.rnibWriter.UpdateEnb(nodebInfo, servedCells) + return + }) + + return err +} + func (w *rNibDataService) PingRnib() bool { err := w.retry("GetListNodebIds", func() (err error) { _, err = w.rnibReader.GetListNodebIds()