mirror of https://github.com/micromata/borgbackup-butler.git

Kai Reinhard
06.03.2019 bf7101f797e8f2a6c3b966762afb1ec063c4428e
borgbutler-core/src/main/java/de/micromata/borgbutler/BorgQueueExecutor.java
@@ -36,25 +36,24 @@
    }
    public void cancelJob(long uniqueJobNumber) {
        AbstractJob<?> job = getQueuedJobByUniqueJobNumber(uniqueJobNumber);
        AbstractJob<?> job = null;
        JobQueue<?> queue = null;
        Iterator<JobQueue<String>> it = queueMap.values().iterator();
        while (it.hasNext()) {
            queue = it.next();
            job = queue.getQueuedJobByUniqueJobNumber(uniqueJobNumber);
            if (job != null) {
                break;
            }
        }
        if (job == null) {
            log.info("Can't cancel job #" + uniqueJobNumber + ". Not found as queued job (may-be already cancelled or finished). Nothing to do.");
            return;
        }
        job.cancel();
        queue.refreshQueue();
    }
    private AbstractJob<?> getQueuedJobByUniqueJobNumber(long uniqueJobNumber) {
        Iterator<JobQueue<String>> it = queueMap.values().iterator();
        while (it.hasNext()) {
            AbstractJob<?> job = it.next().getQueuedJobByUniqueJobNumber(uniqueJobNumber);
            if (job != null) {
                return job;
            }
        }
        return null;
    }
    /**
     * For displaying purposes.
     *