This is an automated email from the ASF dual-hosted git repository.
bschuchardt pushed a commit to branch feature/GEODE-8020b
in repository https://gitbox.apache.org/repos/asf/geode.git
The following commit(s) were added to refs/heads/feature/GEODE-8020b by this
push:
new 5a66aa5 debugging
5a66aa5 is described below
commit 5a66aa5999691be290d1708437ef038c1f9365cc
Author: Bruce Schuchardt <[email protected]>
AuthorDate: Thu Apr 30 10:52:32 2020 -0700
debugging
---
.../distributed/internal/ClusterDistributionManager.java | 4 ++--
.../main/java/org/apache/geode/internal/net/BufferPool.java | 8 ++++----
.../java/org/apache/geode/internal/net/NioSslEngine.java | 2 ++
.../main/java/org/apache/geode/internal/tcp/Connection.java | 13 +++++++++----
.../java/org/apache/geode/internal/tcp/MsgStreamerList.java | 1 +
5 files changed, 18 insertions(+), 10 deletions(-)
diff --git
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
index 022fa59..184ea11 100644
---
a/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
+++
b/geode-core/src/main/java/org/apache/geode/distributed/internal/ClusterDistributionManager.java
@@ -609,8 +609,8 @@ public class ClusterDistributionManager implements
DistributionManager {
if (member != getDistributionManagerId()) {
String relationship = areInSameZone(getDistributionManagerId(), member)
? "" : "not ";
Object[] logArgs = new Object[] {member, relationship};
- logger.info("Member {} is {} equivalent or in the same redundancy zone.",
- logArgs);
+ logger.info("Member {} is {}equivalent or in the same redundancy zone.",
+ logArgs, relationship);
}
}
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/net/BufferPool.java
b/geode-core/src/main/java/org/apache/geode/internal/net/BufferPool.java
index 80a09a7..821ade8 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/net/BufferPool.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/net/BufferPool.java
@@ -92,7 +92,7 @@ public class BufferPool {
} else if (bb.capacity() >= size) {
bb.rewind();
bb.limit(size);
-// logger.warn("BRUCE: acquiring pooled buffer {} hash {}", bb,
Integer.toHexString(System.identityHashCode(bb)));
+ logger.warn("BRUCE: acquiring pooled buffer {} hash {}", bb,
Integer.toHexString(System.identityHashCode(bb)));
return bb;
} else {
@@ -111,8 +111,8 @@ public class BufferPool {
ref = bufferQueue.poll();
}
result = ByteBuffer.allocateDirect(size);
-// logger.warn("BRUCE: allocating new pooled buffer {} hash {}", result,
Integer.toHexString(System.identityHashCode(result)));
-// logger.warn("BRUCE: ", new Exception("stack trace"));
+ logger.warn("BRUCE: allocating new pooled buffer {} hash {}", result,
Integer.toHexString(System.identityHashCode(result)));
+ logger.warn("BRUCE: ", new Exception("stack trace"));
} else {
// if we are using heap buffers then don't bother with keeping them
around
result = ByteBuffer.allocate(size);
@@ -236,7 +236,7 @@ public class BufferPool {
private void releaseBuffer(ByteBuffer bb, boolean send) {
if (bb.isDirect()) {
BBSoftReference bbRef = new BBSoftReference(bb, send);
-// logger.warn("BRUCE: releasing pooled buffer {} hash {}", bb,
Integer.toHexString(System.identityHashCode(bb)));
+ logger.warn("BRUCE: releasing pooled buffer {} hash {}", bb,
Integer.toHexString(System.identityHashCode(bb)));
bufferQueue.offer(bbRef);
} else {
if (send) {
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
b/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
index d948ae7..684b22e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/net/NioSslEngine.java
@@ -269,6 +269,8 @@ public class NioSslEngine implements NioFilter {
peerAppData.limit(peerAppData.capacity());
while (wrappedBuffer.hasRemaining()) {
+// logger.warn("BRUCE: unwrapping buffer {} hash {}",
+// wrappedBuffer,
Integer.toHexString(System.identityHashCode(wrappedBuffer)));
SSLEngineResult unwrapResult = engine.unwrap(wrappedBuffer, peerAppData);
switch (unwrapResult.getStatus()) {
case BUFFER_OVERFLOW:
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
b/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
index 1723e09..0c6692e 100644
--- a/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
+++ b/geode-core/src/main/java/org/apache/geode/internal/tcp/Connection.java
@@ -1595,7 +1595,9 @@ public class Connection implements Runnable {
}
int amountRead;
if (!isInitialRead) {
+ String bufferString = buff.toString();
amountRead = channel.read(buff);
+ logger.info("BRUCE: read {} bytes into {} which is now {}",
amountRead, bufferString, buff);
} else {
isInitialRead = false;
if (!skipInitialRead) {
@@ -1861,6 +1863,8 @@ public class Connection implements Runnable {
originalState = connectionState;
connectionState = STATE_SENDING;
}
+ logger.info("BRUCE: sendPreserialized writing {} hash {} to {} on local
port {} remote port {}",
+ buffer, Integer.toHexString(System.identityHashCode(buffer)),
remoteAddr, socket.getLocalPort(), socket.getPort());
socketInUse = true;
try {
SocketChannel channel = getSocket().getChannel();
@@ -2729,9 +2733,10 @@ public class Connection implements Runnable {
try {
peerDataBuffer = ioFilter.unwrap(inputBuffer);
} catch (SSLException e) {
-// if (e.getMessage().contains("bad record MAC")) {
-// logger.warn("BRUCE: exception unwrapping buffer {} hash {}",
inputBuffer, Integer.toHexString(System.identityHashCode(inputBuffer)));
-// }
+ if (e.getMessage().contains("bad record MAC")) {
+ logger.warn("BRUCE: exception unwrapping buffer {} hash {}
socket.isclosed {}",
+ inputBuffer,
Integer.toHexString(System.identityHashCode(inputBuffer)),
this.socket.isClosed());
+ }
throw e;
}
peerDataBuffer.flip();
@@ -3171,7 +3176,7 @@ public class Connection implements Runnable {
Thread.currentThread().setName(THREAD_KIND_IDENTIFIER + " for " +
remoteAddr + " "
+ (sharedResource ? "" : "un") + "shared" + " " + (preserveOrder ? ""
: "un")
+ "ordered" + " uid=" + uniqueId + (dominoNumber > 0 ? " dom #" +
dominoNumber : "")
- + " port=" + socket.getPort());
+ + " local port=" + socket.getLocalPort() + " remote port=" +
socket.getPort());
}
private void compactOrResizeBuffer(int messageLength) {
diff --git
a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamerList.java
b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamerList.java
index 08b573c..396d56e 100644
---
a/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamerList.java
+++
b/geode-core/src/main/java/org/apache/geode/internal/tcp/MsgStreamerList.java
@@ -39,6 +39,7 @@ public class MsgStreamerList implements BaseMsgStreamer {
private final List<MsgStreamer> streamers;
MsgStreamerList(List<MsgStreamer> streamers) {
+ logger.fatal("BRUCE: someone created a MsgStreamerList!", new
Exception("stack trace"));
this.streamers = streamers;
}
