pkg/control/types.go

   1 /*
   2 ==================================================================================
   3   Copyright (c) 2019 AT&T Intellectual Property.
   4   Copyright (c) 2019 Nokia
   5
   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
   9
  10        http://www.apache.org/licenses/LICENSE-2.0
  11
  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.
  17 ==================================================================================
  18 */
  19
  20 package control
  21
  22 import (
  23         "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap"
  24         "strconv"
  25         "strings"
  26 )
  27
  28 //-----------------------------------------------------------------------------
  29 //
  30 //-----------------------------------------------------------------------------
  31 type RequestId struct {
  32         e2ap.RequestId
  33 }
  34
  35 func (rid *RequestId) String() string {
  36         return "reqid(" + rid.RequestId.String() + ")"
  37 }
  38
  39 //-----------------------------------------------------------------------------
  40 //
  41 //-----------------------------------------------------------------------------
  42 type RmrEndpoint struct {
  43         Addr string // xapp addr
  44         Port uint16 // xapp port
  45 }
  46
  47 func (endpoint RmrEndpoint) String() string {
  48         return endpoint.Addr + ":" + strconv.FormatUint(uint64(endpoint.Port), 10)
  49 }
  50
  51 func (endpoint *RmrEndpoint) Equal(ep *RmrEndpoint) bool {
  52         if (endpoint.Addr == ep.Addr) &&
  53                 (endpoint.Port == ep.Port) {
  54                 return true
  55         }
  56         return false
  57 }
  58
  59 func (endpoint *RmrEndpoint) GetAddr() string {
  60         return endpoint.Addr
  61 }
  62
  63 func (endpoint *RmrEndpoint) GetPort() uint16 {
  64         return endpoint.Port
  65 }
  66
  67 func (endpoint *RmrEndpoint) Set(src string) bool {
  68         elems := strings.Split(src, ":")
  69         if len(elems) == 2 {
  70                 srcAddr := elems[0]
  71                 srcPort, err := strconv.ParseUint(elems[1], 10, 16)
  72                 if err == nil {
  73                         endpoint.Addr = srcAddr
  74                         endpoint.Port = uint16(srcPort)
  75                         return true
  76                 }
  77         }
  78         return false
  79 }
  80
  81 //-----------------------------------------------------------------------------
  82 //
  83 //-----------------------------------------------------------------------------
  84 type RmrEndpointList struct {
  85         Endpoints []RmrEndpoint
  86 }
  87
  88 func (eplist *RmrEndpointList) String() string {
  89         tmpList := eplist.Endpoints
  90         valuesText := []string{}
  91         for i := range tmpList {
  92                 valuesText = append(valuesText, tmpList[i].String())
  93         }
  94         return strings.Join(valuesText, ",")
  95 }
  96
  97 func (eplist *RmrEndpointList) Size() int {
  98         return len(eplist.Endpoints)
  99 }
 100
 101 func (eplist *RmrEndpointList) AddEndpoint(ep *RmrEndpoint) bool {
 102         for i := range eplist.Endpoints {
 103                 if eplist.Endpoints[i].Equal(ep) {
 104                         return false
 105                 }
 106         }
 107         eplist.Endpoints = append(eplist.Endpoints, *ep)
 108         return true
 109 }
 110
 111 func (eplist *RmrEndpointList) DelEndpoint(ep *RmrEndpoint) bool {
 112         for i := range eplist.Endpoints {
 113                 if eplist.Endpoints[i].Equal(ep) {
 114                         eplist.Endpoints[i] = eplist.Endpoints[len(eplist.Endpoints)-1]
 115                         eplist.Endpoints[len(eplist.Endpoints)-1] = RmrEndpoint{"", 0}
 116                         eplist.Endpoints = eplist.Endpoints[:len(eplist.Endpoints)-1]
 117                         return true
 118                 }
 119         }
 120         return false
 121 }
 122
 123 func (eplist *RmrEndpointList) DelEndpoints(otheplist *RmrEndpointList) bool {
 124         var retval bool = false
 125         for i := range otheplist.Endpoints {
 126                 if eplist.DelEndpoint(&otheplist.Endpoints[i]) {
 127                         retval = true
 128                 }
 129         }
 130         return retval
 131 }
 132
 133 func (eplist *RmrEndpointList) HasEndpoint(ep *RmrEndpoint) bool {
 134         for i := range eplist.Endpoints {
 135                 if eplist.Endpoints[i].Equal(ep) {
 136                         return true
 137                 }
 138         }
 139         return false
 140 }
 141
 142 func NewRmrEndpoint(src string) *RmrEndpoint {
 143         ep := &RmrEndpoint{}
 144         if ep.Set(src) == false {
 145                 return nil
 146         }
 147         return ep
 148 }