Return on failed indications
Change-Id: I7f8b014927367527aad88db45e01d0d4ae389739
diff --git a/internal/bbsim/devices/olt.go b/internal/bbsim/devices/olt.go
index bde98cb..c249f62 100644
--- a/internal/bbsim/devices/olt.go
+++ b/internal/bbsim/devices/olt.go
@@ -365,6 +365,7 @@
data := &openolt.Indication_OltInd{OltInd: &openolt.OltIndication{OperState: msg.OperState.String()}}
if err := stream.Send(&openolt.Indication{Data: data}); err != nil {
oltLogger.Errorf("Failed to send Indication_OltInd: %v", err)
+ return
}
oltLogger.WithFields(log.Fields{
@@ -384,6 +385,7 @@
if err := stream.Send(&openolt.Indication{Data: operData}); err != nil {
oltLogger.Errorf("Failed to send Indication_IntfOperInd for NNI: %v", err)
+ return
}
oltLogger.WithFields(log.Fields{
@@ -403,6 +405,7 @@
if err := stream.Send(&openolt.Indication{Data: discoverData}); err != nil {
oltLogger.Errorf("Failed to send Indication_IntfInd: %v", err)
+ return
}
oltLogger.WithFields(log.Fields{
@@ -418,6 +421,7 @@
if err := stream.Send(&openolt.Indication{Data: operData}); err != nil {
oltLogger.Errorf("Failed to send Indication_IntfOperInd for PON: %v", err)
+ return
}
oltLogger.WithFields(log.Fields{