+ return ranStatusChangePublished, nil
+}
+
+func (m *E2TAssociationManager) associateRanAndUpdateNodeb(e2tAddress string, nodebInfo *entities.NodebInfo) (bool, error) {
+
+ rmErr := m.rmClient.AssociateRanToE2TInstance(e2tAddress, nodebInfo.RanName)
+
+ if rmErr != nil {
+ ranStatusChangePublished, _ := m.ranConnectStatusChangeManager.ChangeStatus(nodebInfo, entities.ConnectionStatus_DISCONNECTED)
+ return ranStatusChangePublished, e2managererrors.NewRoutingManagerError()
+ }
+
+ ranStatusChangePublished, rnibErr := m.ranConnectStatusChangeManager.ChangeStatus(nodebInfo, entities.ConnectionStatus_CONNECTED)
+
+ if rnibErr != nil {
+ return ranStatusChangePublished, e2managererrors.NewRnibDbError()
+ }
+
+ nodebInfo.AssociatedE2TInstanceAddress = e2tAddress
+ rnibErr = m.rnibDataService.UpdateNodebInfo(nodebInfo)
+
+ if rnibErr != nil {
+ m.logger.Errorf("#E2TAssociationManager.associateRanAndUpdateNodeb - RAN name: %s - Failed updating nodeb. Error: %s", nodebInfo.RanName, rnibErr)
+ return ranStatusChangePublished, e2managererrors.NewRnibDbError()
+ }
+
+ return ranStatusChangePublished, nil