]> git.ipfire.org Git - thirdparty/pdns.git/commitdiff
ProtobufLogger: Add support for the ServerIdentity field 7004/head
authorRemi Gacogne <remi.gacogne@powerdns.com>
Fri, 28 Sep 2018 14:08:10 +0000 (16:08 +0200)
committerRemi Gacogne <remi.gacogne@powerdns.com>
Fri, 28 Sep 2018 14:11:32 +0000 (16:11 +0200)
contrib/ProtobufLogger.py

index 66f6d539396d23f1730e7180791224044e940d5b..7e9af015b8eda75877b3a952a4b941437313394a 100644 (file)
@@ -152,9 +152,14 @@ class PDNSPBConnHandler(object):
             protostr = 'TCP'
 
         messageidstr = binascii.hexlify(bytearray(msg.messageId))
+
+        serveridstr = 'N/A'
+        if msg.HasField('serverIdentity'):
+            serveridstr = msg.serverIdentity
+
         initialrequestidstr = ''
         if msg.HasField('initialRequestId'):
-            initialrequestidstr = ', initial uuid: ' + binascii.hexlify(bytearray(msg.initialRequestId))
+            initialrequestidstr = ', initial uuid: %s ' % (binascii.hexlify(bytearray(msg.initialRequestId)))
 
         requestorstr = ''
         requestor = self.getRequestorSubnet(msg)
@@ -165,7 +170,7 @@ class PDNSPBConnHandler(object):
         requestorId = msg.requestorId
 
         print('[%s] %s of size %d: %s%s -> %s (%s), id: %d, uuid: %s%s '
-                  'requestorid: %s deviceid: %s' % (datestr,
+                  'requestorid: %s deviceid: %s serverid: %s' % (datestr,
                                                     typestr,
                                                     msg.inBytes,
                                                     ipfromstr,
@@ -176,7 +181,8 @@ class PDNSPBConnHandler(object):
                                                     messageidstr,
                                                     initialrequestidstr,
                                                     requestorId,
-                                                    deviceId))
+                                                    deviceId,
+                                                    serveridstr))
 
     def getRequestorSubnet(self, msg):
         requestorstr = None