Skip to content

Commit

Permalink
ConfigItem: Don't add items to the new items vector before committing
Browse files Browse the repository at this point in the history
This also improves the performance a bit, as we longer have to iterate over the items
and copy them into the new items vector.
  • Loading branch information
yhabteab committed Oct 12, 2022
1 parent f7298e8 commit 400117e
Showing 1 changed file with 10 additions and 5 deletions.
15 changes: 10 additions & 5 deletions lib/config/configitem.cpp
Original file line number Diff line number Diff line change
Expand Up @@ -433,11 +433,9 @@ bool ConfigItem::CommitNewItems(const ActivationContext::Ptr& context, WorkQueue
<< "Committing " << items.size() << " new items.";
#endif /* I2_DEBUG */

for (const auto& ip : items)
newItems.push_back(ip.first);

std::set<Type::Ptr> types;
std::set<Type::Ptr> completed_types;
int itemsCount {0};

for (const Type::Ptr& type : Type::GetAllTypes()) {
if (ConfigObject::TypeInstance->IsAssignableFrom(type))
Expand All @@ -464,7 +462,9 @@ bool ConfigItem::CommitNewItems(const ActivationContext::Ptr& context, WorkQueue
continue;

std::atomic<int> committed_items(0);
upq.ParallelFor(items, [&type, &committed_items](const ItemPair& ip) {
std::mutex newItemsMutex;

upq.ParallelFor(items, [&type, &committed_items, &newItems, &newItemsMutex](const ItemPair& ip) {
const ConfigItem::Ptr& item = ip.first;

if (item->m_Type != type)
Expand All @@ -479,10 +479,15 @@ bool ConfigItem::CommitNewItems(const ActivationContext::Ptr& context, WorkQueue
}

committed_items++;

std::unique_lock<std::mutex> lock(newItemsMutex);
newItems.emplace_back(item);
});

upq.Join();

itemsCount += committed_items;

completed_types.insert(type);

#ifdef I2_DEBUG
Expand All @@ -498,7 +503,7 @@ bool ConfigItem::CommitNewItems(const ActivationContext::Ptr& context, WorkQueue

#ifdef I2_DEBUG
Log(LogDebug, "configitem")
<< "Committed " << items.size() << " items.";
<< "Committed " << itemsCount << " items.";
#endif /* I2_DEBUG */

completed_types.clear();
Expand Down

0 comments on commit 400117e

Please sign in to comment.