public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelDuplexHandler
{
private final int explicitFlushAfterFlushes;
private final boolean consolidateWhenNoReadInProgress;
private final java.lang.Runnable flushTask;
private int flushPendingCount;
private boolean readInProgress;
private org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx;
private java.util.concurrent.Future nextScheduledFlush;
public static final int DEFAULT_EXPLICIT_FLUSH_AFTER_FLUSHES;
public void <init>()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void <init>(int,boolean)>(256, 0);
return;
}
public void <init>(int)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: int;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void <init>(int,boolean)>(v, 0);
return;
}
public void <init>(int, boolean)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler$1 v;
int v;
java.lang.String v;
java.lang.IllegalArgumentException v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: int;
v := @parameter: boolean;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelDuplexHandler: void <init>()>();
if v > 0 goto label;
v = new java.lang.IllegalArgumentException;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("explicitFlushAfterFlushes: \u (expected: > 0)");
specialinvoke v.<java.lang.IllegalArgumentException: void <init>(java.lang.String)>(v);
throw v;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int explicitFlushAfterFlushes> = v;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: boolean consolidateWhenNoReadInProgress> = v;
if v == 0 goto label;
v = new org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler$1;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler$1: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler)>(v);
goto label;
label:
v = null;
label:
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.lang.Runnable flushTask> = v;
return;
}
public void handlerAdded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext ctx> = v;
return;
}
public void flush(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
int v, v, v, v, v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v, v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: boolean readInProgress>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int flushPendingCount>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int flushPendingCount> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int explicitFlushAfterFlushes>;
if v != v goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushNow(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
goto label;
label:
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: boolean consolidateWhenNoReadInProgress>;
if v == 0 goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int flushPendingCount>;
v = v + 1;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int flushPendingCount> = v;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int explicitFlushAfterFlushes>;
if v != v goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushNow(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
goto label;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void scheduleFlush(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
goto label;
label:
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushNow(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
label:
return;
}
public void channelReadComplete(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void resetReadAndFlushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext fireChannelReadComplete()>();
return;
}
public void channelRead(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Object) throws java.lang.Exception
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: java.lang.Object;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: boolean readInProgress> = 1;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext fireChannelRead(java.lang.Object)>(v);
return;
}
public void exceptionCaught(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, java.lang.Throwable) throws java.lang.Exception
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: java.lang.Throwable;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void resetReadAndFlushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext fireExceptionCaught(java.lang.Throwable)>(v);
return;
}
public void disconnect(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void resetReadAndFlushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture disconnect(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return;
}
public void close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void resetReadAndFlushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFuture close(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise)>(v);
return;
}
public void channelWritabilityChanged(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: boolean isWritable()>();
if v != 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
label:
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext fireChannelWritabilityChanged()>();
return;
}
public void handlerRemoved(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext) throws java.lang.Exception
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
return;
}
private void resetReadAndFlushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: boolean readInProgress> = 0;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
return;
}
private void flushIfNeeded(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)
{
int v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int flushPendingCount>;
if v <= 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void flushNow(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)>(v);
label:
return;
}
private void flushNow(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: void cancelScheduledFlush()>();
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: int flushPendingCount> = 0;
interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext flush()>();
return;
}
private void scheduleFlush(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
java.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
java.lang.Runnable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.util.concurrent.Future nextScheduledFlush>;
if v != null goto label;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelHandlerContext: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()>();
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop eventLoop()>();
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.lang.Runnable flushTask>;
v = interfaceinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Future submit(java.lang.Runnable)>(v);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.util.concurrent.Future nextScheduledFlush> = v;
label:
return;
}
private void cancelScheduledFlush()
{
java.util.concurrent.Future v, v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.util.concurrent.Future nextScheduledFlush>;
if v == null goto label;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.util.concurrent.Future nextScheduledFlush>;
interfaceinvoke v.<java.util.concurrent.Future: boolean cancel(boolean)>(0);
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.handler.flush.FlushConsolidationHandler: java.util.concurrent.Future nextScheduledFlush> = null;
label:
return;
}
}