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
Added duplicate detection changes
[ric-plt/submgr.git]
/
pkg
/
control
/
registry.go
diff --git
a/pkg/control/registry.go
b/pkg/control/registry.go
index
671cf51
..
2495d3b
100644
(file)
--- a/
pkg/control/registry.go
+++ b/
pkg/control/registry.go
@@
-40,13
+40,29
@@
type RESTSubscription struct {
xAppIdToE2Id map[int64]int64
SubReqOngoing bool
SubDelReqOngoing bool
xAppIdToE2Id map[int64]int64
SubReqOngoing bool
SubDelReqOngoing bool
-
Md5sum
string
+
lastReqMd5sum
string
}
func (r *RESTSubscription) AddE2InstanceId(instanceId uint32) {
}
func (r *RESTSubscription) AddE2InstanceId(instanceId uint32) {
+
+ for _, v := range r.InstanceIds {
+ if v == instanceId {
+ return
+ }
+
+ }
+
r.InstanceIds = append(r.InstanceIds, instanceId)
}
r.InstanceIds = append(r.InstanceIds, instanceId)
}
+func (r *RESTSubscription) AddMd5Sum(md5sum string) {
+ if md5sum != "" {
+ r.lastReqMd5sum = md5sum
+ } else {
+ xapp.Logger.Error("EMPTY md5sum attempted to be add to subscrition")
+ }
+}
+
func (r *RESTSubscription) DeleteE2InstanceId(instanceId uint32) {
r.InstanceIds = r.InstanceIds[1:]
}
func (r *RESTSubscription) DeleteE2InstanceId(instanceId uint32) {
r.InstanceIds = r.InstanceIds[1:]
}
@@
-63,9
+79,11
@@
func (r *RESTSubscription) DeleteXappIdToE2Id(xAppEventInstanceID int64) {
delete(r.xAppIdToE2Id, xAppEventInstanceID)
}
delete(r.xAppIdToE2Id, xAppEventInstanceID)
}
-func (r *RESTSubscription) SetProcessed() {
+func (r *RESTSubscription) SetProcessed(
err error
) {
r.SubReqOngoing = false
r.SubReqOngoing = false
- r.Md5sum = ""
+ if err != nil {
+ r.lastReqMd5sum = ""
+ }
}
type Registry struct {
}
type Registry struct {