X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Ftransaction.go;h=2f4acab0c1164694831129e0934bf7b7b8d71087;hb=e406a34d5547107533e65ddfbb2074e96d77b4b3;hp=f686b44630a4cdae29622cbf2c3915c5d63c399a;hpb=a189c866d786c2dbde19d34d9dd2404e17b3e407;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/transaction.go b/pkg/control/transaction.go index f686b44..2f4acab 100644 --- a/pkg/control/transaction.go +++ b/pkg/control/transaction.go @@ -20,7 +20,6 @@ package control import ( - "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "strconv" "sync" ) @@ -45,8 +44,9 @@ type Transaction struct { tracker *Tracker // tracker instance Subs *Subscription RmrEndpoint RmrEndpoint - Xid string // xapp xid in req - OrigParams *xapp.RMRParams // request orginal params + Mtype int + Xid string // xapp xid in req + OrigParams *RMRParams // request orginal params RespReceived bool ForwardRespToXapp bool } @@ -61,6 +61,24 @@ func (t *Transaction) String() string { return subId + "/" + t.RmrEndpoint.String() + "/" + t.Xid } +func (t *Transaction) GetXid() string { + t.mutex.Lock() + defer t.mutex.Unlock() + return t.Xid +} + +func (t *Transaction) GetMtype() int { + t.mutex.Lock() + defer t.mutex.Unlock() + return t.Mtype +} + +func (t *Transaction) GetSrc() string { + t.mutex.Lock() + defer t.mutex.Unlock() + return t.RmrEndpoint.String() +} + func (t *Transaction) CheckResponseReceived() bool { t.mutex.Lock() defer t.mutex.Unlock()