public class org.apache.sling.event.impl.jobs.queues.JobQueueImpl extends java.lang.Object implements org.apache.sling.event.jobs.Queue { private static final long MAX_SUSPEND_TIME; private final org.slf4j.Logger logger; private final org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration configuration; private volatile java.lang.String queueName; private volatile boolean running; private final java.util.concurrent.atomic.AtomicLong suspendedSince; private final org.apache.sling.event.impl.jobs.queues.QueueServices services; private final java.util.Map processingJobsLists; private final org.apache.sling.commons.threads.ThreadPool threadPool; private final java.util.concurrent.atomic.AtomicInteger asyncCounter; private final java.util.concurrent.atomic.AtomicBoolean isOutdated; private final java.util.concurrent.atomic.AtomicBoolean closeMarker; private final java.util.concurrent.atomic.AtomicBoolean doFullCacheSearch; private final java.util.concurrent.atomic.AtomicInteger waitCounter; private final org.apache.sling.event.impl.jobs.queues.QueueJobCache cache; private final java.util.concurrent.Semaphore available; private final java.util.concurrent.atomic.AtomicBoolean startJobsGuard; private final java.util.concurrent.locks.ReentrantReadWriteLock lock; private volatile long isSleepingUntil; public static org.apache.sling.event.impl.jobs.queues.JobQueueImpl createQueue(java.lang.String, org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration, org.apache.sling.event.impl.jobs.queues.QueueServices, java.util.Set, java.util.Set) { org.apache.sling.event.impl.jobs.queues.QueueJobCache v; java.lang.String v, v, v, v; boolean v, v, v, v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v; org.slf4j.Logger v; java.util.Iterator v; org.apache.sling.event.jobs.QueueConfiguration$Type v; java.util.Set v, v, v, v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v; org.apache.sling.event.impl.jobs.stats.StatisticsManager v; java.lang.Class v; java.lang.Object v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v; v := @parameter: java.lang.String; v := @parameter: org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration; v := @parameter: org.apache.sling.event.impl.jobs.queues.QueueServices; v := @parameter: java.util.Set; v := @parameter: java.util.Set; v = new org.apache.sling.event.impl.jobs.queues.QueueJobCache; v = v.; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.sling.event.impl.jobs.config.JobManagerConfiguration,java.lang.String,org.apache.sling.event.impl.jobs.stats.StatisticsManager,org.apache.sling.event.jobs.QueueConfiguration$Type,java.util.Set)>(v, v, v, v, v); v = virtualinvoke v.(); v = interfaceinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); 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 = class "Lorg/apache/sling/event/impl/jobs/queues/JobQueueImpl;"; v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.\u0001"); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v) ("createQueue : topic halted due to ClassNotFoundExceptions : \u0001"); interfaceinvoke v.(v); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; return null; label: v = new org.apache.sling.event.impl.jobs.queues.JobQueueImpl; specialinvoke v.(java.lang.String,org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration,org.apache.sling.event.impl.jobs.queues.QueueServices,org.apache.sling.event.impl.jobs.queues.QueueJobCache)>(v, v, v, v); return v; } private void (java.lang.String, org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration, org.apache.sling.event.impl.jobs.queues.QueueServices, org.apache.sling.event.impl.jobs.queues.QueueJobCache) { java.util.concurrent.atomic.AtomicBoolean v, v, v, v; java.util.HashMap v; java.util.concurrent.locks.ReentrantReadWriteLock v; java.util.concurrent.atomic.AtomicInteger v, v; org.apache.sling.event.impl.jobs.queues.QueueJobCache v; int v, v, v; org.apache.sling.commons.threads.ThreadPool v; org.apache.sling.event.impl.EventingThreadPool v; java.lang.String v, v, v, v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v, v; org.slf4j.Logger v, v, v; org.apache.sling.commons.threads.ThreadPoolManager v; java.util.concurrent.Semaphore v; java.util.concurrent.atomic.AtomicLong v; java.lang.Class v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v := @parameter: java.lang.String; v := @parameter: org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration; v := @parameter: org.apache.sling.event.impl.jobs.queues.QueueServices; v := @parameter: org.apache.sling.event.impl.jobs.queues.QueueJobCache; specialinvoke v.()>(); v = new java.util.concurrent.atomic.AtomicLong; specialinvoke v.(long)>(-1L); v. = v; v = new java.util.HashMap; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v. = 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.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.atomic.AtomicInteger; specialinvoke v.()>(); v. = v; v = new java.util.concurrent.atomic.AtomicBoolean; specialinvoke v.(boolean)>(0); v. = v; v = new java.util.concurrent.locks.ReentrantReadWriteLock; specialinvoke v.()>(); v. = v; v. = -1L; v = virtualinvoke v.(); if v <= 0 goto label; v = new org.apache.sling.event.impl.EventingThreadPool; v = v.; v = virtualinvoke v.(); specialinvoke v.(org.apache.sling.commons.threads.ThreadPoolManager,int)>(v, v); v. = v; goto label; label: v = v.; v. = v; label: v. = v; v. = v; v. = v; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u.\u0001"); v = staticinvoke (v); v. = v; v. = 1; v. = v; v = new java.util.concurrent.Semaphore; v = virtualinvoke v.(); specialinvoke v.(int,boolean)>(v, 1); v. = v; v = v.; v = v.; interfaceinvoke v.("Starting job queue {}", v); v = v.; v = v.; interfaceinvoke v.("Configuration for job queue={}", v); return; } public org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration getConfiguration() { org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; return v; } public java.lang.String getName() { java.lang.String v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; return v; } public org.apache.sling.event.jobs.Statistics getStatistics() { org.apache.sling.event.jobs.Statistics v; org.apache.sling.event.impl.jobs.stats.StatisticsManager v; java.lang.String v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = v.; v = v.; v = virtualinvoke v.(v); return v; } public void startJobs() { java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v; org.apache.sling.event.impl.jobs.queues.QueueJobCache v; boolean v, v, v, v, v, v, v; org.apache.sling.event.impl.jobs.stats.StatisticsManager v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v, v; java.lang.Throwable v; java.util.concurrent.atomic.AtomicBoolean v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; org.apache.sling.event.impl.jobs.JobConsumerManager v; org.apache.sling.commons.threads.ThreadPool v; java.util.concurrent.Semaphore v, v, v; org.apache.sling.event.impl.jobs.JobHandler v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl$1 v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; label: v = v.; if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; v = 0; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = v.; v = v.; v = v.; v = v.; v = v.; v = v.; v = virtualinvoke v.(0); v = virtualinvoke v.(v, v, v, v); if v == null goto label; v = 1; v = v.; v = new org.apache.sling.event.impl.jobs.queues.JobQueueImpl$1; specialinvoke v.(org.apache.sling.event.impl.jobs.queues.JobQueueImpl,org.apache.sling.event.impl.jobs.JobHandler)>(v, v); interfaceinvoke v.(v); goto label; label: v = v.; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; if v != 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: v = v.; virtualinvoke v.(0); label: return; catch java.lang.Throwable from label to label with label; } private void startJob(org.apache.sling.event.impl.jobs.JobHandler) { org.apache.sling.event.jobs.consumer.JobExecutionResult v; org.apache.sling.event.jobs.consumer.JobExecutor v, v; java.lang.Long v, v, v, v, v, v, v; java.util.Map v, v; java.lang.Exception v; org.apache.sling.event.impl.jobs.stats.StatisticsManager v; java.lang.Throwable v, v, v, v, v; long v, v, v, v, v, v; org.apache.sling.event.impl.jobs.JobConsumerManager v; java.lang.String v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobExecutionContextImpl v; org.apache.sling.event.impl.jobs.JobHandler v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2 v; org.apache.sling.event.impl.jobs.JobImpl v; java.util.concurrent.atomic.AtomicInteger v; boolean v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v, v, v, v; org.osgi.service.event.EventAdmin v; java.util.concurrent.atomic.AtomicBoolean v; org.apache.sling.event.impl.jobs.queues.JobExecutionResultImpl v; org.slf4j.Logger v, v, v; java.util.concurrent.Semaphore v, v; org.apache.sling.event.jobs.Job$JobState v, v; java.lang.Object v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v := @parameter: org.apache.sling.event.impl.jobs.JobHandler; label: v = v.; virtualinvoke v.(0); label: v = virtualinvoke v.(); v = staticinvoke (); v. = v; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); interfaceinvoke v.("START OK : {}", v); v = virtualinvoke v.("event.job.queued.time", class "Ljava/util/Calendar;"); if v != null goto label; v = staticinvoke (); v = staticinvoke (); v = v - 10000L; virtualinvoke v.(v); label: v = v.; v = virtualinvoke v.(); v = v - v; v = v.; v = v.; v = v.; v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; v = v.; v = staticinvoke (v); staticinvoke (v, "org/apache/sling/event/notification/job/START", v, v); v = v.; entermonitor v; label: v = v.; v = virtualinvoke v.(); interfaceinvoke v.(v, v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = ; v = ; v = new org.apache.sling.event.impl.jobs.queues.JobExecutionContextImpl; v = new org.apache.sling.event.impl.jobs.queues.JobQueueImpl$2; specialinvoke v.(org.apache.sling.event.impl.jobs.queues.JobQueueImpl,org.apache.sling.event.impl.jobs.JobImpl)>(v, v); specialinvoke v.(org.apache.sling.event.impl.jobs.JobHandler,org.apache.sling.event.impl.jobs.queues.JobExecutionContextImpl$ASyncHandler)>(v, v); label: entermonitor v; label: v = virtualinvoke v.(); v = interfaceinvoke v.(v, v); if v != null goto label; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); virtualinvoke v.(v, v, v); v = v.; virtualinvoke v.(); virtualinvoke v.(); goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = ; goto label; label: v = virtualinvoke v.(); if v == 0 goto label; v = virtualinvoke v.(); if v == 0 goto label; v = ; goto label; label: v = ; label: exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(":slingevent:delayOverride", v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.("slingevent:resultMessage", v); label: v = virtualinvoke v.(); specialinvoke v.(v, v, 0); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("Unhandled error occured in job processor \u while processing job \u0001"); interfaceinvoke v.(v, v); v = ; v = ; label: if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(":slingevent:delayOverride", v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.("slingevent:resultMessage", v); label: v = virtualinvoke v.(); specialinvoke v.(v, v, 0); goto label; label: v := @caughtexception; if v == null goto label; v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.(":slingevent:delayOverride", v); label: v = virtualinvoke v.(); if v == null goto label; v = virtualinvoke v.(); virtualinvoke v.("slingevent:resultMessage", v); label: v = virtualinvoke v.(); specialinvoke v.(v, v, 0); label: throw v; label: v := @caughtexception; v = v.; interfaceinvoke v.("Exception during job processing.", v); label: v = v.; virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; virtualinvoke v.(); throw v; label: return; 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.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; } public void outdate() { org.slf4j.Logger v; java.util.concurrent.atomic.AtomicBoolean v; int v; java.lang.String v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; boolean v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = virtualinvoke v.(0, 1); if v == 0 goto label; v = virtualinvoke v.(); v = virtualinvoke v.(); v = dynamicinvoke "makeConcatWithConstants" (v, v) ("\u0001(\u)"); v = v.; v = v.; interfaceinvoke v.("Outdating queue {}, renaming to {}.", v, v); v. = v; label: return; } public boolean tryToClose() { java.lang.Throwable v; java.util.concurrent.atomic.AtomicBoolean v, v; java.util.concurrent.locks.ReentrantReadWriteLock v, v, v, v; java.util.concurrent.locks.ReentrantReadWriteLock$WriteLock v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; boolean v, v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; virtualinvoke v.(); v = v.; v = virtualinvoke v.(); virtualinvoke v.(); label: v = specialinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; virtualinvoke v.(); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); return 1; label: v = v.; virtualinvoke v.(1); label: v = v.; v = virtualinvoke v.(); virtualinvoke v.(); goto label; label: v := @caughtexception; v = v.; v = virtualinvoke v.(); virtualinvoke v.(); throw v; label: return 0; catch java.lang.Throwable from label to label with label; catch java.lang.Throwable from label to label with label; } private boolean canBeClosed() { java.util.concurrent.Semaphore v; java.util.concurrent.atomic.AtomicInteger v, v; int v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; boolean v, v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); if v != 0 goto label; v = v.; v = virtualinvoke v.(); v = v.; v = virtualinvoke v.(); if v != v goto label; v = 1; goto label; label: v = 0; label: return v; } public void close() { java.lang.Throwable v; org.slf4j.Logger v, v; java.util.Map v, v; int v; org.apache.sling.commons.threads.ThreadPool v; java.lang.String v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v. = 0; v = v.; v = v.; interfaceinvoke v.("Shutting down job queue {}", v); virtualinvoke v.(); v = v.; entermonitor v; label: v = v.; interfaceinvoke v.(); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; v = virtualinvoke v.(); if v <= 0 goto label; v = v.; virtualinvoke v.(); label: v = v.; v = v.; interfaceinvoke v.("Stopped job queue {}", v); return; catch java.lang.Throwable from label to label with label; } public void maintain() { org.slf4j.Logger v; java.util.concurrent.atomic.AtomicBoolean v; long v, v, v; java.util.concurrent.atomic.AtomicLong v; byte v, v; java.lang.Long v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = virtualinvoke v.(); v = v cmp -1L; if v == 0 goto label; v = v + 3600000L; v = staticinvoke (); v = v cmp v; if v >= 0 goto label; v = v.; v = staticinvoke (3600000L); interfaceinvoke v.("Waking up suspended queue. It has been suspended for more than {}ms", v); virtualinvoke v.(); label: v = v.; virtualinvoke v.(1); virtualinvoke v.(); return; } public void wakeUpQueue(java.util.Set) { java.util.Set v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueJobCache v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v := @parameter: java.util.Set; v = v.; virtualinvoke v.(v); return; } private void requeue(org.apache.sling.event.impl.jobs.JobHandler) { org.apache.sling.event.impl.jobs.stats.StatisticsManager v; org.apache.sling.event.impl.jobs.queues.QueueJobCache v; org.apache.sling.event.impl.jobs.JobHandler v; java.lang.String v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v := @parameter: org.apache.sling.event.impl.jobs.JobHandler; v = v.; v = v.; v = v.; v = v.; virtualinvoke v.(v, v, v); virtualinvoke v.(); return; } private org.apache.sling.event.impl.jobs.queues.JobQueueImpl$RescheduleInfo handleReschedule(org.apache.sling.event.impl.jobs.JobHandler, org.apache.sling.event.jobs.Job$JobState) { java.lang.Integer v, v, v, v, v; int[] v; boolean v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; java.lang.Object[] v; org.apache.sling.event.impl.jobs.InternalJobState v, v, v, v; long v, v, v; int v, v, v, v, v, v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v, v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl$RescheduleInfo v; org.apache.sling.event.jobs.Job$JobState v, v, v, v; org.apache.sling.event.impl.jobs.JobHandler v; java.lang.Object v, v; org.apache.sling.event.impl.jobs.JobImpl v, v, v, v, v, v, v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v := @parameter: org.apache.sling.event.impl.jobs.JobHandler; v := @parameter: org.apache.sling.event.jobs.Job$JobState; v = new org.apache.sling.event.impl.jobs.queues.JobQueueImpl$RescheduleInfo; specialinvoke v.()>(); v. = v; v = ; v = virtualinvoke v.(); v = v[v]; lookupswitch(v) { case 1: goto label; case 2: goto label; default: goto label; }; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Finished job {}", v); label: v = staticinvoke (); v = v.; v = v - v; v. = v; v = ; v. = v; goto label; label: v = virtualinvoke v.(); v = staticinvoke (0); v = virtualinvoke v.("event.job.retries", v); v = virtualinvoke v.(); v = virtualinvoke v.(); v = staticinvoke (0); v = virtualinvoke v.("event.job.retrycount", v); v = virtualinvoke v.(); v = v + 1; v = (int) -1; if v == v goto label; if v <= v goto label; v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); v = staticinvoke (v); interfaceinvoke v.("Cancelled job {} after {} unsuccessful retries", v, v); label: v = ; v. = v; goto label; label: v. = 1; v = virtualinvoke v.(); virtualinvoke v.(); v = v.; v = newarray (java.lang.Object)[3]; v = virtualinvoke v.(); v = staticinvoke (v); v[0] = v; v = v - v; v = staticinvoke (v); v[1] = v; v = staticinvoke (v); v[2] = v; interfaceinvoke v.("Failed job {}, will retry {} more time(s), retryCount={}", v); v = ; v. = v; goto label; label: v = v.; v = interfaceinvoke v.(); if v == 0 goto label; v = v.; v = virtualinvoke v.(); v = staticinvoke (v); interfaceinvoke v.("Cancelled job {}", v); label: v = ; v. = v; label: v = v.; v = ; if v != v goto label; v = v.; if v != 0 goto label; v = ; v. = v; label: return v; } private boolean finishedJob(java.lang.String, org.apache.sling.event.jobs.Job$JobState, boolean) { java.lang.Long v, v; java.util.Map v, v; boolean v, v, v, v, v, v; org.apache.sling.event.impl.jobs.config.InternalQueueConfiguration v; org.apache.sling.event.impl.jobs.stats.StatisticsManager v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v, v, v; org.osgi.service.event.EventAdmin v; java.lang.Throwable v; org.apache.sling.event.impl.jobs.InternalJobState v, v; long v, v, v; java.lang.String v, v, v, v; org.slf4j.Logger v, v, v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl$RescheduleInfo v; org.apache.sling.event.jobs.Job$JobState v, v, v, v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v; java.lang.Object v; org.apache.sling.event.impl.jobs.JobImpl v, v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v := @parameter: java.lang.String; v := @parameter: org.apache.sling.event.jobs.Job$JobState; v := @parameter: boolean; v = v.; v = v.; v = virtualinvoke v.(); interfaceinvoke v.("FINISHED {} : {}", v, v); v = v.; interfaceinvoke v.("Received finish for job {}, resultState={}", v, v); v = v.; entermonitor v; label: v = v.; v = interfaceinvoke v.(v); exitmonitor v; label: goto label; label: v := @caughtexception; exitmonitor v; throw v; label: v = v.; if v != 0 goto label; v = v.; interfaceinvoke v.("Queue is not running anymore. Discarding finish for {}", v); return 0; label: if v != null goto label; v = v.; interfaceinvoke v.("This job has never been started by this queue: {}", v); return 0; label: v = specialinvoke v.(v, v); v = v.; if v != 0 goto label; v = v.; v = ; if v != v goto label; v = v.; v = virtualinvoke v.(); if v == 0 goto label; label: v = 1; goto label; label: v = 0; label: v = v.; v = v.; v = staticinvoke (v); virtualinvoke v.(v, v, v); goto label; label: specialinvoke v.(v); label: v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = v.; virtualinvoke v.(v, v, v, v); v = v.; v = v.; v = v.; v = virtualinvoke v.(); v = virtualinvoke v.(); v = v.; v = staticinvoke (v); staticinvoke (v, v, v, v); v = v.; return v; catch java.lang.Throwable from label to label with label; } public void resume() { java.util.concurrent.atomic.AtomicLong v; org.slf4j.Logger v; byte v; long v; java.lang.String v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = virtualinvoke v.(-1L); v = v cmp -1L; if v == 0 goto label; v = v.; v = v.; interfaceinvoke v.("Waking up suspended queue {}", v); virtualinvoke v.(); label: return; } public void suspend() { java.util.concurrent.atomic.AtomicLong v; org.slf4j.Logger v; long v; java.lang.String v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; boolean v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = staticinvoke (); v = virtualinvoke v.(-1L, v); if v == 0 goto label; v = v.; v = v.; interfaceinvoke v.("Suspending queue {}", v); label: return; } public boolean isSuspended() { java.util.concurrent.atomic.AtomicLong v; byte v; long v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; boolean v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = virtualinvoke v.(); v = v cmp -1L; if v == 0 goto label; v = 1; goto label; label: v = 0; label: return v; } public synchronized void removeAll() { java.lang.Throwable v, v; org.apache.sling.api.resource.ResourceResolver v; org.apache.sling.event.impl.support.BatchResourceRemover v; org.apache.sling.event.impl.jobs.queues.QueueJobCache v; java.lang.String v, v, v; boolean v, v; org.slf4j.Logger v, v, v; java.util.Iterator v; java.util.Set v; org.apache.sling.api.resource.Resource v, v; org.apache.sling.event.impl.jobs.config.JobManagerConfiguration v, v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl$3 v; java.lang.Object v; org.apache.sling.event.impl.jobs.queues.JobQueueImpl v; org.apache.sling.event.impl.jobs.queues.QueueServices v, v; v := @this: org.apache.sling.event.impl.jobs.queues.JobQueueImpl; v = v.; v = virtualinvoke v.(); v = v.; v = v.; interfaceinvoke v.("Removing all jobs for queue {} : {}", v, v); v = interfaceinvoke v.(); if v != 0 goto label; v = v.; v = v.; v = virtualinvoke v.(); label: v = v.; v = v.; v = virtualinvoke v.(); v = interfaceinvoke v.(v); if v == null goto label; v = new org.apache.sling.event.impl.support.BatchResourceRemover; specialinvoke v.()>(); v = interfaceinvoke v.(); label: v = interfaceinvoke v.(); if v == 0 goto label; v = interfaceinvoke v.