final class org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl extends org.apache.activemq.util.ServiceSupport
{
static final org.slf4j.Logger LOG;
private static final int DATABASE_LOCKED_WAIT_DELAY;
private java.io.File directory;
private org.apache.activemq.store.kahadb.disk.page.PageFile pageFile;
private org.apache.activemq.store.kahadb.disk.journal.Journal journal;
private org.apache.activemq.util.LockFile lockFile;
private final java.util.concurrent.atomic.AtomicLong journalSize;
private boolean failIfDatabaseIsLocked;
private int journalMaxFileLength;
private int journalMaxWriteBatchSize;
private boolean enableIndexWriteAsync;
private org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaData metaData;
private final org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaDataMarshaller metaDataMarshaller;
private final java.util.Map schedulers;
void <init>()
{
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaDataMarshaller v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.util.HashMap v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaData v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
specialinvoke v.<org.apache.activemq.util.ServiceSupport: void <init>()>();
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.concurrent.atomic.AtomicLong journalSize> = v;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int journalMaxFileLength> = 33554432;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int journalMaxWriteBatchSize> = 4194304;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean enableIndexWriteAsync> = 0;
v = new org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaData;
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaData: void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl,org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl)>(v, v);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaData metaData> = v;
v = new org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaDataMarshaller;
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaDataMarshaller: void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl,org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl)>(v, v);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$MetaDataMarshaller metaDataMarshaller> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.Map schedulers> = v;
return;
}
public java.io.File getDirectory()
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
return v;
}
public void setDirectory(java.io.File)
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: java.io.File;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory> = v;
return;
}
public long size()
{
java.io.IOException v;
long v, v, v;
java.lang.RuntimeException v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.page.PageFile v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean isStarted()>();
if v != 0 goto label;
return 0L;
label:
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.concurrent.atomic.AtomicLong journalSize>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: long getDiskSize()>();
v = v + v;
label:
return v;
label:
v := @caughtexception;
v = new java.lang.RuntimeException;
specialinvoke v.<java.lang.RuntimeException: void <init>(java.lang.Throwable)>(v);
throw v;
catch java.io.IOException from label to label with label;
}
public org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl getJobScheduler(java.lang.String) throws java.lang.Exception
{
java.util.Map v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.lang.Object v;
java.lang.String v, v;
java.util.NoSuchElementException v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: java.lang.String;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.Map schedulers>;
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
if v != null goto label;
v = new java.util.NoSuchElementException;
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[])>("No such Job Scheduler in this store: \u0001");
specialinvoke v.<java.util.NoSuchElementException: void <init>(java.lang.String)>(v);
throw v;
label:
return v;
}
public java.util.Set getJobSchedulerNames() throws java.lang.Exception
{
java.util.Map v, v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.util.Set v, v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = staticinvoke <java.util.Collections: java.util.Set emptySet()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.Map schedulers>;
v = interfaceinvoke v.<java.util.Map: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.Map schedulers>;
v = interfaceinvoke v.<java.util.Map: java.util.Set keySet()>();
return v;
label:
return v;
}
protected void doStart() throws java.lang.Exception
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$1 v;
int v, v;
java.lang.String v, v, v, v;
org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v, v, v;
org.slf4j.Logger v;
java.io.File v, v, v, v, v;
java.util.concurrent.atomic.AtomicLong v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.page.Transaction v;
org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v, v, v, v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
if v != null goto label;
v = new java.io.File;
v = staticinvoke <org.apache.activemq.util.IOHelper: java.lang.String getDefaultDataDirectory()>();
v = <java.io.File: java.lang.String pathSeparator>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String)>(v, 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[])>("\u0001\u0001delayedDB");
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory> = v;
label:
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
staticinvoke <org.apache.activemq.util.IOHelper: void mkdirs(java.io.File)>(v);
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: void lock()>();
v = new org.apache.activemq.store.kahadb.disk.journal.Journal;
specialinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void <init>()>();
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal> = v;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void setDirectory(java.io.File)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int getJournalMaxFileLength()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void setMaxFileLength(int)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int getJournalMaxWriteBatchSize()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void setWriteBatchSize(int)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.concurrent.atomic.AtomicLong journalSize>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void setSizeAccumulator(java.util.concurrent.atomic.AtomicLong)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void start()>();
v = new org.apache.activemq.store.kahadb.disk.page.PageFile;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
specialinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void <init>(java.io.File,java.lang.String)>(v, "scheduleDB");
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile> = v;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void setWriteBatchSize(int)>(1);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void load()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
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.LegacyJobSchedulerStoreImpl$1;
specialinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl$1: void <init>(org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl)>(v);
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.Transaction: void execute(org.apache.activemq.store.kahadb.disk.page.Transaction$Closure)>(v);
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void flush()>();
v = <org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl)>(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[])>("\u started");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
return;
}
protected void doStop(org.apache.activemq.util.ServiceStopper) throws java.lang.Exception
{
org.slf4j.Logger v;
java.util.Iterator v;
java.util.Collection v;
org.apache.activemq.util.LockFile v, v;
org.apache.activemq.util.ServiceStopper v;
java.util.Map v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.lang.Object v;
java.lang.String v;
org.apache.activemq.store.kahadb.disk.page.PageFile v, v;
boolean v;
org.apache.activemq.store.kahadb.disk.journal.Journal v, v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: org.apache.activemq.util.ServiceStopper;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.util.Map schedulers>;
v = interfaceinvoke v.<java.util.Map: java.util.Collection values()>();
v = interfaceinvoke v.<java.util.Collection: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerImpl: void stop()>();
goto label;
label:
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: void unload()>();
label:
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: void close()>();
label:
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile>;
if v == null goto label;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile>;
virtualinvoke v.<org.apache.activemq.util.LockFile: void unlock()>();
label:
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile> = null;
v = <org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl)>(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[])>("\u stopped");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
return;
}
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.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.journal.Location v;
org.apache.activemq.util.ByteSequence v;
org.apache.activemq.store.kahadb.disk.journal.Journal v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: org.apache.activemq.util.ByteSequence read(org.apache.activemq.store.kahadb.disk.journal.Location)>(v);
return v;
}
org.apache.activemq.store.kahadb.disk.journal.Location write(org.apache.activemq.util.ByteSequence, boolean) throws java.lang.IllegalStateException, java.io.IOException
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.journal.Location v;
org.apache.activemq.util.ByteSequence v;
boolean v;
org.apache.activemq.store.kahadb.disk.journal.Journal v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: org.apache.activemq.util.ByteSequence;
v := @parameter: boolean;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.journal.Journal journal>;
v = virtualinvoke v.<org.apache.activemq.store.kahadb.disk.journal.Journal: org.apache.activemq.store.kahadb.disk.journal.Location write(org.apache.activemq.util.ByteSequence,boolean)>(v, v);
return v;
}
private void lock() throws java.io.IOException
{
org.slf4j.Logger v;
org.apache.activemq.util.LockFile v, v, v, v;
java.io.IOException v;
java.io.File v, v;
java.lang.InterruptedException v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.lang.String v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile>;
if v != null goto label;
v = new java.io.File;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, "lock");
v = new org.apache.activemq.util.LockFile;
specialinvoke v.<org.apache.activemq.util.LockFile: void <init>(java.io.File,boolean)>(v, 1);
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile> = v;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean failIfDatabaseIsLocked>;
if v == 0 goto label;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile>;
virtualinvoke v.<org.apache.activemq.util.LockFile: void lock()>();
goto label;
label:
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.util.LockFile lockFile>;
virtualinvoke v.<org.apache.activemq.util.LockFile: void lock()>();
label:
goto label;
label:
v := @caughtexception;
v = <org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.slf4j.Logger LOG>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File,java.io.IOException)>(v, 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[])>("Database \u is locked... waiting 10 seconds for the database to be unlocked. Reason: \u0001");
interfaceinvoke v.<org.slf4j.Logger: void info(java.lang.String)>(v);
label:
staticinvoke <java.lang.Thread: void sleep(long)>(10000L);
label:
goto label;
label:
v := @caughtexception;
goto label;
label:
return;
catch java.io.IOException from label to label with label;
catch java.lang.InterruptedException from label to label with label;
}
org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile()
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
org.apache.activemq.store.kahadb.disk.page.PageFile v, v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
virtualinvoke v.<org.apache.activemq.store.kahadb.disk.page.PageFile: boolean isLoaded()>();
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.apache.activemq.store.kahadb.disk.page.PageFile pageFile>;
return v;
}
public boolean isFailIfDatabaseIsLocked()
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean failIfDatabaseIsLocked>;
return v;
}
public void setFailIfDatabaseIsLocked(boolean)
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: boolean;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean failIfDatabaseIsLocked> = v;
return;
}
public int getJournalMaxFileLength()
{
int v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int journalMaxFileLength>;
return v;
}
public void setJournalMaxFileLength(int)
{
int v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: int;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int journalMaxFileLength> = v;
return;
}
public int getJournalMaxWriteBatchSize()
{
int v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int journalMaxWriteBatchSize>;
return v;
}
public void setJournalMaxWriteBatchSize(int)
{
int v;
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: int;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: int journalMaxWriteBatchSize> = v;
return;
}
public boolean isEnableIndexWriteAsync()
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean enableIndexWriteAsync>;
return v;
}
public void setEnableIndexWriteAsync(boolean)
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
boolean v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v := @parameter: boolean;
v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: boolean enableIndexWriteAsync> = v;
return;
}
public java.lang.String toString()
{
org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl v;
java.lang.String v;
java.io.File v;
v := @this: org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl;
v = v.<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: java.io.File directory>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.io.File)>(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[])>("LegacyJobSchedulerStore:\u0001");
return v;
}
static void <clinit>()
{
org.slf4j.Logger v;
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(class "Lorg/apache/activemq/store/kahadb/scheduler/legacy/LegacyJobSchedulerStoreImpl;");
<org.apache.activemq.store.kahadb.scheduler.legacy.LegacyJobSchedulerStoreImpl: org.slf4j.Logger LOG> = v;
return;
}
}