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
v0.11.0 tag. Initial working version with dynamic routing
[ric-plt/submgr.git]
/
pkg
/
control
/
client.go
diff --git
a/pkg/control/client.go
b/pkg/control/client.go
index
14e2455
..
adbe48f
100644
(file)
--- a/
pkg/control/client.go
+++ b/
pkg/control/client.go
@@
-35,14
+35,10
@@
type RtmgrClient struct {
xappDeleteParams *rtmgrhandle.DeleteXappSubscriptionHandleParams
}
xappDeleteParams *rtmgrhandle.DeleteXappSubscriptionHandleParams
}
-func (rc *RtmgrClient) SubscriptionRequestUpdate() error {
+func (rc *RtmgrClient) SubscriptionRequestUpdate(
subRouteAction SubRouteInfo
) error {
xapp.Logger.Debug("SubscriptionRequestUpdate() invoked")
xapp.Logger.Debug("SubscriptionRequestUpdate() invoked")
- subRouteAction := <-SubscriptionReqChan
- // Routing manager handles subscription id as int32 to accomodate -1 and uint16 values
subID := int32(subRouteAction.SubID)
subID := int32(subRouteAction.SubID)
-
- xapp.Logger.Debug("Subscription action details received: ", subRouteAction)
-
+ xapp.Logger.Debug("Subscription action details received. subRouteAction.Command: %v, Address %s, Port %v, subID %v", int16(subRouteAction.Command), subRouteAction.Address, subRouteAction.Port, subID)
xappSubReq := rtmgr_models.XappSubscriptionData{&subRouteAction.Address, &subRouteAction.Port, &subID}
switch subRouteAction.Command {
xappSubReq := rtmgr_models.XappSubscriptionData{&subRouteAction.Address, &subRouteAction.Port, &subID}
switch subRouteAction.Command {
@@
-65,6
+61,7
@@
func (rc *RtmgrClient) SubscriptionRequestUpdate() error {
return nil
}
default:
return nil
}
default:
+ xapp.Logger.Debug("Unknown subRouteAction.Command: %v, Address %s, Port %v, subID: %v", subRouteAction.Command, subRouteAction.Address, subRouteAction.Port, subID)
return nil
}
}
return nil
}
}