From: Jelte Jansen <jelte@isc.org>
Date: Mon, 24 Oct 2011 08:38:43 +0000 (+0200)
Subject: [1180] address review comments
X-Git-Tag: perftcpdns_before_epoll~35^2~26^2
X-Git-Url: http://git.ipfire.org/gitweb.cgi?a=commitdiff_plain;h=ad134a3c515577b5fbff5d05733bdf8d4265fb45;p=thirdparty%2Fkea.git

[1180] address review comments
---

diff --git a/src/bin/msgq/msgq.py.in b/src/bin/msgq/msgq.py.in
index 28a54f9cb2..333ae896d8 100755
--- a/src/bin/msgq/msgq.py.in
+++ b/src/bin/msgq/msgq.py.in
@@ -28,7 +28,6 @@ import struct
 import errno
 import time
 import select
-import pprint
 import random
 from optparse import OptionParser, OptionValueError
 import isc.util.process
@@ -293,9 +292,6 @@ class MsgQ:
             sys.stderr.write("[b10-msgq] Routing decode error: %s\n" % err)
             return
 
-#        sys.stdout.write("\t" + pprint.pformat(routingmsg) + "\n")
-#        sys.stdout.write("\t" + pprint.pformat(data) + "\n")
-
         self.process_command(fd, sock, routingmsg, data)
 
     def process_command(self, fd, sock, routing, data):
@@ -363,7 +359,8 @@ class MsgQ:
                 # in the case the other side seems gone, kill the socket
                 # and drop the send action
                 if sockerr.errno == errno.EPIPE:
-                    print("[b10-msgq] SIGPIPE on send, dropping message")
+                    print("[b10-msgq] SIGPIPE on send, dropping message " +
+                          "and closing connection")
                     self.kill_socket(fileno, sock)
                     return
                 else: