class oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler extends oadd.io.netty.channel.ChannelInboundHandlerAdapter
{
final oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection this$0;
private void <init>(oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection)
{
oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection v;
oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler v;
v := @this: oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler;
v := @parameter: oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection;
v.<oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler: oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection this$0> = v;
specialinvoke v.<oadd.io.netty.channel.ChannelInboundHandlerAdapter: void <init>()>();
return;
}
public void channelWritabilityChanged(oadd.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$WriteManager v;
oadd.io.netty.channel.Channel v;
oadd.io.netty.channel.ChannelHandlerContext v;
oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection v;
oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler v;
boolean v;
v := @this: oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler;
v := @parameter: oadd.io.netty.channel.ChannelHandlerContext;
v = v.<oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$BackPressureHandler: oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection this$0>;
v = v.<oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection: oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$WriteManager writeManager>;
v = interfaceinvoke v.<oadd.io.netty.channel.ChannelHandlerContext: oadd.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<oadd.io.netty.channel.Channel: boolean isWritable()>();
virtualinvoke v.<oadd.org.apache.drill.exec.rpc.AbstractRemoteConnection$WriteManager: void setWritable(boolean)>(v);
interfaceinvoke v.<oadd.io.netty.channel.ChannelHandlerContext: oadd.io.netty.channel.ChannelHandlerContext fireChannelWritabilityChanged()>();
return;
}
}