SEBA-691: Changes in BBSIM startup
Change-Id: I72783c1c6259e39aaf91f56bf5460ed0b94436c2
diff --git a/core/openolt_service.go b/core/openolt_service.go
index 40d14e5..c34468a 100644
--- a/core/openolt_service.go
+++ b/core/openolt_service.go
@@ -70,9 +70,10 @@
return nil
}
-func sendOnuDiscInd(stream openolt.Openolt_EnableIndicationServer, onus []*device.Onu) error {
+func sendOnuDiscInd(stream openolt.Openolt_EnableIndicationServer, onus []*device.Onu, delay int) error {
for i, onu := range onus {
data := &openolt.Indication_OnuDiscInd{&openolt.OnuDiscIndication{IntfId: onu.IntfID, SerialNumber: onu.SerialNumber}}
+ time.Sleep(time.Duration(delay) * time.Millisecond)
if err := stream.Send(&openolt.Indication{Data: data}); err != nil {
logger.Error("Failed to send ONUDiscInd [id: %d]: %v", i, err)
return err
@@ -84,7 +85,7 @@
func sendOnuInd(stream openolt.Openolt_EnableIndicationServer, onus []*device.Onu, delay int) error {
for i, onu := range onus {
- time.Sleep(time.Duration(delay) * time.Millisecond)
+// time.Sleep(time.Duration(delay) * time.Millisecond)
data := &openolt.Indication_OnuInd{&openolt.OnuIndication{IntfId: onu.IntfID, OnuId: onu.OnuID, OperState: "up", AdminState: "up", SerialNumber: onu.SerialNumber}}
if err := stream.Send(&openolt.Indication{Data: data}); err != nil {
logger.Error("Failed to send ONUInd [id: %d]: %v", i, err)
@@ -94,3 +95,13 @@
}
return nil
}
+
+func sendOnuIndtoONU(stream openolt.Openolt_EnableIndicationServer, onu *device.Onu ) {
+ time.Sleep(time.Duration(10000) * time.Millisecond) //TODO:This sleep added because of a known race condition in VOLTHA. Can be removed after fix.
+ data := &openolt.Indication_OnuInd{&openolt.OnuIndication{IntfId: onu.IntfID, OnuId: onu.OnuID, OperState: "up", AdminState: "up", SerialNumber: onu.SerialNumber}}
+ if err := stream.Send(&openolt.Indication{Data: data}); err != nil {
+ logger.Error("Failed to send ONUInd [id: %d]: %v", onu.OnuID, err)
+ }
+ utils.LoggerWithOnu(onu).Info("sendONUInd Onuid")
+
+}