X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;ds=sidebyside;f=pkg%2Fcontrol%2Ftracker.go;h=20af9f04722b681350570793458c51ae28d9065c;hb=a93ec3c226130e8a300b107cd582dc57004e0c40;hp=75127a7a7190d2825a0c44f49dec0697527b5a40;hpb=86a462083a043a01f499610209ba7a1b6ee8d652;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/tracker.go b/pkg/control/tracker.go index 75127a7..20af9f0 100644 --- a/pkg/control/tracker.go +++ b/pkg/control/tracker.go @@ -39,7 +39,6 @@ func (t *Tracker) Init() { func (t *Tracker) TrackTransaction( endpoint *RmrEndpoint, - mtype int, xid string, meid *xapp.RMRMeid, respReceived bool, @@ -54,7 +53,6 @@ func (t *Tracker) TrackTransaction( tracker: nil, Subs: nil, RmrEndpoint: *endpoint, - Mtype: mtype, Xid: xid, Meid: meid, RespReceived: respReceived, @@ -65,13 +63,15 @@ func (t *Tracker) TrackTransaction( defer t.mutex.Unlock() xappkey := TransactionXappKey{*endpoint, xid} - if _, ok := t.transactionXappTable[xappkey]; ok { - err := fmt.Errorf("Tracker: Similar transaction with xappkey %s is ongoing, transaction %s not created ", xappkey, trans) + if othtrans, ok := t.transactionXappTable[xappkey]; ok { + err := fmt.Errorf("Tracker: %s is ongoing, %s not created ", othtrans, trans) return nil, err } trans.tracker = t t.transactionXappTable[xappkey] = trans + xapp.Logger.Info("Tracker: Create %s", trans.String()) + xapp.Logger.Debug("Tracker: transtable=%v", t.transactionXappTable) return trans, nil } @@ -79,8 +79,10 @@ func (t *Tracker) UnTrackTransaction(xappKey TransactionXappKey) (*Transaction, t.mutex.Lock() defer t.mutex.Unlock() if trans, ok2 := t.transactionXappTable[xappKey]; ok2 { + xapp.Logger.Info("Tracker: Delete %s", trans.String()) delete(t.transactionXappTable, xappKey) + xapp.Logger.Debug("Tracker: transtable=%v", t.transactionXappTable) return trans, nil } - return nil, fmt.Errorf("Tracker: No record for xappkey %s", xappKey) + return nil, fmt.Errorf("Tracker: No record %s", xappKey) }