X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Ftracker.go;h=869e8ca66ed590319fae39582e9897931168aa67;hb=refs%2Fchanges%2F97%2F2197%2F6;hp=087b7811a22f2bb9710aa47bba528829a911a5d3;hpb=0388dd945789dae802aaa93c5062e3ae4c45ddf1;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/tracker.go b/pkg/control/tracker.go index 087b781..869e8ca 100644 --- a/pkg/control/tracker.go +++ b/pkg/control/tracker.go @@ -21,7 +21,6 @@ package control import ( "fmt" - "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "sync" ) @@ -37,12 +36,13 @@ func (t *Tracker) Init() { t.transactionXappTable = make(map[TransactionXappKey]*Transaction) } -func (t *Tracker) TrackTransaction(subs *Subscription, endpoint RmrEndpoint, params *xapp.RMRParams, respReceived bool, forwardRespToXapp bool) (*Transaction, error) { +func (t *Tracker) TrackTransaction(endpoint RmrEndpoint, params *RMRParams, respReceived bool, forwardRespToXapp bool) (*Transaction, error) { trans := &Transaction{ tracker: nil, Subs: nil, RmrEndpoint: endpoint, + Mtype: params.Mtype, Xid: params.Xid, OrigParams: params, RespReceived: respReceived, @@ -58,10 +58,6 @@ func (t *Tracker) TrackTransaction(subs *Subscription, endpoint RmrEndpoint, par return nil, err } - err := subs.SetTransaction(trans) - if err != nil { - return nil, err - } trans.tracker = t t.transactionXappTable[xappkey] = trans return trans, nil