public class org.apache.activemq.store.kahadb.disk.page.PageFile extends java.lang.Object { private static final java.lang.String PAGEFILE_SUFFIX; private static final java.lang.String RECOVERY_FILE_SUFFIX; private static final java.lang.String FREE_FILE_SUFFIX; public static final int DEFAULT_PAGE_SIZE; public static final int DEFAULT_WRITE_BATCH_SIZE; public static final int DEFAULT_PAGE_CACHE_SIZE; private static final int RECOVERY_FILE_HEADER_SIZE; private static final int PAGE_FILE_HEADER_SIZE; private static final org.slf4j.Logger LOG; private final java.io.File directory; private final java.lang.String name; private org.apache.activemq.util.RecoverableRandomAccessFile readFile; private org.apache.activemq.util.RecoverableRandomAccessFile writeFile; private org.apache.activemq.util.RecoverableRandomAccessFile recoveryFile; private int pageSize; private int recoveryFileMinPageCount; private int recoveryFileMaxPageCount; private int recoveryPageCount; private final java.util.concurrent.atomic.AtomicBoolean loaded; int writeBatchSize; private java.util.Map pageCache; private boolean enablePageCaching; private int pageCacheSize; private boolean enableRecoveryFile; private boolean enableDiskSyncs; private boolean enabledWriteThread; private final java.util.concurrent.atomic.AtomicBoolean stopWriter; private java.lang.Thread writerThread; private java.util.concurrent.CountDownLatch checkpointLatch; private final java.util.TreeMap writes; private final java.util.concurrent.atomic.AtomicLong nextFreePageId; private org.apache.activemq.store.kahadb.disk.util.SequenceSet freeList; private java.util.concurrent.atomic.AtomicReference recoveredFreeList; private java.util.concurrent.atomic.AtomicReference trackingFreeDuringRecovery; private final java.util.concurrent.atomic.AtomicLong nextTxid; private org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData metaData; private final java.util.HashMap tmpFilesForRemoval; private boolean useLFRUEviction; private float LFUEvictionFactor; public org.apache.activemq.store.kahadb.disk.page.Transaction tx() { 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.disk.page.PageFile; virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.disk.page.Transaction; specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile)>(v); return v; } public void (java.io.File, java.lang.String) { org.apache.activemq.store.kahadb.disk.util.SequenceSet v; java.util.concurrent.atomic.AtomicBoolean v, v; java.util.HashMap v; java.util.concurrent.atomic.AtomicReference v, v; java.io.File v; java.util.concurrent.atomic.AtomicLong v, v; java.util.TreeMap v; int v, v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: java.io.File; v := @parameter: java.lang.String; specialinvoke v.()>(); v = ; v. = v; v. = 1000; v. = 10000; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v = ; v. = v; v. = 1; v = ; v. = v; v. = 1; v. = 1; v. = 0; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v = new java.util.TreeMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v. = 0; v. = 0.2F; v. = v; v. = v; return; } public void delete() throws java.io.IOException { java.lang.IllegalStateException v; java.util.concurrent.atomic.AtomicBoolean v; java.io.File v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot delete page file data when the page file is loaded"); throw v; label: v = specialinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v); v = virtualinvoke v.(); specialinvoke v.(v); return; } public void archive() throws java.io.IOException { java.lang.IllegalStateException v; java.util.concurrent.atomic.AtomicBoolean v; long v; java.io.File v, v, v; java.lang.String v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot delete page file data when the page file is loaded"); throw v; label: v = staticinvoke (); v = specialinvoke v.(); v = staticinvoke (v); specialinvoke v.(v, v); v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(v, v); v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(v, v); return; } private void delete(java.io.File) throws java.io.IOException { java.io.IOException v; java.lang.String v, v; java.io.File v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: java.io.File; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not delete: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } private void archive(java.io.File, java.lang.String) throws java.io.IOException { java.io.IOException v; java.io.File v, v; java.lang.String v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: java.io.File; v := @parameter: java.lang.String; v = virtualinvoke v.(); if v == 0 goto label; v = new java.io.File; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001-\u0001"); specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(v); if v != 0 goto label; v = new java.io.IOException; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not archive: \u to \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: return; } public void load() throws java.io.IOException, java.lang.IllegalStateException { byte v, v, v; java.util.Map v, v; org.apache.activemq.util.LFUCache v; long v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v, v, v; java.util.concurrent.atomic.AtomicLong v, v, v, v; java.lang.IllegalStateException v; org.apache.activemq.util.LRUCache v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v, v, v, v; float v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.atomic.AtomicReference v, v; int v, v, v, v, v, v; org.slf4j.Logger v; org.apache.activemq.util.RecoverableRandomAccessFile v, v, v, v, v, v, v; java.lang.Class v; java.lang.Object v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = v.; if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.activemq.util.LFUCache; v = v.; v = virtualinvoke v.(); specialinvoke v.(int,float)>(v, v); v = staticinvoke (v); v. = v; goto label; label: v = new org.apache.activemq.util.LRUCache; v = v.; v = v.; specialinvoke v.(int,int,float,boolean)>(v, v, 0.75F, 1); v = staticinvoke (v); v. = v; label: v = specialinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = new org.apache.activemq.util.RecoverableRandomAccessFile; specialinvoke v.(java.io.File,java.lang.String,boolean)>(v, "rw", 0); v. = v; v = new org.apache.activemq.util.RecoverableRandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "r"); v. = v; v = v.; v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; specialinvoke v.(); v = v.; v = virtualinvoke v.(); v. = v; goto label; label: v = new org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData; specialinvoke v.()>(); v. = v; v = v.; v = class "Lorg/apache/activemq/store/kahadb/disk/page/PageFile;"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.("1"); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(1); v = v.; virtualinvoke v.(-1L); v = v.; virtualinvoke v.(0L); specialinvoke v.(); label: v = v.; if v == 0 goto label; v = new org.apache.activemq.util.RecoverableRandomAccessFile; v = virtualinvoke v.(); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); v = v + 1L; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; specialinvoke v.(); goto label; label: v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u, Recovering page file..."); interfaceinvoke v.(v); v = v.; v = specialinvoke v.(); virtualinvoke v.(v); v = v.; v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v cmp 4096L; if v >= 0 goto label; v = v.; virtualinvoke v.(4096L); label: v = v.; v = v.; v = virtualinvoke v.(); v = v - 4096L; v = v.; v = v / v; virtualinvoke v.(v); v = v.; virtualinvoke v.(0); specialinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); specialinvoke v.(); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; v = virtualinvoke v.(); specialinvoke v.(v); goto label; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot load the page file when it is already loaded."); throw v; label: return; } private void asyncFreePageRecovery(long) { long v; org.apache.activemq.store.kahadb.disk.page.PageFile$1 v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: long; v = new org.apache.activemq.store.kahadb.disk.page.PageFile$1; specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,java.lang.String,long)>(v, "KahaDB Index Free Page Recovery", v); virtualinvoke v.(5); virtualinvoke v.(1); virtualinvoke v.(); return; } private void recoverFreePages(long) throws java.lang.Exception { java.lang.Throwable v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; long v, v, v, v, v; java.util.concurrent.atomic.AtomicReference v, v; short v; byte v; java.lang.String v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v; boolean v, v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.activemq.util.RecoverableRandomAccessFile v, v; java.io.File v; java.util.concurrent.atomic.AtomicLong v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: long; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u. Recovering pageFile free list due to prior unclean shutdown.."); interfaceinvoke v.(v); v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); v = new org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, v); v = v.; v = virtualinvoke v.(); specialinvoke v.(v); label: v = new org.apache.activemq.store.kahadb.disk.page.Transaction; specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile)>(v); v = virtualinvoke v.(1); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = v cmp v; if v >= 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u. Recovered pageFile free list of size: \u0001"); interfaceinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(null); label: return; catch java.lang.Throwable from label to label with label; } private void loadForRecovery(long) throws java.lang.Exception { org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData v; java.util.concurrent.atomic.AtomicBoolean v; long v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.io.File v; java.util.concurrent.atomic.AtomicLong v; int v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: long; v = v.; virtualinvoke v.(1); v. = 0; v = specialinvoke v.(); v = new org.apache.activemq.util.RecoverableRandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "r"); v. = v; specialinvoke v.(); v = v.; v = virtualinvoke v.(); v. = v; v. = 0; v = v.; virtualinvoke v.(v); return; } public void unload() throws java.io.IOException { java.lang.Throwable v; java.lang.IllegalStateException v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v, v, v; java.util.concurrent.atomic.AtomicBoolean v; long v, v; java.io.InterruptedIOException v; java.util.concurrent.atomic.AtomicReference v; java.util.Map v; int v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData v, v, v, v, v; org.apache.activemq.util.RecoverableRandomAccessFile v, v, v, v; java.util.concurrent.atomic.AtomicLong v; java.util.TreeMap v, v; java.lang.InterruptedException v; java.lang.Object v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = virtualinvoke v.(1, 0); if v == 0 goto label; virtualinvoke v.(); label: specialinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.InterruptedIOException; specialinvoke v.()>(); throw v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(0L); goto label; label: specialinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = v.; v = virtualinvoke v.(); v = v - 1L; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; virtualinvoke v.(0); goto label; label: v = v.; virtualinvoke v.(1); label: specialinvoke v.(); v = v.; if v == null goto label; v = v.; virtualinvoke v.(); v. = null; v = v.; virtualinvoke v.(); v. = null; v = v.; if v == 0 goto label; v = v.; virtualinvoke v.(); v. = null; label: v = v.; virtualinvoke v.(); v = v.; if v == null goto label; v. = null; label: v = v.; entermonitor v; label: v = v.; virtualinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Cannot unload the page file when it is not loaded"); throw v; label: return; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; } public boolean isLoaded() { java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = virtualinvoke v.(); return v; } public boolean isCleanShutdown() { org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public void allowIOResumption() { java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; virtualinvoke v.(1); return; } public void flush() throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; java.util.concurrent.atomic.AtomicBoolean v; java.io.InterruptedIOException v; java.util.concurrent.atomic.AtomicReference v, v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v, v, v; java.io.IOException v; java.util.concurrent.CountDownLatch v, v, v; java.util.TreeMap v, v, v; java.lang.InterruptedException v; java.lang.Object v, v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Page file already stopped: checkpointing is not allowed"); throw v; label: v = v.; v = virtualinvoke v.(); if v == null goto label; v = v.; virtualinvoke v.(null); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(null); virtualinvoke v.(); label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; exitmonitor v; label: return; label: v = v.; if v == 0 goto label; v = v.; if v != null goto label; v = new java.util.concurrent.CountDownLatch; specialinvoke v.(int)>(1); v. = v; label: v = v.; v = v.; virtualinvoke v.(); goto label; label: specialinvoke v.(); exitmonitor v; label: return; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.InterruptedIOException; specialinvoke v.()>(); virtualinvoke v.(v); throw v; label: return; catch java.lang.Throwable 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; } public java.lang.String toString() { java.lang.String v; java.io.File v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = specialinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Page File: \u0001"); return v; } private java.io.File getMainPageFile() { java.lang.String v, v, v; java.io.File v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = new java.io.File; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.data"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); return v; } public java.io.File getFreeFile() { java.lang.String v, v, v; java.io.File v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = new java.io.File; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.free"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); return v; } public java.io.File getRecoveryFile() { java.lang.String v, v, v; java.io.File v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = new java.io.File; v = v.; v = v.; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.redo"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); return v; } public long toOffset(long) { int v; long v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: long; v = v.; v = v * v; v = 4096L + v; return v; } private void loadMetaData() throws java.io.IOException { byte[] v, v; long v, v, v, v; byte v, v, v; java.io.ByteArrayInputStream v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData v, v, v, v; java.util.Properties v, v; java.io.IOException v, v, v; org.apache.activemq.util.RecoverableRandomAccessFile v, v, v, v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = new org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData; specialinvoke v.()>(); v = v; v = new org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData; specialinvoke v.()>(); v = v; label: v = new java.util.Properties; specialinvoke v.()>(); v = newarray (byte)[2048]; v = v.; virtualinvoke v.(0L); v = v.; virtualinvoke v.(v); v = new java.io.ByteArrayInputStream; specialinvoke v.(byte[])>(v); virtualinvoke v.(v); staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = null; label: v = new java.util.Properties; specialinvoke v.()>(); v = newarray (byte)[2048]; v = v.; virtualinvoke v.(2048L); v = v.; virtualinvoke v.(v); v = new java.io.ByteArrayInputStream; specialinvoke v.(byte[])>(v); virtualinvoke v.(v); staticinvoke (v, v); label: goto label; label: v := @caughtexception; v = null; label: if v != null goto label; if v != null goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Could not load page file meta data"); throw v; label: if v == null goto label; v = v.; v = v cmp 0L; if v >= 0 goto label; label: v. = v; goto label; label: if v == null goto label; v = v.; v = v cmp 0L; if v >= 0 goto label; label: v. = v; goto label; label: v = v.; v = v.; v = v cmp v; if v != 0 goto label; v. = v; goto label; label: v. = v; label: return; catch java.io.IOException from label to label with label; catch java.io.IOException from label to label with label; } private void storeMetaData() throws java.io.IOException { byte[] v, v; java.io.ByteArrayOutputStream v; long v, v; int v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; org.apache.activemq.store.kahadb.disk.page.PageFile$MetaData v, v; java.util.Properties v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v, v, v, v, v, v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = v.; v = v + 1L; v. = v; v = new java.util.Properties; specialinvoke v.()>(); v = v.; staticinvoke (v, v, null); v = new java.io.ByteArrayOutputStream; specialinvoke v.(int)>(4096); virtualinvoke v.(v, ""); v = virtualinvoke v.(); if v <= 2048 goto label; v = new java.io.IOException; specialinvoke v.(java.lang.String)>("Configuation is larger than: 2048"); throw v; label: v = virtualinvoke v.(); v = 2048 - v; v = newarray (byte)[v]; staticinvoke (v, 32); virtualinvoke v.(v); virtualinvoke v.(); v = virtualinvoke v.(); v = v.; virtualinvoke v.(0L); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(2048L); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(); return; } private void storeFreeList() throws java.io.IOException { org.apache.activemq.store.kahadb.disk.util.SequenceSet$Marshaller v; java.io.DataOutputStream v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; java.io.FileOutputStream v; java.io.File v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = new java.io.FileOutputStream; v = virtualinvoke v.(); specialinvoke v.(java.io.File)>(v); v = new java.io.DataOutputStream; specialinvoke v.(java.io.OutputStream)>(v); v = ; v = v.; virtualinvoke v.(v, v); virtualinvoke v.(); return; } private void loadFreeList() throws java.io.IOException { java.io.DataInputStream v; org.apache.activemq.store.kahadb.disk.util.SequenceSet$Marshaller v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v, v; java.io.FileInputStream v; java.io.File v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; virtualinvoke v.(); v = new java.io.FileInputStream; v = virtualinvoke v.(); specialinvoke v.(java.io.File)>(v); v = new java.io.DataInputStream; specialinvoke v.(java.io.InputStream)>(v); v = ; v = virtualinvoke v.(v); v. = v; virtualinvoke v.(); return; } public boolean isEnableRecoveryFile() { org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; return v; } public void setEnableRecoveryFile(boolean) { org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: boolean; virtualinvoke v.(); v. = v; return; } public boolean isEnableDiskSyncs() { org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; return v; } public void setEnableDiskSyncs(boolean) { org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: boolean; virtualinvoke v.(); v. = v; return; } public int getPageSize() { int v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; return v; } public int getPageContentSize() { int v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; v = v - 21; return v; } public void setPageSize(int) throws java.lang.IllegalStateException { int v; org.apache.activemq.store.kahadb.disk.page.PageFile v; v := @this: org.apache.activemq.store.kahadb.disk.page.PageFile; v := @parameter: int; virtualinvoke v.(); v.