Stopping OLT gRPC server only after all indications have been sent
Change-Id: I9de1bd5783fad5fa96b50e48dcb973506b841a49
diff --git a/internal/bbsim/devices/onu.go b/internal/bbsim/devices/onu.go
index 0f04039..a73841c 100644
--- a/internal/bbsim/devices/onu.go
+++ b/internal/bbsim/devices/onu.go
@@ -342,6 +342,12 @@
"stream": stream,
}).Debug("Starting ONU Indication Channel")
+ defer onuLogger.WithFields(log.Fields{
+ "onuID": o.ID,
+ "onuSN": o.Sn(),
+ "stream": stream,
+ }).Debug("Stopped handling ONU Indication Channel")
+
loop:
for {
select {
@@ -493,11 +499,6 @@
}
}
}
- onuLogger.WithFields(log.Fields{
- "onuID": o.ID,
- "onuSN": o.Sn(),
- "stream": stream,
- }).Debug("Stopped handling ONU Indication Channel")
}
func NewSN(oltid int, intfid uint32, onuid uint32) *openolt.SerialNumber {