public class org.apache.activemq.store.kahadb.disk.journal.Journal extends java.lang.Object { public static final java.lang.String CALLER_BUFFER_APPENDER; public static final boolean callerBufferAppender; private static final int PREALLOC_CHUNK_SIZE; public static final int RECORD_HEAD_SPACE; public static final byte USER_RECORD_TYPE; public static final byte BATCH_CONTROL_RECORD_TYPE; public static final byte[] BATCH_CONTROL_RECORD_MAGIC; public static final int BATCH_CONTROL_RECORD_SIZE; public static final byte[] BATCH_CONTROL_RECORD_HEADER; public static final byte[] EMPTY_BATCH_CONTROL_RECORD; public static final int EOF_INT; public static final byte EOF_EOT; public static final byte[] EOF_RECORD; private java.util.concurrent.ScheduledExecutorService scheduler; public static final java.lang.String DEFAULT_DIRECTORY; public static final java.lang.String DEFAULT_ARCHIVE_DIRECTORY; public static final java.lang.String DEFAULT_FILE_PREFIX; public static final java.lang.String DEFAULT_FILE_SUFFIX; public static final int DEFAULT_MAX_FILE_LENGTH; public static final int DEFAULT_CLEANUP_INTERVAL; public static final int DEFAULT_MAX_WRITE_BATCH_SIZE; private static final org.slf4j.Logger LOG; protected final java.util.Map inflightWrites; protected java.io.File directory; protected java.io.File directoryArchive; private boolean directoryArchiveOverridden; protected java.lang.String filePrefix; protected java.lang.String fileSuffix; protected boolean started; protected int maxFileLength; protected int writeBatchSize; protected org.apache.activemq.store.kahadb.disk.journal.FileAppender appender; protected org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool accessorPool; protected java.util.Map fileMap; protected java.util.Map fileByFileMap; protected org.apache.activemq.store.kahadb.disk.util.LinkedNodeList dataFiles; protected final java.util.concurrent.atomic.AtomicReference lastAppendLocation; protected java.util.concurrent.ScheduledFuture cleanupTask; protected java.util.concurrent.atomic.AtomicLong totalLength; protected boolean archiveDataLogs; private org.apache.activemq.store.kahadb.disk.journal.ReplicationTarget replicationTarget; protected boolean checksum; protected boolean checkForCorruptionOnStartup; protected boolean enableAsyncDiskSync; private int nextDataFileId; private java.lang.Object dataFileIdLock; private final java.util.concurrent.atomic.AtomicReference currentDataFile; private volatile org.apache.activemq.store.kahadb.disk.journal.DataFile nextDataFile; protected org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope preallocationScope; protected org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationStrategy preallocationStrategy; private java.io.File osKernelCopyTemplateFile; private java.nio.ByteBuffer preAllocateDirectBuffer; private long cleanupInterval; protected org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy journalDiskSyncStrategy; private org.apache.activemq.store.kahadb.disk.journal.Journal$DataFileRemovedListener dataFileRemovedListener; private java.lang.Runnable preAllocateNextDataFileTask; private volatile java.util.concurrent.Future preAllocateNextDataFileFuture; public void () { org.apache.activemq.store.kahadb.disk.journal.Journal$4 v; org.apache.activemq.store.kahadb.disk.journal.Journal$JournalDiskSyncStrategy v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationStrategy v; java.util.concurrent.ConcurrentHashMap v; java.util.HashMap v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope v; java.util.concurrent.atomic.AtomicReference v, v; java.io.File v; java.util.LinkedHashMap v; java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.store.kahadb.disk.util.LinkedNodeList v; java.lang.Object v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; specialinvoke v.()>(); v = new java.util.concurrent.ConcurrentHashMap; specialinvoke v.()>(); v. = v; v = new java.io.File; specialinvoke v.(java.lang.String)>("."); v. = v; v. = 0; v. = "db-"; v. = ".log"; v. = 33554432; v. = 4194304; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.LinkedHashMap; specialinvoke v.()>(); v. = v; v = new org.apache.activemq.store.kahadb.disk.util.LinkedNodeList; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.()>(); v. = v; v. = 1; v. = 1; v = new java.lang.Object; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); v. = v; v = ; v. = v; v = ; v. = v; v. = null; v. = null; v. = 30000L; v = ; v. = v; v = new org.apache.activemq.store.kahadb.disk.journal.Journal$4; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); v. = v; return; } public void corruptRecoveryLocation(org.apache.activemq.store.kahadb.disk.journal.Location) throws java.io.IOException { java.lang.Throwable v; byte[] v; java.io.RandomAccessFile v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v; long v, v, v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessor v; int v, v, v, v, v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.util.ByteSequence v; org.slf4j.Logger v; org.apache.activemq.store.kahadb.disk.util.Sequence v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.io.File v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.DataFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.Location; v = virtualinvoke v.(v); v = v.; v = virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); v = v + 1; virtualinvoke v.(v); v = virtualinvoke v.(); v = newarray (byte)[v]; v = new org.apache.activemq.util.ByteSequence; v = virtualinvoke v.(v); specialinvoke v.(byte[],int,int)>(v, 0, v); v = specialinvoke v.(v, v); if v < 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = staticinvoke (v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); label: v = new org.apache.activemq.store.kahadb.disk.util.Sequence; v = virtualinvoke v.(); v = v - 1; specialinvoke v.(long,long)>(v, v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Corrupt journal records found in \'{}\' between offsets: {}", v, v); virtualinvoke v.(v); v = (int) -1; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(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; } public org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool getAccessorPool() { org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v = v.; return v; } public void allowIOResumption() { org.apache.activemq.store.kahadb.disk.journal.FileAppender v, v; boolean v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v = v.; v = v instanceof org.apache.activemq.store.kahadb.disk.journal.DataFileAppender; if v == 0 goto label; v = v.; v. = 0; label: return; } public void setCleanupInterval(long) { long v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: long; v. = v; return; } public long getCleanupInterval() { long v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v = v.; return v; } private static byte[] createBatchControlRecordHeader() { java.lang.Throwable v; byte[] v, v; java.io.IOException v; java.lang.RuntimeException v; org.apache.activemq.util.DataByteArrayOutputStream v; int v; org.apache.activemq.util.ByteSequence v; label: v = new org.apache.activemq.util.DataByteArrayOutputStream; specialinvoke v.()>(); label: v = ; virtualinvoke v.(v); virtualinvoke v.(2); v = ; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); label: virtualinvoke v.(); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not create batch control record header.", v); throw v; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } private static byte[] createEmptyBatchControlRecordHeader() { java.lang.Throwable v; byte[] v, v; java.io.IOException v; java.lang.RuntimeException v; org.apache.activemq.util.DataByteArrayOutputStream v; int v; org.apache.activemq.util.ByteSequence v; label: v = new org.apache.activemq.util.DataByteArrayOutputStream; specialinvoke v.()>(); label: v = ; virtualinvoke v.(v); virtualinvoke v.(2); v = ; virtualinvoke v.(v); virtualinvoke v.(0); virtualinvoke v.(0L); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); label: virtualinvoke v.(); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not create empty batch control record header.", v); throw v; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } private static byte[] createEofBatchAndLocationRecord() { java.lang.Throwable v; byte[] v; org.apache.activemq.util.DataByteArrayOutputStream v; int v; java.io.IOException v; java.lang.RuntimeException v; org.apache.activemq.util.ByteSequence v; label: v = new org.apache.activemq.util.DataByteArrayOutputStream; specialinvoke v.()>(); label: v = ; virtualinvoke v.(v); virtualinvoke v.(52); v = virtualinvoke v.(); virtualinvoke v.(); v = virtualinvoke v.(); label: virtualinvoke v.(); label: return v; label: v := @caughtexception; throw v; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Could not create eof header.", v); throw v; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } public synchronized void start() throws java.io.IOException { org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope v, v; java.lang.Integer v, v; org.apache.activemq.store.kahadb.disk.util.LinkedNodeList v, v, v, v, v; byte v; java.util.Map v, v, v; org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool v; org.apache.activemq.store.kahadb.disk.util.LinkedNode v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationStrategy v; long v, v, v, v, v, v; java.util.concurrent.ScheduledExecutorService v, v; java.lang.String v, v, v, v, v, v; java.lang.NumberFormatException v; java.io.File v, v, v, v; java.util.concurrent.atomic.AtomicLong v, v, v; org.apache.activemq.store.kahadb.disk.journal.DataFileAppender v, v; org.apache.activemq.store.kahadb.disk.journal.DataFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v; java.util.concurrent.ScheduledFuture v; java.nio.ByteBuffer v, v; int[] v; org.apache.activemq.store.kahadb.disk.journal.Location v, v; boolean v, v, v, v, v, v, v; java.util.Collection v; java.util.concurrent.atomic.AtomicReference v, v, v, v, v, v, v; int v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.LinkedList v; org.apache.activemq.store.kahadb.disk.journal.Journal$3 v; org.slf4j.Logger v, v; java.util.Iterator v; org.apache.activemq.store.kahadb.disk.journal.Journal$1 v; org.apache.activemq.store.kahadb.disk.journal.Journal$2 v; java.util.concurrent.TimeUnit v; java.lang.Object v, v, v, v, v, v; java.io.File[] v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v = v.; if v == 0 goto label; return; label: v = staticinvoke (); v = new org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); v. = v; v. = 1; v = ; if v == 0 goto label; v = new org.apache.activemq.store.kahadb.disk.journal.CallerBufferingDataFileAppender; v = v; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); goto label; label: v = new org.apache.activemq.store.kahadb.disk.journal.DataFileAppender; v = v; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); label: v. = v; v = v.; v = new org.apache.activemq.store.kahadb.disk.journal.Journal$1; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); v = virtualinvoke v.(v); if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; label: v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v - v; v = virtualinvoke v.(v, v); v = staticinvoke (v); v = new org.apache.activemq.store.kahadb.disk.journal.DataFile; specialinvoke v.(java.io.File,int)>(v, v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: goto label; label: v := @caughtexception; label: v = v + 1; goto label; label: v = new java.util.LinkedList; v = v.; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); staticinvoke (v); v = virtualinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("ignoring zero length, partially initialised journal data file: \u0001"); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(v); if v != 0 goto label; label: v = v.; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = virtualinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(v); virtualinvoke v.(v); goto label; label: v = v.; v = ; if v == v goto label; v = ; v = v.; v = virtualinvoke v.(); v = v[v]; tableswitch(v) { case 1: goto label; case 2: goto label; case 3: goto label; case 4: goto label; default: goto label; }; label: v = specialinvoke v.(); v. = v; goto label; label: v = specialinvoke v.(1048576); v. = v; goto label; label: v = virtualinvoke v.(); v = specialinvoke v.(v); v. = v; label: v = new org.apache.activemq.store.kahadb.disk.journal.Journal$2; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); v = staticinvoke (1, v); v. = v; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v. = 1; virtualinvoke v.(); goto label; label: v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v + 1; v. = v; label: v = v.; v = virtualinvoke v.(); if v != null goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(v); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = v cmp v; if v <= 0 goto label; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v <= 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; virtualinvoke v.(v); label: v = v.; v = new org.apache.activemq.store.kahadb.disk.journal.Journal$3; specialinvoke v.(org.apache.activemq.store.kahadb.disk.journal.Journal)>(v); v = v.; v = v.; v = ; v = interfaceinvoke v.(v, v, v, v); v. = v; v = staticinvoke (); v = ; v = v - v; v = dynamicinvoke "makeConcatWithConstants" (v) ("Startup took: \u ms"); interfaceinvoke v.(v); return; catch java.lang.NumberFormatException from label to label with label; } private java.nio.ByteBuffer allocateDirectBuffer(int) { byte[] v; int v; java.nio.ByteBuffer v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: int; v = staticinvoke (v); v = ; virtualinvoke v.(v); return v; } public void preallocateEntireJournalDataFile(org.apache.activemq.util.RecoverableRandomAccessFile) { java.lang.Throwable v; org.slf4j.Logger v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationStrategy v, v, v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope v, v; org.apache.activemq.util.RecoverableRandomAccessFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.util.RecoverableRandomAccessFile; v = ; v = v.; if v == v goto label; label: v = ; v = v.; if v != v goto label; specialinvoke v.(v); goto label; label: v = ; v = v.; if v != v goto label; specialinvoke v.(v); goto label; label: v = ; v = v.; if v != v goto label; specialinvoke v.(v); goto label; label: specialinvoke v.(v); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("cound not preallocate journal data file", v); label: return; catch java.lang.Throwable from label to label with label; } private void doPreallocationSparseFile(org.apache.activemq.util.RecoverableRandomAccessFile) { byte[] v; org.slf4j.Logger v, v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.nio.ByteBuffer v; java.nio.channels.ClosedByInterruptException v; int v, v; java.nio.channels.FileChannel v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.util.RecoverableRandomAccessFile; v = ; v = staticinvoke (v); label: v = virtualinvoke v.(); virtualinvoke v.(0L); virtualinvoke v.(v); v = v.; v = v - 5; virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(0); virtualinvoke v.(0L); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with sparse file", v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with sparse file", v); label: return; catch java.nio.channels.ClosedByInterruptException from label to label with label; catch java.io.IOException from label to label with label; } private void doPreallocationZeros(org.apache.activemq.util.RecoverableRandomAccessFile) { org.slf4j.Logger v, v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.nio.ByteBuffer v, v; java.nio.channels.ClosedByInterruptException v; java.nio.channels.FileChannel v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.util.RecoverableRandomAccessFile; v = v.; virtualinvoke v.(); label: v = virtualinvoke v.(); v = v.; virtualinvoke v.(v); virtualinvoke v.(0); virtualinvoke v.(0L); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with zeros", v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with zeros", v); label: return; catch java.nio.channels.ClosedByInterruptException from label to label with label; catch java.io.IOException from label to label with label; } private void doPreallocationKernelCopy(org.apache.activemq.util.RecoverableRandomAccessFile) { java.lang.Throwable v; java.io.RandomAccessFile v; int v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.io.File v, v, v; java.io.FileNotFoundException v; java.nio.channels.ClosedByInterruptException v; java.nio.channels.FileChannel v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.util.RecoverableRandomAccessFile; label: v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); label: v = virtualinvoke v.(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0L, v, v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with kernel copy", v); goto label; label: v := @caughtexception; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not find the template file on disk at \u0001"); interfaceinvoke v.(v, v); goto label; label: v := @caughtexception; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not transfer the template file to journal, transferFile=\u0001"); interfaceinvoke v.(v, v); label: return; catch java.lang.Throwable from label to label with label; catch java.nio.channels.ClosedByInterruptException from label to label with label; catch java.io.FileNotFoundException from label to label with label; catch java.io.IOException from label to label with label; } private java.io.File createJournalTemplateFile() { java.lang.Throwable v; byte[] v; java.io.RandomAccessFile v; java.nio.ByteBuffer v; int v; java.lang.String v, v, v, v; org.slf4j.Logger v, v; java.io.IOException v; java.io.File v, v, v, v; java.io.FileNotFoundException v; java.nio.channels.FileChannel v, v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v = new java.io.File; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "db-log.template"); label: v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); label: v = virtualinvoke v.(); v = ; v = staticinvoke (v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = virtualinvoke v.(); virtualinvoke v.(1); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not find the template file on disk at \u0001"); interfaceinvoke v.(v, v); goto label; label: v := @caughtexception; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Could not transfer the template file to journal, transferFile=\u0001"); interfaceinvoke v.(v, v); label: return v; catch java.lang.Throwable from label to label with label; catch java.io.FileNotFoundException from label to label with label; catch java.io.IOException from label to label with label; } private void doPreallocationChunkedZeros(org.apache.activemq.util.RecoverableRandomAccessFile) { java.nio.ByteBuffer v, v, v, v, v, v, v; int v, v, v, v; org.slf4j.Logger v, v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.nio.channels.ClosedByInterruptException v; java.nio.channels.FileChannel v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.util.RecoverableRandomAccessFile; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); label: v = virtualinvoke v.(); v = v.; label: if v <= 0 goto label; v = v.; v = virtualinvoke v.(); if v >= v goto label; v = v.; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(v); v = v - v; v = v.; virtualinvoke v.(); goto label; label: virtualinvoke v.(0); virtualinvoke v.(0L); label: goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with zeros", v); goto label; label: v := @caughtexception; v = ; interfaceinvoke v.("Could not preallocate journal file with zeros! Will continue without preallocation", v); label: return; catch java.nio.channels.ClosedByInterruptException from label to label with label; catch java.io.IOException from label to label with label; } private static byte[] bytes(java.lang.String) { byte[] v; java.lang.RuntimeException v; java.lang.String v; java.io.UnsupportedEncodingException v; v := @parameter: java.lang.String; label: v = virtualinvoke v.("UTF-8"); label: return v; label: v := @caughtexception; v = new java.lang.RuntimeException; specialinvoke v.(java.lang.Throwable)>(v); throw v; catch java.io.UnsupportedEncodingException from label to label with label; } public boolean isUnusedPreallocated(org.apache.activemq.store.kahadb.disk.journal.DataFile) throws java.io.IOException { java.lang.Throwable v; byte[] v, v, v; org.apache.activemq.store.kahadb.disk.journal.Journal$PreallocationScope v, v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessor v; int v; org.apache.activemq.util.ByteSequence v; boolean v; java.lang.Exception v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool v, v, v, v; org.apache.activemq.store.kahadb.disk.journal.DataFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.DataFile; v = v.; v = ; if v != v goto label; v = v.; v = virtualinvoke v.(v); label: v = ; v = lengthof v; v = newarray (byte)[v]; virtualinvoke v.(0L, v); v = new org.apache.activemq.util.ByteSequence; specialinvoke v.(byte[])>(v); v = ; v = virtualinvoke v.(v); label: v = v.; virtualinvoke v.(v); return v; label: v := @caughtexception; v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(v); throw v; label: return 0; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; } protected org.apache.activemq.store.kahadb.disk.journal.Location recoveryCheck(org.apache.activemq.store.kahadb.disk.journal.DataFile) throws java.io.IOException { byte[] v, v; java.io.RandomAccessFile v; java.lang.Integer v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessor v; byte v, v; org.apache.activemq.store.kahadb.disk.journal.Location v; org.apache.activemq.util.ByteSequence v; org.apache.activemq.store.kahadb.disk.util.Sequence v; org.apache.activemq.store.kahadb.disk.journal.DataFileAccessorPool v, v, v, v; java.lang.Throwable v; org.apache.activemq.store.kahadb.disk.util.SequenceSet v, v; long v, v, v, v; int 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.lang.String v; org.slf4j.Logger v, v, v; java.io.IOException v; org.apache.activemq.util.RecoverableRandomAccessFile v; java.io.File v, v; java.util.concurrent.atomic.AtomicLong v; org.apache.activemq.store.kahadb.disk.journal.DataFile v; org.apache.activemq.store.kahadb.disk.journal.Journal v; v := @this: org.apache.activemq.store.kahadb.disk.journal.Journal; v := @parameter: org.apache.activemq.store.kahadb.disk.journal.DataFile; v = new org.apache.activemq.store.kahadb.disk.journal.Location; specialinvoke v.()>(); v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(0); v = v.; v = virtualinvoke v.(v); label: v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(0L); v = virtualinvoke v.(); v = virtualinvoke v.(); v = newarray (byte)[v]; v = new org.apache.activemq.util.ByteSequence; v = virtualinvoke v.(v); specialinvoke v.(byte[],int,int)>(v, 0, v); label: v = specialinvoke v.(v, v); if v <= 0 goto label; v = virtualinvoke v.(); v = ; v = v + v; v = v + v; v = v cmp v; if v > 0 goto label; v = virtualinvoke v.(); v = ; v = v + v; v = v + v; virtualinvoke v.(v); goto label; label: if v != 0 goto label; v = virtualinvoke v.(); v = ; v = lengthof v; v = v + v; v = v + v; v = v cmp v; if v <= 0 goto label; label: v = new org.apache.activemq.store.kahadb.disk.util.Sequence; v = virtualinvoke v.(); specialinvoke v.(long)>(v); v = specialinvoke v.(v, v); if v < 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v - v; v = staticinvoke (v); v = v - 1; virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Corrupt journal records found in \'{}\' between offsets: {}", v, v); virtualinvoke v.(v); goto label; label: v = virtualinvoke v.(); v = staticinvoke (v); virtualinvoke v.(v); v = v.; virtualinvoke v.(v); v = ; v = virtualinvoke v.(); interfaceinvoke v.("Corrupt journal records found in \'{}\' from offset: {} to EOF", v, v); label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = ; v = dynamicinvoke "makeConcatWithConstants" (v, v) ("exception on recovery check of: \u, at \u0001"); interfaceinvoke v.(v, v); label: v = v.; virtualinvoke v.(v); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(v); throw v; label: v = virtualinvoke v.(); v = virtualinvoke v.