public class org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet extends javax.servlet.http.HttpServlet
{
public static final java.lang.String DEFAULT_FOUND_SUBJECT;
private static final long serialVersionUID;
private org.apache.nifi.processor.Processor processor;
private java.util.regex.Pattern authorizedPattern;
private org.apache.nifi.logging.ComponentLog logger;
private java.util.concurrent.ConcurrentMap flowFileMap;
private int port;
public void <init>()
{
org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet v;
v := @this: org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet;
specialinvoke v.<javax.servlet.http.HttpServlet: void <init>()>();
return;
}
public void init(javax.servlet.ServletConfig) throws javax.servlet.ServletException
{
javax.servlet.ServletConfig v;
org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet v;
int v;
java.lang.Object v, v, v, v, v;
javax.servlet.ServletContext v;
v := @this: org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet;
v := @parameter: javax.servlet.ServletConfig;
v = interfaceinvoke v.<javax.servlet.ServletConfig: javax.servlet.ServletContext getServletContext()>();
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("processor");
v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.processor.Processor processor> = v;
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("logger");
v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger> = v;
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("authorityPattern");
v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: java.util.regex.Pattern authorizedPattern> = v;
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("flowFileMap");
v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: java.util.concurrent.ConcurrentMap flowFileMap> = v;
v = interfaceinvoke v.<javax.servlet.ServletContext: java.lang.Object getAttribute(java.lang.String)>("port");
v = virtualinvoke v.<java.lang.Integer: int intValue()>();
v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: int port> = v;
return;
}
protected void doDelete(javax.servlet.http.HttpServletRequest, javax.servlet.http.HttpServletResponse) throws javax.servlet.ServletException, java.io.IOException
{
java.lang.Integer v, v, v;
java.util.regex.Matcher v;
byte v;
java.lang.Long v, v;
java.util.Set v;
java.lang.Throwable v;
java.lang.Object[] v, v;
long v, v, v, v, v;
javax.servlet.http.HttpServletRequest v;
org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet v;
org.apache.nifi.processor.Relationship v;
java.lang.String v, v, v, v, v, v, v, v, v, v, v;
org.apache.nifi.processor.ProcessSession v, v;
java.security.cert.X509Certificate v;
java.lang.Runnable v;
boolean v, v, v;
org.apache.nifi.processor.Processor v;
java.security.Principal v;
java.util.regex.Pattern v;
org.apache.nifi.logging.ComponentLog v, v, v, v, v, v;
java.util.concurrent.ConcurrentMap v;
int v, v, v, v, v, v, v, v, v, v, v;
double v, v;
java.util.Iterator v;
javax.servlet.http.HttpServletResponse v;
java.lang.Object v, v, v;
v := @this: org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet;
v := @parameter: javax.servlet.http.HttpServletRequest;
v := @parameter: javax.servlet.http.HttpServletResponse;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getLocalPort()>();
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: int port>;
if v == v goto label;
specialinvoke v.<javax.servlet.http.HttpServlet: void doDelete(javax.servlet.http.HttpServletRequest,javax.servlet.http.HttpServletResponse)>(v, v);
return;
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.Object getAttribute(java.lang.String)>("javax.servlet.request.X509Certificate");
v = "none";
if v == null goto label;
v = lengthof v;
if v <= 0 goto label;
v = lengthof v;
if 0 >= v goto label;
v = v[0];
v = virtualinvoke v.<java.security.cert.X509Certificate: java.security.Principal getSubjectDN()>();
v = interfaceinvoke v.<java.security.Principal: java.lang.String getName()>();
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: java.util.regex.Pattern authorizedPattern>;
v = virtualinvoke v.<java.util.regex.Pattern: java.util.regex.Matcher matcher(java.lang.CharSequence)>(v);
v = virtualinvoke v.<java.util.regex.Matcher: boolean matches()>();
if v != 0 goto label;
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger>;
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.processor.Processor processor>;
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (org.apache.nifi.processor.Processor,java.lang.String)>(v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("\u rejecting transfer attempt from \u because the DN is not authorized");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
interfaceinvoke v.<javax.servlet.http.HttpServletResponse: void sendError(int,java.lang.String)>(403, "not allowed based on dn");
return;
label:
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRequestURI()>();
v = virtualinvoke v.<java.lang.String: int lastIndexOf(java.lang.String)>("/");
v = virtualinvoke v.<java.lang.String: int indexOf(java.lang.String)>("?");
if v >= 0 goto label;
v = virtualinvoke v.<java.lang.String: int length()>();
label:
v = v + 1;
v = virtualinvoke v.<java.lang.String: java.lang.String substring(int,int)>(v, v);
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: java.util.concurrent.ConcurrentMap flowFileMap>;
v = interfaceinvoke v.<java.util.concurrent.ConcurrentMap: java.lang.Object remove(java.lang.Object)>(v);
if v != null goto label;
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger>;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRemoteHost()>();
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getRemotePort()>();
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String,java.lang.String,int,java.lang.String)>(v, v, v, v) <java.lang.invoke.StringConcatFactory: java.lang.invoke.CallSite makeConcatWithConstants(java.lang.invoke.MethodHandles$Lookup,java.lang.String,java.lang.invoke.MethodType,java.lang.String,java.lang.Object[])>("received DELETE for HOLD with ID \u from Remote Host: [\u] Port [\u] SubjectDN [\u], but no HOLD exists with that ID; sending response with Status Code 404");
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void warn(java.lang.String)>(v);
interfaceinvoke v.<javax.servlet.http.HttpServletResponse: void sendError(int)>(404);
return;
label:
v = virtualinvoke v.<org.apache.nifi.processors.standard.ListenHTTP$FlowFileEntryTimeWrapper: java.util.Set getFlowFiles()>();
v = staticinvoke <java.lang.System: long currentTimeMillis()>();
v = virtualinvoke v.<org.apache.nifi.processors.standard.ListenHTTP$FlowFileEntryTimeWrapper: long getEntryTime()>();
v = v - v;
v = 0L;
v = interfaceinvoke v.<java.util.Set: java.util.Iterator iterator()>();
label:
v = interfaceinvoke v.<java.util.Iterator: boolean hasNext()>();
if v == 0 goto label;
v = interfaceinvoke v.<java.util.Iterator: java.lang.Object next()>();
v = interfaceinvoke v.<org.apache.nifi.flowfile.FlowFile: long getSize()>();
v = v + v;
goto label;
label:
v = v / 1000.0;
v = v cmpg 0.0;
if v > 0 goto label;
v = 1.0E-8;
label:
v = v / v;
v = staticinvoke <org.apache.nifi.util.FormatUtils: java.lang.String formatDataSize(double)>(v);
v = dynamicinvoke "makeConcatWithConstants" <java.lang.String (java.lang.String)>(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[])>("\u0001/sec");
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[8];
v = interfaceinvoke v.<java.util.Set: int size()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[0] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[1] = v;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRemoteHost()>();
v[2] = v;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getRemotePort()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[3] = v;
v[4] = v;
v = staticinvoke <java.lang.Long: java.lang.Long valueOf(long)>(v);
v[5] = v;
v[6] = v;
v[7] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void info(java.lang.String,java.lang.Object[])>("received {} files/{} bytes from Remote Host: [{}] Port [{}] SubjectDN [{}] in {} milliseconds at a rate of {}; transferring to \'success\': {}", v);
v = virtualinvoke v.<org.apache.nifi.processors.standard.ListenHTTP$FlowFileEntryTimeWrapper: org.apache.nifi.processor.ProcessSession getSession()>();
v = <org.apache.nifi.processors.standard.ListenHTTP: org.apache.nifi.processor.Relationship RELATIONSHIP_SUCCESS>;
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void transfer(java.util.Collection,org.apache.nifi.processor.Relationship)>(v, v);
v = staticinvoke <org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet$lambda_doDelete_0__317: java.lang.Runnable bootstrap$(org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet,javax.servlet.http.HttpServletResponse,java.lang.String,javax.servlet.http.HttpServletRequest,java.lang.String)>(v, v, v, v, v);
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void commitAsync(java.lang.Runnable)>(v);
label:
goto label;
label:
v := @caughtexception;
v = virtualinvoke v.<org.apache.nifi.processors.standard.ListenHTTP$FlowFileEntryTimeWrapper: org.apache.nifi.processor.ProcessSession getSession()>();
interfaceinvoke v.<org.apache.nifi.processor.ProcessSession: void rollback()>();
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger>;
v = newarray (java.lang.Object)[5];
v[0] = v;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: java.lang.String getRemoteHost()>();
v[1] = v;
v = interfaceinvoke v.<javax.servlet.http.HttpServletRequest: int getRemotePort()>();
v = staticinvoke <java.lang.Integer: java.lang.Integer valueOf(int)>(v);
v[2] = v;
v[3] = v;
v = virtualinvoke v.<java.lang.Throwable: java.lang.String toString()>();
v[4] = v;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Object[])>("Received DELETE for HOLD with ID {} from Remote Host: [{}] Port [{}] SubjectDN [{}], but failed to process the request due to {}", v);
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger>;
v = interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: boolean isDebugEnabled()>();
if v == 0 goto label;
v = v.<org.apache.nifi.processors.standard.servlets.ContentAcknowledgmentServlet: org.apache.nifi.logging.ComponentLog logger>;
interfaceinvoke v.<org.apache.nifi.logging.ComponentLog: void error(java.lang.String,java.lang.Throwable)>("", v);
label:
interfaceinvoke v.<javax.servlet.http.HttpServletResponse: void sendError(int)>(404);
label:
return;
catch java.lang.Throwable from label to label with label;
}
}