Change-Id: I72877bcdcaf16e29235e0178766f6f6e9645617a
Signed-off-by: rangajal <ranjit.angajala@nokia.com>
Signed-off-by: Juha Hyttinen <juha.hyttinen@nokia.com>
replace gerrit.o-ran-sc.org/r/ric-plt/sdlgo => gerrit.o-ran-sc.org/r/ric-plt/sdlgo.git v0.5.2
replace gerrit.o-ran-sc.org/r/ric-plt/sdlgo => gerrit.o-ran-sc.org/r/ric-plt/sdlgo.git v0.5.2
-replace gerrit.o-ran-sc.org/r/ric-plt/xapp-frame => gerrit.o-ran-sc.org/r/ric-plt/xapp-frame.git v0.4.18
+replace gerrit.o-ran-sc.org/r/ric-plt/xapp-frame => gerrit.o-ran-sc.org/r/ric-plt/xapp-frame.git v0.5.12
replace gerrit.o-ran-sc.org/r/com/golog => gerrit.o-ran-sc.org/r/com/golog.git v0.0.1
replace gerrit.o-ran-sc.org/r/com/golog => gerrit.o-ran-sc.org/r/com/golog.git v0.0.1
tc.RecvChan = make(chan *xapp.RMRParams)
tc.RmrControl.Init(desc, srcId, rtgSvc)
tc.RecvChan = make(chan *xapp.RMRParams)
tc.RmrControl.Init(desc, srcId, rtgSvc)
- tc.RMRClient = xapp.NewRMRClientWithParams("tcp:"+strconv.FormatUint(uint64(srcId.Port), 10), 65534, 0, stat)
+ tc.RMRClient = xapp.NewRMRClientWithParams(&xapp.RMRClientParams{
+ ProtPort: "tcp:" + strconv.FormatUint(uint64(srcId.Port), 10),
+ MaxSize: 65534,
+ ThreadType: 0,
+ StatDesc: stat,
+ LowLatency: false,
+ FastAck: false,
+ })
+
tc.RMRClient.SetReadyCB(tc.ReadyCB, nil)
go tc.RMRClient.Start(tc)
tc.RMRClient.SetReadyCB(tc.ReadyCB, nil)
go tc.RMRClient.Start(tc)