Method sync_query

modules/engine/runtime/src/ecs/scheduler.cpp:129–205

}

bool sugoi::scheduler_t::sync_query(sugoi_query_t* query)
{
    SKR_ASSERT(is_main_thread(query->storage));
    
    SkrZoneScopedN("SyncQuery");
    
    llvm_vecsmall::SmallVector<sugoi_group_t*, 64> groups;
    auto add_group = [&](sugoi_group_t* group) {
        groups.push_back(group);
    };
    query->storage->query_groups(query->filter, query->meta, SUGOI_LAMBDA(add_group));
    skr::FlatHashSet<std::pair<sugoi::archetype_t*, sugoi_type_index_t>> syncedEntry;

    auto sync_entry_once = [&](sugoi::archetype_t* type, sugoi_type_index_t i, bool readonly, bool atomic) -> bool
    {
        if(i == kInvalidTypeIndex)
            return false;
        auto entry = std::make_pair(type, i);
        if (syncedEntry.find(entry) != syncedEntry.end())
            return false;
        auto result = sync_entry(type, i, readonly);
        syncedEntry.insert(entry);
        return result;
    };

    auto sync_type = [&](sugoi_type_index_t type, bool readonly, bool atomic) {
        bool result = false;
        for (auto& pair : query->storage->groups)
        {
            auto group = pair.second;
            auto idx = group->archetype->index(type);
            result = sync_entry_once(group->archetype, idx, readonly, atomic) || result;
        }
        return result;
    };

    bool result = false;
    {
        auto params = query->parameters;
        forloop (i, 0, params.length)
        {
            if (type_index_t(params.types[i]).is_tag())
                continue;
            if (params.accesses[i].randomAccess != DOS_SEQ)
            {
                result = sync_type(params.types[i], params.accesses[i].readonly, params.accesses[i].atomic) || result;
            }
            else
            {
                int groupIndex = 0;(void)groupIndex;
                for (auto group : groups)
                {
                    auto localType = group->archetype->index(params.types[i]);
                    if (localType == kInvalidTypeIndex)
                    {
                        auto g = group->get_owner(params.types[i]);
                        if (g)
                        {