mirror of https://github.com/apache/cassandra
Merge branch 'cassandra-3.0' into cassandra-3.11
This commit is contained in:
commit
20abdfcdd3
|
|
@ -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();
|
||||
|
|
|
|||
Loading…
Reference in New Issue