diff options
| author | Carl Hetherington <cth@carlh.net> | 2022-12-24 23:52:25 +0100 |
|---|---|---|
| committer | Carl Hetherington <cth@carlh.net> | 2022-12-24 23:52:25 +0100 |
| commit | 0de66f5453b996003aa7f739815888d0b2a98b50 (patch) | |
| tree | 16800de2a1bcf69354346cb622f07ed68f677aba | |
| parent | 790db8faab093231664c402fcc33b0b96687e222 (diff) | |
Cleanup: simplify some code.
| -rw-r--r-- | src/lib/job_manager.cc | 40 |
1 files changed, 12 insertions, 28 deletions
diff --git a/src/lib/job_manager.cc b/src/lib/job_manager.cc index e17b12853..7a6bda840 100644 --- a/src/lib/job_manager.cc +++ b/src/lib/job_manager.cc @@ -295,50 +295,34 @@ JobManager::analyse_subtitles ( void JobManager::increase_priority (shared_ptr<Job> job) { - bool changed = false; - { boost::mutex::scoped_lock lm (_mutex); - auto last = _jobs.end (); - for (auto i = _jobs.begin(); i != _jobs.end(); ++i) { - if (*i == job && last != _jobs.end()) { - swap (*i, *last); - changed = true; - break; - } - last = i; + auto iter = std::find(_jobs.begin(), _jobs.end(), job); + if (iter == _jobs.begin() || iter == _jobs.end()) { + return; } + swap(*iter, *std::prev(iter)); } - if (changed) { - _empty_condition.notify_all (); - emit (boost::bind(boost::ref(JobsReordered))); - } + _empty_condition.notify_all(); + emit(boost::bind(boost::ref(JobsReordered))); } void JobManager::decrease_priority (shared_ptr<Job> job) { - bool changed = false; - { boost::mutex::scoped_lock lm (_mutex); - for (auto i = _jobs.begin(); i != _jobs.end(); ++i) { - auto next = i; - ++next; - if (*i == job && next != _jobs.end()) { - swap (*i, *next); - changed = true; - break; - } + auto iter = std::find(_jobs.begin(), _jobs.end(), job); + if (iter == _jobs.end() || std::next(iter) == _jobs.end()) { + return; } + swap(*iter, *std::next(iter)); } - if (changed) { - _empty_condition.notify_all (); - emit (boost::bind(boost::ref(JobsReordered))); - } + _empty_condition.notify_all(); + emit(boost::bind(boost::ref(JobsReordered))); } |
