public abstract class org.apache.activemq.store.kahadb.MessageDatabase extends org.apache.activemq.util.ServiceSupport implements org.apache.activemq.broker.BrokerServiceAware { protected org.apache.activemq.broker.BrokerService brokerService; public static final java.lang.String PROPERTY_LOG_SLOW_ACCESS_TIME; public static final int LOG_SLOW_ACCESS_TIME; public static final java.io.File DEFAULT_DIRECTORY; protected static final org.apache.activemq.protobuf.Buffer UNMATCHED; private static final org.slf4j.Logger LOG; static final int CLOSED_STATE; static final int OPEN_STATE; static final long NOT_ACKED; static final int VERSION; static final byte COMPACTED_JOURNAL_FILE; protected org.apache.activemq.store.kahadb.disk.page.PageFile pageFile; protected org.apache.activemq.store.kahadb.disk.journal.Journal journal; protected org.apache.activemq.store.kahadb.MessageDatabase$Metadata metadata; protected final org.apache.activemq.store.PersistenceAdapterStatistics persistenceAdapterStatistics; protected org.apache.activemq.store.kahadb.MessageDatabase$MetadataMarshaller metadataMarshaller; protected boolean failIfDatabaseIsLocked; protected boolean deleteAllMessages; protected java.io.File directory; protected java.io.File indexDirectory; protected java.util.concurrent.ScheduledExecutorService scheduler; private final java.lang.Object schedulerLock; protected org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy journalDiskSyncStrategy; protected boolean archiveDataLogs; protected java.io.File directoryArchive; protected java.util.concurrent.atomic.AtomicLong journalSize; long journalDiskSyncInterval; long checkpointInterval; long cleanupInterval; boolean cleanupOnStop; int journalMaxFileLength; int journalMaxWriteBatchSize; boolean enableIndexWriteAsync; int setIndexWriteBatchSize; private java.lang.String preallocationScope; private java.lang.String preallocationStrategy; protected java.util.concurrent.atomic.AtomicBoolean opened; private boolean ignoreMissingJournalfiles; private int indexCacheSize; private boolean checkForCorruptJournalFiles; protected org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy purgeRecoveredXATransactionStrategy; private boolean checksumJournalFiles; protected boolean forceRecoverIndex; private boolean archiveCorruptedIndex; private boolean useIndexLFRUEviction; private float indexLFUEvictionFactor; private boolean enableIndexDiskSyncs; private boolean enableIndexRecoveryFile; private boolean enableIndexPageCaching; java.util.concurrent.locks.ReentrantReadWriteLock checkpointLock; private boolean enableAckCompaction; private int compactAcksAfterNoGC; private boolean compactAcksIgnoresStoreGrowth; private int checkPointCyclesWithNoGC; private int journalLogOnLastCompactionCheck; private boolean enableSubscriptionStatistics; protected final java.util.concurrent.atomic.AtomicReference lastAsyncJournalUpdate; private org.apache.activemq.store.kahadb.disk.journal.Location nextRecoveryPosition; private org.apache.activemq.store.kahadb.disk.journal.Location lastRecoveryPosition; protected final java.util.concurrent.locks.ReentrantReadWriteLock indexLock; private final java.util.HashSet journalFilesBeingReplicated; final java.lang.Runnable nullCompletionCallback; protected final java.util.HashMap storedDestinations; protected final java.util.concurrent.ConcurrentMap storeCache; private final java.util.LinkedHashMap inflightTransactions; protected final java.util.LinkedHashMap preparedTransactions; public void () { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$MetadataMarshaller v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationStrategy v; java.util.concurrent.atomic.AtomicBoolean v; java.util.HashMap v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope v; java.util.concurrent.locks.ReentrantReadWriteLock v, v; java.util.concurrent.atomic.AtomicReference v; java.util.HashSet v; java.util.LinkedHashMap v, v; int v; java.lang.String v, v; org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v; org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy v; org.apache.activemq.store.PersistenceAdapterStatistics v; java.util.concurrent.ConcurrentHashMap v; org.apache.activemq.store.kahadb.MessageDatabase$20 v; java.io.File v; java.util.concurrent.atomic.AtomicLong v; java.lang.Object v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; specialinvoke v.()>(); v = new org.apache.activemq.store.kahadb.MessageDatabase$Metadata; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v. = v; v = new org.apache.activemq.store.PersistenceAdapterStatistics; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.store.kahadb.MessageDatabase$MetadataMarshaller; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v. = v; v = ; v. = v; v. = null; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = ; v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(0L); v. = v; v. = 1000L; v. = 5000L; v. = 30000L; v. = 1; v. = 33554432; v. = 4194304; v. = 0; v = ; v. = v; v = ; v = virtualinvoke v.(); v. = v; v = ; v = virtualinvoke v.(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.()>(); v. = v; v. = 0; v. = 10000; v. = 0; v = ; v. = v; v. = 1; v. = 0; v. = 0; v. = 0; v. = 0.2F; v. = 1; v. = 1; v. = 1; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v. = 1; v. = 10; v. = 0; v. = 0; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v = new java.util.HashSet; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.store.kahadb.MessageDatabase$20; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.util.LinkedHashMap; specialinvoke v.()>(); v. = v; v = new java.util.LinkedHashMap; specialinvoke v.()>(); v. = v; return; } public void doStart() throws java.lang.Exception { org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; virtualinvoke v.(); return; } public void doStop(org.apache.activemq.util.ServiceStopper) throws java.lang.Exception { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.util.ServiceStopper v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.util.ServiceStopper; virtualinvoke v.(); return; } public void allowIOResumption() { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: return; } private void loadPageFile() throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.HashMap v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$1 v; org.apache.activemq.store.kahadb.MessageDatabase$2 v; org.apache.activemq.store.kahadb.disk.page.PageFile v; org.apache.activemq.store.kahadb.disk.page.Transaction v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$1; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.disk.page.PageFile)>(v, v); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$2; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(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 startCheckpoint() { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; long v, v, v, v, v, v, v; byte v, v, v, v; java.util.concurrent.ScheduledExecutorService v, v, v, v; java.lang.String v, v; boolean v, v, v; org.slf4j.Logger v; java.util.concurrent.TimeUnit v; java.lang.Object v; org.apache.activemq.store.kahadb.MessageDatabase$3 v; org.apache.activemq.store.kahadb.MessageDatabase$CheckpointRunner v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = v cmp 0L; if v != 0 goto label; v = v.; v = v cmp 0L; if v != 0 goto label; v = ; v = virtualinvoke v.(); if v == 0 goto label; v = "shutdown/"; goto label; label: v = ""; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("periodic checkpoint/cleanup disabled, will occur on clean \u0001restart"); interfaceinvoke v.(v); return; label: v = v.; entermonitor v; label: v = v.; if v == null goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; label: v = new org.apache.activemq.store.kahadb.MessageDatabase$3; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v = staticinvoke (v); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v cmp 0L; if v <= 0 goto label; v = v.; goto label; label: v = v.; label: v = staticinvoke (v, 500L); goto label; label: v = v.; v = v cmp 0L; if v <= 0 goto label; v = v.; goto label; label: v = v.; label: v = staticinvoke (v, 500L); label: v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$CheckpointRunner; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v = ; interfaceinvoke v.(v, 0L, v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return; catch java.lang.Throwable from label to label with label; } public void open() throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.atomic.AtomicBoolean v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v; boolean v, v, v; org.slf4j.Logger v, v, v; java.lang.Exception v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; 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 = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Index corrupted. Recovering the index through journal replay. Cause:\u0001"); interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Index load failure", v); label: v = v.; virtualinvoke v.(); label: goto label; label: v := @caughtexception; label: v = v.; if v == 0 goto label; v = v.; virtualinvoke v.(); goto label; label: v = v.; virtualinvoke v.(); label: v = specialinvoke v.(); v. = v; virtualinvoke v.(); v. = null; specialinvoke v.(); label: specialinvoke v.(); specialinvoke v.(); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; } public void load() throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.Date v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.data.KahaTraceCommand v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; org.slf4j.Logger v; java.io.File v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; staticinvoke (v); v = v.; if v == 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(0); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(); v. = null; v = virtualinvoke v.(); virtualinvoke v.(); v = ; interfaceinvoke v.("Persistence store purged."); v. = 0; label: virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.data.KahaTraceCommand; specialinvoke v.()>(); v = new java.util.Date; specialinvoke v.()>(); v = dynamicinvoke "makeConcatWithConstants" (v) ("LOADED \u0001"); v = virtualinvoke 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; } public void close() throws java.io.IOException, java.lang.InterruptedException { java.lang.Throwable v, v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.atomic.AtomicBoolean v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.concurrent.ConcurrentMap v; java.util.concurrent.ScheduledExecutorService v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v; org.apache.activemq.store.kahadb.disk.page.Page v; java.util.concurrent.atomic.AtomicLong v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(1, 0); if v == 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = v.; if v == null goto label; v = virtualinvoke v.(); specialinvoke v.(v); label: v = v.; virtualinvoke v.(); v = specialinvoke v.(); 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.; virtualinvoke v.(); v = v.; entermonitor v; label: v = v.; if v == null goto label; v = v.; staticinvoke (v, -1L); v. = null; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(0L); label: return; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public void unload() throws java.io.IOException, java.lang.InterruptedException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v; boolean v; org.apache.activemq.store.kahadb.disk.journal.Location[] v; org.apache.activemq.store.kahadb.disk.page.Page v; org.apache.activemq.store.kahadb.MessageDatabase$4 v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; 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.; v. = 1; v = v.; v = virtualinvoke v.(); v = v[0]; v. = v; v = v.; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$4; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(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: virtualinvoke v.(); return; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.store.kahadb.disk.journal.Location[] getInProgressTxLocationRange() { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.LinkedHashMap v, v, v, v, v; boolean v, v, v, v, v, v; java.util.Iterator v, v; java.util.Collection v, v; org.apache.activemq.store.kahadb.disk.journal.Location[] v; java.lang.Object v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = newarray (org.apache.activemq.store.kahadb.disk.journal.Location)[2]; v[0] = null; v[1] = null; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; specialinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; specialinvoke v.(v, v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } private void trackMaxAndMin(org.apache.activemq.store.kahadb.disk.journal.Location[], java.util.List) { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Location[] v; java.util.List v; int v, v, v, v; java.lang.Object v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location[]; v := @parameter: java.util.List; v = interfaceinvoke v.(0); v = virtualinvoke v.(); v = v[0]; if v == null goto label; v = v[0]; v = virtualinvoke v.(v); if v > 0 goto label; label: v[0] = v; label: v = interfaceinvoke v.(); v = v - 1; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = v[1]; if v == null goto label; v = v[1]; v = virtualinvoke v.(v); if v < 0 goto label; label: v[1] = v; label: return; } public java.lang.String getTransactions() { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$TranInfo v, v; boolean v, v, v, v, v, v; java.util.Set v, v; java.lang.Throwable v, v; java.util.ArrayList v; java.util.LinkedHashMap v, v, v, v, v, v; java.lang.String v; java.util.Iterator v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$TranInfo; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$TranInfo; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v = interfaceinvoke v.(); v. = v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: virtualinvoke v.(v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = virtualinvoke v.(); return v; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } public java.lang.String getPreparedTransaction(org.apache.activemq.command.TransactionId) { java.lang.Throwable v; java.util.Iterator v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$TranInfo v; java.util.LinkedHashMap v, v, v; java.lang.Object v, v, v; java.lang.String v; org.apache.activemq.command.TransactionId v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.command.TransactionId; v = ""; v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v == null goto label; v = new org.apache.activemq.store.kahadb.MessageDatabase$TranInfo; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v. = v; v = v.; v = virtualinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } private void recover() throws java.lang.IllegalStateException, java.io.IOException { org.apache.activemq.store.kahadb.data.KahaTransactionInfo v, v, v; java.util.Set v, v; org.apache.activemq.store.kahadb.data.KahaCommitCommand v; java.lang.Throwable v, v, v; long v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.LinkedHashMap v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; java.util.LinkedHashSet v; java.io.IOException v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v, v; org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; int[] v; org.apache.activemq.store.kahadb.data.KahaRollbackCommand v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy v; float v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; java.util.HashSet v, v; int v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.Iterator v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$5 v; java.lang.Object v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = staticinvoke (); v = specialinvoke v.(); v = specialinvoke v.(); v = v | v; v = specialinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(null); goto label; label: v = v; label: v = v; if v == null goto label; v = 0; v = virtualinvoke v.(); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Recovering from the journal @\u0001"); interfaceinvoke v.(v); label: if v == null goto label; label: v = virtualinvoke v.(v); v = v.; 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); if v == null goto label; v = virtualinvoke v.(); if v == v goto label; v = virtualinvoke v.(); v = v.; virtualinvoke v.(); label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = v % 100000; if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("@\u, \u entries recovered .."); interfaceinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = ; v = v - v; v = v / 1000.0F; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Recovery replayed \u operations from the journal in \u seconds."); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$5; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); virtualinvoke v.(v); v = new java.util.HashSet; specialinvoke v.()>(); v = new java.util.HashSet; specialinvoke v.()>(); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.(v); goto label; label: interfaceinvoke v.(v); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("rolling back recovered indoubt local transaction \u0001"); interfaceinvoke v.(v); label: v = new org.apache.activemq.store.kahadb.data.KahaRollbackCommand; specialinvoke v.()>(); v = staticinvoke (v); v = virtualinvoke v.(v); virtualinvoke v.(v, 0, null, null); goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("discarding recovered in-flight XA transaction \u0001"); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; entermonitor v; label: v = new java.util.LinkedHashSet; v = v.; v = virtualinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = ; v = v.; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; default: goto label; }; label: v = ; interfaceinvoke v.("Recovered prepared XA TX: [{}]", v); goto label; label: v = new org.apache.activemq.store.kahadb.data.KahaCommitCommand; specialinvoke v.()>(); v = staticinvoke (v); v = virtualinvoke v.(v); virtualinvoke v.(v, 0, null, null); v = ; interfaceinvoke v.("Recovered and Committing prepared XA TX: [{}]", v); goto label; label: v = new org.apache.activemq.store.kahadb.data.KahaRollbackCommand; specialinvoke v.()>(); v = staticinvoke (v); v = virtualinvoke v.(v); virtualinvoke v.(v, 0, null, null); v = ; interfaceinvoke v.("Recovered and Rolling Back prepared XA TX: [{}]", v); goto label; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw 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.io.IOException 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.Throwable from label to label with label; } private org.apache.activemq.store.kahadb.data.KahaTransactionInfo createLocalTransactionInfo(org.apache.activemq.command.TransactionId) { org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; org.apache.activemq.command.TransactionId v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.command.TransactionId; v = staticinvoke (v); return v; } private org.apache.activemq.store.kahadb.disk.journal.Location minimum(org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.disk.journal.Location) { org.apache.activemq.store.kahadb.MessageDatabase v; int v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; 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 = v; if v == null goto label; v = virtualinvoke v.(v); if v >= 0 goto label; v = v; goto label; label: v = v; label: return v; } private boolean recoverProducerAudit() throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.protobuf.Buffer v; org.apache.activemq.ActiveMQMessageAuditNoSync v, v; int v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v; org.slf4j.Logger v; org.apache.activemq.protobuf.BufferInputStream v; java.lang.Exception v; org.apache.activemq.store.kahadb.MessageDatabase$MessageDatabaseObjectInputStream v; java.lang.Object v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = 1; v = v.; v = v.; if v == null goto label; label: v = v.; v = v.; v = virtualinvoke v.(v); v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageDatabaseObjectInputStream; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.io.InputStream)>(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v); v = 0; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Cannot recover message audit", v); label: return v; catch java.lang.Exception from label to label with label; } private boolean recoverAckMessageFileMap() throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.protobuf.Buffer v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v; org.slf4j.Logger v; org.apache.activemq.protobuf.BufferInputStream v; java.lang.Exception v; org.apache.activemq.store.kahadb.MessageDatabase$MessageDatabaseObjectInputStream v; java.lang.Object v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = 1; v = v.; v = v.; if v == null goto label; label: v = v.; v = v.; v = virtualinvoke v.(v); v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageDatabaseObjectInputStream; v = virtualinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(java.io.InputStream)>(v); v = v.; v = virtualinvoke v.(); v. = v; v = v.; v = v.; virtualinvoke v.(1); v = 0; label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Cannot recover ackMessageFileMap", v); label: return v; catch java.lang.Exception from label to label with label; } protected void recoverIndex(org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v, v, v; java.lang.Integer v, v; byte v, v; java.util.Map v, v, v; long v, v, v, v, v, v, v, v, v, v, v; java.util.LinkedHashMap v; java.io.IOException v, v, v; org.apache.activemq.ActiveMQMessageAuditNoSync v; java.util.Collection v, v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v, v; java.util.HashSet v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v, v; int v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; java.util.Set v, v, v, v, v; org.apache.activemq.store.kahadb.disk.util.LinkedNode v; java.util.ArrayList v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; float v, v; java.util.HashMap v, v, v, v; org.apache.activemq.store.kahadb.disk.index.BTreeVisitor$BetweenVisitor v, v, v; java.util.Iterator v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$8 v; org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys v, v; org.apache.activemq.store.kahadb.MessageDatabase$6 v; org.apache.activemq.store.kahadb.MessageDatabase$7 v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v = staticinvoke (); v = v.; v = virtualinvoke v.(); v = 0L; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$6; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.disk.journal.Location,java.util.ArrayList)>(v, v, v); virtualinvoke v.(v, v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = v.; virtualinvoke v.(v, v); v = v.; v = v.; virtualinvoke v.(v, v); v = v.; v = v.; v = v.; virtualinvoke v.(v); v = v + 1L; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = v cmp 0L; if v <= 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = ; v = v - v; v = v / 1000.0F; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Rolled back \u messages from the index in \u seconds."); interfaceinvoke v.(v); label: v = 0L; v = staticinvoke (); v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$7; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.disk.util.SequenceSet)>(v, v); virtualinvoke v.(v, v); goto label; label: v = new java.util.HashSet; specialinvoke v.()>(); label: v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Some journal files are missing: \u0001"); interfaceinvoke v.(v); label: v = new java.util.ArrayList; specialinvoke v.()>(); v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new org.apache.activemq.store.kahadb.disk.index.BTreeVisitor$BetweenVisitor; v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); specialinvoke v.(int,int)>(v, 0); v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = v + 1; specialinvoke v.(int,int)>(v, 0); specialinvoke v.(java.lang.Comparable,java.lang.Comparable)>(v, v); virtualinvoke v.(v); goto label; label: v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.disk.index.BTreeVisitor$BetweenVisitor; v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); specialinvoke v.(int,int)>(v, v); v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = v + 1; specialinvoke v.(int,int)>(v, 0); specialinvoke v.(java.lang.Comparable,java.lang.Comparable)>(v, v); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); label: if v == null goto label; v = new org.apache.activemq.store.kahadb.disk.index.BTreeVisitor$BetweenVisitor; v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); specialinvoke v.(int,int)>(v, v); v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = v + 1; specialinvoke v.(int,int)>(v, v); specialinvoke v.(java.lang.Comparable,java.lang.Comparable)>(v, v); virtualinvoke v.(v); virtualinvoke v.(v); virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = new java.util.LinkedHashMap; specialinvoke v.()>(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$8; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,java.util.List,java.util.LinkedHashMap)>(v, v, v); virtualinvoke v.(v, v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; if v == 0 goto label; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v, v); v = v.; v = v.; virtualinvoke v.(v, v); v = v.; v = v.; virtualinvoke v.(v, v); v = ; v = interfaceinvoke v.(); v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v, v) ("[\u] dropped: \u at corrupt location: \u0001"); interfaceinvoke v.(v); v = v + 1L; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: v = ; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("[\u] references corrupt locations: \u0001"); interfaceinvoke v.(v); v = new java.io.IOException; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Detected missing/corrupt journal files referenced by:[\u] \u messages affected."); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v.; if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Detected corrupt journal files. \u0001"); interfaceinvoke v.(v); v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Detected corrupt journal files. \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Detected missing journal files. \u0001"); interfaceinvoke v.(v); v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v) ("Detected missing journal files. \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = v cmp 0L; if v <= 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = staticinvoke (); v = ; v = v - v; v = v / 1000.0F; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Detected missing/corrupt journal files. Dropped \u messages from the index in \u seconds."); interfaceinvoke v.(v); label: return; } public void incrementalRecover() throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; if v != null goto label; v = v.; if v != null goto label; v = specialinvoke v.(); v. = v; goto label; label: v = v.; v = v.; v = virtualinvoke v.(v); v. = v; label: v = v.; if v == null goto label; v = v.; v. = v; v = v.; v = v.; v. = v; v = v.; v = virtualinvoke v.(v); v = v.; v = null; virtualinvoke v.(v, v, v); v = v.; v = v.; v = virtualinvoke v.(v); v. = v; goto label; 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; } public org.apache.activemq.store.kahadb.disk.journal.Location getLastUpdatePosition() throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Location v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = v.; return v; } private org.apache.activemq.store.kahadb.disk.journal.Location getRecoveryPosition() throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v, v; boolean v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; if v != 0 goto label; v = v.; v = v.; if v == null goto label; v = v.; v = v.; return v; label: v = v.; v = v.; if v == null goto label; v = v.; v = v.; v = specialinvoke v.(v); return v; label: v = v.; v = virtualinvoke v.(null); return v; } private org.apache.activemq.store.kahadb.disk.journal.Location getNextInitializedLocation(org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; int v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(); v = (int) -1; if v != v goto label; if v == null goto label; v = virtualinvoke v.(); v = (int) -1; if v == v goto label; v = v.; v = virtualinvoke v.(v); return v; label: return v; } protected void checkpointCleanup(boolean) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.atomic.AtomicBoolean v; long v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v; byte v; int v, v; java.lang.String v; boolean v, v, v; org.slf4j.Logger v, v; org.apache.activemq.store.PersistenceAdapterStatistics v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = staticinvoke (); v = v.; v = virtualinvoke v.(); if v != 0 goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: specialinvoke v.(v); v = staticinvoke (); v = v - v; v = ; if v <= 0 goto label; v = ; v = v cmp v; if v <= 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Slow KahaDB access: cleanup took \u0001"); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(v); label: return; catch java.lang.Throwable from label to label with label; } public org.apache.activemq.util.ByteSequence toByteSequence(org.apache.activemq.store.kahadb.JournalCommand) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.util.DataByteArrayOutputStream v; int v, v, v; org.apache.activemq.store.kahadb.data.KahaEntryType v; org.apache.activemq.util.ByteSequence v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v = interfaceinvoke v.(); v = new org.apache.activemq.util.DataByteArrayOutputStream; v = v + 1; specialinvoke v.(int)>(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); interfaceinvoke v.(v); v = virtualinvoke v.(); return v; } public org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Location v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v = virtualinvoke v.(v, 0, null, null); return v; } public org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand, java.lang.Runnable) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Runnable v; org.apache.activemq.store.kahadb.disk.journal.Location v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v := @parameter: java.lang.Runnable; v = virtualinvoke v.(v, 0, null, null, v); return v; } public org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand, boolean, org.apache.activemq.store.kahadb.MessageDatabase$IndexAware, java.lang.Runnable) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; java.lang.Runnable v; org.apache.activemq.store.kahadb.disk.journal.Location v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v := @parameter: boolean; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$IndexAware; v := @parameter: java.lang.Runnable; v = virtualinvoke v.(v, v, v, v, null); return v; } public org.apache.activemq.store.kahadb.disk.journal.Location store(org.apache.activemq.store.kahadb.JournalCommand, boolean, org.apache.activemq.store.kahadb.MessageDatabase$IndexAware, java.lang.Runnable, java.lang.Runnable) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Runnable v, v; byte v; java.util.concurrent.locks.ReentrantReadWriteLock$ReadLock v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; org.apache.activemq.util.ByteSequence v; boolean v, v, v; org.apache.activemq.broker.BrokerService v; org.apache.activemq.store.PersistenceAdapterStatistics v, v; java.lang.Throwable v; long v, v, v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.atomic.AtomicReference v; int v, v; java.lang.String v, v; org.slf4j.Logger v, v, v; java.io.IOException v; org.apache.activemq.store.kahadb.data.KahaEntryType v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v := @parameter: boolean; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$IndexAware; v := @parameter: java.lang.Runnable; v := @parameter: java.lang.Runnable; label: v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = staticinvoke (); if v != null goto label; v = v.; v = virtualinvoke v.(v, v); goto label; label: v = v.; v = virtualinvoke v.(v, v); label: v = v; v = staticinvoke (); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); label: virtualinvoke v.(v, v, v); v = staticinvoke (); v = v - v; v = ; if v <= 0 goto label; v = ; v = v cmp v; if v <= 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v - v; v = v - v; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Slow KahaDB access: Journal append took: \u ms, Index update took \u ms"); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(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: if v == null goto label; interfaceinvoke v.(); label: return v; label: v := @caughtexception; v = ; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("KahaDB failed to store to Journal, command of type: \u0001"); interfaceinvoke v.(v, v); v = v.; virtualinvoke v.(v); throw v; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } public org.apache.activemq.store.kahadb.JournalCommand load(org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; long v, v, v; org.apache.activemq.protobuf.Message v; byte v, v; org.apache.activemq.util.DataByteArrayInputStream v; int v, v; java.lang.String v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.util.ByteSequence v; boolean v; org.slf4j.Logger v, v; org.apache.activemq.store.PersistenceAdapterStatistics v, v; java.io.IOException v; org.apache.activemq.store.kahadb.data.KahaEntryType v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = staticinvoke (); v = v.; v = virtualinvoke v.(v); v = staticinvoke (); v = v - v; v = ; if v <= 0 goto label; v = ; v = v cmp v; if v <= 0 goto label; v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Slow KahaDB access: Journal read took: \u ms"); interfaceinvoke v.(v); label: v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); v = new org.apache.activemq.util.DataByteArrayInputStream; specialinvoke v.(org.apache.activemq.util.ByteSequence)>(v); v = virtualinvoke v.(); v = staticinvoke (v); if v != null goto label; v = new java.io.IOException; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Could not load journal record, null type information from: \u at location: \u0001"); specialinvoke v.(java.lang.String)>(v); throw v; label: v = virtualinvoke v.(); interfaceinvoke v.(v); return v; } void process(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; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$9 v; int v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; 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; specialinvoke v.(v); v = null; virtualinvoke v.(v, v, v); goto label; label: v = new org.apache.activemq.store.kahadb.MessageDatabase$9; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); interfaceinvoke v.(v); label: return; } private void initMessageStore(org.apache.activemq.store.kahadb.JournalCommand) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase$10 v; org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; v = new org.apache.activemq.store.kahadb.MessageDatabase$10; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); interfaceinvoke v.(v); return; } void process(org.apache.activemq.store.kahadb.JournalCommand, org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.MessageDatabase$IndexAware) throws java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$11 v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; org.apache.activemq.store.kahadb.disk.journal.Location v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; 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.MessageDatabase$IndexAware; v = new org.apache.activemq.store.kahadb.MessageDatabase$11; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.disk.journal.Location,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware)>(v, v, v); interfaceinvoke v.(v); return; } protected void process(org.apache.activemq.store.kahadb.data.KahaAddMessageCommand, org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.MessageDatabase$IndexAware) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$12 v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; java.util.List v; org.apache.activemq.store.kahadb.MessageDatabase$AddOperation v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$IndexAware; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); v = new org.apache.activemq.store.kahadb.MessageDatabase$AddOperation; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaAddMessageCommand,org.apache.activemq.store.kahadb.disk.journal.Location,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware)>(v, v, v, v); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$12; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaAddMessageCommand,org.apache.activemq.store.kahadb.disk.journal.Location,org.apache.activemq.store.kahadb.MessageDatabase$IndexAware)>(v, 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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$13 v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand v; org.apache.activemq.store.kahadb.disk.journal.Location 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.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$13; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand,org.apache.activemq.store.kahadb.disk.journal.Location)>(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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$14 v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand v; org.apache.activemq.store.kahadb.MessageDatabase$RemoveOperation v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v; org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; java.util.List v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = specialinvoke v.(v); v = new org.apache.activemq.store.kahadb.MessageDatabase$RemoveOperation; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand,org.apache.activemq.store.kahadb.disk.journal.Location)>(v, v, v); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$14; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand,org.apache.activemq.store.kahadb.disk.journal.Location)>(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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$15 v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand v; org.apache.activemq.store.kahadb.disk.journal.Location 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.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$15; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand,org.apache.activemq.store.kahadb.disk.journal.Location)>(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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$16 v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location 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.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$16; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand,org.apache.activemq.store.kahadb.disk.journal.Location)>(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; catch java.lang.Throwable from label to label with label; } protected void processLocation(org.apache.activemq.store.kahadb.disk.journal.Location) { java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; 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; } protected void process(org.apache.activemq.store.kahadb.data.KahaCommitCommand, org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.MessageDatabase$IndexAware) throws java.io.IOException { java.lang.Throwable v, v; org.apache.activemq.store.kahadb.MessageDatabase$17 v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.LinkedHashMap v, v, v; org.apache.activemq.command.TransactionId v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.disk.page.PageFile v; org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; org.apache.activemq.store.kahadb.data.KahaCommitCommand v; java.lang.Object v; org.apache.activemq.store.kahadb.MessageDatabase$IndexAware v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaCommitCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$IndexAware; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v != null goto label; v = v.; virtualinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v != null goto label; if v == null goto label; interfaceinvoke v.(-1L); label: virtualinvoke v.(v); return; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$17; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,java.util.List,org.apache.activemq.store.kahadb.disk.journal.Location)>(v, v, v); virtualinvoke v.(v); v = v.; 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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaPrepareCommand, org.apache.activemq.store.kahadb.disk.journal.Location) { java.lang.Throwable v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.LinkedHashMap v, v, v; org.apache.activemq.command.TransactionId v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v, v; org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; java.util.Iterator v; org.apache.activemq.store.kahadb.data.KahaPrepareCommand v; java.lang.Object v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaPrepareCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v == null goto label; v = v.; virtualinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v); goto label; 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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaRollbackCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { java.lang.Throwable v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v; java.util.LinkedHashMap v, v, v; org.apache.activemq.store.kahadb.data.KahaRollbackCommand v; org.apache.activemq.command.TransactionId v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v, v, v; org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; java.util.Iterator v; java.lang.Object v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRollbackCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = staticinvoke (v); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v != null goto label; v = v.; virtualinvoke v.(v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = virtualinvoke v.(); if v == 0 goto label; if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, v); goto label; 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; catch java.lang.Throwable from label to label with label; } protected void process(org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Integer v; java.util.TreeSet v; java.util.Map v; int v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; boolean v, v; java.util.Set v; org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand v; org.apache.activemq.store.kahadb.disk.journal.DataFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = new java.util.TreeSet; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = v.; virtualinvoke v.(v); label: return; } long updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaAddMessageCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.ActiveMQMessageAuditNoSync v; java.lang.Long v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v; org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v; java.lang.Object[] v; long v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v, v, v, v; int v, v, v; java.lang.String v, v, v, v, v, v; org.slf4j.Logger v; org.apache.activemq.store.kahadb.data.KahaDestination v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys v, v; java.lang.Object v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaAddMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v != null goto label; return -1L; label: v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v == 0 goto label; return -1L; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = 4; label: v = v.; v = virtualinvoke v.(); v = v.; v = staticinvoke (v); v = virtualinvoke v.(v, v, v); if v != null goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v, v, v); if v != null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; v = staticinvoke (v); v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,org.apache.activemq.store.kahadb.disk.journal.Location)>(v, v); virtualinvoke v.(v, v, v, v); v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = virtualinvoke v.(); v = staticinvoke (v); specialinvoke v.(v, v, v, v); label: v = v.; v. = v; goto label; label: v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = virtualinvoke v.(v); if v >= 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = virtualinvoke v.(); v[0] = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v[1] = v; v = virtualinvoke v.(); v[2] = v; interfaceinvoke v.("Duplicate message add attempt rejected. Destination: {}://{}, Message id: {}", v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; virtualinvoke v.(v, v); v = -1L; goto label; label: v = v.; virtualinvoke v.(v, v, v); v = v.; virtualinvoke v.(); v = v.; v. = v; label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return v; } void trackPendingAdd(org.apache.activemq.store.kahadb.data.KahaDestination, java.lang.Long) { org.apache.activemq.store.kahadb.data.KahaDestination v; java.lang.Long v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Object v; java.util.HashMap v; java.lang.String v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: java.lang.Long; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: return; } void trackPendingAddComplete(org.apache.activemq.store.kahadb.data.KahaDestination, java.lang.Long) { org.apache.activemq.store.kahadb.data.KahaDestination v; java.lang.Long v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Object v; java.util.HashMap v; java.lang.String v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: java.lang.Long; v = v.; v = virtualinvoke v.(v); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: return; } void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v, v; boolean v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.kahadb.data.KahaAddMessageCommand v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; long v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v; int v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.lang.String v, v, v, v; java.util.Iterator v; org.apache.activemq.store.kahadb.data.KahaDestination v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys v, v; java.lang.Object v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaUpdateMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); goto label; label: v = 4; label: v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys; v = virtualinvoke v.(); specialinvoke v.(java.lang.String,org.apache.activemq.store.kahadb.disk.journal.Location)>(v, v); v = virtualinvoke v.(v, v, v, v); v = v.; virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); if v == null goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; if v == 0 goto label; v = v.; if v == null goto label; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v == v goto label; v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = v.; virtualinvoke v.(v, v); label: v = v.; v. = v; goto label; label: virtualinvoke v.(v, v, v); label: return; } void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.protobuf.Buffer v, v; byte v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v; boolean v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v; long v; org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v, v, v, v; int v; java.lang.String v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v; org.apache.activemq.store.kahadb.data.KahaDestination v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys v, v; org.apache.activemq.store.kahadb.MessageDatabase$LastAck v; java.lang.Object v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = v.; v = v.; virtualinvoke v.(v, v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; specialinvoke v.(v, v); v = v.; v. = v; goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("message not found in order index: \u for: \u0001"); interfaceinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("message not found in sequence id index: \u0001"); interfaceinvoke v.(v); goto label; label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = ; if v == v goto label; v = v.; virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$LastAck; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,long,byte)>(v, v, v); virtualinvoke v.(v, v, v); label: v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = v.; specialinvoke v.(v, v); label: specialinvoke v.(v, v, v, v, v); v = v.; v. = v; goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("on ack, no message sequence exists for id: \u and sub: \u0001"); interfaceinvoke v.(v); label: return; } private void recordAckMessageReferenceLocation(org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.disk.journal.Location) { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.atomic.AtomicBoolean v; java.lang.Integer v, v, v, v; java.util.HashSet v; java.util.Map v, v; int v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v; java.lang.Object v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != null goto label; v = new java.util.HashSet; specialinvoke v.()>(); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = v.; v = v.; virtualinvoke v.(1); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(v); label: return; } void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredMessageStoreStatistics v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; java.util.HashMap v; long v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand v; java.util.concurrent.ConcurrentMap v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v, v, v, v; java.lang.String v, v; org.apache.activemq.store.kahadb.data.KahaDestination v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v. = null; v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = v.; virtualinvoke v.(v, v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(v); interfaceinvoke v.(v); return; } void updateIndex(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand, org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand v; org.apache.activemq.store.kahadb.disk.journal.Location v; boolean v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.MessageStoreSubscriptionStatistics v; long v, v; org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand v; java.util.HashSet v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v; int v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v; java.lang.String v, v, v; org.slf4j.Logger v; org.apache.activemq.store.kahadb.data.KahaDestination v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$LastAck v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(v); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("ignoring journal replay of replay of sub from: \u0001"); interfaceinvoke v.(v); return; label: v = v.; virtualinvoke v.(v, v, v); v = v.; virtualinvoke v.(v, v, v); v = -1L; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; v = v - 1L; goto label; label: specialinvoke v.(v, v, v); label: v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$LastAck; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,long)>(v, v); virtualinvoke v.(v, v, v); v = v.; virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); v = v.; virtualinvoke v.(v); specialinvoke v.(v, v, v, v); v = virtualinvoke v.(); v = virtualinvoke v.(v); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(v); if v == 0 goto label; v = new org.apache.activemq.store.kahadb.data.KahaRemoveDestinationCommand; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(v, v, null); v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } private void checkpointUpdate(boolean) throws java.io.IOException { java.lang.Throwable v, v; org.apache.activemq.store.kahadb.MessageDatabase$18 v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v; boolean v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.MessageDatabase$18; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,boolean)>(v, v); v = virtualinvoke v.(v); v = v.; virtualinvoke 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: 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; catch java.lang.Throwable from label to label with label; } java.util.Set checkpointUpdate(org.apache.activemq.store.kahadb.disk.page.Transaction, boolean) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v; java.lang.Integer v, v, v, v, v, v, v, v, v, v, v, v; byte v; java.lang.Long v; java.util.Map v, v, v, v, v, v; java.lang.Object[] v, v; long v, v, v; java.util.concurrent.ScheduledExecutorService v; java.util.SortedSet v; org.apache.activemq.ActiveMQMessageAuditNoSync v; java.util.Collection v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v, v, v, v; java.util.HashSet v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Page v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; java.util.Set v, v; java.lang.Exception v; org.apache.activemq.store.kahadb.disk.util.LinkedNode v; org.apache.activemq.store.kahadb.MessageDatabase$MetadataMarshaller v; java.util.TreeSet v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v; java.io.File v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$AckCompactionRunner v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.List v; java.util.HashMap v; org.apache.activemq.store.kahadb.MessageDatabase$19 v; java.util.Iterator v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location[] v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: boolean; v = virtualinvoke v.(); v = virtualinvoke v.(); staticinvoke ("activemq.persistenceDir", v); v = ; interfaceinvoke v.("Checkpoint started."); v = v.; v = v.; v = v.; v. = 2; v = v.; v = specialinvoke v.(); v. = v; v = v.; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = v.; if v != null goto label; label: v = v.; v = specialinvoke v.(); v. = v; label: v = v.; v = v.; virtualinvoke v.(0); v = virtualinvoke v.(); v = v.; v = v[0]; v. = v; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, 1); v = new java.util.TreeSet; specialinvoke 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); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Last update: \u, full gc candidates set: \u0001"); interfaceinvoke v.(v); label: if v == null goto label; v = new java.util.TreeSet; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); specialinvoke v.(java.util.SortedSet)>(v); virtualinvoke v.(v); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(v); label: v = v.; v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; v = v.; v = v.; virtualinvoke v.(1); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("rewriting producerSequenceIdTracker:\u0001"); interfaceinvoke v.(v); label: v = staticinvoke (v); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("gc candidates after producerSequenceIdTrackerLocation:\u, \u0001"); interfaceinvoke v.(v); label: v = v.; v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("gc candidates after ackMessageFileMapLocation:\u, \u0001"); interfaceinvoke v.(v); label: v = v[0]; if v == null goto label; v = v[0]; v = virtualinvoke v.(); label: v = v[1]; v = virtualinvoke v.(); if v > v goto label; v = staticinvoke (v); virtualinvoke v.(v); v = v + 1; goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("gc candidates after in progress tx range:\u, \u0001"); interfaceinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$19; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,java.util.TreeSet)>(v, v); virtualinvoke v.(v, v); v = interfaceinvoke v.(); v = v.; if v == null goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 1 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v cmp 1L; if v != 0 goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = newarray (java.lang.Object)[3]; v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Found candidate for rewrite: sub {} on {} from file {}", v); label: v = v.; v = virtualinvoke v.(v, v); v = v.; v = specialinvoke v.(v); virtualinvoke v.(v, v, v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v, v); v = ; v = newarray (java.lang.Object)[4]; v[0] = v; v = interfaceinvoke v.(); v[1] = v; v = staticinvoke (v); v[2] = v; v = virtualinvoke v.(); v = v - 1L; v = staticinvoke (v); v[3] = v; interfaceinvoke v.("sub {} on {} in dataFile {} has pendingCount {}", v); label: v = staticinvoke (v); virtualinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = interfaceinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("gc candidates after dest:\u, \u0001"); interfaceinvoke v.(v); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("gc candidates: \u0001"); interfaceinvoke v.(v); v = ; v = v.; v = v.; v = dynamicinvoke "makeConcatWithConstants" (v) ("ackMessageFileMap: \u0001"); interfaceinvoke v.(v); label: v = 0; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(v); if v == null goto label; 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 = virtualinvoke v.(v); if v != 0 goto label; interfaceinvoke v.(); label: v = virtualinvoke v.(v); if v == 0 goto label; v = v; v = v.; v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = 1; goto label; label: v = 0; label: v = v | v; v = v.; v = v.; virtualinvoke v.(1); goto label; label: v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("not removing data file: \u as contained ack(s) refer to referenced file: \u0001"); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v != 0 goto label; v = ; interfaceinvoke v.("Cleanup removing the data files: {}", v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = v | v; v = v.; v = v.; virtualinvoke v.(1); goto label; label: if v == 0 goto label; virtualinvoke v.(v, 0); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = v + 1; v. = v; v = virtualinvoke v.(); if v < v goto label; v = v.; v = v.; v = interfaceinvoke v.(); if v <= 1 goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == v goto label; v = virtualinvoke v.(); if v == 0 goto label; label: v = ; interfaceinvoke v.("No files GC\'d checking if threshold to ACK compaction has been met."); label: v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$AckCompactionRunner; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); interfaceinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error on queueing the Ack Compactor", v); goto label; label: v = ; interfaceinvoke v.("Journal activity detected, no Ack compaction scheduled."); label: v. = 0; goto label; label: v = ; v = v.; v = staticinvoke (v); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Not yet time to check for compaction: {} of {} cycles", v, v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v. = v; label: staticinvoke ("activemq.persistenceDir"); v = ; interfaceinvoke v.("Checkpoint done."); return v; catch java.lang.Exception from label to label with label; } private boolean blockedFromCompaction(int) { org.slf4j.Logger v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Integer v, v; org.apache.activemq.store.kahadb.disk.journal.Location[] v; int v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != v goto label; return 1; label: v = virtualinvoke v.(); v = v[0]; if v == null goto label; v = v[0]; v = virtualinvoke v.(); label: v = v[1]; v = virtualinvoke v.(); if v > v goto label; if v != v goto label; v = ; v = staticinvoke (v); interfaceinvoke v.("Compaction target:{} blocked by inflight transaction records: {}", v, v); return 1; label: v = v + 1; goto label; label: return 0; } private void forwardAllAcks(java.lang.Integer, java.util.Set) throws java.lang.IllegalStateException, java.io.IOException { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v; java.lang.Integer v, v; java.util.Map v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v, v; org.apache.activemq.util.ByteSequence v, v; boolean v, v; java.util.Set v, v; org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand v; java.lang.Throwable v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v, v, v; java.util.concurrent.atomic.AtomicBoolean v, v; java.util.HashMap v; java.util.concurrent.locks.ReentrantReadWriteLock v, v; java.util.HashSet v; org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender v; int v, v, v, v, v, v; org.slf4j.Logger v, v, v, v, v, v; java.util.Iterator v; java.io.IOException v; java.lang.Object v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.DataFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.Integer; v := @parameter: java.util.Set; v = ; interfaceinvoke v.("Attempting to move all acks in journal:{} to the front. Referenced files:{}", v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(1); v = ; interfaceinvoke v.("Reserved file for forwarded acks: {}", v); v = new java.util.HashMap; specialinvoke v.()>(); v = new org.apache.activemq.store.kahadb.disk.journal.TargetedDataFileAppender; v = v.; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal,org.apache.activemq.store.kahadb.disk.journal.DataFile)>(v, v); label: v = new org.apache.activemq.store.kahadb.data.KahaRewrittenDataFileCommand; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(v); virtualinvoke v.(v, 1, 0); v = ; interfaceinvoke v.("Marked ack rewrites file as replacing file: {}", v); v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); v = v + 1; specialinvoke v.(int,int)>(v, 0); v = new org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(); specialinvoke v.(int,int)>(v, 0); v = specialinvoke v.(v, v); label: if v == null goto label; v = null; label: v = virtualinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Error loading command during ack forward: {}", v); label: v = specialinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(v); v = virtualinvoke v.(v, 1, 0); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); label: v = specialinvoke v.(v, v); goto label; label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = ; interfaceinvoke v.("ACKS forwarded, updates for ack locations: {}", v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v != null goto label; v = new java.util.HashSet; specialinvoke v.()>(); v = interfaceinvoke v.(); interfaceinvoke v.(v); v = v.; v = v.; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = v.; virtualinvoke v.(1); goto label; label: v = interfaceinvoke v.(); interfaceinvoke v.(v); goto label; label: v = v.; v = v.; interfaceinvoke v.(v); v = v.; v = v.; virtualinvoke v.(1); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); v = ; v = v.; v = v.; interfaceinvoke v.("ACK File Map following updates: {}", v); return; catch java.io.IOException from label to label with label; catch java.lang.Throwable from label to label with label; } private boolean shouldForward(org.apache.activemq.store.kahadb.JournalCommand) { org.apache.activemq.store.kahadb.JournalCommand v; org.apache.activemq.store.kahadb.MessageDatabase v; boolean v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.JournalCommand; if v != null goto label; return 0; label: v = v instanceof org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand; if v != 0 goto label; v = v instanceof org.apache.activemq.store.kahadb.data.KahaCommitCommand; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: return v; } private org.apache.activemq.store.kahadb.disk.journal.Location getNextLocationForAckForward(org.apache.activemq.store.kahadb.disk.journal.Location, org.apache.activemq.store.kahadb.disk.journal.Location) { org.slf4j.Logger v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.io.IOException v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v; boolean v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = null; label: v = v.; v = virtualinvoke v.(v, v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Failed to load next journal location after: {}, reason: {}", v, v); v = ; v = interfaceinvoke v.(); if v == 0 goto label; v = ; interfaceinvoke v.("Failed to load next journal location after: {}", v, v); label: return v; catch java.io.IOException from label to label with label; } private org.apache.activemq.store.kahadb.disk.journal.Location checkpointProducerAudit() throws java.io.IOException { byte[] v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v; java.io.ByteArrayOutputStream v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.protobuf.Buffer v; java.io.InterruptedIOException v; java.lang.Runnable v; java.util.concurrent.atomic.AtomicReference v, v; org.apache.activemq.ActiveMQMessageAuditNoSync v, v, v; java.io.ObjectOutputStream v; java.lang.String v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v; org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand v; java.util.concurrent.CountDownLatch v; java.lang.InterruptedException v; java.lang.Object v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = v.; if v == null goto label; v = v.; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.ObjectOutputStream; specialinvoke v.(java.io.OutputStream)>(v); v = v.; v = v.; virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.data.KahaProducerAuditCommand; specialinvoke v.()>(); v = new org.apache.activemq.protobuf.Buffer; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v, v); label: v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); throw v; label: v := @caughtexception; v = new java.io.InterruptedIOException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; label: v = v.; v = v.; return v; catch java.lang.InterruptedException from label to label with label; } private org.apache.activemq.store.kahadb.disk.journal.Location checkpointAckMessageFileMap() throws java.io.IOException { byte[] v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; java.io.ByteArrayOutputStream v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.protobuf.Buffer v; java.io.InterruptedIOException v; java.lang.Runnable v; java.util.concurrent.CountDownLatch v; java.lang.InterruptedException v; org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand v; java.util.Map v; java.io.ObjectOutputStream v; java.lang.Object v; java.lang.String v; org.apache.activemq.store.kahadb.disk.journal.Location v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.ObjectOutputStream; specialinvoke v.(java.io.OutputStream)>(v); v = v.; v = v.; virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(); v = new org.apache.activemq.store.kahadb.data.KahaAckMessageFileMapCommand; specialinvoke v.()>(); v = new org.apache.activemq.protobuf.Buffer; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v, v); label: v = virtualinvoke v.(); virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.InterruptedIOException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; catch java.lang.InterruptedException from label to label with label; } private org.apache.activemq.store.kahadb.disk.journal.Location checkpointSubscriptionCommand(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand v; java.io.InterruptedIOException v; java.lang.Runnable v; java.util.concurrent.CountDownLatch v; java.lang.InterruptedException v; java.lang.String 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.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand; v = virtualinvoke v.(v); v = v.; v = v.; v = virtualinvoke v.(v, v); label: v = virtualinvoke v.(); virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = new java.io.InterruptedIOException; v = virtualinvoke v.(); specialinvoke v.(java.lang.String)>(v); throw v; label: return v; catch java.lang.InterruptedException from label to label with label; } public java.util.HashSet getJournalFilesBeingReplicated() { java.util.HashSet v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } protected org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination getStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination, org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException { org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v, v, v, v; org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.HashMap v, v; java.lang.Object v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v != null goto label; v = virtualinvoke v.(); v = ; if v == v goto label; v = virtualinvoke v.(); v = ; if v != v goto label; label: v = 1; goto label; label: v = 0; label: v = specialinvoke v.(v, v, v); v = v.; virtualinvoke v.(v, v); label: return v; } protected org.apache.activemq.store.MessageStoreStatistics getStoredMessageStoreStatistics(org.apache.activemq.store.kahadb.data.KahaDestination, org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException { org.apache.activemq.store.MessageStoreStatistics v; org.apache.activemq.store.kahadb.MessageDatabase$StoredMessageStoreStatistics v, v; org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v = virtualinvoke v.(v, v); if v == null goto label; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v); goto label; label: v = null; label: return v; } protected org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination getExistingStoredDestination(org.apache.activemq.store.kahadb.data.KahaDestination, org.apache.activemq.store.kahadb.disk.page.Transaction) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.disk.index.BTreeIndex v; org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.HashMap v; java.lang.Object v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); if v != null goto label; v = v.; v = v.; v = virtualinvoke v.(v, v); if v == 0 goto label; v = virtualinvoke v.(v, v); label: return v; } private org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination loadStoredDestination(org.apache.activemq.store.kahadb.disk.page.Transaction, java.lang.String, boolean) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; byte v, v; org.apache.activemq.store.kahadb.MessageDatabase$LocationSizeMarshaller v; long v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.util.StringMarshaller v, v, v, v, v; org.apache.activemq.store.kahadb.disk.util.LongMarshaller v, v; org.apache.activemq.store.kahadb.disk.util.SequenceSet$Marshaller v; org.apache.activemq.store.kahadb.MessageDatabase$StoredMessageStoreStatistics v, v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.util.LocationMarshaller v; org.apache.activemq.store.kahadb.MessageDatabase$Metadata v, v, v, v, v, v; java.util.HashSet v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v, v, v, v, v, v, v, v, v, v, v, v, v; int v, v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Page v, v, v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; org.apache.activemq.store.kahadb.MessageDatabase$KahaSubscriptionCommandMarshaller v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderCursor v; org.apache.activemq.store.kahadb.MessageDatabase$LastAckMarshaller v; java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase v; boolean v, v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; java.util.HashMap v; java.util.Iterator v, v, v, v, v, v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: java.lang.String; v := @parameter: boolean; v = v.; v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = new org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v = v; v = v.; virtualinvoke v.(v); v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v); v. = v; v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v); v. = v; if v == 0 goto label; v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v); v. = v; v = new org.apache.activemq.store.kahadb.disk.index.BTreeIndex; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v); v. = v; v = new org.apache.activemq.store.kahadb.disk.index.ListIndex; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v); v. = v; v = new org.apache.activemq.store.kahadb.disk.index.ListIndex; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v); v. = v; label: v = new org.apache.activemq.store.kahadb.MessageDatabase$StoredMessageStoreStatistics; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,org.apache.activemq.store.kahadb.disk.page.PageFile,org.apache.activemq.store.kahadb.disk.page.Page)>(v, v, v); v. = v; v = v.; v = v.; virtualinvoke v.(v, v, v); label: v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$LocationSizeMarshaller; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = v.; if v >= 6 goto label; v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v, v); v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v, v, v); goto label; label: if v == 0 goto label; v = v.; v = ; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$LastAckMarshaller; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; v = ; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = v.; v = v.; if v >= 3 goto label; v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderCursor; v = interfaceinvoke v.(); v = v.; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,long)>(v, v); v = virtualinvoke v.(v, v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); specialinvoke v.(v, v, v, v); goto label; label: v = v.; v = interfaceinvoke v.(); v = interfaceinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; v = v.; v = v cmp 0L; if v != 0 goto label; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = v.; v = interfaceinvoke v.(); v = v.; v = v + 1L; v = staticinvoke (v, v); v. = v; goto label; label: v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = staticinvoke (v, v); v. = v; goto label; label: v = v.; v = v.; if v >= 7 goto label; v = v.; v = v.; virtualinvoke v.(v, v, v); label: return v; } protected void clearStoreStats(org.apache.activemq.store.kahadb.data.KahaDestination) { org.apache.activemq.store.MessageStoreStatistics v; org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.String v; org.apache.activemq.store.MessageStoreSubscriptionStatistics v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v = virtualinvoke v.(v); v = virtualinvoke v.(v); v = virtualinvoke v.(v); if v == null goto label; virtualinvoke v.(); label: if v == null goto label; virtualinvoke v.(); label: return; } protected void incrementAndAddSizeToStoreStat(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaDestination, long) throws java.io.IOException { org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: long; v = virtualinvoke v.(v, v); v = virtualinvoke v.(v); virtualinvoke v.(v, v, v, v); return; } protected void incrementAndAddSizeToStoreStat(org.apache.activemq.store.kahadb.disk.page.Transaction, java.lang.String, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, long) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; org.apache.activemq.store.MessageStoreStatistics v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredMessageStoreStatistics v, v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: long; v = virtualinvoke v.(v); if v == null goto label; specialinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); goto label; label: if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != null goto label; v = new org.apache.activemq.store.MessageStoreStatistics; specialinvoke v.()>(); v = v; label: specialinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); label: return; } private void incrementAndAddSizeToStoreStat(long, org.apache.activemq.store.MessageStoreStatistics) { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.store.MessageStoreStatistics v; byte v; org.apache.activemq.store.kahadb.MessageDatabase v; long v; org.apache.activemq.management.SizeStatisticImpl v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: long; v := @parameter: org.apache.activemq.store.MessageStoreStatistics; v = virtualinvoke v.(); virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); label: return; } protected void decrementAndSubSizeToStoreStat(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaDestination, long) throws java.io.IOException { org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: long; v = virtualinvoke v.(v, v); v = virtualinvoke v.(v); virtualinvoke v.(v, v, v, v); return; } protected void decrementAndSubSizeToStoreStat(org.apache.activemq.store.kahadb.disk.page.Transaction, java.lang.String, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, long) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; org.apache.activemq.store.MessageStoreStatistics v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredMessageStoreStatistics v, v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: java.lang.String; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: long; v = virtualinvoke v.(v); if v == null goto label; specialinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); goto label; label: if v == null goto label; v = v.; v = virtualinvoke v.(v); if v != null goto label; v = new org.apache.activemq.store.MessageStoreStatistics; specialinvoke v.()>(); v = v; label: specialinvoke v.(v, v); v = v.; virtualinvoke v.(v, v); label: return; } private void decrementAndSubSizeToStoreStat(long, org.apache.activemq.store.MessageStoreStatistics) { org.apache.activemq.management.CountStatisticImpl v; org.apache.activemq.store.MessageStoreStatistics v; byte v; org.apache.activemq.store.kahadb.MessageDatabase v; long v, v; org.apache.activemq.management.SizeStatisticImpl v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: long; v := @parameter: org.apache.activemq.store.MessageStoreStatistics; v = virtualinvoke v.(); virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(); v = neg v; virtualinvoke v.(v); label: return; } protected void incrementAndAddSizeToStoreStat(org.apache.activemq.store.kahadb.data.KahaDestination, java.lang.String, long) { org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; long v; java.lang.String v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: java.lang.String; v := @parameter: long; v = virtualinvoke v.(v); virtualinvoke v.(v, v, v); return; } protected void incrementAndAddSizeToStoreStat(java.lang.String, java.lang.String, long) { org.apache.activemq.store.kahadb.MessageDatabase v; long v; org.apache.activemq.management.SizeStatisticImpl v; org.apache.activemq.store.MessageStoreSubscriptionStatistics v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.lang.String v, v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: long; v = v.; if v == 0 goto label; v = virtualinvoke v.(v); if v == null goto label; if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(v); virtualinvoke v.(v); label: return; } protected void decrementAndSubSizeToStoreStat(java.lang.String, java.lang.String, long) { org.apache.activemq.store.kahadb.MessageDatabase v; long v, v; org.apache.activemq.management.SizeStatisticImpl v; org.apache.activemq.store.MessageStoreSubscriptionStatistics v; org.apache.activemq.management.CountStatisticImpl v; byte v; java.lang.String v, v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v := @parameter: long; v = v.; if v == 0 goto label; v = virtualinvoke v.(v); if v == null goto label; if v == null goto label; v = virtualinvoke v.(v); virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = virtualinvoke v.(v); v = neg v; virtualinvoke v.(v); label: return; } protected void decrementAndSubSizeToStoreStat(org.apache.activemq.store.kahadb.data.KahaDestination, java.lang.String, long) { org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; long v; java.lang.String v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: java.lang.String; v := @parameter: long; v = virtualinvoke v.(v); virtualinvoke v.(v, v, v); return; } protected org.apache.activemq.store.MessageStoreStatistics getStoreStats(java.lang.String) { org.apache.activemq.store.MessageStoreStatistics v; org.slf4j.Logger v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Object v; java.lang.String v; java.lang.Exception v; java.util.concurrent.ConcurrentMap v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v = null; label: v = v.; v = interfaceinvoke v.(v); if v == null goto label; v = interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Getting size counter of destination failed", v); label: return v; catch java.lang.Exception from label to label with label; } protected org.apache.activemq.store.MessageStoreSubscriptionStatistics getSubStats(java.lang.String) { org.apache.activemq.store.MessageStore v; org.slf4j.Logger v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.MessageStoreSubscriptionStatistics v; java.lang.Exception v; java.util.concurrent.ConcurrentMap v; java.lang.Object v; java.lang.String v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v = null; label: v = v.; v = interfaceinvoke v.(v); v = v instanceof org.apache.activemq.store.TopicMessageStore; if v == 0 goto label; v = interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Getting size counter of destination failed", v); label: return v; catch java.lang.Exception from label to label with label; } protected boolean matchType(org.apache.activemq.broker.region.Destination, org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType) { org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v, v, v; org.apache.activemq.store.kahadb.MessageDatabase v; boolean v, v, v, v; org.apache.activemq.broker.region.Destination v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.broker.region.Destination; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType; v = v instanceof org.apache.activemq.broker.region.Topic; if v == 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; return 1; label: v = v instanceof org.apache.activemq.broker.region.Queue; if v == 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; return 1; label: return 0; } private void addAckLocation(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.Long, java.lang.String) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v, v; java.lang.Long v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.Long; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v, v, v); goto label; label: v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v, v, v); label: return; } private void addAckLocationForRetroactiveSub(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String) throws java.io.IOException { java.util.Iterator v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; java.lang.Object v, v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; boolean v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); v = v.; v = virtualinvoke v.(v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(v, v, v); return; } private void addAckLocationForNewMessage(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.data.KahaDestination, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.Long) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; long v, v, v, v, v, v; java.util.HashSet v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v; java.lang.Long v; int v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; boolean v; java.util.Iterator v; org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.disk.util.Sequence v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys v; java.lang.Object v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.Long; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v != null goto label; v = new org.apache.activemq.store.kahadb.disk.util.SequenceSet; specialinvoke v.()>(); v = new org.apache.activemq.store.kahadb.disk.util.Sequence; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1L; specialinvoke v.(long,long)>(v, v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v, v, v); goto label; label: v = new org.apache.activemq.store.kahadb.disk.util.Sequence; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1L; specialinvoke v.(long,long)>(v, v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v, v, v); label: v = v.; v = virtualinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: return; } private void removeAckLocationsForSub(org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand, org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; java.util.ArrayList v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v, v; int v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.lang.String v, v; java.util.Iterator v, v, v; org.apache.activemq.store.kahadb.data.KahaDestination v; java.lang.Object v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaSubscriptionCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(v); if v != 0 goto label; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v == 0 goto label; label: return; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = specialinvoke v.(v, v, v); if v != 0 goto label; virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, v, v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: return; } private boolean isSequenceReferenced(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.Long) throws java.io.IOException { java.util.Iterator v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; java.util.HashSet v; java.lang.Long v; java.lang.Object v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v; org.apache.activemq.store.kahadb.disk.page.Transaction v; boolean v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.Long; v = v.; v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; return 1; label: return 0; } private void removeAckLocation(org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand, org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String, java.lang.Long) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v, v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Long v; org.apache.activemq.store.kahadb.disk.journal.Location v, v, v; boolean v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v; java.util.ArrayList v; org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v, v, v; int v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v, v; java.lang.String v, v; java.util.Iterator v; org.apache.activemq.store.kahadb.data.KahaDestination v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageKeys v; java.lang.Object v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaRemoveMessageCommand; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v := @parameter: java.lang.Long; if v == null goto label; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); if v != 0 goto label; v = v.; virtualinvoke v.(v, v, v); goto label; label: v = v.; virtualinvoke v.(v, v); label: v = v.; v = virtualinvoke v.(v, v); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = specialinvoke v.(v, v, v); if v == 0 goto label; return; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; virtualinvoke v.(v, v, v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); v = v.; virtualinvoke v.(v, v); v = v.; v = interfaceinvoke v.(); virtualinvoke v.(v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); goto label; label: return; } public org.apache.activemq.store.kahadb.MessageDatabase$LastAck getLastAck(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String) throws java.io.IOException { org.apache.activemq.store.kahadb.disk.index.BTreeIndex v; org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; java.lang.Object v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v = v.; v = virtualinvoke v.(v, v); return v; } protected org.apache.activemq.store.kahadb.disk.util.SequenceSet getSequenceSet(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v, v); return v; label: return null; } protected long getStoredMessageCount(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; long v, v; byte v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); v = v cmp 0L; if v <= 0 goto label; v = v - 1L; goto label; label: v = 0L; label: return v; label: return 0L; } protected java.util.Map getStoredMessageSize(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.util.List) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.Long v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; boolean v, v, v, v, v; java.util.Set v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; java.util.List v; org.apache.activemq.store.kahadb.disk.util.LinkedNode v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderCursor v; java.util.HashMap v, v; long v, v, v, v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v; int v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.util.Iterator v, v, v; java.util.concurrent.atomic.AtomicLong v; java.lang.Object v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.util.List; v = new java.util.HashMap; specialinvoke v.()>(); v = new java.util.HashMap; specialinvoke v.()>(); v = v.; if v == null goto label; v = null; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); interfaceinvoke v.(v, v); v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); v = staticinvoke (v, v); goto label; label: v = v; label: v = staticinvoke (v); interfaceinvoke v.(v, v); goto label; label: if v == null goto label; v = virtualinvoke v.(); goto label; label: v = 0L; label: v = staticinvoke (v); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderCursor; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,long)>(v, v); v = virtualinvoke v.(v, v); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); goto label; label: return v; } protected long getStoredMessageSize(org.apache.activemq.store.kahadb.disk.page.Transaction, org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination, java.lang.String) throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; long v, v, v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderIndex v; int v, v; org.apache.activemq.store.kahadb.disk.index.ListIndex v, v; java.lang.String v; org.apache.activemq.store.kahadb.disk.journal.Location v; boolean v, v, v, v, v; java.util.Iterator v; org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination v; java.lang.Object v, v, v, v; org.apache.activemq.store.kahadb.disk.util.LinkedNode v; org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderCursor v; org.apache.activemq.store.kahadb.disk.page.Transaction v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.disk.page.Transaction; v := @parameter: org.apache.activemq.store.kahadb.MessageDatabase$StoredDestination; v := @parameter: java.lang.String; v = 0L; v = v.; if v == null goto label; v = v.; v = virtualinvoke v.(v, v); if v == null goto label; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); v = v.; v = new org.apache.activemq.store.kahadb.MessageDatabase$MessageOrderCursor; v = virtualinvoke v.(); specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase,long)>(v, v); v = virtualinvoke v.(v, v); v = virtualinvoke v.(); if v != 1 goto label; v = 1; goto label; label: v = 0; label: v = v; label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; label: v = interfaceinvoke v.(); v = v.; v = virtualinvoke v.(); v = v + v; goto label; label: return v; } protected java.lang.String key(org.apache.activemq.store.kahadb.data.KahaDestination) { org.apache.activemq.store.kahadb.data.KahaDestination$DestinationType v; org.apache.activemq.store.kahadb.data.KahaDestination v; org.apache.activemq.store.kahadb.MessageDatabase v; int v; java.lang.String v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaDestination; v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001:\u0001"); return v; } private java.util.List getInflightTx(org.apache.activemq.store.kahadb.data.KahaTransactionInfo) { java.lang.Throwable v; org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; org.apache.activemq.store.kahadb.MessageDatabase v; java.util.ArrayList v; java.util.LinkedHashMap v, v, v; java.lang.Object v; org.apache.activemq.command.TransactionId v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaTransactionInfo; v = staticinvoke (v); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(v); if v != null goto label; v = new java.util.ArrayList; specialinvoke v.()>(); v = staticinvoke (v); v = v.; virtualinvoke v.(v, v); label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: return v; catch java.lang.Throwable from label to label with label; } private org.apache.activemq.command.TransactionId key(org.apache.activemq.store.kahadb.data.KahaTransactionInfo) { org.apache.activemq.store.kahadb.data.KahaTransactionInfo v; org.apache.activemq.command.TransactionId v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.store.kahadb.data.KahaTransactionInfo; v = staticinvoke (v); return v; } private org.apache.activemq.store.kahadb.disk.page.PageFile createPageFile() throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v, v, v, v; int v, v; float v; org.apache.activemq.store.kahadb.disk.page.PageFile v; boolean v, v, v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; if v != null goto label; v = v.; v. = v; label: v = v.; staticinvoke (v); v = new org.apache.activemq.store.kahadb.disk.page.PageFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "db"); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); return v; } protected org.apache.activemq.store.kahadb.disk.journal.Journal createJournal() throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationStrategy v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope v; int v, v; java.lang.String v, v, v, v, v, v; boolean v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v; java.io.File v, v, v, v; java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = new org.apache.activemq.store.kahadb.disk.journal.Journal; specialinvoke v.()>(); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = v.; if v != 0 goto label; v = v.; if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v); label: return v; } private org.apache.activemq.store.kahadb.MessageDatabase$Metadata createMetadata() { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; int v, v; org.apache.activemq.ActiveMQMessageAuditNoSync v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = new org.apache.activemq.store.kahadb.MessageDatabase$Metadata; specialinvoke v.(org.apache.activemq.store.kahadb.MessageDatabase)>(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); return v; } protected abstract void configureMetadata(); public int getJournalMaxWriteBatchSize() { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setJournalMaxWriteBatchSize(int) { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v. = v; return; } public java.io.File getDirectory() { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setDirectory(java.io.File) { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.io.File; v. = v; return; } public boolean isDeleteAllMessages() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setDeleteAllMessages(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public void setIndexWriteBatchSize(int) { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v. = v; return; } public int getIndexWriteBatchSize() { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setEnableIndexWriteAsync(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } boolean isEnableIndexWriteAsync() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public boolean isEnableJournalDiskSyncs() { org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v, v; org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = ; if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } public void setEnableJournalDiskSyncs(boolean) { org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v, v; org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; if v == 0 goto label; v = ; v. = v; goto label; label: v = ; v. = v; label: return; } public org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy getJournalDiskSyncStrategyEnum() { org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public java.lang.String getJournalDiskSyncStrategy() { org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v; java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(); return v; } public void setJournalDiskSyncStrategy(java.lang.String) { org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.String v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; return; } public long getJournalDiskSyncInterval() { long v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setJournalDiskSyncInterval(long) { long v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: long; v. = v; return; } public long getCheckpointInterval() { long v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setCheckpointInterval(long) { long v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: long; v. = v; return; } public long getCleanupInterval() { long v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setCleanupInterval(long) { long v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: long; v. = v; return; } public boolean getCleanupOnStop() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setCleanupOnStop(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public void setJournalMaxFileLength(int) { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v. = v; return; } public int getJournalMaxFileLength() { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setMaxFailoverProducersToTrack(int) { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; int v; org.apache.activemq.ActiveMQMessageAuditNoSync v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v = v.; v = v.; virtualinvoke v.(v); return; } public int getMaxFailoverProducersToTrack() { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; int v; org.apache.activemq.ActiveMQMessageAuditNoSync v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = v.; v = virtualinvoke v.(); return v; } public void setFailoverProducersAuditDepth(int) { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; int v; org.apache.activemq.ActiveMQMessageAuditNoSync v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v = v.; v = v.; virtualinvoke v.(v); return; } public int getFailoverProducersAuditDepth() { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; int v; org.apache.activemq.ActiveMQMessageAuditNoSync v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = v.; v = virtualinvoke v.(); return v; } public org.apache.activemq.store.kahadb.disk.page.PageFile getPageFile() throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.page.PageFile v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; if v != null goto label; v = specialinvoke v.(); v. = v; label: v = v.; return v; } public org.apache.activemq.store.kahadb.disk.journal.Journal getJournal() throws java.io.IOException { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.kahadb.disk.journal.Journal v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; if v != null goto label; v = virtualinvoke v.(); v. = v; label: v = v.; return v; } protected org.apache.activemq.store.kahadb.MessageDatabase$Metadata getMetadata() { org.apache.activemq.store.kahadb.MessageDatabase$Metadata v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public boolean isFailIfDatabaseIsLocked() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setFailIfDatabaseIsLocked(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public boolean isIgnoreMissingJournalfiles() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setIgnoreMissingJournalfiles(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public int getIndexCacheSize() { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setIndexCacheSize(int) { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v. = v; return; } public boolean isCheckForCorruptJournalFiles() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setCheckForCorruptJournalFiles(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy getPurgeRecoveredXATransactionStrategyEnum() { org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public java.lang.String getPurgeRecoveredXATransactionStrategy() { java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; v = virtualinvoke v.(); return v; } public void setPurgeRecoveredXATransactionStrategy(java.lang.String) { org.apache.activemq.store.kahadb.MessageDatabase$PurgeRecoveredXATransactionStrategy v; org.apache.activemq.store.kahadb.MessageDatabase v; java.lang.String v, v, v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v); v. = v; return; } public boolean isChecksumJournalFiles() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setChecksumJournalFiles(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public void setBrokerService(org.apache.activemq.broker.BrokerService) { org.apache.activemq.broker.BrokerService v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: org.apache.activemq.broker.BrokerService; v. = v; return; } public boolean isArchiveDataLogs() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setArchiveDataLogs(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public java.io.File getDirectoryArchive() { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setDirectoryArchive(java.io.File) { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.io.File; v. = v; return; } public boolean isArchiveCorruptedIndex() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setArchiveCorruptedIndex(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public float getIndexLFUEvictionFactor() { float v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setIndexLFUEvictionFactor(float) { float v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: float; v. = v; return; } public boolean isUseIndexLFRUEviction() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setUseIndexLFRUEviction(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public void setEnableIndexDiskSyncs(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public void setEnableIndexRecoveryFile(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public void setEnableIndexPageCaching(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public boolean isEnableIndexDiskSyncs() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public boolean isEnableIndexRecoveryFile() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public boolean isEnableIndexPageCaching() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public org.apache.activemq.store.PersistenceAdapterStatistics getPersistenceAdapterStatistics() { org.apache.activemq.store.kahadb.MessageDatabase v; org.apache.activemq.store.PersistenceAdapterStatistics v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public java.io.File getIndexDirectory() { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setIndexDirectory(java.io.File) { org.apache.activemq.store.kahadb.MessageDatabase v; java.io.File v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.io.File; v. = v; return; } public java.lang.String getPreallocationScope() { java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setPreallocationScope(java.lang.String) { java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v. = v; return; } public java.lang.String getPreallocationStrategy() { java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setPreallocationStrategy(java.lang.String) { java.lang.String v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: java.lang.String; v. = v; return; } public int getCompactAcksAfterNoGC() { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setCompactAcksAfterNoGC(int) { int v; org.apache.activemq.store.kahadb.MessageDatabase v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: int; v. = v; return; } public boolean isCompactAcksIgnoresStoreGrowth() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setCompactAcksIgnoresStoreGrowth(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public boolean isEnableAckCompaction() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setEnableAckCompaction(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } public boolean isEnableSubscriptionStatistics() { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v = v.; return v; } public void setEnableSubscriptionStatistics(boolean) { org.apache.activemq.store.kahadb.MessageDatabase v; boolean v; v := @this: org.apache.activemq.store.kahadb.MessageDatabase; v := @parameter: boolean; v. = v; return; } static void () { byte[] v; org.slf4j.Logger v; int v; org.apache.activemq.protobuf.Buffer v; java.lang.Integer v; java.io.File v; v = staticinvoke ("org.apache.activemq.store.kahadb.LOG_SLOW_ACCESS_TIME", 0); v = virtualinvoke v.(); = v; v = new java.io.File; specialinvoke v.(java.lang.String)>("KahaDB"); = v; v = new org.apache.activemq.protobuf.Buffer; v = newarray (byte)[0]; specialinvoke v.(byte[])>(v); = v; v = staticinvoke (class "Lorg/apache/activemq/store/kahadb/MessageDatabase;"); = v; return; } }