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
Subscription manager v0.10.0
[ric-plt/submgr.git]
/
test
/
rco
/
rco.go
diff --git
a/test/rco/rco.go
b/test/rco/rco.go
index
6ba36d0
..
21062eb
100644
(file)
--- a/
test/rco/rco.go
+++ b/
test/rco/rco.go
@@
-59,7
+59,11
@@
func init() {
if SEEDSN == 0 || SEEDSN > 65535 {
SEEDSN = 12345
}
if SEEDSN == 0 || SEEDSN > 65535 {
SEEDSN = 12345
}
- DELETESEEDSN = SEEDSN
+ DELETESEEDSN = uint16(viper.GetInt("delete_seed_sn"))
+ if DELETESEEDSN == 0 || DELETESEEDSN > 65535 {
+ DELETESEEDSN = SEEDSN
+ }
+
xapp.Logger.Info("Initial SEQUENCE NUMBER: %v", SEEDSN)
}
xapp.Logger.Info("Initial SEQUENCE NUMBER: %v", SEEDSN)
}
@@
-77,9
+81,7
@@
func (r *Rco) GenerateDeletePayload(sub_id uint16) (payload []byte, err error) {
if err != nil {
return make([]byte, 0), errors.New("Unable to decode data provided in RCO_DELETE RAWDATA environment variable")
}
if err != nil {
return make([]byte, 0), errors.New("Unable to decode data provided in RCO_DELETE RAWDATA environment variable")
}
- xapp.Logger.Info("SetSubscriptionDeleteRequestSequenceNumber1")
payload, err = r.SetSubscriptionDeleteRequestSequenceNumber(skeleton, sub_id)
payload, err = r.SetSubscriptionDeleteRequestSequenceNumber(skeleton, sub_id)
- xapp.Logger.Info("SetSubscriptionDeleteRequestSequenceNumber2")
return
}
return
}
@@
-106,6
+108,7
@@
func (r *Rco) SendRequests() (err error) {
for {
time.Sleep(2 * time.Second)
c <- submgr.RmrDatagram{12010, SEEDSN, message}
for {
time.Sleep(2 * time.Second)
c <- submgr.RmrDatagram{12010, SEEDSN, message}
+ SEEDSN++
time.Sleep(2 * time.Second)
c <- submgr.RmrDatagram{12020, DELETESEEDSN, deletemessage}
DELETESEEDSN++
time.Sleep(2 * time.Second)
c <- submgr.RmrDatagram{12020, DELETESEEDSN, deletemessage}
DELETESEEDSN++
@@
-118,7
+121,7
@@
func (r *Rco) Run() {
message := <-c
payload_seq_num, err := r.GetSubscriptionRequestSequenceNumber(message.Payload)
if err != nil {
message := <-c
payload_seq_num, err := r.GetSubscriptionRequestSequenceNumber(message.Payload)
if err != nil {
- xapp.Logger.Debug("Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
+ xapp.Logger.Debug("Unable to get Subscription Sequence Number from Payload due to: " + err.Error())
}
params.SubId = int(message.SubscriptionId)
params.Mtype = message.MessageType
}
params.SubId = int(message.SubscriptionId)
params.Mtype = message.MessageType