This is an automated email from the ASF dual-hosted git repository.
brandonwilliams pushed a commit to branch cassandra-3.0
in repository https://gitbox.apache.org/repos/asf/cassandra.git
The following commit(s) were added to refs/heads/cassandra-3.0 by this push:
new f71dfdc Push connection reset by peer messages to trace
f71dfdc is described below
commit f71dfdc37569398e282158e188be946eb1d5de01
Author: Brandon Williams <[email protected]>
AuthorDate: Mon Oct 18 12:29:35 2021 -0500
Push connection reset by peer messages to trace
Patch by brandonwilliams; reviewed by bereng for CASSANDRA-16954
---
src/java/org/apache/cassandra/transport/Message.java | 6 ++++++
1 file changed, 6 insertions(+)
diff --git a/src/java/org/apache/cassandra/transport/Message.java
b/src/java/org/apache/cassandra/transport/Message.java
index 3c2f38c..d27a57c 100644
--- a/src/java/org/apache/cassandra/transport/Message.java
+++ b/src/java/org/apache/cassandra/transport/Message.java
@@ -34,6 +34,7 @@ import java.util.concurrent.atomic.AtomicBoolean;
import io.netty.buffer.ByteBuf;
import io.netty.channel.*;
+import io.netty.channel.unix.Errors;
import io.netty.handler.codec.MessageToMessageDecoder;
import io.netty.handler.codec.MessageToMessageEncoder;
@@ -774,6 +775,11 @@ public abstract class Message
NoSpamLogger.log(logger, NoSpamLogger.Level.WARN, 1,
TimeUnit.MINUTES, "Protocol exception with client networking: " +
cause.getMessage());
}
}
+ else if (Throwables.anyCauseMatches(cause, t -> t instanceof
Errors.NativeIoException))
+ {
+ ClientMetrics.instance.markUnknownException();
+ logger.trace("Native exception in client networking,", cause);
+ }
else
{
ClientMetrics.instance.markUnknownException();
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
