FROM nexus3.o-ran-sc.org:10002/o-ran-sc/bldr-ubuntu20-c-go:1.0.0 as rtmgrbuild
# Install RMr shared library
-ARG RMRVERSION=4.7.4
+ARG RMRVERSION=4.8.0
RUN wget --content-disposition https://packagecloud.io/o-ran-sc/release/packages/debian/stretch/rmr_${RMRVERSION}_amd64.deb/download.deb && dpkg -i rmr_${RMRVERSION}_amd64.deb && rm -rf rmr_${RMRVERSION}_amd64.deb
# Install RMr development header files
RUN wget --content-disposition https://packagecloud.io/o-ran-sc/release/packages/debian/stretch/rmr-dev_${RMRVERSION}_amd64.deb/download.deb && dpkg -i rmr-dev_${RMRVERSION}_amd64.deb && rm -rf rmr-dev_${RMRVERSION}_amd64.deb
+### v0.8.2
+* Added some checks for E2tcreate handling and RMR update to v4.8.0
+
### v0.8.1
* RIC-702: Clean-up logging in routing manager
# By default this file is in the docker build directory,
# but the location can configured in the JJB template.
---
-tag: 0.8.1
+tag: 0.8.2
go updateEp()
time.Sleep(5 * time.Second)
sendRoutesToAll()
- /* Sometimes first message fails, retry after 5 sec */
- time.Sleep(5 * time.Second)
- sendRoutesToAll()
+ for i := 0; i <= 5; i++ {
+ /* Sometimes first message fails, retry after 5 sec */
+ time.Sleep(10 * time.Second)
+ sendRoutesToAll()
+ }
for {
xapp.Logger.Debug("Periodic Routes value = %s", xapp.Config.GetString("periodicroutes"))
//"routing-manager/pkg/restapi/operations/handle"
"routing-manager/pkg/rpe"
"routing-manager/pkg/rtmgr"
+ "routing-manager/pkg/sbi"
"routing-manager/pkg/sdl"
"strconv"
"strings"
m.Unlock()
updateEp()
//sendPartialRoutesToAll(nil, rtmgr.E2Type)
+ sbi.Conn.Lock()
+ rtmgr.RMRConnStatus[*data.E2TAddress] = false
+ sbi.Conn.Unlock()
+
sendRoutesToAll()
time.Sleep(10 * time.Second)
- for ep, value := range rtmgr.RMRConnStatus {
- if ep == *data.E2TAddress && value == true {
- rtmgr.RMRConnStatus[ep] = false //Reset to false incase of E2t restart scenario
- return nil
- }
+ if rtmgr.RMRConnStatus[*data.E2TAddress] == true {
+ sbi.Conn.Lock()
+ delete(rtmgr.RMRConnStatus, *data.E2TAddress)
+ sbi.Conn.Unlock()
+ xapp.Logger.Debug("RMRConnStatus Map after = %v", rtmgr.RMRConnStatus)
+ return nil
}
return errors.New("Error while adding new E2T " + *data.E2TAddress)
var rmrdynamiccallid = 201
var addendpointct = 1
var count int
-var conn sync.Mutex
+var Conn sync.Mutex
type RmrPush struct {
Sbi
xapp.Logger.Error("Invoked send_data to try again due to return value : %v", ret)
}
- conn.Lock()
+ Conn.Lock()
rtmgr.RMRConnStatus[ep.Uuid] = ret
- conn.Unlock()
+ Conn.Unlock()
// Handling per connection .. may be updating global map
//channel <- EPStatus{ep.Uuid, ret}