public class org.apache.nifi.processors.standard.HandleHttpRequest extends org.apache.nifi.processor.AbstractProcessor { private static final java.lang.String MIME_TYPE__MULTIPART_FORM_DATA; private static final java.util.regex.Pattern URL_QUERY_PARAM_DELIMITER; public static final org.apache.nifi.components.AllowableValue CLIENT_NONE; public static final org.apache.nifi.components.AllowableValue CLIENT_WANT; public static final org.apache.nifi.components.AllowableValue CLIENT_NEED; public static final org.apache.nifi.components.PropertyDescriptor PORT; public static final org.apache.nifi.components.PropertyDescriptor HOSTNAME; public static final org.apache.nifi.components.PropertyDescriptor HTTP_CONTEXT_MAP; public static final org.apache.nifi.components.PropertyDescriptor SSL_CONTEXT; public static final org.apache.nifi.components.PropertyDescriptor HTTP_PROTOCOL_STRATEGY; public static final org.apache.nifi.components.PropertyDescriptor URL_CHARACTER_SET; public static final org.apache.nifi.components.PropertyDescriptor PATH_REGEX; public static final org.apache.nifi.components.PropertyDescriptor ALLOW_GET; public static final org.apache.nifi.components.PropertyDescriptor ALLOW_POST; public static final org.apache.nifi.components.PropertyDescriptor ALLOW_PUT; public static final org.apache.nifi.components.PropertyDescriptor ALLOW_DELETE; public static final org.apache.nifi.components.PropertyDescriptor ALLOW_HEAD; public static final org.apache.nifi.components.PropertyDescriptor ALLOW_OPTIONS; public static final org.apache.nifi.components.PropertyDescriptor MAXIMUM_THREADS; public static final org.apache.nifi.components.PropertyDescriptor ADDITIONAL_METHODS; public static final org.apache.nifi.components.PropertyDescriptor PARAMETERS_TO_ATTRIBUTES; public static final org.apache.nifi.components.PropertyDescriptor CLIENT_AUTH; public static final org.apache.nifi.components.PropertyDescriptor CONTAINER_QUEUE_SIZE; public static final org.apache.nifi.components.PropertyDescriptor MULTIPART_REQUEST_MAX_SIZE; public static final org.apache.nifi.components.PropertyDescriptor MULTIPART_READ_BUFFER_SIZE; public static final org.apache.nifi.processor.Relationship REL_SUCCESS; private static final java.util.List propertyDescriptors; private volatile org.eclipse.jetty.server.Server server; private volatile boolean ready; private volatile java.util.concurrent.BlockingQueue containerQueue; private final java.util.concurrent.atomic.AtomicBoolean initialized; private final java.util.concurrent.atomic.AtomicBoolean runOnPrimary; private final java.util.concurrent.atomic.AtomicReference parameterToAttributesReference; private final org.apache.nifi.processors.standard.http.CertificateAttributesProvider certificateAttributesProvider; public void () { org.apache.nifi.processors.standard.http.HandleHttpRequestCertificateAttributesProvider v; org.apache.nifi.processors.standard.HandleHttpRequest v; java.util.concurrent.atomic.AtomicBoolean v, v; java.util.concurrent.atomic.AtomicReference v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicReference; specialinvoke v.(java.lang.Object)>(null); v. = v; v = new org.apache.nifi.processors.standard.http.HandleHttpRequestCertificateAttributesProvider; specialinvoke v.()>(); v. = v; return; } protected java.util.List getSupportedPropertyDescriptors() { java.util.List v; org.apache.nifi.processors.standard.HandleHttpRequest v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v = ; return v; } public java.util.Set getRelationships() { java.util.Set v; org.apache.nifi.processor.Relationship v; org.apache.nifi.processors.standard.HandleHttpRequest v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v = ; v = staticinvoke (v); return v; } public void clearInit() { java.util.concurrent.atomic.AtomicBoolean v; org.apache.nifi.processors.standard.HandleHttpRequest v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v = v.; virtualinvoke v.(0); return; } synchronized void initializeServer(org.apache.nifi.processor.ProcessContext) throws java.lang.Exception { javax.net.ssl.SSLContext v; java.lang.Integer v, v; org.apache.nifi.components.PropertyDescriptor v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.eclipse.jetty.server.Server v; java.util.Set v; org.apache.nifi.components.AllowableValue v, v; org.apache.nifi.controller.ControllerService v, v; org.apache.nifi.processors.standard.HandleHttpRequest$1 v; java.lang.Object[] v; long v, v, v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processors.standard.http.HttpProtocolStrategy v; org.eclipse.jetty.server.Connector[] v; org.apache.nifi.scheduling.ExecutionNode v, v; org.apache.nifi.processors.standard.HandleHttpRequest v; org.apache.nifi.components.PropertyValue v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; boolean v, v, v, v, v, v, v, v, v, v, v, v, v; java.util.concurrent.LinkedBlockingQueue v; java.util.regex.Pattern v; java.util.concurrent.atomic.AtomicBoolean v, v, v; java.lang.String[] v, v; org.apache.nifi.logging.ComponentLog v; java.util.concurrent.atomic.AtomicReference v; java.util.HashSet v, v; org.apache.nifi.jetty.configuration.connector.StandardServerConnectorFactory v; int v, v, v, v, v, v, v, v; java.lang.Boolean v, v, v, v, v, v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v; org.eclipse.jetty.server.ServerConnector v; org.eclipse.jetty.server.Connector v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v := @parameter: org.apache.nifi.processor.ProcessContext; v = v.; v = virtualinvoke v.(); if v == 0 goto label; return; label: v = v.; v = interfaceinvoke v.(); v = ; v = virtualinvoke v.(v); virtualinvoke v.(v); v = new java.util.concurrent.LinkedBlockingQueue; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(int)>(v); v. = v; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = interfaceinvoke v.(); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/ssl/SSLContextService;"); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(class "Lorg/apache/nifi/http/HttpContextMap;"); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = specialinvoke v.(v); v = new org.apache.nifi.jetty.configuration.connector.StandardServerConnectorFactory; specialinvoke v.(org.eclipse.jetty.server.Server,int)>(v, v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); v = ; v = virtualinvoke v.(); v = virtualinvoke v.(v); virtualinvoke v.(v); if v != null goto label; v = null; goto label; label: v = interfaceinvoke v.(); label: virtualinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = staticinvoke (v); v = virtualinvoke v.(); virtualinvoke v.(v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (v, v); virtualinvoke v.(v); v = staticinvoke (v); if v == 0 goto label; virtualinvoke v.(v); label: virtualinvoke v.(v); v = new java.util.HashSet; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("GET"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("POST"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("PUT"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("DELETE"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("HEAD"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); v = virtualinvoke v.(); if v == 0 goto label; interfaceinvoke v.("OPTIONS"); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(","); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.(v); label: v = v + 1; goto label; label: v = new java.util.HashSet; specialinvoke v.()>(); v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(","); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = virtualinvoke v.(); if v != 0 goto label; interfaceinvoke v.(v); label: v = v + 1; goto label; label: v = v.; virtualinvoke v.(v); label: v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); if v != null goto label; v = null; goto label; label: v = staticinvoke (v); label: v = new org.apache.nifi.processors.standard.HandleHttpRequest$1; specialinvoke v.(org.apache.nifi.processors.standard.HandleHttpRequest,java.util.Set,java.util.regex.Pattern,org.apache.nifi.processor.ProcessContext)>(v, v, v, v); virtualinvoke v.(v); v. = v; virtualinvoke v.(); v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Started Connector {}", v); v = v + 1; goto label; label: v = v.; virtualinvoke v.(1); v. = 1; return; } protected int getPort() { java.lang.IllegalStateException v; org.apache.nifi.processors.standard.HandleHttpRequest v; org.eclipse.jetty.server.Connector[] v; int v, v, v; org.eclipse.jetty.server.Connector v; org.eclipse.jetty.server.Server v; boolean v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v = v.; v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = v instanceof org.eclipse.jetty.server.ServerConnector; if v == 0 goto label; v = virtualinvoke v.(); return v; label: v = v + 1; goto label; label: v = new java.lang.IllegalStateException; specialinvoke v.(java.lang.String)>("Server is not listening on any ports"); throw v; } protected int getRequestQueueSize() { int v; java.util.concurrent.BlockingQueue v; org.apache.nifi.processors.standard.HandleHttpRequest v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v = v.; v = interfaceinvoke v.(); return v; } public void shutdown() throws java.lang.Exception { java.lang.Object[] v, v, v; org.apache.nifi.processors.standard.HandleHttpRequest v; org.apache.nifi.logging.ComponentLog v, v, v, v; int v, v, v, v; org.eclipse.jetty.server.Server v, v, v, v, v, v, v, v; boolean v; org.eclipse.jetty.server.Connector[] v, v; org.eclipse.jetty.server.Connector v, v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v. = 0; v = v.; if v != null goto label; v = virtualinvoke v.(); interfaceinvoke v.("Server not configured"); goto label; label: v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = v.; v[0] = v; interfaceinvoke v.("Server Stopped {}", v); goto label; label: v = v.; v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Stopping Connector {}", v); v = v + 1; goto label; label: virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); v = v.; virtualinvoke v.(); virtualinvoke v.(); v = v.; v = virtualinvoke v.(); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Stopped Connector {}", v); v = v + 1; goto label; label: return; } void drainContainerQueue() { java.lang.Object[] v; java.util.Iterator v; org.apache.nifi.processors.standard.HandleHttpRequest v; java.util.concurrent.BlockingQueue v, v; org.apache.nifi.logging.ComponentLog v, v; java.lang.Integer v; java.util.ArrayList v; int v; java.lang.Object v; boolean v, v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); interfaceinvoke v.("No Pending Requests Queued"); goto label; label: v = new java.util.ArrayList; specialinvoke v.()>(); v = v.; interfaceinvoke v.(v); v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v = interfaceinvoke v.(); v = staticinvoke (v); v[0] = v; interfaceinvoke v.("Pending Requests Queued [{}]", v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); specialinvoke v.(503, "Stopping Server", v); goto label; label: return; } public void onPrimaryNodeChange(org.apache.nifi.'annotation'.notification.PrimaryNodeState) { java.lang.Object[] v, v; org.apache.nifi.processors.standard.HandleHttpRequest v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.nifi.logging.ComponentLog v, v; java.lang.Exception v; org.apache.nifi.'annotation'.notification.PrimaryNodeState v, v; boolean v, v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v := @parameter: org.apache.nifi.'annotation'.notification.PrimaryNodeState; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = ; v = virtualinvoke v.(v); if v == 0 goto label; v = virtualinvoke v.(); v = newarray (java.lang.Object)[1]; v[0] = v; interfaceinvoke v.("Server Shutdown Started: Primary Node State Changed [{}]", v); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Server Shutdown Failed: Primary Node State Changed [{}]", v); label: return; catch java.lang.Exception from label to label with label; } public void onTrigger(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession) throws org.apache.nifi.processor.exception.ProcessException { org.apache.nifi.components.PropertyDescriptor v, v; java.lang.Thread v; java.util.concurrent.BlockingQueue v; java.lang.Exception v, v, v, v, v, v; org.apache.nifi.processor.DataUnit v, v; java.lang.Throwable v, v, v, v; java.lang.Object[] v, v, v, v; java.lang.Double v, v; long v, v; java.util.ArrayList v; javax.servlet.http.HttpServletRequest v; java.lang.String v, v, v, v; java.io.IOException v, v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.processors.standard.HandleHttpRequest v; org.apache.nifi.components.PropertyValue v, v; boolean v, v, v, v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v, v, v, v; java.util.Collection v; java.util.UUID v, v; javax.servlet.MultipartConfigElement v; java.util.List v; java.util.Optional v, v, v; javax.servlet.ServletInputStream v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.nifi.logging.ComponentLog v, v, v, v, v; org.apache.nifi.processor.exception.ProcessException v; int v, v, v; java.io.OutputStream v, v; java.util.Iterator v, v, v, v; org.apache.nifi.processor.ProcessContext v; java.util.concurrent.TimeUnit v; java.lang.InterruptedException v; java.lang.Object v, v, v, v, v, v; java.io.InputStream v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; label: v = v.; v = virtualinvoke v.(); if v != 0 goto label; virtualinvoke v.(v); label: goto label; label: v := @caughtexception; interfaceinvoke v.(); label: virtualinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); interfaceinvoke v.("Server Shutdown Failed after Initialization Failed", v); label: v = new org.apache.nifi.processor.exception.ProcessException; specialinvoke v.(java.lang.String,java.lang.Throwable)>("Failed to initialize the server", v); throw v; label: v = v.; v = ; v = interfaceinvoke v.(2L, v); label: goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(); return; label: if v != null goto label; return; label: v = staticinvoke (); v = virtualinvoke v.(); v = interfaceinvoke v.(); v = staticinvoke (v, "multipart/form-data"); if v == 0 goto label; v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = ; v = interfaceinvoke v.(v); v = ; v = interfaceinvoke v.(v); v = virtualinvoke v.(); v = staticinvoke ("java.io.tmpdir"); v = new javax.servlet.MultipartConfigElement; specialinvoke v.(java.lang.String,long,long,int)>(v, v, v, v); interfaceinvoke v.("org.eclipse.jetty.multipartConfig", v); v = null; label: v = new java.util.ArrayList; v = interfaceinvoke v.(); specialinvoke v.(java.util.Collection)>(v); v = staticinvoke (v); v = interfaceinvoke v.(); v = staticinvoke (); v = virtualinvoke v.(); v = 0; label: if v >= v goto label; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(v); label: v = interfaceinvoke v.(); staticinvoke (v, v); label: if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); virtualinvoke v.(v, v, v, v); label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Couldn\'t delete underlying storage for {}", v); goto label; label: return; label: v = specialinvoke v.(v, v, v, v, v); v = specialinvoke v.(v, v, v, v, v); if v != 0 goto label; v = specialinvoke v.(v, v, v, v); if v == 0 goto label; label: specialinvoke v.(v, v, v, v); v = v + 1; goto label; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Couldn\'t delete underlying storage for {}", v); goto label; label: v := @caughtexception; v = staticinvoke (); virtualinvoke v.(v, v, v, v); label: if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Couldn\'t delete underlying storage for {}", v); goto label; label: v := @caughtexception; if v == null goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); label: interfaceinvoke v.(); label: goto label; label: v := @caughtexception; v = virtualinvoke v.(); v = newarray (java.lang.Object)[2]; v[0] = v; v[1] = v; interfaceinvoke v.("Couldn\'t delete underlying storage for {}", v); goto label; label: throw v; label: v = interfaceinvoke v.(); label: v = interfaceinvoke v.(v); label: v = interfaceinvoke v.(); staticinvoke (v, v); label: if v == null goto label; virtualinvoke v.(); goto label; label: v := @caughtexception; throw v; label: v := @caughtexception; v = staticinvoke (v); virtualinvoke v.(v, v, v, v); return; label: v = staticinvoke (); v = virtualinvoke v.(); v = specialinvoke v.(v, v, v, v, v); v = specialinvoke v.(v, v, v, v); if v == 0 goto label; specialinvoke v.(v, v, v, v); label: return; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.InterruptedException from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Exception from label to label with label; catch java.io.IOException from label to label with label; catch javax.servlet.ServletException from label to label with label; catch java.lang.IllegalStateException from label to label with label; catch java.io.IOException from label to label with label; catch javax.servlet.ServletException from label to label with label; catch java.lang.IllegalStateException from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; catch java.lang.Exception from label to label with label; catch java.lang.Throwable from label to label with label; catch java.io.IOException from label to label with label; } private org.apache.nifi.flowfile.FlowFile savePartAttributes(org.apache.nifi.processor.ProcessSession, javax.servlet.http.Part, org.apache.nifi.flowfile.FlowFile, int, int) { org.apache.nifi.processors.standard.HandleHttpRequest v; java.util.HashMap v; long v; java.lang.Integer v, v; java.lang.Long v; int v, v, v; java.lang.String v, v, v, v, v; boolean v; java.util.Iterator v; org.apache.nifi.flowfile.FlowFile v, v; java.util.Collection v; org.apache.nifi.processor.ProcessSession v; javax.servlet.http.Part v; java.lang.Object v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: javax.servlet.http.Part; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: int; v := @parameter: int; v = new java.util.HashMap; specialinvoke v.()>(); v = interfaceinvoke v.(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); v = dynamicinvoke "makeConcatWithConstants" (v) ("http.headers.multipart.\u0001"); specialinvoke v.(v, v, v); goto label; label: v = interfaceinvoke v.(); v = staticinvoke (v); specialinvoke v.(v, "http.multipart.size", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.multipart.content.type", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.multipart.name", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.multipart.filename", v); v = v + 1; v = staticinvoke (v); specialinvoke v.(v, "http.multipart.fragments.sequence.number", v); v = staticinvoke (v); specialinvoke v.(v, "http.multipart.fragments.total.number", v); v = interfaceinvoke v.(v, v); return v; } private org.apache.nifi.flowfile.FlowFile saveRequestAttributes(org.apache.nifi.processor.ProcessContext, org.apache.nifi.processor.ProcessSession, javax.servlet.http.HttpServletRequest, org.apache.nifi.flowfile.FlowFile, java.lang.String) { java.util.Enumeration v, v; java.lang.Integer v; org.apache.nifi.components.PropertyDescriptor v; java.util.Map v; javax.servlet.http.Cookie[] v; javax.servlet.http.HttpServletRequest v; java.lang.StringBuffer v; java.lang.String 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, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.nifi.processor.ProcessSession v; org.apache.nifi.processors.standard.HandleHttpRequest v; org.apache.nifi.components.PropertyValue v; java.util.Locale v; org.apache.nifi.processors.standard.http.CertificateAttributesProvider v; boolean v, v, v, v, v; org.apache.nifi.flowfile.FlowFile v, v; java.security.Principal v; java.util.regex.Pattern v; java.io.UnsupportedEncodingException v; java.lang.String[] v; java.util.HashMap v; java.util.concurrent.atomic.AtomicReference v; org.apache.nifi.processor.exception.ProcessException v; int v, v, v, v, v, v, v, v, v, v, v; javax.servlet.http.Cookie v; org.apache.nifi.processor.ProcessContext v; javax.servlet.DispatcherType v; java.lang.Object v, v, v; v := @this: org.apache.nifi.processors.standard.HandleHttpRequest; v := @parameter: org.apache.nifi.processor.ProcessContext; v := @parameter: org.apache.nifi.processor.ProcessSession; v := @parameter: javax.servlet.http.HttpServletRequest; v := @parameter: org.apache.nifi.flowfile.FlowFile; v := @parameter: java.lang.String; v = interfaceinvoke v.(); if v != null goto label; v = ; v = interfaceinvoke v.(v); v = interfaceinvoke v.(); goto label; label: v = interfaceinvoke v.(); label: v = v; v = new java.util.HashMap; specialinvoke v.()>(); label: specialinvoke v.(v, "http.context.identifier", v); v = interfaceinvoke v.(); specialinvoke v.(v, "mime.type", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.servlet.path", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.context.path", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.method", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.local.addr", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.local.name", v); v = interfaceinvoke v.(); if v == null goto label; v = staticinvoke (v, v); specialinvoke v.(v, "http.query.string", v); label: v = interfaceinvoke v.(); specialinvoke v.(v, "http.remote.host", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.remote.addr", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.remote.user", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.protocol", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.request.uri", v); v = interfaceinvoke v.(); v = virtualinvoke v.(); specialinvoke v.(v, "http.request.url", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.auth.type", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.requested.session.id", v); v = interfaceinvoke v.(); if v == null goto label; v = virtualinvoke v.(); specialinvoke v.(v, "http.dispatcher.type", v); label: v = interfaceinvoke v.(); specialinvoke v.(v, "http.character.encoding", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.locale", v); v = interfaceinvoke v.(); specialinvoke v.(v, "http.server.name", v); v = interfaceinvoke v.(); v = staticinvoke (v); specialinvoke v.(v, "http.server.port", v); v = v.; v = virtualinvoke v.(); if v == null goto label; v = interfaceinvoke v.(); if v != 0 goto label; v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.(); v = interfaceinvoke v.(v); if v == 0 goto label; v = dynamicinvoke "makeConcatWithConstants" (v) ("http.param.\u0001"); v = interfaceinvoke v.(v); interfaceinvoke v.(v, v); goto label; label: v = interfaceinvoke v.(); if v == null goto label; v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v) ("http.cookie.\u."); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001value"); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001domain"); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001path"); v = virtualinvoke v.(); interfaceinvoke v.(v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001max.age"); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001version"); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("\u0001secure"); v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.(v, v); v = v + 1; goto label; label: if v == null goto label; v = ; v = virtualinvoke v.(v); v = lengthof v; v = 0; label: if v >= v goto label; v = v[v]; v = virtualinvoke v.("="); if v >= 0 goto label; v = staticinvoke (v, v); v = dynamicinvoke "makeConcatWithConstants" (v) ("http.query.param.\u0001"); interfaceinvoke v.(v, ""); goto label; label: v = virtualinvoke v.(0, v); v = virtualinvoke v.