X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=pkg%2Fcontrol%2Ftransaction.go;h=735954ef713558923446a8b1d049ba9cdec73484;hb=af91f971681842c22dc0fad165c0cbf7ebaa0e4d;hp=2f4acab0c1164694831129e0934bf7b7b8d71087;hpb=e406a34d5547107533e65ddfbb2074e96d77b4b3;p=ric-plt%2Fsubmgr.git diff --git a/pkg/control/transaction.go b/pkg/control/transaction.go index 2f4acab..735954e 100644 --- a/pkg/control/transaction.go +++ b/pkg/control/transaction.go @@ -20,10 +20,75 @@ package control import ( + "gerrit.o-ran-sc.org/r/ric-plt/e2ap/pkg/packer" + "gerrit.o-ran-sc.org/r/ric-plt/xapp-frame/pkg/xapp" "strconv" "sync" + "time" ) +//----------------------------------------------------------------------------- +// +//----------------------------------------------------------------------------- + +type TransactionBase struct { + mutex sync.Mutex // + Seq uint64 // + tracker *Tracker //tracker instance + Meid *xapp.RMRMeid //meid transaction related + Mtype int //Encoded message type to be send + Payload *packer.PackedData //Encoded message to be send + EventChan chan interface{} +} + +func (t *TransactionBase) SendEvent(event interface{}, waittime time.Duration) (bool, bool) { + if waittime > 0 { + select { + case t.EventChan <- event: + return true, false + case <-time.After(waittime): + return false, true + } + return false, false + } + t.EventChan <- event + return true, false +} + +func (t *TransactionBase) WaitEvent(waittime time.Duration) (interface{}, bool) { + if waittime > 0 { + select { + case event := <-t.EventChan: + return event, false + case <-time.After(waittime): + return nil, true + } + } + event := <-t.EventChan + return event, false +} + +func (t *TransactionBase) GetMtype() int { + t.mutex.Lock() + defer t.mutex.Unlock() + return t.Mtype +} + +func (t *TransactionBase) GetMeid() *xapp.RMRMeid { + t.mutex.Lock() + defer t.mutex.Unlock() + if t.Meid != nil { + return t.Meid + } + return nil +} + +func (t *TransactionBase) GetPayload() *packer.PackedData { + t.mutex.Lock() + defer t.mutex.Unlock() + return t.Payload +} + //----------------------------------------------------------------------------- // //----------------------------------------------------------------------------- @@ -33,78 +98,61 @@ type TransactionXappKey struct { } func (key *TransactionXappKey) String() string { - return key.RmrEndpoint.String() + "/" + key.Xid + return "transkey(" + key.RmrEndpoint.String() + "/" + key.Xid + ")" } //----------------------------------------------------------------------------- // //----------------------------------------------------------------------------- type Transaction struct { - mutex sync.Mutex - tracker *Tracker // tracker instance - Subs *Subscription - RmrEndpoint RmrEndpoint - Mtype int - Xid string // xapp xid in req - OrigParams *RMRParams // request orginal params - RespReceived bool - ForwardRespToXapp bool + TransactionBase // + XappKey *TransactionXappKey // } func (t *Transaction) String() string { - t.mutex.Lock() - defer t.mutex.Unlock() - var subId string = "?" - if t.Subs != nil { - subId = strconv.FormatUint(uint64(t.Subs.Seq), 10) + var transkey string = "transkey(N/A)" + if t.XappKey != nil { + transkey = t.XappKey.String() } - return subId + "/" + t.RmrEndpoint.String() + "/" + t.Xid + return "trans(" + strconv.FormatUint(uint64(t.Seq), 10) + "/" + t.Meid.RanName + "/" + transkey + ")" } -func (t *Transaction) GetXid() string { +func (t *Transaction) GetEndpoint() *RmrEndpoint { t.mutex.Lock() defer t.mutex.Unlock() - return t.Xid + if t.XappKey != nil { + return &t.XappKey.RmrEndpoint + } + return nil } -func (t *Transaction) GetMtype() int { +func (t *Transaction) GetXid() string { t.mutex.Lock() defer t.mutex.Unlock() - return t.Mtype + if t.XappKey != nil { + return t.XappKey.Xid + } + return "" } 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() - if t.RespReceived == false { - t.RespReceived = true - return false + if t.XappKey != nil { + return t.XappKey.RmrEndpoint.String() } - return true -} - -func (t *Transaction) RetryTransaction() { - t.mutex.Lock() - defer t.mutex.Unlock() - t.RespReceived = false + return "" } func (t *Transaction) Release() { t.mutex.Lock() - defer t.mutex.Unlock() - if t.Subs != nil { - t.Subs.UnSetTransaction(t) - } - if t.tracker != nil { - xappkey := TransactionXappKey{t.RmrEndpoint, t.Xid} - t.tracker.UnTrackTransaction(xappkey) - } - t.Subs = nil + xapp.Logger.Debug("Transaction: Release %s", t.String()) + tracker := t.tracker + xappkey := t.XappKey t.tracker = nil + t.mutex.Unlock() + + if tracker != nil && xappkey != nil { + tracker.UnTrackTransaction(*xappkey) + } }