diff --git a/src/java/org/apache/cassandra/transport/Message.java b/src/java/org/apache/cassandra/transport/Message.java index 4a834732e3..5f89d47f22 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; @@ -779,6 +780,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();