2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
4 // Copyright (c) 2020 Samsung Electronics Co., Ltd. All Rights Reserved.
6 // Licensed under the Apache License, Version 2.0 (the "License");
7 // you may not use this file except in compliance with the License.
8 // You may obtain a copy of the License at
10 // http://www.apache.org/licenses/LICENSE-2.0
12 // Unless required by applicable law or agreed to in writing, software
13 // distributed under the License is distributed on an "AS IS" BASIS,
14 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
15 // See the License for the specific language governing permissions and
16 // limitations under the License.
18 // This source code is part of the near-RT RIC (RAN Intelligent Controller)
19 // platform project (RICP).
24 "e2mgr/e2managererrors"
27 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
32 type ranListManagerInstance struct {
34 rnibDataService services.RNibDataService
36 nbIdentityMap map[string]*entities.NbIdentity
39 type RanListManager interface {
40 InitNbIdentityMap() error
41 AddNbIdentity(nodeType entities.Node_Type, nbIdentity *entities.NbIdentity) error
42 UpdateNbIdentityConnectionStatus(nodeType entities.Node_Type, ranName string, connectionStatus entities.ConnectionStatus) error
43 RemoveNbIdentity(nodeType entities.Node_Type, ranName string) error
44 GetNbIdentityList() []*entities.NbIdentity
45 GetNbIdentity(ranName string) (*entities.NbIdentity, error)
46 UpdateHealthcheckTimeStampReceived(oldRRanName string) (*entities.NbIdentity, *entities.NbIdentity)
47 UpdateHealthcheckTimeStampSent(oldRRanName string) (*entities.NbIdentity, *entities.NbIdentity)
48 UpdateNbIdentities(nodeType entities.Node_Type, oldNbIdentities []*entities.NbIdentity, newNbIdentities []*entities.NbIdentity) error
51 func NewRanListManager(logger *logger.Logger, rnibDataService services.RNibDataService) RanListManager {
52 return &ranListManagerInstance{
54 rnibDataService: rnibDataService,
55 nbIdentityMap: make(map[string]*entities.NbIdentity),
59 func (m *ranListManagerInstance) InitNbIdentityMap() error {
60 nbIds, err := m.rnibDataService.GetListNodebIds()
63 m.logger.Errorf("#ranListManagerInstance.InitNbIdentityMap - Failed fetching RAN list from DB. error: %s", err)
67 for _, v := range nbIds {
68 m.nbIdentityMap[v.InventoryName] = v
71 m.logger.Infof("#ranListManagerInstance.InitNbIdentityMap - Successfully initiated nodeb identity map")
72 m.logger.Debugf("#ranListManagerInstance.InitNbIdentityMap - nodeb Identity map: %s", m.nbIdentityMap)
76 func (m *ranListManagerInstance) AddNbIdentity(nodeType entities.Node_Type, nbIdentity *entities.NbIdentity) error {
80 m.nbIdentityMap[nbIdentity.InventoryName] = nbIdentity
82 err := m.rnibDataService.AddNbIdentity(nodeType, nbIdentity)
85 m.logger.Errorf("#ranListManagerInstance.AddNbIdentity - RAN name: %s - Failed adding nodeb identity to DB. error: %s", nbIdentity.InventoryName, err)
89 m.logger.Infof("#ranListManagerInstance.AddNbIdentity - RAN name: %s - Successfully added nodeb identity", nbIdentity.InventoryName)
90 m.logger.Debugf("#ranListManagerInstance.AddNbIdentity - nodeb Identity map: %s", m.nbIdentityMap)
94 func (m *ranListManagerInstance) UpdateNbIdentityConnectionStatus(nodeType entities.Node_Type, ranName string, connectionStatus entities.ConnectionStatus) error {
98 m.logger.Infof("#ranListManagerInstance.UpdateNbIdentityConnectionStatus - RAN name: %s - updating nodeb identity connection status", ranName)
100 oldNbIdentity, ok := m.nbIdentityMap[ranName]
102 m.logger.Errorf("#ranListManagerInstance.UpdateNbIdentityConnectionStatus - RAN name: %s - nodeb identity not found in nbIdentityMap", ranName)
103 return e2managererrors.NewInternalError()
106 newNbIdentity := &entities.NbIdentity{
107 GlobalNbId: oldNbIdentity.GlobalNbId,
108 InventoryName: ranName,
109 ConnectionStatus: connectionStatus,
110 HealthCheckTimestampSent: oldNbIdentity.HealthCheckTimestampSent,
111 HealthCheckTimestampReceived: oldNbIdentity.HealthCheckTimestampReceived,
113 m.nbIdentityMap[ranName] = newNbIdentity
115 err := m.rnibDataService.UpdateNbIdentity(nodeType, oldNbIdentity, newNbIdentity)
117 m.logger.Errorf("#ranListManagerInstance.UpdateNbIdentityConnectionStatus - RAN name: %s - Failed updating nodeb identity in DB. error: %s", ranName, err)
120 m.logger.Infof("#ranListManagerInstance.UpdateNbIdentityConnectionStatus - RAN name: %s - Successfully updated nodeb identity", ranName)
124 func (m *ranListManagerInstance) RemoveNbIdentity(nodeType entities.Node_Type, ranName string) error {
128 m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - deleting nodeb identity from memory and db...", ranName)
130 nbIdentity, ok := m.nbIdentityMap[ranName]
132 m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - nodeb identity not found", ranName)
136 delete(m.nbIdentityMap, ranName)
138 err := m.rnibDataService.RemoveNbIdentity(nodeType, nbIdentity)
140 m.logger.Errorf("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - Failed removing nodeb identity from DB. error: %s", ranName, err)
144 m.logger.Infof("#ranListManagerInstance.RemoveNbIdentity - RAN name: %s - Successfully deleted nodeb identity", ranName)
148 func (m *ranListManagerInstance) GetNbIdentityList() []*entities.NbIdentity {
149 nbIds := make([]*entities.NbIdentity, 0, len(m.nbIdentityMap))
150 for _, v := range m.nbIdentityMap {
151 nbIds = append(nbIds, v)
154 m.logger.Infof("#ranListManagerInstance.GetNbIdentityList - %d identity returned", len(nbIds))
159 func (m *ranListManagerInstance) GetNbIdentity(ranName string) (*entities.NbIdentity, error) {
160 nbIdentity, ok := m.nbIdentityMap[ranName]
162 m.logger.Infof("#ranListManagerInstance.GetNbIdentity - RAN name: %s - nodeb identity not found", ranName)
163 return nil , e2managererrors.NewResourceNotFoundError()
166 m.logger.Infof("#ranListManagerInstance.GetNbIdentity - RAN name: %s - nodeb identity returned", ranName)
168 return nbIdentity, nil
171 func (m *ranListManagerInstance) UpdateHealthcheckTimeStampSent(oldRRanName string) (*entities.NbIdentity, *entities.NbIdentity){
172 currentTimeStamp := time.Now().UnixNano()
173 oldNbIdentity := m.nbIdentityMap[oldRRanName]
175 newNbIdentity := &entities.NbIdentity{
176 GlobalNbId: oldNbIdentity.GlobalNbId,
177 InventoryName: oldNbIdentity.InventoryName,
178 ConnectionStatus: oldNbIdentity.ConnectionStatus,
179 HealthCheckTimestampSent: currentTimeStamp,
180 HealthCheckTimestampReceived: oldNbIdentity.HealthCheckTimestampReceived,
183 m.nbIdentityMap[oldNbIdentity.InventoryName] = newNbIdentity
184 return oldNbIdentity, newNbIdentity
187 func (m *ranListManagerInstance) UpdateHealthcheckTimeStampReceived(oldRRanName string) (*entities.NbIdentity, *entities.NbIdentity){
188 currentTimeStamp := time.Now().UnixNano()
189 oldNbIdentity := m.nbIdentityMap[oldRRanName]
191 newNbIdentity := &entities.NbIdentity{
192 GlobalNbId: oldNbIdentity.GlobalNbId,
193 InventoryName: oldNbIdentity.InventoryName,
194 ConnectionStatus: oldNbIdentity.ConnectionStatus,
195 HealthCheckTimestampSent: oldNbIdentity.HealthCheckTimestampSent,
196 HealthCheckTimestampReceived: currentTimeStamp,
199 m.nbIdentityMap[oldNbIdentity.InventoryName] = newNbIdentity
200 return oldNbIdentity, newNbIdentity
203 func (m *ranListManagerInstance) UpdateNbIdentities(nodeType entities.Node_Type, oldNbIdentities []*entities.NbIdentity, newNbIdentities []*entities.NbIdentity) error {
207 err := m.rnibDataService.UpdateNbIdentities(nodeType, oldNbIdentities, newNbIdentities)
210 m.logger.Errorf("#ranListManagerInstance.UpdateNbIdentities not completed for %d nbIdentities of nodetype - %s", len(newNbIdentities), nodeType.String())
212 m.logger.Infof("#ranListManagerInstance.UpdateNbIdentities completed successfully for %d nbIdentities of nodetype - %s", len(newNbIdentities), nodeType.String())