class org.apache.sling.event.impl.jobs.queues.QueueJobCache$1 extends java.lang.Object implements org.apache.sling.event.impl.jobs.JobTopicTraverser$JobCallback
{
final java.util.List val$list;
final org.apache.sling.event.impl.jobs.stats.StatisticsManager val$statisticsManager;
final java.lang.String val$queueName;
final java.lang.String val$topic;
final java.util.concurrent.atomic.AtomicBoolean val$scanTopic;
final java.util.concurrent.atomic.AtomicBoolean val$haltTopic;
final org.apache.sling.event.impl.jobs.queues.QueueJobCache this$0;
void <init>(org.apache.sling.event.impl.jobs.queues.QueueJobCache, java.util.List, org.apache.sling.event.impl.jobs.stats.StatisticsManager, java.lang.String, java.lang.String, java.util.concurrent.atomic.AtomicBoolean, java.util.concurrent.atomic.AtomicBoolean)
{
java.util.concurrent.atomic.AtomicBoolean v, v;
java.util.List v;
org.apache.sling.event.impl.jobs.queues.QueueJobCache$1 v;
org.apache.sling.event.impl.jobs.stats.StatisticsManager v;
org.apache.sling.event.impl.jobs.queues.QueueJobCache v;
java.lang.String v, v;
v := @this: org.apache.sling.event.impl.jobs.queues.QueueJobCache$1;
v := @parameter: org.apache.sling.event.impl.jobs.queues.QueueJobCache;
v := @parameter: java.util.List;
v := @parameter: org.apache.sling.event.impl.jobs.stats.StatisticsManager;
v := @parameter: java.lang.String;
v := @parameter: java.lang.String;
v := @parameter: java.util.concurrent.atomic.AtomicBoolean;
v := @parameter: java.util.concurrent.atomic.AtomicBoolean;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.queues.QueueJobCache this$0> = v;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.List val$list> = v;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.stats.StatisticsManager val$statisticsManager> = v;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.lang.String val$queueName> = v;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.lang.String val$topic> = v;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.concurrent.atomic.AtomicBoolean val$scanTopic> = v;
v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.concurrent.atomic.AtomicBoolean val$haltTopic> = v;
specialinvoke v.<java.lang.Object: void <init>()>();
return;
}
public boolean handle(org.apache.sling.event.impl.jobs.JobImpl)
{
org.apache.sling.event.impl.jobs.queues.QueueJobCache$1 v;
int[] v;
org.apache.sling.event.impl.jobs.queues.QueueJobCache v, v, v, v;
boolean v, v;
java.util.List v, v, v;
org.apache.sling.event.impl.jobs.stats.StatisticsManager v;
java.util.concurrent.atomic.AtomicBoolean v, v, v, v;
java.util.Calendar v, v;
int v, v, v, v;
java.lang.String v, v;
org.slf4j.Logger v, v, v;
org.apache.sling.event.jobs.Job$JobState v;
org.apache.sling.event.impl.jobs.JobHandler v;
org.apache.sling.event.impl.jobs.JobImpl$ReadErrorType v;
org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v;
org.apache.sling.event.impl.jobs.JobImpl v;
v := @this: org.apache.sling.event.impl.jobs.queues.QueueJobCache$1;
v := @parameter: org.apache.sling.event.impl.jobs.JobImpl;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.util.Calendar getProcessingStarted()>();
if v != null goto label;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: boolean hasReadErrors()>();
if v != 0 goto label;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.List val$list>;
interfaceinvoke v.<java.util.List: boolean add(java.lang.Object)>(v);
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.stats.StatisticsManager val$statisticsManager>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.lang.String val$queueName>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.lang.String val$topic>;
virtualinvoke v.<org.apache.sling.event.impl.jobs.stats.StatisticsManager: void jobQueued(java.lang.String,java.lang.String)>(v, v);
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.List val$list>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v != 10 goto label;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.concurrent.atomic.AtomicBoolean val$scanTopic>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
goto label;
label:
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: java.util.Calendar getProcessingStarted()>();
if v == null goto label;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.queues.QueueJobCache this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Ignoring job {} - processing already started.", v);
goto label;
label:
v = <org.apache.sling.event.impl.jobs.queues.QueueJobCache$2: int[] $SwitchMap$org$apache$sling$event$impl$jobs$JobImpl$ReadErrorType>;
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl: org.apache.sling.event.impl.jobs.JobImpl$ReadErrorType getReadErrorType()>();
v = virtualinvoke v.<org.apache.sling.event.impl.jobs.JobImpl$ReadErrorType: int ordinal()>();
v = v[v];
lookupswitch(v)
{
case 1: goto label;
case 2: goto label;
default: goto label;
};
label:
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.concurrent.atomic.AtomicBoolean val$haltTopic>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.concurrent.atomic.AtomicBoolean val$scanTopic>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.queues.QueueJobCache this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Failing job {} due to unrecoverable read errors.", v);
v = new org.apache.sling.event.impl.jobs.JobHandler;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.queues.QueueJobCache this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache: org.apache.sling.event.impl.jobs.config.JobManagerConfiguration configuration>;
specialinvoke v.<org.apache.sling.event.impl.jobs.JobHandler: void <init>(org.apache.sling.event.impl.jobs.JobImpl,org.apache.sling.event.jobs.consumer.JobExecutor,org.apache.sling.event.impl.jobs.config.JobManagerConfiguration)>(v, null, v);
v = <org.apache.sling.event.jobs.Job$JobState: org.apache.sling.event.jobs.Job$JobState ERROR>;
virtualinvoke v.<org.apache.sling.event.impl.jobs.JobHandler: void finished(org.apache.sling.event.jobs.Job$JobState,boolean,java.lang.Long)>(v, 1, null);
goto label;
label:
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.concurrent.atomic.AtomicBoolean val$scanTopic>;
virtualinvoke v.<java.util.concurrent.atomic.AtomicBoolean: void set(boolean)>(1);
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: org.apache.sling.event.impl.jobs.queues.QueueJobCache this$0>;
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache: org.slf4j.Logger logger>;
interfaceinvoke v.<org.slf4j.Logger: void debug(java.lang.String,java.lang.Object)>("Ignoring job {} due to recoverable read errors.", v);
label:
v = v.<org.apache.sling.event.impl.jobs.queues.QueueJobCache$1: java.util.List val$list>;
v = interfaceinvoke v.<java.util.List: int size()>();
if v >= 10 goto label;
v = 1;
goto label;
label:
v = 0;
label:
return v;
}
}