public class org.apache.qpid.proton.reactor.impl.TaskImpl extends java.lang.Object implements org.apache.qpid.proton.reactor.Task, java.lang.Comparable
{
private final long deadline;
private final int counter;
private boolean cancelled;
private org.apache.qpid.proton.engine.Record attachments;
private org.apache.qpid.proton.reactor.Reactor reactor;
public void <init>(long, int)
{
org.apache.qpid.proton.engine.impl.RecordImpl v;
int v;
org.apache.qpid.proton.reactor.impl.TaskImpl v;
long v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v := @parameter: long;
v := @parameter: int;
specialinvoke v.<java.lang.Object: void <init>()>();
v.<org.apache.qpid.proton.reactor.impl.TaskImpl: boolean cancelled> = 0;
v = new org.apache.qpid.proton.engine.impl.RecordImpl;
specialinvoke v.<org.apache.qpid.proton.engine.impl.RecordImpl: void <init>()>();
v.<org.apache.qpid.proton.reactor.impl.TaskImpl: org.apache.qpid.proton.engine.Record attachments> = v;
v.<org.apache.qpid.proton.reactor.impl.TaskImpl: long deadline> = v;
v.<org.apache.qpid.proton.reactor.impl.TaskImpl: int counter> = v;
return;
}
public int compareTo(org.apache.qpid.proton.reactor.impl.TaskImpl)
{
long v, v, v, v;
byte v, v;
int v, v, v, v;
org.apache.qpid.proton.reactor.impl.TaskImpl v, v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v := @parameter: org.apache.qpid.proton.reactor.impl.TaskImpl;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: long deadline>;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: long deadline>;
v = v cmp v;
if v >= 0 goto label;
v = (int) -1;
v = v;
goto label;
label:
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: long deadline>;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: long deadline>;
v = v cmp v;
if v <= 0 goto label;
v = 1;
goto label;
label:
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: int counter>;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: int counter>;
v = v - v;
label:
return v;
}
public long deadline()
{
org.apache.qpid.proton.reactor.impl.TaskImpl v;
long v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: long deadline>;
return v;
}
public boolean isCancelled()
{
org.apache.qpid.proton.reactor.impl.TaskImpl v;
boolean v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: boolean cancelled>;
return v;
}
public void cancel()
{
org.apache.qpid.proton.reactor.impl.TaskImpl v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v.<org.apache.qpid.proton.reactor.impl.TaskImpl: boolean cancelled> = 1;
return;
}
public void setReactor(org.apache.qpid.proton.reactor.Reactor)
{
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.reactor.impl.TaskImpl v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v := @parameter: org.apache.qpid.proton.reactor.Reactor;
v.<org.apache.qpid.proton.reactor.impl.TaskImpl: org.apache.qpid.proton.reactor.Reactor reactor> = v;
return;
}
public org.apache.qpid.proton.reactor.Reactor getReactor()
{
org.apache.qpid.proton.reactor.Reactor v;
org.apache.qpid.proton.reactor.impl.TaskImpl v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: org.apache.qpid.proton.reactor.Reactor reactor>;
return v;
}
public org.apache.qpid.proton.engine.Record attachments()
{
org.apache.qpid.proton.reactor.impl.TaskImpl v;
org.apache.qpid.proton.engine.Record v;
v := @this: org.apache.qpid.proton.reactor.impl.TaskImpl;
v = v.<org.apache.qpid.proton.reactor.impl.TaskImpl: org.apache.qpid.proton.engine.Record attachments>;
return v;
}
}