commit 9f9facafc64002d468afa4d71cbe0801c91471ec
author Onur Kalinagac <onur.kalinagac@netsia.com> Thu Jan 21 14:04:34 2021 +0000
committer onurka <onur.kalinagac@netsia.com> Mon Jan 25 09:58:42 2021 +0300
tree edac0c866efb35c72fde82f33271c45a3b49956d
parent 13dd58bd6166067a9dd784df4c559e747c85914f

IP parameter added to ONU IGMP join/leave cli command

Change-Id: I1d821950deacba1d82d47731e644b917f3a6d7ed

internal/bbsim/api/onus_handler.go

diff --git a/internal/bbsim/api/onus_handler.go b/internal/bbsim/api/onus_handler.go
index 3c84380..43b624f 100644
--- a/internal/bbsim/api/onus_handler.go
+++ b/internal/bbsim/api/onus_handler.go
@@ -231,8 +231,9 @@
 	res := &bbsim.Response{}
 
 	logger.WithFields(log.Fields{
-		"OnuSn":     req.OnuReq.SerialNumber,
-		"subAction": req.SubActionVal,
+		"OnuSn":        req.OnuReq.SerialNumber,
+		"subAction":    req.SubActionVal,
+		"GroupAddress": req.GroupAddress,
 	}).Infof("Received igmp request for ONU")
 
 	olt := devices.GetOLT()
@@ -269,7 +270,7 @@
 					"Service": service.Name,
 				}).Debugf("Sending %s event on Service %s", event, service.Name)
 
-				if err := service.IGMPState.Event(event); err != nil {
+				if err := service.IGMPState.Event(event, devices.IgmpMessage{GroupAddress: req.GroupAddress}); err != nil {
 					logger.WithFields(log.Fields{
 						"OnuId":   onu.ID,
 						"IntfId":  onu.PonPortID,