@InterfaceAudience.Private public class NettyRpcServerChannelWritabilityHandler extends org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
Modifier and Type | Field and Description |
---|---|
private BooleanSupplier |
isWritabilityBackpressureEnabled |
private MetricsHBaseServer |
metrics |
(package private) static String |
NAME |
private IntSupplier |
pendingBytesFatalThreshold |
private long |
unwritableStartTime |
private boolean |
writable |
Constructor and Description |
---|
NettyRpcServerChannelWritabilityHandler(MetricsHBaseServer metrics,
IntSupplier pendingBytesFatalThreshold,
BooleanSupplier isWritabilityBackpressureEnabled) |
Modifier and Type | Method and Description |
---|---|
void |
channelWritabilityChanged(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
private boolean |
handleFatalThreshold(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
private void |
handleWritabilityChanged(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) |
void |
write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx,
Object msg,
org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) |
bind, close, connect, deregister, disconnect, flush, read
channelActive, channelInactive, channelRead, channelReadComplete, channelRegistered, channelUnregistered, exceptionCaught, userEventTriggered
ensureNotSharable, handlerAdded, handlerRemoved, isSharable
static final String NAME
private final MetricsHBaseServer metrics
private final IntSupplier pendingBytesFatalThreshold
private final BooleanSupplier isWritabilityBackpressureEnabled
private boolean writable
private long unwritableStartTime
NettyRpcServerChannelWritabilityHandler(MetricsHBaseServer metrics, IntSupplier pendingBytesFatalThreshold, BooleanSupplier isWritabilityBackpressureEnabled)
public void write(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx, Object msg, org.apache.hbase.thirdparty.io.netty.channel.ChannelPromise promise) throws Exception
write
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelOutboundHandler
write
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelDuplexHandler
Exception
public void channelWritabilityChanged(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx) throws Exception
channelWritabilityChanged
in interface org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandler
channelWritabilityChanged
in class org.apache.hbase.thirdparty.io.netty.channel.ChannelInboundHandlerAdapter
Exception
private boolean handleFatalThreshold(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
private void handleWritabilityChanged(org.apache.hbase.thirdparty.io.netty.channel.ChannelHandlerContext ctx)
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.