public class org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask extends java.lang.Object
{
private final org.slf4j.Logger logger;
private final org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration;
public void <init>(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)
{
org.slf4j.Logger v;
java.lang.Class v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask v;
v := @this: org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask;
v := @parameter: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration;
specialinvoke v.<java.lang.Object: void <init>()>();
v = virtualinvoke v.<java.lang.Object: java.lang.Class getClass()>();
v = staticinvoke <org.slf4j.LoggerFactory: org.slf4j.Logger getLogger(java.lang.Class)>(v);
v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.slf4j.Logger logger> = v;
v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration> = v;
return;
}
public void run()
{
org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask v;
v := @this: org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask;
specialinvoke v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: void initialScan()>();
return;
}
private void initialScan()
{
java.lang.Throwable v;
org.apache.sling.api.resource.ResourceResolver v;
org.slf4j.Logger v, v;
java.util.Iterator v;
org.apache.sling.api.resource.Resource v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v;
java.lang.Object v;
java.lang.String v, v;
org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask v;
boolean v;
v := @this: org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask;
v = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String)>("Scanning repository for unfinished jobs...");
v = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: org.apache.sling.api.resource.ResourceResolver createResourceResolver()>();
if v != null goto label;
return;
label:
v = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.config.JobManagerConfiguration: java.lang.String getLocalJobsPath()>();
v = interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: org.apache.sling.api.resource.Resource getResource(java.lang.String)>(v);
if v == null goto label;
v = interfaceinvoke v.<org.apache.sling.api.resource.Resource: java.util.Iterator listChildren()>();
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 = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.apache.sling.api.resource.Resource: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Found topic {}", v);
specialinvoke v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: void initTopic(org.apache.sling.api.resource.Resource)>(v);
goto label;
label:
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
goto label;
label:
v := @caughtexception;
interfaceinvoke v.<org.apache.sling.api.resource.ResourceResolver: void close()>();
throw v;
label:
return;
catch java.lang.Throwable from label to label with label;
}
private void initTopic(org.apache.sling.api.resource.Resource)
{
org.slf4j.Logger v, v, v;
org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask$1 v;
org.apache.sling.api.resource.Resource v;
java.lang.String v, v;
org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask v;
v := @this: org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask;
v := @parameter: org.apache.sling.api.resource.Resource;
v = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.apache.sling.api.resource.Resource: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Initializing topic {}...", v);
v = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.slf4j.Logger logger>;
v = new org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask$1;
specialinvoke v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask$1: void <init>(org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask,org.apache.sling.api.resource.Resource)>(v, v);
staticinvoke <org.apache.sling.event.impl.jobs.JobTopicTraverser: void traverse(org.slf4j.Logger,org.apache.sling.api.resource.Resource,org.apache.sling.event.impl.jobs.JobTopicTraverser$JobCallback)>(v, v, v);
v = v.<org.apache.sling.event.impl.jobs.tasks.FindUnfinishedJobsTask: org.slf4j.Logger logger>;
v = interfaceinvoke v.<org.apache.sling.api.resource.Resource: java.lang.String getName()>();
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Topic {} initialized", v);
return;
}
}