X-Git-Url: https://gerrit.o-ran-sc.org/r/gitweb?a=blobdiff_plain;f=test%2Frco%2Frco.go;h=21062eb6017432ccc57ca7ec2cd4e59a6102fd07;hb=e00186861608731e2390055a0e1b1cf455670508;hp=6ba36d0868420aea36aefb8a7c8652980ba11641;hpb=e9608cd4ebb86e569dbc74978689fb8104a0d493;p=ric-plt%2Fsubmgr.git

diff --git a/test/rco/rco.go b/test/rco/rco.go
index 6ba36d0..21062eb 100644
--- a/test/rco/rco.go
+++ b/test/rco/rco.go
@@ -59,7 +59,11 @@ func init() {
 	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)
 }
 
@@ -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")
 	}
-	xapp.Logger.Info("SetSubscriptionDeleteRequestSequenceNumber1")
 	payload, err = r.SetSubscriptionDeleteRequestSequenceNumber(skeleton, sub_id)
-	xapp.Logger.Info("SetSubscriptionDeleteRequestSequenceNumber2")
 	return
 }
 
@@ -106,6 +108,7 @@ func (r *Rco) SendRequests() (err error) {
 	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++
@@ -118,7 +121,7 @@ func (r *Rco) Run() {
 		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