X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fxapptweaks%2Frmrendpoint.go;fp=pkg%2Fxapptweaks%2Frmrendpoint.go;h=0000000000000000000000000000000000000000;hb=9dc5adc78d459157a42ef8997eeced82a3616f01;hp=4b5ae480b7ef3cf0ce383749470c0b6c8d80d161;hpb=f3f4efb9be78f25d3417ecbbce3ea988550e5381;p=ric-plt%2Fsubmgr.git diff --git a/pkg/xapptweaks/rmrendpoint.go b/pkg/xapptweaks/rmrendpoint.go deleted file mode 100644 index 4b5ae48..0000000 --- a/pkg/xapptweaks/rmrendpoint.go +++ /dev/null @@ -1,141 +0,0 @@ -/* -================================================================================== - Copyright (c) 2019 AT&T Intellectual Property. - Copyright (c) 2019 Nokia - - Licensed under the Apache License, Version 2.0 (the "License"); - you may not use this file except in compliance with the License. - You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. -================================================================================== -*/ - -package xapptweaks - -import ( - "strconv" - "strings" -) - -//----------------------------------------------------------------------------- -// -//----------------------------------------------------------------------------- -type RmrEndpoint struct { - Addr string // xapp addr - Port uint16 // xapp port -} - -func (endpoint RmrEndpoint) String() string { - return endpoint.Addr + ":" + strconv.FormatUint(uint64(endpoint.Port), 10) -} - -func (endpoint *RmrEndpoint) Equal(ep *RmrEndpoint) bool { - if (endpoint.Addr == ep.Addr) && - (endpoint.Port == ep.Port) { - return true - } - return false -} - -func (endpoint *RmrEndpoint) GetAddr() string { - return endpoint.Addr -} - -func (endpoint *RmrEndpoint) GetPort() uint16 { - return endpoint.Port -} - -func (endpoint *RmrEndpoint) Set(src string) bool { - elems := strings.Split(src, ":") - if len(elems) == 2 { - srcAddr := elems[0] - srcPort, err := strconv.ParseUint(elems[1], 10, 16) - if err == nil { - endpoint.Addr = srcAddr - endpoint.Port = uint16(srcPort) - return true - } - } - return false -} - -//----------------------------------------------------------------------------- -// -//----------------------------------------------------------------------------- -type RmrEndpointList struct { - Endpoints []RmrEndpoint -} - -func (eplist *RmrEndpointList) String() string { - valuesText := eplist.StringList() - return strings.Join(valuesText, ",") -} - -func (eplist *RmrEndpointList) StringList() []string { - tmpList := eplist.Endpoints - valuesText := []string{} - for i := range tmpList { - valuesText = append(valuesText, tmpList[i].String()) - } - return valuesText -} - -func (eplist *RmrEndpointList) Size() int { - return len(eplist.Endpoints) -} - -func (eplist *RmrEndpointList) AddEndpoint(ep *RmrEndpoint) bool { - for i := range eplist.Endpoints { - if eplist.Endpoints[i].Equal(ep) { - return false - } - } - eplist.Endpoints = append(eplist.Endpoints, *ep) - return true -} - -func (eplist *RmrEndpointList) DelEndpoint(ep *RmrEndpoint) bool { - for i := range eplist.Endpoints { - if eplist.Endpoints[i].Equal(ep) { - eplist.Endpoints[i] = eplist.Endpoints[len(eplist.Endpoints)-1] - eplist.Endpoints[len(eplist.Endpoints)-1] = RmrEndpoint{"", 0} - eplist.Endpoints = eplist.Endpoints[:len(eplist.Endpoints)-1] - return true - } - } - return false -} - -func (eplist *RmrEndpointList) DelEndpoints(otheplist *RmrEndpointList) bool { - var retval bool = false - for i := range otheplist.Endpoints { - if eplist.DelEndpoint(&otheplist.Endpoints[i]) { - retval = true - } - } - return retval -} - -func (eplist *RmrEndpointList) HasEndpoint(ep *RmrEndpoint) bool { - for i := range eplist.Endpoints { - if eplist.Endpoints[i].Equal(ep) { - return true - } - } - return false -} - -func NewRmrEndpoint(src string) *RmrEndpoint { - ep := &RmrEndpoint{} - if ep.Set(src) == false { - return nil - } - return ep -}