Changed xapptweak rmr send function to take in retry releated timeout

[ric-plt/submgr.git] / pkg / xapptweaks / rmrwrapper.go

diff --git a/pkg/xapptweaks/rmrwrapper.go b/pkg/xapptweaks/rmrwrapper.go
index ef633bd..ac602bf 100644 (file)
--- a/pkg/xapptweaks/rmrwrapper.go
+++ b/pkg/xapptweaks/rmrwrapper.go
@@ -47,14 +47,16 @@ func (tc *RmrWrapper) Unlock() {
 func (tc *RmrWrapper) Init() {
 }
 
-func (tc *RmrWrapper) RmrSend(params *RMRParams) (err error) {
+func (tc *RmrWrapper) RmrSend(params *RMRParams, to time.Duration) (err error) {
        if tc.Rmr == nil {
                err = fmt.Errorf("Failed rmr object nil for %s", params.String())
                return
        }
-       status := false
-       i := 1
-       for ; i <= 10 && status == false; i++ {
+       tc.Lock()
+       status := tc.Rmr.Send(params.RMRParams, false)
+       tc.Unlock()
+       i := 0
+       for ; i < int(to)*2 && status == false; i++ {
                tc.Lock()
                status = tc.Rmr.Send(params.RMRParams, false)
                tc.Unlock()