[geode] branch feature/GEM-1772 updated: GEM-1772: Added additional debugging

[boglesby]

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

boglesby pushed a commit to branch feature/GEM-1772
in repository https://gitbox.apache.org/repos/asf/geode.git


The following commit(s) were added to refs/heads/feature/GEM-1772 by this push:
     new 0483f40  GEM-1772: Added additional debugging
0483f40 is described below

commit 0483f402fd1aa8d279b8597f8fa9057a3cd00cb6
Author: Barry Oglesby <bogle...@pivotal.io>
AuthorDate: Wed Jun 20 18:20:42 2018 -0700

    GEM-1772: Added additional debugging
---
 .../apache/geode/distributed/internal/direct/DirectChannel.java    | 7 +++++++
 .../src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java   | 7 +++++++
 2 files changed, 14 insertions(+)

diff --git 
a/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
 
b/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
index 664b600..83abd90 100644
--- 
a/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
+++ 
b/geode-core/src/main/java/org/apache/geode/distributed/internal/direct/DirectChannel.java
@@ -342,6 +342,10 @@ public class DirectChannel {
         final List cons = new ArrayList(destinations.length);
         ConnectExceptions ce = getConnections(mgr, msg, destinations, 
orderedMsg, retry, ackTimeout,
             ackSDTimeout, cons);
+        if (msg instanceof DistributedPutAllOperation.PutAllMessage) {
+          logger
+              .warn("XXX DirectChannel sendToMany got connections=" + cons + 
"; exceptions=" + ce);
+        }
         if (directReply && msg.getProcessorId() > 0) { // no longer a 
direct-reply message?
           directReply = false;
         }
@@ -397,6 +401,9 @@ public class DirectChannel {
               startTime = System.currentTimeMillis();
             }
             ms.reserveConnections(startTime, ackTimeout, ackSDTimeout);
+            if (msg instanceof DistributedPutAllOperation.PutAllMessage) {
+              logger.warn("XXX DirectChannel sendToMany reserved connections");
+            }
 
             int result = ms.writeMessage();
             if (bytesWritten == 0) {
diff --git 
a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java 
b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java
index af54679..59dc3b3 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamer.java
@@ -37,6 +37,7 @@ import org.apache.geode.internal.HeapDataOutputStream;
 import org.apache.geode.internal.InternalDataSerializer;
 import org.apache.geode.internal.ObjToByteArraySerializer;
 import org.apache.geode.internal.Version;
+import org.apache.geode.internal.cache.DistributedPutAllOperation;
 import org.apache.geode.internal.i18n.LocalizedStrings;
 import org.apache.geode.internal.logging.LogService;
 
@@ -313,8 +314,14 @@ public class MsgStreamer extends OutputStream
     for (Iterator it = this.cons.iterator(); it.hasNext();) {
       Connection con = (Connection) it.next();
       try {
+        if (this.msg instanceof DistributedPutAllOperation.PutAllMessage) {
+          logger.warn("XXX MsgStreamer realFlush about to write con=" + con + 
"; msg=" + this.msg);
+        }
         con.sendPreserialized(this.buffer,
             lastFlushForMessage && this.msg.containsRegionContentChange(), 
conflationMsg);
+        if (this.msg instanceof DistributedPutAllOperation.PutAllMessage) {
+          logger.warn("XXX MsgStreamer realFlush completed write con=" + con + 
"; msg=" + this.msg);
+        }
       } catch (IOException ex) {
         it.remove();
         if (this.ce == null)