Code Review
/
ric-plt
/
submgr.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
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) 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
}
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()
tc.Lock()
status = tc.Rmr.Send(params.RMRParams, false)
tc.Unlock()