public class org.apache.nifi.processors.standard.TestDebugFlow extends java.lang.Object
{
private org.apache.nifi.processors.standard.DebugFlow debugFlow;
private org.apache.nifi.util.TestRunner runner;
private org.apache.nifi.processor.ProcessSession session;
private final java.util.Map contents;
private final java.util.Map attribs;
private java.util.Map namesToContent;
public void <init>()
{
java.util.HashMap v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
specialinvoke v.<java.lang.Object: void <init>()>();
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs> = v;
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map namesToContent> = v;
return;
}
public void setup() throws java.io.IOException
{
java.lang.Integer v, v, v, v;
org.apache.nifi.components.PropertyDescriptor 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;
java.util.Map v, v, v, v, v;
org.apache.nifi.processors.standard.DebugFlow v, v;
java.util.HashMap v;
org.apache.nifi.processors.standard.TestDebugFlow v;
int v, v, v, v;
java.lang.String v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v;
org.apache.nifi.processor.ProcessSessionFactory v;
java.lang.Object v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = 0;
label:
if v >= 6 goto label;
v = v + 1;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("testFile\u.txt");
v = v + 1;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("Hello World \u0001!");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = new java.util.HashMap;
specialinvoke v.<java.util.HashMap: void <init>()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes UUID>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = v + 1;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (int)>(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[])>("TESTING-FILE-\u0001-TESTING");
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map namesToContent>;
interfaceinvoke v.<java.util.Map: java.lang.Object put(java.lang.Object,java.lang.Object)>(v, v);
v = v + 1;
goto label;
label:
v = new org.apache.nifi.processors.standard.DebugFlow;
specialinvoke v.<org.apache.nifi.processors.standard.DebugFlow: void <init>()>();
v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.processors.standard.DebugFlow debugFlow> = v;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.processors.standard.DebugFlow debugFlow>;
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.TestDebugFlow: org.apache.nifi.util.TestRunner runner> = v;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.processor.ProcessSessionFactory getProcessSessionFactory()>();
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSessionFactory: org.apache.nifi.processor.ProcessSession createSession()>();
v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.processor.ProcessSession session> = v;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_SKIP_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_YIELD_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "0");
return;
}
private boolean isInContents(byte[])
{
byte[] v;
java.util.Map v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v := @parameter: byte[];
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = new java.lang.String;
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
v = interfaceinvoke v.<java.util.Map: boolean containsValue(java.lang.Object)>(v);
return v;
}
public void testFlowFileSuccess()
{
byte[] v, v, v, v, v, v, v;
java.lang.Integer 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;
java.util.Map v, v;
boolean v, v, v, v, v, v;
java.util.List v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
int v;
java.lang.Object v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(7);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 6);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(1);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(2);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(3);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(4);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(5);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testFlowFileFailure()
{
byte[] v;
java.lang.Integer 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;
java.util.Map v, v, v, v, v, v, v, v;
java.util.List v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
int v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(7);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 6);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(1);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(2);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(3);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(4);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(5);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(5);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
return;
}
public void testFlowFileSuccessAndFailure()
{
byte[] v;
java.lang.Integer v, v, v, 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;
java.util.Map v, v, v, v, v, v, v, v;
java.util.List v, v, v, v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.processor.Relationship v, v, v, v, v, v, v, v;
int v;
java.lang.Object v, v, v, v, v, v, v, v, v, v, v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(7);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 3);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(1);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(1);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(2);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(1);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(3);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(2);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(4);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(2);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(5);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
virtualinvoke v.<org.apache.nifi.util.MockFlowFile: void assertContentEquals(java.lang.String)>(v);
return;
}
public void testFlowFileRollback() throws java.io.IOException
{
byte[] v, v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.controller.queue.QueueSize v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v;
java.util.Map v, v, v;
org.apache.nifi.flowfile.FlowFile v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.processor.Relationship v, v;
int v, v;
java.lang.String v, v, v;
org.apache.nifi.processor.ProcessSession v, v;
java.lang.Object v, v, v;
org.apache.nifi.flowfile.attributes.CoreAttributes v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(7);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertQueueNotEmpty()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.controller.queue.QueueSize getQueueSize()>();
v = virtualinvoke v.<org.apache.nifi.controller.queue.QueueSize: int getObjectCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(6, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.processor.ProcessSession session>;
v = interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: org.apache.nifi.flowfile.FlowFile get()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertNotNull(java.lang.Object)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map namesToContent>;
v = <org.apache.nifi.flowfile.attributes.CoreAttributes: org.apache.nifi.flowfile.attributes.CoreAttributes FILENAME>;
v = virtualinvoke v.<org.apache.nifi.flowfile.attributes.CoreAttributes: java.lang.String key()>();
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: java.lang.String getAttribute(java.lang.String)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = new java.lang.String;
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
specialinvoke v.<java.lang.String: void <init>(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(java.lang.Object,java.lang.Object)>(v, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.processor.ProcessSession session>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
return;
}
public void testFlowFileRollbackYield()
{
byte[] v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.controller.queue.QueueSize v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v;
java.util.Map v, v;
int v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(7);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertQueueNotEmpty()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.controller.queue.QueueSize getQueueSize()>();
v = virtualinvoke v.<org.apache.nifi.controller.queue.QueueSize: int getObjectCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(6, v);
return;
}
public void testFlowFileRollbackPenalty()
{
byte[] v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.controller.queue.QueueSize v;
org.apache.nifi.processor.Relationship v, v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v;
java.util.Map v, v;
int v, v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(7);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 0);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertQueueNotEmpty()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.controller.queue.QueueSize getQueueSize()>();
v = virtualinvoke v.<org.apache.nifi.controller.queue.QueueSize: int getObjectCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(6, v);
return;
}
public void testFlowFileDefaultException()
{
java.lang.Throwable v, v;
byte[] v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.util.TestRunner v, v, v;
java.util.Map v, v;
java.lang.String v;
boolean v;
org.junit.jupiter.api.function.Executable v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testFlowFileDefaultException_0__54: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/RuntimeException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testFlowFileNonDefaultException()
{
java.lang.Throwable v, v;
byte[] v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v, v;
java.lang.String v;
boolean v;
org.junit.jupiter.api.function.Executable v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "java.lang.RuntimeException");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testFlowFileNonDefaultException_1__55: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/RuntimeException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testFlowFileNPEException()
{
java.lang.Throwable v, v;
byte[] v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v, v, v, v;
java.util.Map v, v;
java.lang.String v;
boolean v;
org.junit.jupiter.api.function.Executable v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "java.lang.NullPointerException");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(0);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testFlowFileNPEException_2__56: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/NullPointerException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testFlowFileBadException()
{
org.apache.nifi.util.TestRunner v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_CLASS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "java.lang.NonExistantException");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertNotValid()>();
return;
}
public void testFlowFileExceptionRollover()
{
java.lang.Throwable v, v;
byte[] v;
org.apache.nifi.processors.standard.TestDebugFlow v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.util.TestRunner v, v, v;
java.util.Map v, v;
int v;
java.lang.String v;
boolean v;
org.junit.jupiter.api.function.Executable v;
java.lang.Object v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "2");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testFlowFileExceptionRollover_3__57: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/RuntimeException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testFlowFileAll()
{
byte[] v, v, v;
java.lang.Integer v, v;
org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v;
org.apache.nifi.controller.queue.QueueSize v;
org.apache.nifi.util.TestRunner v, v, v, v, v, v, v, v, v, v, v, v, v, v, v;
java.util.Map v, v;
boolean v, v;
java.util.List v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.processor.Relationship v, v, v, v;
int v, v;
java.lang.Object v, v, v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_SUCCESS_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_FAILURE_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_YIELD_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_ROLLBACK_PENALTY_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = 0;
label:
if v >= 6 goto label;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map contents>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
v = virtualinvoke v.<java.lang.String: byte[] getBytes()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: java.util.Map attribs>;
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v = interfaceinvoke v.<java.util.Map: java.lang.Object get(java.lang.Object)>(v);
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.util.MockFlowFile enqueue(byte[],java.util.Map)>(v, v);
v = v + 1;
goto label;
label:
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(5);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertTransferCount(org.apache.nifi.processor.Relationship,int)>(v, 1);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.controller.queue.QueueSize getQueueSize()>();
v = virtualinvoke v.<org.apache.nifi.controller.queue.QueueSize: int getObjectCount()>();
staticinvoke <org.junit.jupiter.api.Assertions: void assertEquals(int,int)>(4, v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: 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.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.processor.Relationship REL_FAILURE>;
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.lang.Object get(int)>(0);
v = virtualinvoke v.<org.apache.nifi.util.MockFlowFile: byte[] toByteArray()>();
v = specialinvoke v.<org.apache.nifi.processors.standard.TestDebugFlow: boolean isInContents(byte[])>(v);
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(2);
return;
}
public void testNoFlowFileZeroIterations()
{
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.util.TestRunner v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(4);
return;
}
public void testNoFlowFileSkip()
{
org.apache.nifi.util.TestRunner v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_SKIP_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(4);
return;
}
public void testNoFlowFileDefaultException()
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v;
org.apache.nifi.util.TestRunner v, v;
org.junit.jupiter.api.function.Executable v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testNoFlowFileDefaultException_4__58: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/RuntimeException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testNoFlowFileNonDefaultException()
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v, v, v;
org.junit.jupiter.api.function.Executable v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "java.lang.RuntimeException");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testNoFlowFileNonDefaultException_5__59: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/RuntimeException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testNoFlowFileOtherException()
{
java.lang.Throwable v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v, v;
org.apache.nifi.util.TestRunner v, v, v;
org.junit.jupiter.api.function.Executable v;
java.lang.String v;
boolean v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "java.lang.NullPointerException");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = staticinvoke <org.apache.nifi.processors.standard.TestDebugFlow$lambda_testNoFlowFileOtherException_6__60: org.junit.jupiter.api.function.Executable bootstrap$(org.apache.nifi.processors.standard.TestDebugFlow)>(v);
v = staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Throwable assertThrows(java.lang.Class,org.junit.jupiter.api.function.Executable)>(class "Ljava/lang/AssertionError;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.Throwable getCause()>();
staticinvoke <org.junit.jupiter.api.Assertions: java.lang.Object assertInstanceOf(java.lang.Class,java.lang.Object)>(class "Ljava/lang/NullPointerException;", v);
v = virtualinvoke v.<java.lang.AssertionError: java.lang.String getMessage()>();
v = virtualinvoke v.<java.lang.String: boolean contains(java.lang.CharSequence)>("forced by org.apache.nifi.processors.standard.DebugFlow");
staticinvoke <org.junit.jupiter.api.Assertions: void assertTrue(boolean)>(v);
return;
}
public void testNoFlowFileBadException()
{
org.apache.nifi.util.TestRunner v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v, v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_EXCEPTION_CLASS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "java.lang.NonExistantException");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertNotValid()>();
return;
}
public void testNoFlowFileYield()
{
org.apache.nifi.util.TestRunner v, v, v;
org.apache.nifi.processors.standard.TestDebugFlow v;
org.apache.nifi.components.PropertyDescriptor v;
v := @this: org.apache.nifi.processors.standard.TestDebugFlow;
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
v = <org.apache.nifi.processors.standard.DebugFlow: org.apache.nifi.components.PropertyDescriptor NO_FF_YIELD_ITERATIONS>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: org.apache.nifi.components.ValidationResult setProperty(org.apache.nifi.components.PropertyDescriptor,java.lang.String)>(v, "1");
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void assertValid()>();
v = v.<org.apache.nifi.processors.standard.TestDebugFlow: org.apache.nifi.util.TestRunner runner>;
interfaceinvoke v.<org.apache.nifi.util.TestRunner: void run(int)>(4);
return;
}
}