git-tfs-id: [http://tfs.userrendszerhaz.hu:8080/tfs/DefaultCollection]$/MediaCube...
authorSweidan Omar <TFS\sweidan.omar>
Thu, 28 Apr 2022 08:13:12 +0000 (08:13 +0000)
committerSweidan Omar <TFS\sweidan.omar>
Thu, 28 Apr 2022 08:13:12 +0000 (08:13 +0000)
server/user.jobengine.osgi.server/src/user/jobengine/server/JobEngine.java

index e0e7ff1e8612a1f7172b929a9dc0b75e77129244..af5db131fc955b38febfc1606c58b1cbe4738d18 100644 (file)
@@ -577,35 +577,34 @@ public class JobEngine implements IJobEngine {
 
                // vegigmenni a submittedJobs-on!
 
-               Set<Long> ids = submittedJobs.keySet();         
+               Set<Long> ids = submittedJobs.keySet();
                for (long id : ids) {
                        if (!submittedJobs.containsKey(id))
                                continue;
-                       
+
                        IJobRuntime runtime = submittedJobs.get(id);
                        if (runtime == null)
                                continue;
 
                        if (!template.getFileName().equals(runtime.getTemplate()))
                                continue;
-                       
-                       //'EXECUTING', 'WAIT_EXECUTOR', 'WAIT_SUSPEND', 'RUNNABLE'
-                       if(runtime.isExecuting() || runtime.isRunnable() || runtime.isWaitingSuspend()|| runtime.isWaitingExecutor())
+
+                       // 'EXECUTING', 'WAIT_EXECUTOR', 'WAIT_SUSPEND', 'RUNNABLE'
+                       if (runtime.isExecuting() || runtime.isRunnable() || runtime.isWaitingSuspend()
+                                       || runtime.isWaitingExecutor())
                                throw new JobEngineException(String.format("Can not submit job. Job with %s.%s already running",
                                                template.getFileName(), template.getName()));
                }
-/*             
-               List<Job> runningJobs = itemManager.getRunningJobs(template.getFileName());
-               if (runningJobs != null) {
-                       for (Job job : runningJobs) {
-                               Job runningJob = getJob(job.getId());
-
-                               if (runningJob != null && runningJob.getStatus() != JobStatus.SUSPENDED)
-                                       throw new JobEngineException(String.format("Can not submit job. Job with %s.%s already running",
-                                                       template.getFileName(), template.getName()));
-                       }
-               }
-*/             
+               /*
+                * List<Job> runningJobs = itemManager.getRunningJobs(template.getFileName());
+                * if (runningJobs != null) { for (Job job : runningJobs) { Job runningJob =
+                * getJob(job.getId());
+                * 
+                * if (runningJob != null && runningJob.getStatus() != JobStatus.SUSPENDED)
+                * throw new JobEngineException(String.
+                * format("Can not submit job. Job with %s.%s already running",
+                * template.getFileName(), template.getName())); } }
+                */
        }
 
        @Override