BlockStorage/repertory
1
0
Fork 0
Code Issues 3 Pull Requests Releases 9 Wiki Activity

refactor
All checks were successful
BlockStorage/repertory/pipeline/head This commit looks good
Details

Browse Source
This commit is contained in:
sgraves76
2024-12-03 16:38:38 -06:00
parent 31e20e9af0
commit b9ce21853f
1 changed files with 4 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
repertory/librepertory/src/utils/polling.cpp
View File

@@ -32,12 +32,12 @@ void polling::frequency_thread(
unique_mutex_lock lock(mutex_); unique_mutex_lock lock(mutex_);
auto futures = std::accumulate( auto futures = std::accumulate(
items_.begin(), items_.end(), std::deque<std::future<void>>{}, items_.begin(), items_.end(), std::deque<std::future<void>>{},
[this, &freq](auto &&futures, auto &&item) { [this, &freq](auto &&list, auto &&item) {
if (item.second.freq != freq) { if (item.second.freq != freq) {
return futures; return list;
} }
futures.emplace_back( list.emplace_back(
std::async(std::launch::async, [this, &freq, item]() -> void { std::async(std::launch::async, [this, &freq, item]() -> void {
if (config_->get_event_level() == event_level::trace || if (config_->get_event_level() == event_level::trace ||
freq != frequency::second) { freq != frequency::second) {
@@ -50,7 +50,7 @@ void polling::frequency_thread(
event_system::instance().raise<polling_item_end>(item.first); event_system::instance().raise<polling_item_end>(item.first);
} }
})); }));
return futures; return list;
}); });
lock.unlock(); lock.unlock();