X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=reader%2FrNibReader.go;fp=reader%2FrNibReader.go;h=49ee38c9aa561ead3f8d4115c9cc30dab4609eb6;hb=e5088a008ff7b9b7bb2a206f1eecf446aac598c1;hp=0509326d67dedd1be39efd847276941c89c9fac1;hpb=0ef0f0f391bd57b6b86c40de9f0819111cd54327;p=ric-plt%2Fnodeb-rnib.git diff --git a/reader/rNibReader.go b/reader/rNibReader.go index 0509326..49ee38c 100644 --- a/reader/rNibReader.go +++ b/reader/rNibReader.go @@ -58,11 +58,6 @@ type RNibReader interface { GetRanLoadInformation(inventoryName string) (*entities.RanLoadInformation, common.IRNibError) } -const( - EnbType = "ENB" - GnbType = "GNB" -) - /* Init initializes the infrastructure required for the RNibReader instance */ @@ -126,17 +121,17 @@ func (w *rNibReaderInstance) GetCellList(inventoryName string) (*entities.Cells, func (w *rNibReaderInstance) GetListGnbIds() (*[]*entities.NbIdentity, common.IRNibError) { defer readerPool.Put(w) - return w.getListNodebIdsByType(GnbType) + return w.getListNodebIdsByType(entities.Node_GNB.String()) } func (w *rNibReaderInstance) GetListEnbIds() (*[]*entities.NbIdentity, common.IRNibError) { defer readerPool.Put(w) - return w.getListNodebIdsByType(EnbType) + return w.getListNodebIdsByType(entities.Node_ENB.String()) } func (w *rNibReaderInstance) GetCountGnbList() (int, common.IRNibError) { defer readerPool.Put(w) - size, err := (*w.sdl).GroupSize(GnbType) + size, err := (*w.sdl).GroupSize(entities.Node_GNB.String()) if err != nil { return 0, common.NewInternalError(err) } @@ -171,15 +166,21 @@ func (w *rNibReaderInstance) GetCellById(cellType entities.Cell_Type, cellId str func (w *rNibReaderInstance) GetListNodebIds()([]*entities.NbIdentity, common.IRNibError){ defer readerPool.Put(w) - dataEnb, err := (*w.sdl).GetMembers(EnbType) + dataEnb, err := (*w.sdl).GetMembers(entities.Node_ENB.String()) + if err != nil{ + return nil, common.NewInternalError(err) + } + dataGnb, err := (*w.sdl).GetMembers(entities.Node_GNB.String()) if err != nil{ return nil, common.NewInternalError(err) } - dataGnb, err := (*w.sdl).GetMembers(GnbType) + dataUnknown, err := (*w.sdl).GetMembers(entities.Node_UNKNOWN.String()) if err != nil{ return nil, common.NewInternalError(err) } - data, rnibErr := unmarshalIdentityList(append(dataEnb, dataGnb...)) + allIds := append(dataEnb, dataGnb...) + allIds = append(allIds, dataUnknown...) + data, rnibErr := unmarshalIdentityList(allIds) return *data, rnibErr } @@ -266,4 +267,4 @@ func unmarshalIdentityList(data []string) (*[]*entities.NbIdentity, common.IRNib func Close() { readerPool.Close() -} +} \ No newline at end of file