Chaging some log levels for better packet tracing
Adding flows and groups informations on:
- flow-add-failed
- failed-to-add-flows-will-attempt-deletion
Change-Id: I5b0e124f617b41590173ee9cb2dc8d31de5aff16
(cherry picked from commit 5bd2f6f28674e64286c4795ba3b3432ecab0879d)
diff --git a/rw_core/core/device/logical_agent.go b/rw_core/core/device/logical_agent.go
index 7bfa264..73bd37f 100644
--- a/rw_core/core/device/logical_agent.go
+++ b/rw_core/core/device/logical_agent.go
@@ -229,7 +229,13 @@
defer cancel()
start := time.Now()
if err := agent.deviceMgr.addFlowsAndGroups(subCtx, deviceId, value.ListFlows(), value.ListGroups(), flowMetadata); err != nil {
- logger.Errorw(ctx, "flow-add-failed", log.Fields{"deviceID": deviceId, "error": err, "wait-time": time.Since(start)})
+ logger.Errorw(ctx, "flow-add-failed", log.Fields{
+ "deviceID": deviceId,
+ "error": err,
+ "wait-time": time.Since(start),
+ "flows": value.ListFlows(),
+ "groups": value.ListGroups(),
+ })
response.Error(status.Errorf(codes.Internal, "flow-add-failed: %s", deviceId))
}
response.Done()
@@ -317,10 +323,12 @@
}
func (agent *LogicalAgent) packetOut(ctx context.Context, packet *ofp.OfpPacketOut) {
- logger.Debugw(ctx, "packet-out", log.Fields{
- "packet": hex.EncodeToString(packet.Data),
- "inPort": packet.GetInPort(),
- })
+ if logger.V(log.InfoLevel) {
+ logger.Infow(ctx, "packet-out", log.Fields{
+ "packet": hex.EncodeToString(packet.Data),
+ "inPort": packet.GetInPort(),
+ })
+ }
outPort := fu.GetPacketOutPort(packet)
//frame := packet.GetData()
//TODO: Use a channel between the logical agent and the device agent
@@ -330,11 +338,14 @@
}
func (agent *LogicalAgent) packetIn(ctx context.Context, port uint32, transactionID string, packet []byte) {
- logger.Debugw(ctx, "packet-in", log.Fields{
- "port": port,
- "packet": hex.EncodeToString(packet),
- "transactionId": transactionID,
- })
+ if logger.V(log.InfoLevel) {
+ logger.Infow(ctx, "packet-in", log.Fields{
+ "port": port,
+ "packet": hex.EncodeToString(packet),
+ "transactionId": transactionID,
+ })
+ }
+
packetIn := fu.MkPacketIn(port, packet)
agent.ldeviceMgr.SendPacketIn(ctx, agent.logicalDeviceID, transactionID, packetIn)
logger.Debugw(ctx, "sending-packet-in", log.Fields{"packet": hex.EncodeToString(packetIn.Data)})
diff --git a/rw_core/core/device/logical_agent_flow.go b/rw_core/core/device/logical_agent_flow.go
index 224b1f4..53209a1 100644
--- a/rw_core/core/device/logical_agent_flow.go
+++ b/rw_core/core/device/logical_agent_flow.go
@@ -168,10 +168,20 @@
go func() {
// Wait for completion
if res := coreutils.WaitForNilOrErrorResponses(agent.defaultTimeout, respChannels...); res != nil {
- logger.Infow(ctx, "failed-to-add-flows-will-attempt-deletion", log.Fields{"errors": res, "logical-device-id": agent.logicalDeviceID})
+ logger.Infow(ctx, "failed-to-add-flows-will-attempt-deletion", log.Fields{
+ "errors": res,
+ "logical-device-id": agent.logicalDeviceID,
+ "flows": flows,
+ "groups": groups,
+ })
// Revert added flows
if err := agent.revertAddedFlows(log.WithSpanFromContext(context.Background(), ctx), mod, flow, flowToReplace, deviceRules, toMetadata(flowMeterConfig)); err != nil {
- logger.Errorw(ctx, "failure-to-delete-flows-after-failed-addition", log.Fields{"logical-device-id": agent.logicalDeviceID, "error": err})
+ logger.Errorw(ctx, "failure-to-delete-flows-after-failed-addition", log.Fields{
+ "error": err,
+ "logical-device-id": agent.logicalDeviceID,
+ "flows": flows,
+ "groups": groups,
+ })
}
}
}()