import (
"fmt"
"gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap"
+ "gerrit.o-ran-sc.org/r/ric-plt/submgr/pkg/xapptweaks"
+ "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/models"
"gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp"
"sync"
"time"
}
}
+func (r *Registry) QueryHandler() (models.SubscriptionList, error) {
+ r.mutex.Lock()
+ defer r.mutex.Unlock()
+
+ resp := models.SubscriptionList{}
+ for _, subs := range r.register {
+ subs.mutex.Lock()
+ resp = append(resp, &models.SubscriptionData{SubscriptionID: int64(subs.ReqId.Seq), Meid: subs.Meid.RanName, Endpoint: subs.EpList.StringList()})
+ subs.mutex.Unlock()
+ }
+ return resp, nil
+}
+
func (r *Registry) allocateSubs(trans *TransactionXapp, subReqMsg *e2ap.E2APSubscriptionRequest) (*Subscription, error) {
if len(r.subIds) > 0 {
sequenceNumber := r.subIds[0]
// Find possible existing Policy subscription
//
if actionType == e2ap.E2AP_ActionTypePolicy {
- if subs, ok := r.register[subReqMsg.RequestId.Seq]; ok {
+ if subs, ok := r.register[trans.GetSubId()]; ok {
xapp.Logger.Debug("CREATE %s. Existing subscription for Policy found", subs.String())
subs.SetCachedResponse(nil, true)
return subs, nil
//
// Subscription route delete
//
- tmpList := RmrEndpointList{}
+ tmpList := xapptweaks.RmrEndpointList{}
tmpList.AddEndpoint(trans.GetEndpoint())
subRouteAction := SubRouteInfo{tmpList, uint16(seqId)}
r.rtmgrClient.SubscriptionRequestDelete(subRouteAction)