commit 741d50de0ae092e5ff0c78cfc66a5afc10f05dfe
author Wailok Shum <wailok@opennetworking.org> Wed Dec 15 23:11:15 2021 +0800
committer Charles Chan <charles@opennetworking.org> Fri Dec 17 19:11:34 2021 +0000
tree 41b07a5ce3358e7dc055f879686a7f0dc056ba1d
parent 95f124892cc601215e3eb9f9b77550f957fde736

[SDFAB-820] Improve error logging in StreamClientImpl

Change-Id: I93a737f31432743f20917b8c85dd54d8b81eee62

protocols/p4runtime/ctl/src/main/java/org/onosproject/p4runtime/ctl/client/StreamClientImpl.java

diff --git a/protocols/p4runtime/ctl/src/main/java/org/onosproject/p4runtime/ctl/client/StreamClientImpl.java b/protocols/p4runtime/ctl/src/main/java/org/onosproject/p4runtime/ctl/client/StreamClientImpl.java
index b2516b4..5d227e4 100644
--- a/protocols/p4runtime/ctl/src/main/java/org/onosproject/p4runtime/ctl/client/StreamClientImpl.java
+++ b/protocols/p4runtime/ctl/src/main/java/org/onosproject/p4runtime/ctl/client/StreamClientImpl.java
@@ -445,6 +445,12 @@
                     case ARBITRATION:
                         handleArbitrationUpdate(message.getArbitration());
                         return;
+                    case ERROR:
+                        P4RuntimeOuterClass.StreamError error = message.getError();
+                        log.warn("Receive stream error {} from {} Canonical Code: {} Message: {} Space: {} Code: {}",
+                                error.getDetailsCase(), deviceId, error.getCanonicalCode(), error.getMessage(),
+                                error.getSpace(), error.getCode());
+                        return;
                     default:
                         log.warn("Unrecognized StreamMessageResponse from {}: {}",
                                  deviceId, message.getUpdateCase());