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
commit 9157dd23b2db58e6cd2a02a71fef9aab2dab7982 Author: Barry Oglesby <[email protected]> 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)
