[VOL-4291] OfAgent changes for gRPC migration
Change-Id: I8da1db6df49d478ef24ec8f9bd719e9692f48a7f
diff --git a/internal/pkg/openflow/flowMod.go b/internal/pkg/openflow/flowMod.go
index 4f8ab63..fd71798 100644
--- a/internal/pkg/openflow/flowMod.go
+++ b/internal/pkg/openflow/flowMod.go
@@ -20,11 +20,12 @@
"context"
"encoding/binary"
"encoding/json"
- ofp "github.com/opencord/goloxi/of13"
- "github.com/opencord/voltha-lib-go/v5/pkg/log"
- "github.com/opencord/voltha-protos/v4/go/openflow_13"
- "github.com/opencord/voltha-protos/v4/go/voltha"
"net"
+
+ ofp "github.com/opencord/goloxi/of13"
+ "github.com/opencord/voltha-lib-go/v7/pkg/log"
+ "github.com/opencord/voltha-protos/v5/go/openflow_13"
+ "github.com/opencord/voltha-protos/v5/go/voltha"
)
var oxmMap = map[string]int32{
@@ -253,12 +254,11 @@
Xid: flowAdd.Xid,
}
if logger.V(log.DebugLevel) {
- flowUpdateJs, _ := json.Marshal(flowUpdate)
- logger.Debugf(ctx, "FlowAdd being sent to Voltha",
+ logger.Debugw(ctx, "FlowAdd being sent to Voltha",
log.Fields{
- "device-id": ofc.DeviceID,
- "flow-mod-object": flowUpdate,
- "flow-mod-request": flowUpdateJs})
+ "device-id": ofc.DeviceID,
+ "flow-mod-object": flowUpdate,
+ })
}
if _, err := volthaClient.UpdateLogicalDeviceFlowTable(log.WithSpanFromContext(context.Background(), ctx), &flowUpdate); err != nil {
logger.Errorw(ctx, "Error calling FlowAdd ",