X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=E2Manager%2Fmanagers%2Fran_list_manager.go;h=030180f50c80f91cec554ffcd11d68d89ba76ff7;hb=refs%2Fchanges%2F56%2F4456%2F1;hp=d6dbd8e8eb6e3160c14a585a79202b29cfda91fb;hpb=a590417b434ba8e556f1a9b26ff7b6edbb2097ce;p=ric-plt%2Fe2mgr.git diff --git a/E2Manager/managers/ran_list_manager.go b/E2Manager/managers/ran_list_manager.go old mode 100644 new mode 100755 index d6dbd8e..030180f --- a/E2Manager/managers/ran_list_manager.go +++ b/E2Manager/managers/ran_list_manager.go @@ -97,7 +97,26 @@ func (m *ranListManagerInstance) UpdateNbIdentityConnectionStatus(nodeType entit } func (m *ranListManagerInstance) RemoveNbIdentity(nodeType entities.Node_Type, ranName string) error { - //TODO: implement + m.mux.Lock() + defer m.mux.Unlock() + + m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - deleting nodeb identity from memory and db...", ranName) + + nbIdentity, ok := m.nbIdentityMap[ranName] + if !ok { + m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - nodeb identity not found", ranName) + return nil + } + + delete(m.nbIdentityMap, ranName) + + err := m.rnibDataService.RemoveNbIdentity(nodeType, nbIdentity) + if err != nil { + m.logger.Errorf("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - Failed removing nodeb identity from DB. error: %s", ranName, err) + return err + } + + m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - Successfully deleted nodeb identity", ranName) return nil } @@ -107,5 +126,7 @@ func (m *ranListManagerInstance) GetNbIdentityList() []*entities.NbIdentity { nbIds = append(nbIds, v) } + m.logger.Infof("#ranListManagerInstance.GetNbIdentityList - %d identity returned", len(nbIds)) + return nbIds }