X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Ftransaction.go;h=282d291c201a374f023178d5a428d798f76aec54;hb=3a9697375fa1ebb0d39e7516756b08fcb64f4cb8;hp=570cb7ab22d7a3d36eb60d9fb1bb686ec5b4de7b;hpb=47518ae7612cbfb1562fa1f74b9023389d8cfd61;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/transaction.go b/pkg/control/transaction.go index 570cb7a..282d291 100644 --- a/pkg/control/transaction.go +++ b/pkg/control/transaction.go @@ -20,11 +20,12 @@ package control import ( - "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap" - "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "strconv" "sync" "time" + + "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/e2ap" + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" ) //----------------------------------------------------------------------------- @@ -130,6 +131,7 @@ func (t *TransactionSubs) Release() { // //----------------------------------------------------------------------------- type TransactionXappKey struct { + InstanceID uint32 xapp.RmrEndpoint Xid string // xapp xid in req } @@ -198,6 +200,9 @@ func (t *TransactionXapp) Release() { t.mutex.Unlock() if tracker != nil && xappkey != nil { - tracker.UnTrackTransaction(*xappkey) + _, err := tracker.UnTrackTransaction(*xappkey) + if err != nil { + xapp.Logger.Error("tracker.UnTrackTransaction() failed:%s", err.Error()) + } } }