2 // Copyright 2019 AT&T Intellectual Property
3 // Copyright 2019 Nokia
5 // Licensed under the Apache License, Version 2.0 (the "License");
6 // you may not use this file except in compliance with the License.
7 // You may obtain a copy of the License at
9 // http://www.apache.org/licenses/LICENSE-2.0
11 // Unless required by applicable law or agreed to in writing, software
12 // distributed under the License is distributed on an "AS IS" BASIS,
13 // WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
14 // See the License for the specific language governing permissions and
15 // limitations under the License.
21 "e2mgr/e2managererrors"
24 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/common"
25 "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
31 type E2TInstancesManager struct {
32 rnibDataService services.RNibDataService
37 type IE2TInstancesManager interface {
38 GetE2TInstance(e2tAddress string) (*entities.E2TInstance, error)
39 GetE2TInstances() ([]*entities.E2TInstance, error)
40 GetE2TInstancesNoLogs() ([]*entities.E2TInstance, error)
41 AddE2TInstance(e2tAddress string) error
42 RemoveE2TInstance(e2tInstance *entities.E2TInstance) error
43 SelectE2TInstance() (string, error)
44 AssociateRan(ranName string, e2tAddress string) error
45 DissociateRan(ranName string, e2tAddress string) error
46 ActivateE2TInstance(e2tInstance *entities.E2TInstance) error
47 ResetKeepAliveTimestamp(e2tAddress string) error
50 func NewE2TInstancesManager(rnibDataService services.RNibDataService, logger *logger.Logger) *E2TInstancesManager {
51 return &E2TInstancesManager{
52 rnibDataService: rnibDataService,
57 func (m *E2TInstancesManager) GetE2TInstance(e2tAddress string) (*entities.E2TInstance, error) {
58 e2tInstance, err := m.rnibDataService.GetE2TInstance(e2tAddress)
62 _, ok := err.(*common.ResourceNotFoundError)
65 m.logger.Errorf("#E2TInstancesManager.GetE2TInstance - E2T Instance address: %s - Failed retrieving E2TInstance. error: %s", e2tAddress, err)
67 m.logger.Infof("#E2TInstancesManager.GetE2TInstance - E2T Instance address: %s not found on DB", e2tAddress)
71 return e2tInstance, err
74 func (m *E2TInstancesManager) GetE2TInstancesNoLogs() ([]*entities.E2TInstance, error) {
75 e2tAddresses, err := m.rnibDataService.GetE2TAddressesNoLogs()
78 _, ok := err.(*common.ResourceNotFoundError)
81 m.logger.Errorf("#E2TInstancesManager.GetE2TInstancesNoLogs - Failed retrieving E2T addresses. error: %s", err)
82 return nil, e2managererrors.NewRnibDbError()
85 return []*entities.E2TInstance{}, nil
88 if len(e2tAddresses) == 0 {
89 return []*entities.E2TInstance{}, nil
92 e2tInstances, err := m.rnibDataService.GetE2TInstancesNoLogs(e2tAddresses)
95 _, ok := err.(*common.ResourceNotFoundError)
98 m.logger.Errorf("#E2TInstancesManager.GetE2TInstancesNoLogs - Failed retrieving E2T instances list. error: %s", err)
100 return e2tInstances, err
103 return e2tInstances, nil
106 func (m *E2TInstancesManager) GetE2TInstances() ([]*entities.E2TInstance, error) {
107 e2tAddresses, err := m.rnibDataService.GetE2TAddresses()
111 _, ok := err.(*common.ResourceNotFoundError)
114 m.logger.Errorf("#E2TInstancesManager.GetE2TInstances - Failed retrieving E2T addresses. error: %s", err)
115 return nil, e2managererrors.NewRnibDbError()
118 m.logger.Infof("#E2TInstancesManager.GetE2TInstances - Empty E2T addresses list")
119 return []*entities.E2TInstance{}, nil
122 if len(e2tAddresses) == 0 {
123 m.logger.Infof("#E2TInstancesManager.GetE2TInstances - Empty E2T addresses list")
124 return []*entities.E2TInstance{}, nil
127 e2tInstances, err := m.rnibDataService.GetE2TInstances(e2tAddresses)
130 m.logger.Errorf("#E2TInstancesManager.GetE2TInstances - Failed retrieving E2T instances list. error: %s", err)
131 return e2tInstances, e2managererrors.NewRnibDbError()
134 if len(e2tInstances) == 0 {
135 m.logger.Warnf("#E2TInstancesManager.GetE2TInstances - Empty E2T instances list")
136 return e2tInstances, nil
139 return e2tInstances, nil
142 func (m *E2TInstancesManager) ResetKeepAliveTimestampsForAllE2TInstances() {
144 e2tInstances, err := m.GetE2TInstances()
147 m.logger.Errorf("E2TInstancesManager.ResetKeepAliveTimestampForAllE2TInstances - Couldn't reset timestamps due to a DB error")
151 if len(e2tInstances) == 0 {
152 m.logger.Infof("E2TInstancesManager.ResetKeepAliveTimestampForAllE2TInstances - No instances, ignoring reset")
156 for _, v := range e2tInstances {
158 if v.State != entities.Active {
162 v.KeepAliveTimestamp = time.Now().UnixNano()
164 err := m.rnibDataService.SaveE2TInstance(v)
167 m.logger.Errorf("E2TInstancesManager.ResetKeepAliveTimestampForAllE2TInstances - E2T address: %s - failed resetting e2t instance keep alive timestamp. error: %s", v.Address, err)
171 m.logger.Infof("E2TInstancesManager.ResetKeepAliveTimestampForAllE2TInstances - Done with reset")
174 func findActiveE2TInstanceWithMinimumAssociatedRans(e2tInstances []*entities.E2TInstance) *entities.E2TInstance {
175 var minInstance *entities.E2TInstance
176 minAssociatedRanCount := math.MaxInt32
178 for _, v := range e2tInstances {
179 if v.State == entities.Active && len(v.AssociatedRanList) < minAssociatedRanCount {
180 minAssociatedRanCount = len(v.AssociatedRanList)
188 func (m *E2TInstancesManager) AddE2TInstance(e2tAddress string) error {
193 e2tInstance := entities.NewE2TInstance(e2tAddress)
194 err := m.rnibDataService.SaveE2TInstance(e2tInstance)
197 m.logger.Errorf("#E2TInstancesManager.AddE2TInstance - E2T Instance address: %s - Failed saving E2T instance. error: %s", e2tInstance.Address, err)
201 e2tAddresses, err := m.rnibDataService.GetE2TAddresses()
205 _, ok := err.(*common.ResourceNotFoundError)
208 m.logger.Errorf("#E2TInstancesManager.AddE2TInstance - E2T Instance address: %s - Failed retrieving E2T addresses list. error: %s", e2tInstance.Address, err)
213 e2tAddresses = append(e2tAddresses, e2tInstance.Address)
215 err = m.rnibDataService.SaveE2TAddresses(e2tAddresses)
218 m.logger.Errorf("#E2TInstancesManager.AddE2TInstance - E2T Instance address: %s - Failed saving E2T addresses list. error: %s", e2tInstance.Address, err)
222 m.logger.Infof("#E2TInstancesManager.AddE2TInstance - E2T Instance address: %s - successfully added E2T instance", e2tInstance.Address)
226 func (m *E2TInstancesManager) DissociateRan(ranName string, e2tAddress string) error {
231 e2tInstance, err := m.rnibDataService.GetE2TInstance(e2tAddress)
234 m.logger.Errorf("#E2TInstancesManager.DissociateRan - E2T Instance address: %s - Failed retrieving E2TInstance. error: %s", e2tAddress, err)
238 i := 0 // output index
239 for _, v := range e2tInstance.AssociatedRanList {
241 // copy and increment index
242 e2tInstance.AssociatedRanList[i] = v
247 e2tInstance.AssociatedRanList = e2tInstance.AssociatedRanList[:i]
249 err = m.rnibDataService.SaveE2TInstance(e2tInstance)
252 m.logger.Errorf("#E2TInstancesManager.DissociateRan - E2T Instance address: %s - Failed saving E2TInstance. error: %s", e2tAddress, err)
256 m.logger.Infof("#E2TInstancesManager.DissociateRan - successfully dissociated RAN %s from E2T %s", ranName, e2tInstance.Address)
260 func (m *E2TInstancesManager) RemoveE2TInstance(e2tInstance *entities.E2TInstance) error {
263 func (m *E2TInstancesManager) SelectE2TInstance() (string, error) {
265 e2tInstances, err := m.GetE2TInstances()
271 if len(e2tInstances) == 0 {
272 m.logger.Errorf("#E2TInstancesManager.SelectE2TInstance - No E2T instance found")
273 return "", e2managererrors.NewE2TInstanceAbsenceError()
276 min := findActiveE2TInstanceWithMinimumAssociatedRans(e2tInstances)
279 m.logger.Errorf("#E2TInstancesManager.SelectE2TInstance - No active E2T instance found")
280 return "", e2managererrors.NewE2TInstanceAbsenceError()
283 m.logger.Infof("#E2TInstancesManager.SelectE2TInstance - successfully selected E2T instance. address: %s", min.Address)
284 return min.Address, nil
287 func (m *E2TInstancesManager) AssociateRan(ranName string, e2tAddress string) error {
292 e2tInstance, err := m.rnibDataService.GetE2TInstance(e2tAddress)
295 m.logger.Errorf("#E2TInstancesManager.AssociateRan - E2T Instance address: %s - Failed retrieving E2TInstance. error: %s", e2tAddress, err)
296 return e2managererrors.NewRnibDbError()
299 e2tInstance.AssociatedRanList = append(e2tInstance.AssociatedRanList, ranName)
301 err = m.rnibDataService.SaveE2TInstance(e2tInstance)
304 m.logger.Errorf("#E2TInstancesManager.AssociateRan - E2T Instance address: %s - Failed saving E2TInstance. error: %s", e2tAddress, err)
305 return e2managererrors.NewRnibDbError()
308 m.logger.Infof("#E2TInstancesManager.AssociateRan - successfully associated RAN %s with E2T %s", ranName, e2tInstance.Address)
312 func (h E2TInstancesManager) ActivateE2TInstance(e2tInstance *entities.E2TInstance) error{
314 if e2tInstance == nil {
315 h.logger.Errorf("#E2TInstancesManager.ActivateE2TInstance - e2tInstance empty")
316 return e2managererrors.NewInternalError()
319 h.logger.Infof("#E2TInstancesManager.ActivateE2TInstance - E2T Address: %s - activate E2T instance", e2tInstance.Address)
321 e2tInstance.State = entities.Active
322 e2tInstance.KeepAliveTimestamp = time.Now().UnixNano()
324 err := h.rnibDataService.SaveE2TInstance(e2tInstance)
326 h.logger.Errorf("#E2TInstancesManager.ActivateE2TInstance - E2T Instance address: %s - Failed saving E2TInstance. error: %s", e2tInstance.Address, err)
332 func (m *E2TInstancesManager) ResetKeepAliveTimestamp(e2tAddress string) error {
337 e2tInstance, err := m.rnibDataService.GetE2TInstanceNoLogs(e2tAddress)
340 m.logger.Errorf("#E2TInstancesManager.ResetKeepAliveTimestamp - E2T Instance address: %s - Failed retrieving E2TInstance. error: %s", e2tAddress, err)
344 if e2tInstance.State == entities.ToBeDeleted || e2tInstance.State == entities.RoutingManagerFailure {
345 m.logger.Warnf("#E2TInstancesManager.ResetKeepAliveTimestamp - Ignore. This Instance is about to deleted")
350 e2tInstance.KeepAliveTimestamp = time.Now().UnixNano()
351 err = m.rnibDataService.SaveE2TInstanceNoLogs(e2tInstance)
354 m.logger.Errorf("#E2TInstancesManager.ResetKeepAliveTimestamp - E2T Instance address: %s - Failed saving E2TInstance. error: %s", e2tAddress, err)