diff --git a/src/java/org/apache/cassandra/transport/Message.java b/src/java/org/apache/cassandra/transport/Message.java index 3c2f38c5a6..d27a57c321 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();