- err = w.rnibWriter.UpdateNodebInfoOnConnectionStatusInversion(nodebInfo, w.rnibWriterConfig.StateChangeMessageChannel, event)
+ err = w.rnibWriter.UpdateNodebInfoOnConnectionStatusInversion(nodebInfo, event)
+ return
+ })
+
+ return err
+}
+
+func (w *rNibDataService) AddEnb(nodebInfo *entities.NodebInfo) error {
+ w.logger.Infof("#RnibDataService.AddEnb - nodebInfo: %s", nodebInfo)
+
+ err := w.retry("AddEnb", func() (err error) {
+ err = w.rnibWriter.AddEnb(nodebInfo)
+ return
+ })
+
+ return err
+}
+
+func (w *rNibDataService) UpdateNbIdentity(nodeType entities.Node_Type, oldNbIdentity *entities.NbIdentity, newNbIdentity *entities.NbIdentity) error {
+ err := w.retry("UpdateNbIdentities", func() (err error) {
+ err = w.rnibWriter.UpdateNbIdentities(nodeType, []*entities.NbIdentity{oldNbIdentity}, []*entities.NbIdentity{newNbIdentity})
+ return
+ })
+
+ return err
+}
+
+func (w *rNibDataService) UpdateNbIdentities(nodeType entities.Node_Type, oldNbIdentities []*entities.NbIdentity, newNbIdentities []*entities.NbIdentity) error {
+ err := w.retry("UpdateNbIdentities", func() (err error) {
+ err = w.rnibWriter.UpdateNbIdentities(nodeType, oldNbIdentities, newNbIdentities)