public class org.apache.nifi.processors.standard.TestTailFile extends java.lang.Object { private static final org.slf4j.Logger logger; private java.io.File file; private java.io.File existingFile; private java.io.File otherFile; private java.io.RandomAccessFile raf; private java.io.RandomAccessFile otherRaf; private org.apache.nifi.processors.standard.TailFile processor; private org.apache.nifi.util.TestRunner runner; public void () { org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; specialinvoke v.()>(); return; } public void setup() throws java.io.IOException { java.lang.Throwable v; java.io.RandomAccessFile v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v; java.io.OutputStreamWriter v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v, v, v, v; org.apache.nifi.processors.standard.TailFile v, v; java.io.BufferedWriter v; java.io.FileOutputStream v; java.io.File v, v, v, v, v, v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; staticinvoke ("org.slf4j.simpleLogger.log.org.apache.nifi.processors.standard", "TRACE"); specialinvoke v.(); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/existing-log.txt"); v. = v; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); v = new java.io.BufferedWriter; v = new java.io.OutputStreamWriter; v = new java.io.FileOutputStream; v = v.; specialinvoke v.(java.io.File)>(v); specialinvoke v.(java.io.OutputStream)>(v); specialinvoke v.(java.io.Writer)>(v); label: virtualinvoke v.("Line 1"); virtualinvoke v.(); virtualinvoke v.("Line 2"); virtualinvoke v.(); virtualinvoke v.("Line 3"); virtualinvoke v.(); virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = new java.io.File; specialinvoke v.(java.lang.String)>("target/testDir"); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); staticinvoke (v); label: v = new java.io.File; specialinvoke v.(java.lang.String)>("target/testDir/log.txt"); v. = v; v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); staticinvoke (v); v = new org.apache.nifi.processors.standard.TailFile; specialinvoke v.()>(); v. = v; v = v.; v = staticinvoke (v); v. = v; v = v.; v = ; interfaceinvoke v.(v, "target/log.txt"); v = v.; interfaceinvoke v.(); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; return; catch java.lang.Throwable from label to label with label; } public void cleanup() throws java.io.IOException { java.io.RandomAccessFile v, v, v, v; org.apache.nifi.util.MockProcessContext v; int v, v; java.lang.String v; org.apache.nifi.processors.standard.TestTailFile v; boolean v; org.apache.nifi.processors.standard.TailFile v, v; java.io.File v, v, v; java.io.File[] v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; if v == null goto label; v = v.; virtualinvoke v.(); label: v = v.; v = new org.apache.nifi.util.MockProcessContext; v = v.; specialinvoke v.(org.apache.nifi.components.ConfigurableComponent)>(v); virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(".log"); if v == 0 goto label; virtualinvoke v.(); label: v = v + 1; goto label; label: staticinvoke ("org.slf4j.simpleLogger.log.org.apache.nifi.processors.standard"); return; } public void testNULContentWithReReadOnNulFalseLeaveNul() throws java.lang.Exception { org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.util.TestRunner v; org.apache.nifi.components.PropertyDescriptor v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "false"); virtualinvoke v.(); return; } public void testNULContentWithReReadOnNulDefault() throws java.lang.Exception { java.lang.String[] v; java.util.List v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = newarray (java.lang.String)[2]; v[0] = "first_line_with_nul\u0000\n"; v[1] = "second_line\n"; v = staticinvoke (v); specialinvoke v.("first_line_with_nul\u0000\n", null, "second_line\n", v); return; } public void testNULContentWithReReadOnNulFalseOverwriteNul() throws java.lang.Exception { java.lang.String[] v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v; java.util.List v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "false"); v = "first_line_with_nul"; v = virtualinvoke v.(); v = staticinvoke (v); v = newarray (java.lang.String)[2]; v[0] = "first_line_with_nul\u0000\n"; v[1] = "overwrite_nul_and_continue_first_line_but_end_up_in_second_line_anyway\n"; v = staticinvoke (v); specialinvoke v.("first_line_with_nul\u0000\n", v, "!!overwrite_nul_and_continue_first_line_but_end_up_in_second_line_anyway\n", v); return; } public void testNULContentWithReReadOnNulTrue() throws java.lang.Exception { java.lang.String[] v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v; java.util.List v; org.apache.nifi.util.TestRunner v; int v; java.lang.String v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "true"); v = "first_line_with_nul"; v = virtualinvoke v.(); v = staticinvoke (v); v = newarray (java.lang.String)[1]; v[0] = "first_line_with_nul overwrite_nul_and_continue_first_line\n"; v = staticinvoke (v); specialinvoke v.("first_line_with_nul\u0000\n", v, " overwrite_nul_and_continue_first_line\n", v); return; } private void testNULContent(java.lang.String, java.lang.Integer, java.lang.String, java.util.List) throws java.io.IOException { byte[] v, v; java.io.RandomAccessFile v, v, v; java.lang.Integer v; java.util.function.Function v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; int v, v; java.lang.String v, v, v; java.util.stream.Collector v; org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; java.util.stream.Stream v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: java.lang.String; v := @parameter: java.lang.Integer; v := @parameter: java.lang.String; v := @parameter: java.util.List; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 1); if v == null goto label; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; v = interfaceinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v, v); return; } public void testNULContentWhenRolledOver() throws java.io.IOException { byte[] v, v, v, v; java.io.RandomAccessFile v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v; java.util.stream.Collector v; org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; java.util.stream.Stream v, v, v; java.lang.Throwable v; java.lang.String[] v; long v; java.util.function.Function v, v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String v, v, v, v; java.io.File v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.txt*"); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "true"); v = v.; v = "a\nb"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = newarray (byte)[2]; v[0] = 0; v[1] = 0; virtualinvoke v.(v); v = v.; v = virtualinvoke v.(); v = specialinvoke v.(0); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); label: virtualinvoke v.(3L); v = "c\n"; v = virtualinvoke v.(); virtualinvoke v.(v); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = "d\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = newarray (java.lang.String)[3]; v[0] = "a\n"; v[1] = "bc\n"; v[2] = "d\n"; v = staticinvoke (v); staticinvoke (v, v); return; catch java.lang.Throwable from label to label with label; } public void testRotateMultipleBeforeConsuming() throws java.io.IOException { byte[] v, v, v, v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v; java.util.stream.Collector v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.util.stream.Stream v, v, v; java.util.function.Function v, v; org.apache.nifi.processor.Relationship v, v, v; int v; java.lang.String v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.txt*"); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = "1.5\n"; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(0); v = v.; v = "2\n"; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(1); v = v.; v = "3\n"; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(2); v = v.; v = "4\n"; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(3); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 5); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); staticinvoke (5, v); v = interfaceinvoke v.("1\n"); staticinvoke (v); v = interfaceinvoke v.("1.5\n"); staticinvoke (v); v = interfaceinvoke v.("2\n"); staticinvoke (v); v = interfaceinvoke v.("3\n"); staticinvoke (v); v = interfaceinvoke v.("4\n"); staticinvoke (v); v = v.; interfaceinvoke v.(); return; } public void testStartPositionCurrentTime() throws java.io.IOException { byte[] v, v, v, v; java.io.RandomAccessFile v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v; java.lang.String v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.components.AllowableValue v; java.util.List v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(0); v = v.; v = "2\n"; v = virtualinvoke v.(); virtualinvoke v.(v); specialinvoke v.(1); v = v.; v = "3\n4\n5\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "6\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("6\n"); return; } private java.io.File rollover(int) throws java.io.IOException { java.io.RandomAccessFile v, v; java.io.File v, v, v, v, v, v; int v; java.lang.String v, v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: int; v = v.; virtualinvoke v.(); v = new java.io.File; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.\u.log"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); v = v.; virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; return v; } public void testFileWrittenToAfterRollover() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v; org.apache.nifi.components.AllowableValue v; long v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v; java.io.File v, v, v; org.apache.nifi.util.TestRunner 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, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v; java.util.List v, v, v, v, v, v, v, v; int v; java.io.PrintStream v, v, v, v, v; java.lang.Object v, v, v, v, v, v, v, v; java.nio.channels.FileChannel v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "true"); v = v.; v = ; interfaceinvoke v.(v, "10 mins"); v = v.; v = "a\nb\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("a\nb\n"); v = v.; interfaceinvoke v.(); v = v.; v = "c\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("c\n"); v = v.; interfaceinvoke v.(); v = v.; v = "d\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); v = v.; v = virtualinvoke v.(v); staticinvoke (v); v = v.; v = virtualinvoke v.(); virtualinvoke v.(1); v = ; virtualinvoke v.("Wrote d\\n and rolled file"); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "new file\n"; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("d\n"); v = v.; interfaceinvoke v.(); v = v.; v = "e\nf"; v = virtualinvoke v.(); virtualinvoke v.(v); v = ; virtualinvoke v.("Wrote e\\nf"); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("e\n"); v = v.; interfaceinvoke v.(); v = v.; v = "\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); v = v.; virtualinvoke v.(0); v = ; virtualinvoke v.("Wrote \\n\\0\\0\\0"); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("f\n"); v = v.; interfaceinvoke v.(); v = v.; v = v.; v = virtualinvoke v.(); v = v - 3L; virtualinvoke v.(v); v = v.; v = "g\nh"; v = virtualinvoke v.(); virtualinvoke v.(v); v = ; virtualinvoke v.("Truncated the NUL bytes and replaced with g\\nh"); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("g\n"); v = v.; interfaceinvoke v.(); v = 0; label: if v >= 100 goto label; v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 0); staticinvoke (1L); v = v + 1; goto label; label: v = virtualinvoke v.(500L); staticinvoke (v); v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("Set lastModified on \u to 500"); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("h"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("new file\n"); v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); return; } public void testConsumeAfterTruncationStartAtBeginningOfFile() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; java.io.PrintStream v, v, v; java.io.File v, v, v, v, v, v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.txt*"); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = ; virtualinvoke v.("Ingested 6 bytes"); v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.previous"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = ; v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("Rolled over file to \u.previous"); virtualinvoke v.(v); v = v.; virtualinvoke v.(0L); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); staticinvoke (1000L); v = v.; v = "HELLO\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = ; virtualinvoke v.("Wrote out 6 bytes to tailed file"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("HELLO\n"); return; } public void testConsumeAfterTruncationStartAtCurrentTime() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v; java.io.RandomAccessFile v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; java.lang.String v, v, v; java.io.File v, v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "log.txt*"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt.1"); v = virtualinvoke v.(v); staticinvoke (v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); staticinvoke (1000L); v = v.; v = "HELLO\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("HELLO\n"); return; } public void testStartAtBeginningOfFile() throws java.io.IOException, java.lang.InterruptedException { byte[] v; java.io.RandomAccessFile v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v; java.util.List v; org.apache.nifi.processor.Relationship v, v; org.apache.nifi.util.TestRunner v, v, v, v; java.lang.Object v; java.lang.String v, v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = "hello world\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello world\n"); return; } public void testStartAtCurrentTime() throws java.io.IOException, java.lang.InterruptedException { byte[] v; java.io.RandomAccessFile v; org.apache.nifi.components.AllowableValue v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v; java.lang.String v, v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; v = "hello world\n"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (1000L); v = v.; interfaceinvoke v.(100); v = v.; v = ; interfaceinvoke v.(v, 0); return; } public void testStartAtBeginningOfTime() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v; java.io.RandomAccessFile v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.util.TestRunner v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v, v, v, v; org.apache.nifi.components.AllowableValue v; java.util.List v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, v, v, v, v, v, v, v; java.util.Iterator v; java.io.File v, v, v, v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = "hello"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u.previous"); specialinvoke v.(java.io.File,java.lang.String)>(v, v); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "world\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = ; interfaceinvoke v.(v, "log.txt*"); v = v.; v = ; v = ; v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 2); v = 0; v = 0; v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = new java.lang.String; v = virtualinvoke v.(); specialinvoke v.(byte[])>(v); v = "world\n"; v = virtualinvoke v.(v); if v == 0 goto label; v = 1; goto label; label: v = "hello"; v = virtualinvoke v.(v); if v == 0 goto label; v = 1; goto label; label: v = dynamicinvoke "makeConcatWithConstants" (v) ("Got unexpected content: \u0001"); staticinvoke (v); goto label; label: staticinvoke (v); staticinvoke (v); return; } public void testRemainderOfFileRecoveredAfterRestart() throws java.io.IOException { byte[] v, v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; java.lang.String v, v, v; java.io.File v, v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log*.txt"); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "new file\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("new file\n"); return; } public void testRemainderOfFileRecoveredIfRolledOverWhileRunning() throws java.io.IOException { byte[] v, v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v; java.lang.String v, v, v; java.io.File v, v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log*.txt"); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("1\n"); return; } public void testRolloverAfterHavingReadAllData() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; java.lang.String v, v, v; java.io.File v, v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (1000L); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("1\n"); return; } public void testRolloverWriteMoreDataThanPrevious() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; java.lang.String v, v, v; java.io.File v, v, v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "longer than hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("longer than hello\n"); return; } public void testMultipleRolloversAfterHavingReadAllData() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; java.lang.String v, v, v, v; java.io.File v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); staticinvoke (1000L); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.2"); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "abc\n"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (100L); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("abc\n"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(2); virtualinvoke v.("1\n"); return; } public void testMultipleRolloversAfterHavingReadAllDataWhileStillRunning() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; java.lang.String v, v, v, v; java.io.File v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); staticinvoke (1000L); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.2"); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "abc\n"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (100L); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("abc\n"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(2); virtualinvoke v.("1\n"); return; } public void testMultipleRolloversWithLongerFileLength() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; java.lang.String v, v, v, v; java.io.File v, v, v, v, v, v, v, v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 0); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.2"); virtualinvoke v.(v); staticinvoke (1200L); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "abc\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); staticinvoke (1200L); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); v. = v; v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "This is a longer line than the other files had.\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("world"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(1); virtualinvoke v.("abc\n"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(2); virtualinvoke v.("This is a longer line than the other files had.\n"); return; } public void testConsumeWhenNewLineFound() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v; byte v; java.util.Map v; long v, v, v; org.apache.nifi.processors.standard.TailFile$TailFileState v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v; org.apache.nifi.processor.Processor v; java.util.List v, v, v, v; java.lang.Object v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); staticinvoke (1100L); v = v.; v = "Hello, World"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "\r\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = interfaceinvoke v.(); v = virtualinvoke v.(); v = interfaceinvoke v.("target/log.txt"); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); staticinvoke ("target/log.txt", v); v = virtualinvoke v.(); v = staticinvoke (); v = v cmp v; if v > 0 goto label; v = 1; goto label; label: v = 0; label: staticinvoke (v); v = virtualinvoke v.(); staticinvoke (14L, v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("Hello, World\r\n"); v = v.; interfaceinvoke v.(); v = v.; v = "12345"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("12345\n"); v = v.; interfaceinvoke v.(); v = v.; v = "carriage\rreturn\r"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("carriage\r"); v = v.; interfaceinvoke v.(); v = v.; v = "\r\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("return\r\r\n"); return; } public void testMultiLineWaitsForRegexMatchShutdownBetweenReads() throws java.io.IOException { org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; specialinvoke v.(1); return; } public void testMultiLineWaitsForRegexMatchWithoutShutdownBetweenReads() throws java.io.IOException { org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; specialinvoke v.(0); return; } private void testMultiLineWaitsForRegexMatch(boolean) throws java.io.IOException { byte[] v, v, v, v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v; org.apache.nifi.components.state.Scope v; java.util.Map v; org.apache.nifi.state.MockStateManager v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v; org.apache.nifi.components.state.StateMap v; java.util.List v, v; int v, v, v, v, v, v, v, v, v, v; org.slf4j.Logger v; java.lang.Object v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: boolean; v = v.; v = ; interfaceinvoke v.(v, "<\\d>"); v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; v = "<1>Hello, World\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "<2>Good-bye, World\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, v, 1); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); v = v.; v = "<3>Start of multi-line\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, v, v); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); v = 0; label: if v >= 10 goto label; v = ; v = dynamicinvoke "makeConcatWithConstants" (v) ("i = \u0001"); interfaceinvoke v.(v); v = v.; v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, v, v); v = v.; v = ; interfaceinvoke v.(v, 0); v = v + 1; goto label; label: v = v.; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = "<1>Hello, World\n"; v = virtualinvoke v.(); v = "<2>Good-bye, World\n"; v = virtualinvoke v.(); v = v + v; v = "<3>Start of multi-line\n"; v = virtualinvoke v.(); v = v + v; v = v + 20; v = staticinvoke (v); v = interfaceinvoke v.("file.0.length"); staticinvoke (v, v); v = "<1>Hello, World\n"; v = virtualinvoke v.(); v = "<2>Good-bye, World\n"; v = virtualinvoke v.(); v = v + v; v = staticinvoke (v); v = interfaceinvoke v.("file.0.position"); staticinvoke (v, v); v = v.; v = "<4>Last One\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, v, v); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("<3>Start of multi-line\n0\n1\n2\n3\n4\n5\n6\n7\n8\n9\n"); v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = newarray (byte)[0]; virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, v, v); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("<4>Last One\n"); return; } public void testRolloverAndUpdateAtSameTime() throws java.io.IOException { byte[] v, v, v; java.io.RandomAccessFile v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v; org.apache.nifi.processor.Relationship v, v, v, v; java.lang.String v, v, v; java.io.File v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "log.*"); v = v.; v = "hello there\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); v = v.; v = "another"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "new file\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0, 1); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("another"); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(1, 1, 0); v = v.; v = ; interfaceinvoke v.(v, 0); return; } public void testRolloverWhenNoRollingPattern() throws java.io.IOException { byte[] v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; java.util.List v, v; org.apache.nifi.processor.Relationship v, v, v, v, v; java.lang.String v, v, v, v; java.io.File v, v, v, v, v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = "hello there\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; interfaceinvoke v.(); v = v.; v = "another"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "new file\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("new file\n"); v = v.; interfaceinvoke v.(); v = v.; virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.2"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = v.; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "new file with longer data in the new file\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(0); virtualinvoke v.("with longer data in the new file\n"); v = v.; interfaceinvoke v.(); return; } public void testMultipleFiles() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v, v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v, v; java.util.stream.Stream v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.util.TestRunner 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.nifi.processors.standard.TestTailFile v; java.lang.Object v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v; java.io.File v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.function.Predicate v, v, v, v, v, v, v, v; java.util.List v, v, v, v, v, v, v, v; java.util.Optional v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "target"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.("/"); if v == 0 goto label; v = "(testDir/)?log(ging)?.txt"; goto label; label: v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("(testDir\u)?log(ging)?.txt"); label: v = v.; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "${filename}.?"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "true"); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/logging.txt"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "hey\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "hi\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 3); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("hey\n"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("hi\n"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = v.; v = "world!"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (100L); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); virtualinvoke v.(); virtualinvoke v.(); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/testDir/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/testDir/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "2\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/testDir/logging.txt"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "3\n"; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 5); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); return; } public void testDetectNewFile() throws java.io.IOException, java.lang.InterruptedException { java.lang.Runnable v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v; java.util.function.Predicate v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v; java.util.stream.Stream v, v; org.apache.nifi.processor.Relationship v, v, v; java.util.concurrent.ScheduledExecutorService v; java.util.concurrent.TimeUnit v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "target"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "1 sec"); v = v.; v = ; interfaceinvoke v.(v, "log_[0-9]*\\.txt"); v = v.; v = ; interfaceinvoke v.(v, "false"); specialinvoke v.("target/log_1.txt", "firstLine\n"); v = staticinvoke (v); v = staticinvoke (1); v = ; interfaceinvoke v.(v, 2L, v); v = v.; interfaceinvoke v.(2000L); v = v.; interfaceinvoke v.(3); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; interfaceinvoke v.(); return; } public void testHandleRemovedFile() throws java.io.IOException { org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v; java.nio.file.Path v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v; java.util.function.Predicate v, v; org.apache.nifi.components.AllowableValue v; java.util.List v, v, v, v; java.util.stream.Stream v, v; java.lang.String[] v, v, v; org.apache.nifi.processor.Relationship v, v, v; java.lang.String v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "target"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "1 sec"); v = v.; v = ; interfaceinvoke v.(v, "log_[0-9]*\\.txt"); v = v.; v = ; interfaceinvoke v.(v, "false"); v = newarray (java.lang.String)[1]; v[0] = "log_1.txt"; v = staticinvoke ("target", v); v = interfaceinvoke v.(); v = newarray (java.lang.String)[1]; v[0] = "log_2.txt"; v = staticinvoke ("target", v); v = interfaceinvoke v.(); specialinvoke v.(v, "firstLine\n"); specialinvoke v.(v, "secondLine\n"); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); specialinvoke v.(2); v = newarray (java.lang.String)[2]; v[0] = v; v[1] = v; v = staticinvoke (v); specialinvoke v.(v); specialinvoke v.(v); v = v.; interfaceinvoke v.(1); specialinvoke v.(1); v = staticinvoke (v); specialinvoke v.(v); v = v.; interfaceinvoke v.(); return; } public void testMultipleFilesWithBasedirAndFilenameEL() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v; java.io.RandomAccessFile v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v; org.apache.nifi.components.AllowableValue v, v; org.apache.nifi.processor.Relationship v, v; java.lang.String v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; interfaceinvoke v.("vrBaseDirectory", "target"); v = v.; v = ; interfaceinvoke v.(v, "${vrBaseDirectory}"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = ; v = virtualinvoke v.("/"); if v == 0 goto label; v = "(testDir/)?log(ging)?.txt"; goto label; label: v = ; v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("(testDir\u)?log(ging)?.txt"); label: v = v.; interfaceinvoke v.("vrFilename", v); v = v.; v = ; interfaceinvoke v.(v, "${vrFilename}"); v = v.; v = ; interfaceinvoke v.(v, "${filename}.?"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "true"); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; v = "hi\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 2); return; } public void testMultipleFilesInSameDirectory() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v, v, v; java.io.RandomAccessFile v, v, v, v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v; org.apache.nifi.components.AllowableValue v, v; java.util.stream.Stream v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v; java.io.File v, v, v, v, v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v, v, v, v, v, v, v; java.util.function.Predicate v, v, v, v, v, v; java.util.List v, v, v, v, v, v; java.util.Optional v, v; java.lang.Object v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "${filename}.?"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "target"); v = v.; v = ; interfaceinvoke v.(v, "log(ging)?.txt"); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/logging.txt"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "hey\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("hey\n"); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.("hello\n"); v = v.; interfaceinvoke v.(); v = "guys"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; v = "world"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (100L); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 0); v = v.; virtualinvoke v.(); virtualinvoke v.(); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/logging.1"); virtualinvoke v.(v); v = v.; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.1"); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/log.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v. = v; v = v.; v = "1\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.RandomAccessFile; v = new java.io.File; specialinvoke v.(java.lang.String)>("target/logging.txt"); specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "2\n"; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(); v = v.; interfaceinvoke v.(1); v = v.; v = ; interfaceinvoke v.(v, 4); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); return; } public void testMultipleFilesChangingNameStrategy() throws java.io.IOException, java.lang.InterruptedException { byte[] v, v, v, v, v, v, v, v; java.io.RandomAccessFile v, v, v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v; org.apache.nifi.components.AllowableValue v, v; java.util.stream.Stream v, v, v, v, v, v, v, v; org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v, v, v, v; java.lang.String v, v, v, v, v, v, v, v; java.io.File v, v, v, v; org.apache.nifi.util.TestRunner 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.nifi.processors.standard.TestTailFile v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.function.Predicate v, v, v, v, v, v, v, v; java.util.List v, v, v, v, v, v, v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; v = ; interfaceinvoke v.(v, v); v = v.; v = ; interfaceinvoke v.(v, "target"); v = v.; v = ; interfaceinvoke v.(v, ".*app-.*.log"); v = v.; v = ; interfaceinvoke v.(v, "2s"); v = v.; v = ; interfaceinvoke v.(v, "5s"); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/app-2016-09-07.log"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "hey\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/my-app-2016-09-07.log"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = v.; interfaceinvoke v.(1, 0); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; interfaceinvoke v.(); v = "hey2\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = "hello2\n"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (2000L); v = v.; interfaceinvoke v.(1, 0); v = v.; v = ; interfaceinvoke v.(v, 2); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; interfaceinvoke v.(); v = "hey3\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = "hello3\n"; v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(); virtualinvoke v.(); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/app-2016-09-08.log"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "hey\n"; v = virtualinvoke v.(); virtualinvoke v.(v); v = new java.io.File; specialinvoke v.(java.lang.String)>("target/my-app-2016-09-08.log"); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = "hello\n"; v = virtualinvoke v.(); virtualinvoke v.(v); staticinvoke (2000L); v = v.; interfaceinvoke v.(1); virtualinvoke v.(); virtualinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 4); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); staticinvoke (v); v = v.; interfaceinvoke v.(); return; } public void testMigrateFrom100To110() throws java.io.IOException { byte[] v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.state.Scope v, v; org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.state.MockStateManager v; org.apache.nifi.components.state.StateMap v; java.util.List v; java.lang.Throwable v; java.io.ByteArrayOutputStream v; java.util.HashMap v; org.apache.nifi.processor.Relationship v, v, v; java.io.OutputStreamWriter v; java.lang.String v, v, v, v, v, v, v, v; java.util.Iterator v; java.io.BufferedWriter v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "target/existing-log.txt"); v = v.; v = interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "target/existing-log.txt"); interfaceinvoke v.("checksum", "2279929157"); interfaceinvoke v.("position", "14"); interfaceinvoke v.("timestamp", "1480639134000"); v = ; virtualinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 1); v = v.; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = new java.io.ByteArrayOutputStream; specialinvoke v.()>(); v = new java.io.BufferedWriter; v = new java.io.OutputStreamWriter; specialinvoke v.(java.io.OutputStream)>(v); specialinvoke v.(java.io.Writer)>(v); label: virtualinvoke v.("Line 3"); virtualinvoke v.(); label: virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v = virtualinvoke v.(); virtualinvoke v.(v); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.("filename"); staticinvoke (v); v = interfaceinvoke v.("checksum"); staticinvoke (v); v = interfaceinvoke v.("position"); staticinvoke (v); v = interfaceinvoke v.("timestamp"); staticinvoke (v); v = interfaceinvoke v.("file.0.filename"); staticinvoke ("target/existing-log.txt", v); v = interfaceinvoke v.("file.0.checksum"); staticinvoke ("3380848603", v); v = interfaceinvoke v.("file.0.position"); staticinvoke ("21", v); v = interfaceinvoke v.("file.0.timestamp"); staticinvoke (v); v = v.; interfaceinvoke v.(); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); return; catch java.lang.Throwable from label to label with label; } public void testMigrateFrom100To110FileNotFound() throws java.io.IOException { org.apache.nifi.state.MockStateManager v; java.util.HashMap v; org.apache.nifi.components.PropertyDescriptor v; org.apache.nifi.components.state.Scope v; org.apache.nifi.processor.Relationship v; org.apache.nifi.util.TestRunner v, v, v, v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v = v.; v = ; interfaceinvoke v.(v, "target/not-existing-log.txt"); v = v.; v = interfaceinvoke v.(); v = new java.util.HashMap; specialinvoke v.()>(); interfaceinvoke v.("filename", "target/not-existing-log.txt"); interfaceinvoke v.("checksum", "2279929157"); interfaceinvoke v.("position", "14"); interfaceinvoke v.("timestamp", "1480639134000"); v = ; virtualinvoke v.(v, v); v = v.; interfaceinvoke v.(); v = v.; v = ; interfaceinvoke v.(v, 0); return; } private void assertNumberOfStateMapEntries(int) throws java.io.IOException { org.apache.nifi.state.MockStateManager v; org.apache.nifi.components.state.StateMap v; org.apache.nifi.components.state.Scope v; org.apache.nifi.util.TestRunner v; java.util.Map v; int v, v, v; org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: int; v = v.; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); v = 6 * v; v = interfaceinvoke v.(); v = interfaceinvoke v.(); staticinvoke (v, v); return; } private void assertFilenamesInStateMap(java.util.Collection) throws java.io.IOException { java.util.function.Function v; java.util.HashSet v; org.apache.nifi.components.state.Scope v; org.apache.nifi.util.TestRunner v; java.util.Map v; java.util.stream.Collector v; org.apache.nifi.processors.standard.TestTailFile v; org.apache.nifi.state.MockStateManager v; java.util.function.Predicate v; java.util.Collection v; java.util.Set v; org.apache.nifi.components.state.StateMap v; java.util.stream.Stream v, v, v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: java.util.Collection; v = v.; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = staticinvoke (); v = interfaceinvoke v.(v); v = new java.util.HashSet; specialinvoke v.(java.util.Collection)>(v); staticinvoke (v, v); return; } private void cleanFiles(java.lang.String) { org.apache.nifi.processors.standard.TestTailFile$1 v; java.io.File v, v; int v, v; java.lang.String v; java.io.File[] v; org.apache.nifi.processors.standard.TestTailFile v; boolean v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: java.lang.String; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v == 0 goto label; v = new org.apache.nifi.processors.standard.TestTailFile$1; specialinvoke v.(org.apache.nifi.processors.standard.TestTailFile)>(v); v = virtualinvoke v.(v); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; virtualinvoke v.(); v = v + 1; goto label; label: return; } private void clean() { org.apache.nifi.processors.standard.TestTailFile v; v := @this: org.apache.nifi.processors.standard.TestTailFile; specialinvoke v.("target"); specialinvoke v.("target/testDir"); return; } private java.io.RandomAccessFile initializeFile(java.lang.String, java.lang.String) throws java.io.IOException { byte[] v; java.io.RandomAccessFile v; java.io.File v; java.lang.String v, v; org.apache.nifi.processors.standard.TestTailFile v; boolean v, v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: java.lang.String; v := @parameter: java.lang.String; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = virtualinvoke v.(); staticinvoke (v); v = new java.io.RandomAccessFile; specialinvoke v.(java.io.File,java.lang.String)>(v, "rw"); v = virtualinvoke v.(); virtualinvoke v.(v); virtualinvoke v.(); return v; } private void deleteFile(java.lang.String) throws java.io.IOException { java.lang.String v; org.apache.nifi.processors.standard.TestTailFile v; java.io.File v; boolean v; v := @this: org.apache.nifi.processors.standard.TestTailFile; v := @parameter: java.lang.String; v = new java.io.File; specialinvoke v.(java.lang.String)>(v); v = virtualinvoke v.(); staticinvoke (v); return; } static void () { org.slf4j.Logger v; v = staticinvoke (class "Lorg/apache/nifi/processors/standard/TestTailFile;"); = v; return; } }