Code Review
/
ric-plt
/
xapp-frame.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Add new interfaces
[ric-plt/xapp-frame.git]
/
pkg
/
xapp
/
rmr.go
diff --git
a/pkg/xapp/rmr.go
b/pkg/xapp/rmr.go
index
a4955d1
..
c835408
100755
(executable)
--- a/
pkg/xapp/rmr.go
+++ b/
pkg/xapp/rmr.go
@@
-55,13
+55,14
@@
var RMRCounterOpts = []CounterOpts{
type RMRStatistics struct{}
type RMRClient struct {
type RMRStatistics struct{}
type RMRClient struct {
- context unsafe.Pointer
- ready int
- wg sync.WaitGroup
- mux sync.Mutex
- stat map[string]Counter
- consumers []MessageConsumer
- readyCb ReadyCB
+ context unsafe.Pointer
+ ready int
+ wg sync.WaitGroup
+ mux sync.Mutex
+ stat map[string]Counter
+ consumers []MessageConsumer
+ readyCb ReadyCB
+ readyCbParams interface{}
}
type MessageConsumer interface {
}
type MessageConsumer interface {
@@
-105,7
+106,7
@@
func (m *RMRClient) Start(c MessageConsumer) {
}
if m.readyCb != nil {
}
if m.readyCb != nil {
- m.readyCb()
+ m.readyCb(
m.readyCbParams
)
}
m.Wait()
}
m.Wait()
@@
-216,8
+217,9
@@
func (m *RMRClient) IsReady() bool {
return m.ready != 0
}
return m.ready != 0
}
-func (m *RMRClient) SetReadyCB(cb ReadyCB) {
+func (m *RMRClient) SetReadyCB(cb ReadyCB
, params interface{}
) {
m.readyCb = cb
m.readyCb = cb
+ m.readyCbParams = params
}
func (m *RMRClient) GetRicMessageId(name string) (int, bool) {
}
func (m *RMRClient) GetRicMessageId(name string) (int, bool) {