public class org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl extends org.apache.activemq.store.kahadb.AbstractKahaDBStore implements org.apache.activemq.broker.scheduler.JobSchedulerStore { private static final org.slf4j.Logger LOG; private org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData metaData; private final org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$MetaDataMarshaller metaDataMarshaller; private final java.util.Map schedulers; private java.io.File legacyStoreArchiveDirectory; static final java.util.UUID SCHEDULER_STORE_TOKEN; static final int CURRENT_VERSION; public void () { org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v; java.util.HashMap v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$MetaDataMarshaller v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; specialinvoke v.()>(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); v. = v; v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$MetaDataMarshaller; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl,org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v, v); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; return; } public org.apache.activemq.broker.scheduler.JobScheduler getJobScheduler(java.lang.String) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.Map v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v; boolean v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$1 v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(v); if v != null goto label; v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$1; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl,org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl,java.lang.String)>(v, v, v); virtualinvoke v.(v); v = v; v = v.; interfaceinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = v.; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return v; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; catch java.lang.Throwable from label to label with label; } public boolean removeJobScheduler(java.lang.String) throws java.lang.Exception { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.Map v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v; java.lang.Object v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$2 v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = 1; goto label; label: v = 0; label: v = v; if v == 0 goto label; virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$2; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl,java.lang.String,org.apache.activemq.store.kahadb.scheduler.JobSchedulerImpl)>(v, v, v); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return v; catch java.lang.Throwable from label to label with label; } public void setLegacyStoreArchiveDirectory(java.io.File) { java.io.File v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: java.io.File; v. = v; return; } public java.io.File getLegacyStoreArchiveDirectory() { java.io.File v, v, v, v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; if v != null goto label; v = new java.io.File; v = virtualinvoke v.(); specialinvoke v.(java.io.File,java.lang.String)>(v, "legacySchedulerStore"); v. = v; label: v = v.; v = virtualinvoke v.(); return v; } public void load() throws java.io.IOException { java.lang.Throwable v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v; boolean v, v; org.slf4j.Logger v, v, v, v, v; org.apache.activemq.store.kahadb.scheduler.UnknownStoreVersionException v; java.lang.Exception v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Can\'t start until store update is performed."); specialinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); specialinvoke v.(); v = ; interfaceinvoke v.("Update from legacy Scheduler store completed successfully."); goto label; label: v := @caughtexception; v = ; v = virtualinvoke v.(); interfaceinvoke v.("Index corrupted. Recovering the index through journal replay. Cause: {}", v); v = ; interfaceinvoke v.("Index load failure", v); label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; label: v = v.; virtualinvoke v.(); label: v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); v. = v; v. = null; specialinvoke v.(); label: virtualinvoke v.(); specialinvoke v.(); label: v = ; interfaceinvoke v.("{} started.", v); return; catch org.apache.activemq.store.kahadb.scheduler.UnknownStoreVersionException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } public void unload() throws java.io.IOException { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v, v, v; java.lang.Thread v, v; java.util.Map v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v, v, v; boolean v, v, v, v; java.util.Collection v; java.lang.Exception v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$3 v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; java.lang.Throwable v, v, v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; org.slf4j.Logger v; java.util.Iterator v; java.io.IOException v; org.apache.activemq.store.kahadb.disk.page.Page v, v; java.lang.InterruptedException v; java.lang.Object v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(1, 0); if v == 0 goto label; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.IOException; specialinvoke v.(java.lang.Throwable)>(v); throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$3; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = v.; entermonitor v; label: v = v.; if v == null goto label; label: v = v.; virtualinvoke v.(); v. = null; label: goto label; label: v := @caughtexception; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; label: v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); v. = v; label: v = ; interfaceinvoke v.("{} stopped.", v); return; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } private void loadPageFile() throws java.io.IOException { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$4 v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$4; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl,org.apache.activemq.store.kahadb.disk.page.PageFile)>(v, v); virtualinvoke v.(v); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } private void upgradeFromLegacy() throws java.io.IOException { org.apache.activemq.store.kahadb.scheduler.legacy.LegacyStoreReplayer v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v; org.slf4j.Logger v; java.io.File v, v, v, v; java.lang.Exception v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$6 v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$5 v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; virtualinvoke v.(); v. = null; label: v = v.; virtualinvoke v.(); v. = null; label: goto label; label: v := @caughtexception; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; interfaceinvoke v.("Attempting to move old store files from {} to {}", v, v); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$5; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); staticinvoke (v, v, v); v = virtualinvoke v.(); virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); v. = v; v. = null; specialinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.legacy.LegacyStoreReplayer; v = virtualinvoke v.(); specialinvoke v.(java.io.File)>(v); virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$6; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl)>(v); virtualinvoke v.(v); virtualinvoke v.(1); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); return; catch java.lang.Exception from label to label with label; } protected void checkpointUpdate(org.apache.activemq.store.kahadb.disk.page.Transaction, boolean) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v; java.lang.Integer v; java.util.Map v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v, v, v, v, v, v, v, v, v; java.util.Set v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$7 v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; java.util.TreeSet v, v; java.util.ArrayList v; int v; java.lang.String v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$MetaDataMarshaller v; org.slf4j.Logger v, v, v, v, v, v, v, v, v; java.util.Iterator v, v, v; org.apache.activemq.store.kahadb.disk.page.Page v; java.lang.Object v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: boolean; v = ; interfaceinvoke v.("Job Scheduler Store Checkpoint started."); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(2); v = v.; v = virtualinvoke v.(); v = v.; virtualinvoke v.(v, v, 1); v = v.; virtualinvoke v.(); if v == 0 goto label; v = new java.util.TreeSet; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = new java.util.TreeSet; specialinvoke v.(java.util.SortedSet)>(v); v = ; interfaceinvoke v.("Last update: {}, full gc candidates set: {}", v, v); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$7; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl,java.util.TreeSet)>(v, v); virtualinvoke v.(v, v); v = ; interfaceinvoke v.("gc candidates after reference check: {}", v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = new java.util.ArrayList; specialinvoke v.()>(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = 1; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = ; v = interfaceinvoke v.(); interfaceinvoke v.("A remove in log {} has an add still in existance in {}.", v, v); v = 0; label: if v != 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); interfaceinvoke v.("All removes in log {} are orphaned, file can be GC\'d", v); v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v); goto label; label: v = ; interfaceinvoke v.("gc candidates after removals check: {}", v); v = virtualinvoke v.(); if v != 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Cleanup removing the data files: \u0001"); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(v); label: v = ; interfaceinvoke v.("Job Scheduler Store Checkpoint complete."); return; } protected void incrementJournalCount(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v; java.lang.Integer v, v, v; int v, v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = v + 1; goto label; label: v = 1; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); virtualinvoke v.(v, v, v); return; } protected void decrementJournalCount(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v; java.lang.Integer v, v, v, v; int v, v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = v - 1; if v > 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); virtualinvoke v.(v, v, v); label: return; } protected void decrementJournalCount(org.apache.activemq.store.kahadb.disk.page.Transaction, java.util.HashMap) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v; java.util.HashMap v; java.lang.Integer v, v, v, v; int v, v, v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v, v; boolean v; java.util.Iterator v; java.util.Set v; java.lang.Object v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: java.util.HashMap; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v - v; if v > 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); virtualinvoke v.(v, v, v); goto label; label: return; } protected void referenceRemovedLocation(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.scheduler.JobLocation) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v; java.lang.Integer v, v, v; java.util.ArrayList v; org.apache.activemq.store.kahadb.scheduler.JobLocation v; int v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: org.apache.activemq.store.kahadb.scheduler.JobLocation; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v); if v != null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = v; label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v, v); return; } protected void referenceRemovedLocation(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.disk.journal.Location, java.util.List) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v; java.lang.Integer v, v; java.util.ArrayList v; java.util.List v; int v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v, v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: java.util.List; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v); if v != null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = v; label: interfaceinvoke v.(v); v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v, v, v); return; } protected org.apache.activemq.util.ByteSequence getPayload(org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { byte[] v; org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.protobuf.Buffer v; int v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.util.ByteSequence v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = new org.apache.activemq.util.ByteSequence; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(byte[],int,int)>(v, v, v); return v; } public void readLockIndex() { java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return; } public void readUnlockIndex() { java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return; } public void writeLockIndex() { java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return; } public void writeUnlockIndex() { java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return; } public java.lang.String toString() { java.lang.String v; java.io.File v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("JobSchedulerStore: \u0001"); return v; } protected java.lang.String getPageFileName() { org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; return "scheduleDB"; } protected java.io.File getDefaultDataDirectory() { java.lang.String v; java.io.File v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = new java.io.File; v = staticinvoke (); specialinvoke v.(java.lang.String,java.lang.String)>(v, "delayedDB"); return v; } protected void doRecover(org.apache.activemq.store.kahadb.JournalCommand, org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; int v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; if v == null goto label; v = virtualinvoke v.(v); if v < 0 goto label; virtualinvoke v.(v, v); label: return; } protected void process(org.apache.activemq.store.kahadb.JournalCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$8 v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = new org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$8; specialinvoke v.(org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl,org.apache.activemq.store.kahadb.disk.journal.Location)>(v, v); interfaceinvoke v.(v); return; } protected void processLocation(org.apache.activemq.store.kahadb.disk.journal.Location) { java.lang.Throwable v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return; catch java.lang.Throwable from label to label with label; } private void recover() throws java.lang.IllegalStateException, java.io.IOException { java.lang.Float v; org.apache.activemq.store.kahadb.JournalCommand v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.lang.Integer v, v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerKahaDBMetaData v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v; float v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl$9 v; org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl v; java.lang.Throwable v; long v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; int v, v; java.lang.String v, v, v; org.slf4j.Logger v, v, v, v, v; java.io.IOException v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.scheduler.JobSchedulerStoreImpl; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = staticinvoke (); v = specialinvoke v.(); v = v; if v == null goto label; v = 0; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Recovering from the scheduled job journal @\u0001"); interfaceinvoke v.(v); label: if v == null goto label; label: v = virtualinvoke v.(v); v = v.; virtualinvoke v.(v); virtualinvoke v.(v, v, v); v = v + 1; label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to recover data at position:\u0001"); interfaceinvoke v.(v, v); v = v.; virtualinvoke v.(v); goto label; label: v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Failed to recover data at position:\u0001"); specialinvoke v.(java.lang.String,java.lang.Throwable)>(v, v); throw v; label: v = v.; v = virtualinvoke v.(v); v =