Added additional logging

belugabehr · belugabehr · commit 2793db2f1a4b · 2019-10-10T14:57:06.000-04:00
diff --git a/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java b/zookeeper-server/src/main/java/org/apache/zookeeper/server/quorum/QuorumCnxManager.java
@@ -1233,6 +1233,7 @@ private void addToSendQueue(final BlockingQueue<ByteBuffer> queue,
         final ByteBuffer buffer) {
         final boolean success = queue.offer(buffer);
         if (!success) {
+            LOG.debug("Could not insert buffer into queue. Discarding one.");
             queue.poll();
             queue.offer(buffer);
         }
@@ -1245,7 +1246,7 @@ private void addToSendQueue(final BlockingQueue<ByteBuffer> queue,
      * @return
      *      true if the specified queue is empty
      */
-    private boolean isSendQueueEmpty(BlockingQueue<ByteBuffer> queue) {
+    private boolean isSendQueueEmpty(final BlockingQueue<ByteBuffer> queue) {
         return queue.isEmpty();
     }
 
@@ -1285,6 +1286,7 @@ public void addToRecvQueue(final Message msg) {
         synchronized (this.recvQueue) {
             final boolean success = this.recvQueue.offer(msg);
             if (!success) {
+              LOG.debug("Could not insert buffer into recv queue. Discarding one.");
               this.recvQueue.poll();
               this.recvQueue.offer(msg);
             }
