X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Fregistry.go;h=1adb4f7253d8dc945ec317f121f843b65256e862;hb=refs%2Fchanges%2F77%2F2177%2F2;hp=4f5c4fd41f4a8aedfde3a1c1be3880cdf40a0d13;hpb=ff8dccd02d76eebfccc0b509ce0b42a2c1760e12;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/registry.go b/pkg/control/registry.go index 4f5c4fd..1adb4f7 100644 --- a/pkg/control/registry.go +++ b/pkg/control/registry.go @@ -21,65 +21,131 @@ package control import ( "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" + "strconv" "sync" ) +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- +type Subscription struct { + mutex sync.Mutex + Seq uint16 + Active bool + // + Meid *xapp.RMRMeid + RmrEndpoint // xapp endpoint + Trans *Transaction +} + +func (s *Subscription) String() string { + s.mutex.Lock() + defer s.mutex.Unlock() + return strconv.FormatUint(uint64(s.Seq), 10) + "/" + s.RmrEndpoint.String() + "/" + s.Meid.RanName +} + +func (s *Subscription) Confirmed() { + s.mutex.Lock() + defer s.mutex.Unlock() + s.Active = true +} + +func (s *Subscription) UnConfirmed() { + s.mutex.Lock() + defer s.mutex.Unlock() + s.Active = false +} + +func (s *Subscription) IsConfirmed() bool { + s.mutex.Lock() + defer s.mutex.Unlock() + return s.Active +} + +func (s *Subscription) SetTransaction(trans *Transaction) bool { + s.mutex.Lock() + defer s.mutex.Unlock() + if s.Trans == nil { + s.Trans = trans + return true + } + return false +} + +func (s *Subscription) UnSetTransaction(trans *Transaction) bool { + s.mutex.Lock() + defer s.mutex.Unlock() + if trans == nil || trans == s.Trans { + s.Trans = nil + return true + } + return false +} + +func (s *Subscription) GetTransaction() *Transaction { + s.mutex.Lock() + defer s.mutex.Unlock() + return s.Trans +} + +func (s *Subscription) SubRouteInfo(act Action) SubRouteInfo { + s.mutex.Lock() + defer s.mutex.Unlock() + return SubRouteInfo{act, s.RmrEndpoint.Addr, s.RmrEndpoint.Port, s.Seq} +} + +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- type Registry struct { - register map[uint16]bool + register map[uint16]*Subscription counter uint16 mutex sync.Mutex } // This method should run as a constructor func (r *Registry) Initialize(seedsn uint16) { - r.register = make(map[uint16]bool) + r.register = make(map[uint16]*Subscription) r.counter = seedsn } // Reserves and returns the next free sequence number -func (r *Registry) ReserveSequenceNumber() (uint16, bool) { +func (r *Registry) ReserveSubscription(endPoint RmrEndpoint, meid *xapp.RMRMeid) *Subscription { // Check is current SequenceNumber valid + // Allocate next SequenceNumber value and retry N times r.mutex.Lock() defer r.mutex.Unlock() - sequenceNumber := r.counter - if _, ok := r.register[sequenceNumber]; ok { - xapp.Logger.Error("Invalid SeqenceNumber sequenceNumber: %v", sequenceNumber) - return sequenceNumber, false + var subs *Subscription = nil + var retrytimes uint16 = 1000 + for ; subs == nil && retrytimes > 0; retrytimes-- { + sequenceNumber := r.counter + if r.counter == 65535 { + r.counter = 0 + } else { + r.counter++ + } + if _, ok := r.register[sequenceNumber]; ok == false { + r.register[sequenceNumber] = &Subscription{ + Seq: sequenceNumber, + Active: false, + RmrEndpoint: endPoint, + Meid: meid, + Trans: nil, + } + return r.register[sequenceNumber] + } } - r.register[sequenceNumber] = false - - // Allocate next SequenceNumber value - if r.counter == 65535 { - r.counter = 0 - } else { - r.counter++ - } - return sequenceNumber, true + return nil } -// This function checks the validity of the given subscription id -func (r *Registry) IsValidSequenceNumber(sn uint16) bool { +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 true + return r.register[sn] } - return false -} - -// This function sets the give id as confirmed in the register -func (r *Registry) setSubscriptionToConfirmed(sn uint16) { - r.mutex.Lock() - defer r.mutex.Unlock() - r.register[sn] = true -} - -//This function sets the given id as unused in the register -func (r *Registry) deleteSubscription(sn uint16) { - r.mutex.Lock() - defer r.mutex.Unlock() - r.register[sn] = false + return nil } //This function releases the given id as unused in the register