[calcite-avatica] branch master updated: [CALCITE-4962] Protobuf debug does not show request/response type

[xiong]

This is an automated email from the ASF dual-hosted git repository.

xiong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/calcite-avatica.git


The following commit(s) were added to refs/heads/master by this push:
     new e9d14a6  [CALCITE-4962] Protobuf debug does not show request/response 
type
e9d14a6 is described below

commit e9d14a684a54cadc0d6feca2b8aae08e7152a705
Author: Marco Jorge <marco.jo...@outsystems.com>
AuthorDate: Thu Dec 23 12:17:02 2021 -0500

    [CALCITE-4962] Protobuf debug does not show request/response type
---
 .../avatica/remote/ProtobufTranslationImpl.java    | 24 ++++++++++++++++++----
 1 file changed, 20 insertions(+), 4 deletions(-)

diff --git 
a/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
 
b/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
index eb616a2..7686223 100644
--- 
a/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
+++ 
b/core/src/main/java/org/apache/calcite/avatica/remote/ProtobufTranslationImpl.java
@@ -105,7 +105,11 @@ public class ProtobufTranslationImpl implements 
ProtobufTranslation {
       // This should already be an aliased CodedInputStream from the 
WireMessage parsing.
       Message msg = parser.parseFrom(serializedMessage.newCodedInput());
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Deserialized request '{}'", 
TextFormat.shortDebugString(msg));
+        LOG.trace(
+            "Deserialized {} '{}'",
+            msg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(msg)
+        );
       }
       return impl.deserialize(msg);
     }
@@ -129,7 +133,11 @@ public class ProtobufTranslationImpl implements 
ProtobufTranslation {
         InvalidProtocolBufferException {
       Message msg = parser.parseFrom(serializedMessage);
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Deserialized response '{}'", 
TextFormat.shortDebugString(msg));
+        LOG.trace(
+            "Deserialized {} '{}'",
+            msg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(msg)
+        );
       }
       return impl.deserialize(msg);
     }
@@ -348,7 +356,11 @@ public class ProtobufTranslationImpl implements 
ProtobufTranslation {
       Message responseMsg = response.serialize();
       // Serialization of the response may be large
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Serializing response '{}'", 
TextFormat.shortDebugString(responseMsg));
+        LOG.trace(
+            "Serializing {} '{}'",
+            responseMsg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(responseMsg)
+        );
       }
       serializeMessage(out, responseMsg);
       return out.toArray();
@@ -364,7 +376,11 @@ public class ProtobufTranslationImpl implements 
ProtobufTranslation {
       Message requestMsg = request.serialize();
       // Serialization of the request may be large
       if (LOG.isTraceEnabled()) {
-        LOG.trace("Serializing request '{}'", 
TextFormat.shortDebugString(requestMsg));
+        LOG.trace(
+            "Serializing {} '{}'",
+            requestMsg.getClass().getSimpleName(),
+            TextFormat.shortDebugString(requestMsg)
+        );
       }
       serializeMessage(out, requestMsg);
       return out.toArray();