RSM/services/resource_status_service.go

   1 //
   2 // Copyright 2019 AT&T Intellectual Property
   3 // Copyright 2019 Nokia
   4 //
   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
   8 //
   9 //      http://www.apache.org/licenses/LICENSE-2.0
  10 //
  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.
  16 //
  17
  18 package services
  19
  20 import (
  21         "fmt"
  22         "gerrit.o-ran-sc.org/r/ric-plt/nodeb-rnib.git/entities"
  23         "rsm/e2pdus"
  24         "rsm/enums"
  25         "rsm/logger"
  26         "rsm/models"
  27         "rsm/rmrcgo"
  28         "rsm/services/rmrsender"
  29 )
  30
  31 type ResourceStatusService struct {
  32         logger    *logger.Logger
  33         rmrSender *rmrsender.RmrSender
  34 }
  35
  36 type IResourceStatusService interface {
  37         BuildAndSendInitiateRequest(nodeb *entities.NodebInfo, config *models.RsmGeneralConfiguration, enb1MeasurementId int64) error
  38         BuildAndSendStopRequest(nodeb *entities.NodebInfo, config *models.RsmGeneralConfiguration, enb1MeasurementId int64, enb2MeasurementId int64) error
  39 }
  40
  41 func NewResourceStatusService(logger *logger.Logger, rmrSender *rmrsender.RmrSender) *ResourceStatusService {
  42         return &ResourceStatusService{
  43                 logger:    logger,
  44                 rmrSender: rmrSender,
  45         }
  46 }
  47
  48 func (m *ResourceStatusService) BuildAndSendInitiateRequest(nodeb *entities.NodebInfo, config *models.RsmGeneralConfiguration, enb1MeasurementId int64) error {
  49
  50         return m.buildAndSendResourceStatusRequest(enums.Registration_Request_start, nodeb, config, enb1MeasurementId, 0)
  51 }
  52
  53 func (m *ResourceStatusService) BuildAndSendStopRequest(nodeb *entities.NodebInfo, config *models.RsmGeneralConfiguration, enb1MeasurementId int64, enb2MeasurementId int64) error {
  54
  55         return m.buildAndSendResourceStatusRequest(enums.Registration_Request_stop, nodeb, config, enb1MeasurementId, enb2MeasurementId)
  56 }
  57
  58 func (m *ResourceStatusService) buildAndSendResourceStatusRequest(registrationRequest enums.Registration_Request, nodeb *entities.NodebInfo, config *models.RsmGeneralConfiguration, enb1MeasurementId int64, enb2MeasurementId int64) error {
  59
  60         cellIdList, err := m.extractCellIdList(nodeb)
  61
  62         if err != nil {
  63                 return err
  64         }
  65
  66         requestParams := buildResourceStatusRequestParams(config, cellIdList, enb1MeasurementId, enb2MeasurementId)
  67
  68         payload, payloadAsString, err := e2pdus.BuildPackedResourceStatusRequest(registrationRequest, requestParams, e2pdus.MaxAsn1PackedBufferSize, e2pdus.MaxAsn1CodecMessageBufferSize, m.logger.DebugEnabled())
  69
  70         if err != nil {
  71                 m.logger.Errorf("#ResourceStatusService.buildAndSendResourceStatusRequest - RAN name: %s. Failed to build and pack resource status %s request. error: %s", nodeb.RanName, registrationRequest, err)
  72                 return err
  73         }
  74
  75         m.logger.Debugf("#ResourceStatusService.buildAndSendResourceStatusRequest - RAN name: %s. Successfully build packed payload: %s", nodeb.RanName, payloadAsString)
  76         rmrMsg := models.NewRmrMessage(rmrcgo.RicResStatusReq, nodeb.RanName, payload)
  77
  78         return m.rmrSender.Send(rmrMsg)
  79 }
  80
  81 func (m *ResourceStatusService) extractCellIdList(nodeb *entities.NodebInfo) ([]string, error) {
  82
  83         enb, ok := nodeb.Configuration.(*entities.NodebInfo_Enb)
  84
  85         if !ok {
  86                 m.logger.Errorf("#ResourceStatusService.extractCellIdList - RAN name: %s - invalid configuration", nodeb.RanName)
  87                 return []string{}, fmt.Errorf("invalid configuration for RAN %s", nodeb.RanName)
  88         }
  89
  90         cells := enb.Enb.ServedCells
  91
  92         if len(cells) == 0 {
  93                 m.logger.Errorf("#ResourceStatusService.extractCellIdList - RAN name: %s - empty cell list", nodeb.RanName)
  94                 return []string{}, fmt.Errorf("empty cell list for RAN %s", nodeb.RanName)
  95         }
  96
  97         cellIdList := make([]string, len(cells))
  98         for index, cellInfo := range cells {
  99                 cellIdList[index] = cellInfo.CellId
 100         }
 101
 102         return cellIdList, nil
 103 }
 104
 105 func buildResourceStatusRequestParams(config *models.RsmGeneralConfiguration, cellIdList []string, enb1MeasurementId int64, enb2MeasurementId int64) *e2pdus.ResourceStatusRequestData {
 106         return &e2pdus.ResourceStatusRequestData{
 107                 CellIdList:                   cellIdList,
 108                 MeasurementID:                e2pdus.Measurement_ID(enb1MeasurementId),
 109                 MeasurementID2:               e2pdus.Measurement_ID(enb2MeasurementId),
 110                 PartialSuccessAllowed:        config.PartialSuccessAllowed,
 111                 PrbPeriodic:                  config.PrbPeriodic,
 112                 TnlLoadIndPeriodic:           config.TnlLoadIndPeriodic,
 113                 HwLoadIndPeriodic:            config.HwLoadIndPeriodic,
 114                 AbsStatusPeriodic:            config.AbsStatusPeriodic,
 115                 RsrpMeasurementPeriodic:      config.RsrpMeasurementPeriodic,
 116                 CsiPeriodic:                  config.CsiPeriodic,
 117                 PeriodicityMS:                config.PeriodicityMs,
 118                 PeriodicityRsrpMeasurementMS: config.PeriodicityRsrpMeasurementMs,
 119                 PeriodicityCsiMS:             config.PeriodicityCsiMs,
 120         }
 121 }