final class org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl extends org.apache.activemq.util.ServiceSupport
{
private final org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store;
private java.lang.String name;
private org.apache.activemq.store.kahadb.disk.index.BTreeIndex index;
void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl)
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
specialinvoke v.<org.apache.activemq.util.ServiceSupport: void <init>()>();
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store> = v;
return;
}
public void setName(java.lang.String)
{
java.lang.String v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: java.lang.String;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: java.lang.String name> = v;
return;
}
public java.lang.String getName()
{
java.lang.String v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: java.lang.String name>;
return v;
}
public long getNextScheduleTime() throws java.io.IOException
{
java.util.Map$Entry v;
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
long v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.lang.Object v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: java.util.Map$Entry getFirst(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
if v == null goto label;
v = interfaceinvoke v.<java.util.Map$Entry: java.lang.Object getKey()>();
v = virtualinvoke v.<java.lang.Long: long longValue()>();
goto label;
label:
v = -1L;
label:
return v;
}
public java.util.List getNextScheduleJobs() throws java.io.IOException
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$1 v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
java.util.ArrayList v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$1;
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$1: void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl,java.util.List)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(v);
return v;
}
public java.util.List getAllJobs() throws java.io.IOException
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$2 v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
java.util.ArrayList v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$2;
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$2: void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl,java.util.List)>(v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(v);
return v;
}
public java.util.List getAllJobs(long, long) throws java.io.IOException
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$3 v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
long v, v;
java.util.ArrayList v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: long;
v := @parameter: long;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: org.apache.activemq.store.kahadb.disk.page.Transaction tx()>();
v = new org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$3;
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$3: void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl,long,long,java.util.List)>(v, v, v, v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(v);
return v;
}
org.apache.activemq.util.ByteSequence getPayload(org.apache.activemq.store.kahadb.disk.journal.Location) throws java.lang.IllegalStateException, java.io.IOException
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.journal.Location v;
org.apache.activemq.util.ByteSequence v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.ByteSequence getPayload(org.apache.activemq.store.kahadb.disk.journal.Location)>(v);
return v;
}
public java.lang.String toString()
{
java.lang.String v, v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: java.lang.String name>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("LegacyJobScheduler: \u0001");
return v;
}
protected void doStart() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
return;
}
protected void doStop(org.apache.activemq.util.ServiceStopper) throws java.lang.Exception
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
org.apache.activemq.util.ServiceStopper v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: org.apache.activemq.util.ServiceStopper;
return;
}
void createIndexes(org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
long v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
org.apache.activemq.store.kahadb.disk.page.Page v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: org.apache.activemq.store.kahadb.disk.page.Page allocate()>();
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Page: long getPageId()>();
specialinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void <init>(org.apache.activemq.store.kahadb.disk.page.PageFile,long)>(v, v);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index> = v;
return;
}
void load(org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$ValueMarshaller v;
org.apache.activemq.store.kahadb.disk.util.LongMarshaller v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
v = <org.apache.activemq.store.kahadb.disk.util.LongMarshaller: org.apache.activemq.store.kahadb.disk.util.LongMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setKeyMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
v = <org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$ValueMarshaller: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$ValueMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setValueMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void load(org.apache.activemq.store.kahadb.disk.page.Transaction)>(v);
return;
}
void read(java.io.DataInput) throws java.io.IOException
{
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
long v;
java.io.DataInput v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$ValueMarshaller v;
java.lang.String v;
org.apache.activemq.store.kahadb.disk.util.LongMarshaller v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: java.io.DataInput;
v = interfaceinvoke v.<java.io.DataInput: java.lang.String readUTF()>();
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: java.lang.String name> = v;
v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl store>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()>();
v = interfaceinvoke v.<java.io.DataInput: long readLong()>();
specialinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void <init>(org.apache.activemq.store.kahadb.disk.page.PageFile,long)>(v, v);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index> = v;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
v = <org.apache.activemq.store.kahadb.disk.util.LongMarshaller: org.apache.activemq.store.kahadb.disk.util.LongMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setKeyMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
v = <org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$ValueMarshaller: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl$ValueMarshaller INSTANCE>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: void setValueMarshaller(org.apache.activemq.store.kahadb.disk.util.Marshaller)>(v);
return;
}
public void write(java.io.DataOutput) throws java.io.IOException
{
java.io.DataOutput v;
org.apache.activemq.store.kahadb.disk.index.BTreeIndex v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl v;
long v;
java.lang.String v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl;
v := @parameter: java.io.DataOutput;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: java.lang.String name>;
interfaceinvoke v.<java.io.DataOutput: void writeUTF(java.lang.String)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: org.apache.activemq.store.kahadb.disk.index.BTreeIndex index>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.index.BTreeIndex: long getPageId()>();
interfaceinvoke v.<java.io.DataOutput: void writeLong(long)>(v);
return;
}
}