Code Review
/
ric-plt
/
a1.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Reading Rmr Configuration
[ric-plt/a1.git]
/
pkg
/
rmr
/
rmr.go
diff --git
a/pkg/rmr/rmr.go
b/pkg/rmr/rmr.go
index
4f4aa41
..
d9ec0f0
100644
(file)
--- a/
pkg/rmr/rmr.go
+++ b/
pkg/rmr/rmr.go
@@
-29,6
+29,7
@@
import (
"net/http"
"strconv"
"net/http"
"strconv"
+ "gerrit.o-ran-sc.org/r/ric-plt/a1/config"
"gerrit.o-ran-sc.org/r/ric-plt/a1/pkg/a1"
"gerrit.o-ran-sc.org/r/ric-plt/a1/pkg/models"
"gerrit.o-ran-sc.org/r/ric-plt/a1/pkg/policy"
"gerrit.o-ran-sc.org/r/ric-plt/a1/pkg/a1"
"gerrit.o-ran-sc.org/r/ric-plt/a1/pkg/models"
"gerrit.o-ran-sc.org/r/ric-plt/a1/pkg/policy"
@@
-57,17
+58,18
@@
type IRmrSender interface {
}
func NewRMRSender(policyManager *policy.PolicyManager) IRmrSender {
}
func NewRMRSender(policyManager *policy.PolicyManager) IRmrSender {
+ config := config.ParseConfiguration()
RMRclient := xapp.NewRMRClientWithParams(&xapp.RMRClientParams{
StatDesc: "",
RmrData: xapp.PortData{
RMRclient := xapp.NewRMRClientWithParams(&xapp.RMRClientParams{
StatDesc: "",
RmrData: xapp.PortData{
- //TODO: Read configuration from config file
- Name:
""
,
- MaxSize:
65534
,
- ThreadType:
0
,
- LowLatency:
false
,
- FastAck:
false
,
- MaxRetryOnFailure:
1
,
- Port:
4561
,
+
+ Name:
config.Name
,
+ MaxSize:
config.MaxSize
,
+ ThreadType:
config.ThreadType
,
+ LowLatency:
config.LowLatency
,
+ FastAck:
config.FastAck
,
+ MaxRetryOnFailure:
config.MaxRetryOnFailure
,
+ Port:
config.Port
,
},
})
},
})