Revert "[VOL-4102] Adding exponential backoff to retry reconnection in case of a"
This reverts commit 66fbaf55ddb256bb84be1b907d4f12071bfac052.
Reason for revert: It should not be needed to try to reconnect the stream on a gRPC disconnect as the gRPC should be trying to reconnect under the hood. This needs more investigation but it's breaking the soft-reboot scenario so it's reverted for now.
Change-Id: I14d4b6f3a76d2feefe6e52f0736061de18d53206
diff --git a/internal/pkg/core/openolt_flowmgr.go b/internal/pkg/core/openolt_flowmgr.go
index 3cc00c7..eb35925 100644
--- a/internal/pkg/core/openolt_flowmgr.go
+++ b/internal/pkg/core/openolt_flowmgr.go
@@ -2136,10 +2136,7 @@
//RemoveFlow removes the flow from the device
func (f *OpenOltFlowMgr) RemoveFlow(ctx context.Context, flow *ofp.OfpFlowStats) error {
- logger.Infow(ctx, "removing-flow", log.Fields{
- "flow": *flow,
- "device-id": f.deviceHandler.device.Id,
- })
+ logger.Infow(ctx, "removing-flow", log.Fields{"flow": *flow})
var direction string
actionInfo := make(map[string]interface{})
@@ -2252,9 +2249,7 @@
logger.Infow(ctx, "adding-flow",
log.Fields{
"flow": flow,
- "flowmetadata": flowMetadata,
- "device-id": f.deviceHandler.device.Id,
- })
+ "flowmetadata": flowMetadata})
formulateClassifierInfoFromFlow(ctx, classifierInfo, flow)
err := formulateActionInfoFromFlow(ctx, actionInfo, classifierInfo, flow)