X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Ftracker.go;h=df3d56e4bf4685feb98f8ee5bad7660c8ad99fd9;hb=HEAD;hp=46971d9ba55c9337fe843ae5f2c70cbc6c08c7c5;hpb=9dc5adc78d459157a42ef8997eeced82a3616f01;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/tracker.go b/pkg/control/tracker.go index 46971d9..df3d56e 100644 --- a/pkg/control/tracker.go +++ b/pkg/control/tracker.go @@ -21,6 +21,7 @@ package control import ( "fmt" + "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap" "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "sync" ) @@ -58,13 +59,13 @@ func (t *Tracker) NewSubsTransaction(subs *Subscription) *TransactionSubs { func (t *Tracker) NewXappTransaction( endpoint *xapp.RmrEndpoint, xid string, - subid uint32, + requestId e2ap.RequestId, meid *xapp.RMRMeid) *TransactionXapp { trans := &TransactionXapp{} - trans.XappKey = &TransactionXappKey{*endpoint, xid} + trans.XappKey = &TransactionXappKey{requestId.Id, *endpoint, xid} trans.Meid = meid - trans.SubId = subid + trans.RequestId = requestId t.initTransaction(&trans.Transaction) xapp.Logger.Debug("CREATE %s", trans.String()) return trans @@ -103,5 +104,5 @@ func (t *Tracker) UnTrackTransaction(xappKey TransactionXappKey) (*TransactionXa //xapp.Logger.Debug("Tracker: transtable=%v", t.transactionXappTable) return trans, nil } - return nil, fmt.Errorf("Tracker: No record %s", xappKey) + return nil, fmt.Errorf("Tracker: No record %v", xappKey) }