public class org.apache.nifi.processors.standard.AbstractTestTailFileScenario extends java.lang.Object
{
public static final java.lang.String TEST_DIRECTORY;
public static final java.lang.String TARGET_FILE_PATH;
public static final java.lang.String NUL_SUBSTITUTE;
public static final java.lang.Long POST_ROLLOVER_WAIT_PERSIOD_SECONDS;
protected java.io.File file;
protected java.io.RandomAccessFile randomAccessFile;
private org.apache.nifi.processors.standard.TailFile processor;
protected org.apache.nifi.util.TestRunner runner;
private java.util.concurrent.atomic.AtomicBoolean stopAfterEachTrigger;
protected java.util.concurrent.atomic.AtomicLong wordIndex;
protected java.util.concurrent.atomic.AtomicLong rolloverIndex;
protected java.util.concurrent.atomic.AtomicLong timeAdjustment;
protected java.util.concurrent.atomic.AtomicBoolean rolloverSwitchPending;
protected java.util.LinkedList nulPositions;
protected java.util.List expected;
private java.util.Random random;
public void <init>()
{
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public void setUp() throws java.io.IOException
{
java.io.RandomAccessFile v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario$1 v;
java.util.concurrent.atomic.AtomicBoolean v, v;
java.util.Random v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v;
java.util.ArrayList v;
java.lang.Long v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v;
java.lang.String v;
java.util.LinkedList v;
boolean v, v;
org.apache.nifi.processors.standard.TailFile v;
java.io.File v, v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
java.util.concurrent.atomic.AtomicLong v, v, v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void clean()>();
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("target/testTailFileScenario");
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v != 0 goto label;
v = virtualinvoke v.<java.io.File: boolean mkdirs()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
label:
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void createTargetFile()>();
v = new java.io.RandomAccessFile;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
specialinvoke v.<java.io.RandomAccessFile: void <init>(java.io.File,java.lang.String)>(v, "rw");
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile> = v;
v = new org.apache.nifi.processors.standard.AbstractTestTailFileScenario$1;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$1: void <init>(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.processors.standard.TailFile processor> = v;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.processors.standard.TailFile processor>;
v = staticinvoke <org.apache.nifi.util.TestRunners: org.apache.nifi.util.TestRunner newTestRunner(org.apache.nifi.processor.Processor)>(v);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner> = v;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TailFile: org.apache.nifi.components.PropertyDescriptor FILENAME>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "target/testTailFileScenario/in.txt");
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TailFile: org.apache.nifi.components.PropertyDescriptor ROLLING_FILENAME_PATTERN>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "in.txt*");
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TailFile: org.apache.nifi.components.PropertyDescriptor REREAD_ON_NUL>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "true");
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TailFile: org.apache.nifi.components.PropertyDescriptor POST_ROLLOVER_TAIL_PERIOD>;
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.lang.Long POST_ROLLOVER_WAIT_PERSIOD_SECONDS>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.Long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u sec");
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, 0, 1);
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean stopAfterEachTrigger> = v;
v = new java.util.LinkedList;
specialinvoke v.<java.util.LinkedList: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.LinkedList nulPositions> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(1L);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong wordIndex> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(1L);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong rolloverIndex> = v;
v = new java.util.concurrent.atomic.AtomicLong;
specialinvoke v.<java.util.concurrent.atomic.AtomicLong: void <init>(long)>(0L);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong timeAdjustment> = v;
v = new java.util.concurrent.atomic.AtomicBoolean;
specialinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void <init>(boolean)>(0);
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean rolloverSwitchPending> = v;
v = new java.util.ArrayList;
specialinvoke v.<java.util.ArrayList: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.List expected> = v;
v = new java.util.Random;
specialinvoke v.<java.util.Random: void <init>()>();
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.Random random> = v;
return;
}
public void tearDown() throws java.io.IOException
{
org.apache.nifi.processors.standard.TailFile v, v;
java.io.RandomAccessFile v, v;
org.apache.nifi.util.MockProcessContext v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
if v == null goto label;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
virtualinvoke v.<java.io.RandomAccessFile: void close()>();
label:
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.processors.standard.TailFile processor>;
v = new org.apache.nifi.util.MockProcessContext;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.processors.standard.TailFile processor>;
specialinvoke v.<org.apache.nifi.util.MockProcessContext: void <init>(org.apache.nifi.components.ConfigurableComponent)>(v);
virtualinvoke v.<org.apache.nifi.processors.standard.TailFile: void cleanup(org.apache.nifi.processor.ProcessContext)>(v);
return;
}
public void testScenario(java.util.List) throws java.lang.Exception
{
java.util.List v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v := @parameter: java.util.List;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void testScenario(java.util.List,boolean)>(v, 0);
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void tearDown()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void setUp()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void testScenario(java.util.List,boolean)>(v, 1);
return;
}
public void testScenario(java.util.List, boolean) throws java.lang.Exception
{
org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action v, v, v, v, v;
java.util.concurrent.atomic.AtomicBoolean v;
java.util.function.Function v, v;
org.apache.nifi.processor.Relationship v;
org.apache.nifi.util.TestRunner v;
java.lang.String v, v;
java.util.stream.Collector v, v, v;
boolean v, v;
java.util.Iterator v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
java.util.List v, v, v;
java.util.stream.Stream v, v, v, v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v := @parameter: java.util.List;
v := @parameter: boolean;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean stopAfterEachTrigger>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(v);
v = interfaceinvoke v.<java.util.List: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
goto label;
label:
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void overwriteRemainingNuls()>();
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action WRITE_NEW_LINE>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action TRIGGER>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action EXPIRE_ROLLOVER_WAIT_PERIOD>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action TRIGGER>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action TRIGGER>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.TailFile: org.apache.nifi.processor.Relationship REL_SUCCESS>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: java.util.List getFlowFilesForRelationship(org.apache.nifi.processor.Relationship)>(v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$toByteArray__25: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$init__26: java.util.function.Function bootstrap$()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.util.stream.Stream map(java.util.function.Function)>(v);
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector toList()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.List expected>;
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector joining()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = interfaceinvoke v.<java.util.List: java.util.stream.Stream stream()>();
v = staticinvoke <java.util.stream.Collectors: java.util.stream.Collector joining()>();
v = interfaceinvoke v.<java.util.stream.Stream: java.lang.Object collect(java.util.stream.Collector)>(v);
v = virtualinvoke v.<java.lang.Object: java.lang.String toString()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (boolean,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u \u0001");
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object,java.lang.String)>(v, v, v);
return;
}
private void clean()
{
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void cleanFiles(java.lang.String)>("target/testTailFileScenario");
return;
}
private void cleanFiles(java.lang.String)
{
java.io.File v, v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
int v, v;
java.lang.String v;
java.io.File[] v;
boolean v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v := @parameter: java.lang.String;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>(v);
v = virtualinvoke v.<java.io.File: boolean exists()>();
if v == 0 goto label;
v = virtualinvoke v.<java.io.File: java.io.File[] listFiles()>();
v = lengthof v;
v = 0;
label:
if v >= v goto label;
v = v[v];
virtualinvoke v.<java.io.File: boolean delete()>();
v = v + 1;
goto label;
label:
return;
}
private void createTargetFile() throws java.io.IOException
{
java.io.File v, v, v;
boolean v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = new java.io.File;
specialinvoke v.<java.io.File: void <init>(java.lang.String)>("target/testTailFileScenario/in.txt");
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file> = v;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
virtualinvoke v.<java.io.File: boolean delete()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
v = virtualinvoke v.<java.io.File: boolean createNewFile()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
private void overwriteRemainingNuls() throws java.lang.Exception
{
org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action v;
java.util.LinkedList v;
boolean v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
label:
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.LinkedList nulPositions>;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v != 0 goto label;
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action OVERWRITE_NUL>;
virtualinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario$Action: void run(org.apache.nifi.processors.standard.AbstractTestTailFileScenario)>(v);
goto label;
label:
return;
}
private void writeWord() throws java.io.IOException
{
byte[] v;
java.io.RandomAccessFile v;
java.util.concurrent.atomic.AtomicLong v;
java.util.List v;
long v;
java.lang.String v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong wordIndex>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndIncrement()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (long)>(v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("-word_\u0001-");
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.RandomAccessFile: void write(byte[])>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.List expected>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
return;
}
private void writeNewLine() throws java.io.IOException
{
byte[] v;
java.io.RandomAccessFile v;
java.util.List v;
java.lang.String v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = "\n";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.RandomAccessFile: void write(byte[])>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.List expected>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("\n");
return;
}
private void writeNul() throws java.io.IOException
{
byte[] v;
java.io.RandomAccessFile v, v;
long v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
java.util.List v;
java.lang.Long v;
java.lang.String v;
java.util.LinkedList v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.LinkedList nulPositions>;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = virtualinvoke v.<java.io.RandomAccessFile: long getFilePointer()>();
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
virtualinvoke v.<java.util.LinkedList: boolean add(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = "\u0000";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.RandomAccessFile: void write(byte[])>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.List expected>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>("X");
return;
}
private void overwriteNul() throws java.io.IOException
{
byte[] v;
java.io.RandomAccessFile v, v, v, v;
java.util.Random v;
long v, v;
int v, v;
java.lang.String v;
java.util.LinkedList v, v, v;
boolean v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
java.lang.Object v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.LinkedList nulPositions>;
v = virtualinvoke v.<java.util.LinkedList: boolean isEmpty()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.LinkedList nulPositions>;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.Random random>;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.LinkedList nulPositions>;
v = virtualinvoke v.<java.util.LinkedList: int size()>();
v = virtualinvoke v.<java.util.Random: int nextInt(int)>(v);
v = virtualinvoke v.<java.util.LinkedList: java.lang.Object remove(int)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = virtualinvoke v.<java.io.RandomAccessFile: long getFilePointer()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
virtualinvoke v.<java.io.RandomAccessFile: void seek(long)>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
v = "X";
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
virtualinvoke v.<java.io.RandomAccessFile: void write(byte[])>(v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
virtualinvoke v.<java.io.RandomAccessFile: void seek(long)>(v);
label:
return;
}
private void trigger()
{
org.apache.nifi.util.TestRunner v;
java.util.concurrent.atomic.AtomicBoolean v;
boolean v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean stopAfterEachTrigger>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int,boolean,boolean)>(1, v, 0);
return;
}
private void rollover() throws java.io.IOException
{
java.util.concurrent.atomic.AtomicBoolean v;
long v;
java.io.File v, v, v, v, v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
java.util.concurrent.atomic.AtomicLong v;
java.lang.String v, v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = new java.io.File;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
v = virtualinvoke v.<java.io.File: java.io.File getParentFile()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
v = virtualinvoke v.<java.io.File: java.lang.String getName()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong rolloverIndex>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long getAndIncrement()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,long)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u.\u0001");
specialinvoke v.<java.io.File: void <init>(java.io.File,java.lang.String)>(v, v);
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
virtualinvoke v.<java.io.File: boolean renameTo(java.io.File)>(v);
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void createTargetFile()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean rolloverSwitchPending>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
return;
}
private void switchFile() throws java.lang.Exception
{
java.io.RandomAccessFile v, v;
java.util.concurrent.atomic.AtomicBoolean v, v;
java.io.File v;
boolean v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean rolloverSwitchPending>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: boolean get()>();
if v == 0 goto label;
specialinvoke v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: void overwriteRemainingNuls()>();
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile>;
virtualinvoke v.<java.io.RandomAccessFile: void close()>();
v = new java.io.RandomAccessFile;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.File file>;
specialinvoke v.<java.io.RandomAccessFile: void <init>(java.io.File,java.lang.String)>(v, "rw");
v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.io.RandomAccessFile randomAccessFile> = v;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicBoolean rolloverSwitchPending>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(0);
label:
return;
}
private void expireRolloverWaitPeriod() throws java.lang.Exception
{
long v, v, v, v, v;
org.apache.nifi.processors.standard.AbstractTestTailFileScenario v;
java.util.concurrent.atomic.AtomicLong v, v;
java.lang.Long v;
v := @this: org.apache.nifi.processors.standard.AbstractTestTailFileScenario;
v = <org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.lang.Long POST_ROLLOVER_WAIT_PERSIOD_SECONDS>;
v = virtualinvoke v.<java.lang.Long: long longValue()>();
v = v * 1000L;
v = v + 100L;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong timeAdjustment>;
v = v.<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.util.concurrent.atomic.AtomicLong timeAdjustment>;
v = virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: long get()>();
v = v + v;
virtualinvoke v.<java.util.concurrent.atomic.AtomicLong: void set(long)>(v);
return;
}
static void <clinit>()
{
java.lang.Long v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(100L);
<org.apache.nifi.processors.standard.AbstractTestTailFileScenario: java.lang.Long POST_ROLLOVER_WAIT_PERSIOD_SECONDS> = v;
return;
}
}