X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fregistry.go;h=c27e6a2ca967f390c9a9d62208461e66e0523d28;hb=5c161a94ae1b291dd13ff951a4d852566e1e4d47;hp=6717612f3b5561de2d52adea348026f0f7d17be0;hpb=1455c85dea3fba44cdcba8a92864be730691a6ec;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/registry.go b/pkg/control/registry.go index 6717612..c27e6a2 100644 --- a/pkg/control/registry.go +++ b/pkg/control/registry.go @@ -19,61 +19,86 @@ package control -import "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" +import ( + "fmt" + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" + "sync" +) +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- type Registry struct { - register map[uint16]bool - counter uint16 + mutex sync.Mutex + register map[uint16]*Subscription + subIds []uint16 + rtmgrClient *RtmgrClient } // This method should run as a constructor -func (r *Registry) Initialize(seedsn uint16) { - r.register = make(map[uint16]bool) - r.counter = seedsn +func (r *Registry) Initialize() { + r.register = make(map[uint16]*Subscription) + var i uint16 + for i = 0; i < 65535; i++ { + r.subIds = append(r.subIds, i+1) + } } // Reserves and returns the next free sequence number -func (r *Registry) ReserveSequenceNumber() uint16 { - if r.IsValidSequenceNumber(r.counter) { } - sequenceNumber := r.counter - r.register[sequenceNumber] = false - r.shift() - return sequenceNumber -} +func (r *Registry) ReserveSubscription(endPoint *RmrEndpoint, meid *xapp.RMRMeid) (*Subscription, error) { + // Check is current SequenceNumber valid + // Allocate next SequenceNumber value and retry N times + r.mutex.Lock() + defer r.mutex.Unlock() + var subs *Subscription = nil + var retrytimes uint16 = 1000 + for ; subs == nil && retrytimes > 0; retrytimes-- { + sequenceNumber := r.subIds[0] + r.subIds = r.subIds[1:] + if _, ok := r.register[sequenceNumber]; ok == false { + subs := &Subscription{ + registry: r, + Seq: sequenceNumber, + Active: false, + RmrEndpoint: *endPoint, + Meid: meid, + Trans: nil, + } + r.register[sequenceNumber] = subs -// This function checks the validity of the given subscription id -func (r *Registry) IsValidSequenceNumber(sn uint16) bool { - xapp.Logger.Debug("Registry map: %v", r.register) - if _, ok := r.register[sn]; ok { - return true + // Update routing + r.mutex.Unlock() + err := subs.UpdateRoute(CREATE) + r.mutex.Lock() + if err != nil { + if _, ok := r.register[sequenceNumber]; ok { + delete(r.register, sequenceNumber) + } + return nil, err + } + return subs, nil + } } - return false -} - -// This function sets the give id as confirmed in the register -func (r *Registry) setSubscriptionToConfirmed(sn uint16) { - r.register[sn] = true + return nil, fmt.Errorf("Registry: Failed to reserves subscription. RmrEndpoint: %s, Meid: %s", endPoint, meid.RanName) } -func (r *Registry) shift() { - if r.counter == 65535 { - r.counter = 0 - } else { - r.counter++ +func (r *Registry) GetSubscription(sn uint16) *Subscription { + r.mutex.Lock() + defer r.mutex.Unlock() + xapp.Logger.Debug("Registry map: %v", r.register) + if _, ok := r.register[sn]; ok { + return r.register[sn] } + return nil } -//This function sets the given id as unused in the register -func (r *Registry) deleteSubscription(sn uint16) { - r.register[sn] = false -} - -//This function releases the given id as unused in the register -func (r *Registry) releaseSequenceNumber(sn uint16) bool { - if r.register[sn] { - return false - } else { +func (r *Registry) DelSubscription(sn uint16) bool { + r.mutex.Lock() + defer r.mutex.Unlock() + if _, ok := r.register[sn]; ok { + r.subIds = append(r.subIds, sn) delete(r.register, sn) return true } + return false }