public class org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise extends org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise implements org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelFlushPromiseNotifier$FlushCheckpoint
{
private final org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel;
private long checkpoint;
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel)
{
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: void <init>()>();
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel> = v;
return;
}
public void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel, org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
java.lang.Object v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: void <init>(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor)>(v);
v = staticinvoke <org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.internal.ObjectUtil: java.lang.Object checkNotNull(java.lang.Object,java.lang.String)>(v, "channel");
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel> = v;
return;
}
protected org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor executor()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.EventLoop v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v = specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.EventExecutor executor()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: 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()>();
return v;
label:
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel channel>;
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess(java.lang.Void)>(null);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setSuccess(java.lang.Void)
{
java.lang.Void v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: java.lang.Void;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise setSuccess(java.lang.Object)>(v);
return v;
}
public boolean trySuccess()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: boolean trySuccess(java.lang.Object)>(null);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise setFailure(java.lang.Throwable)
{
java.lang.Throwable v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: java.lang.Throwable;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise setFailure(java.lang.Throwable)>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise addListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
public transient org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise addListeners(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[])
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise addListeners(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[])>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise removeListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise removeListener(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener)>(v);
return v;
}
public transient org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise removeListeners(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[])
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[] v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[];
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise removeListeners(org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.GenericFutureListener[])>(v);
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise sync() throws java.lang.InterruptedException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise sync()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise syncUninterruptibly()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise syncUninterruptibly()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise await() throws java.lang.InterruptedException
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise await()>();
return v;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise awaitUninterruptibly()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.Promise awaitUninterruptibly()>();
return v;
}
public long flushCheckpoint()
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v = v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: long checkpoint>;
return v;
}
public void flushCheckpoint(long)
{
long v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v := @parameter: long;
v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: long checkpoint> = v;
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise promise()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
return v;
}
protected void checkDeadLock()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.Channel v;
boolean v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
v = virtualinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise: 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 isRegistered()>();
if v == 0 goto label;
specialinvoke v.<org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.util.concurrent.DefaultPromise: void checkDeadLock()>();
label:
return;
}
public org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.ChannelPromise unvoid()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
return v;
}
public boolean isVoid()
{
org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise v;
v := @this: org.apache.hive.kudu.org.apache.kudu.shaded.io.netty.channel.DefaultChannelPromise;
return 0;
}
}