Method schedule_ecs_job

modules/engine/runtime/src/ecs/scheduler.cpp:291–533

} // namespace sugoi

skr::task::event_t sugoi::scheduler_t::schedule_ecs_job(sugoi_query_t* query, EIndex batchSize, sugoi_system_callback_t callback, void* u,
sugoi_system_lifetime_callback_t init, sugoi_system_lifetime_callback_t teardown, sugoi_resource_operation_t* resources)
{
    query->storage->build_queries();
    skr::task::event_t result;
    SkrZoneScopedN("SchedualECSJob");

    SKR_ASSERT(is_main_thread(query->storage));
    SKR_ASSERT(query->parameters.length < 32);
    llvm_vecsmall::SmallVector<sugoi_group_t*, 64> groups;
    auto add_group = [&](sugoi_group_t* group) {
        groups.push_back(group);
    };
    auto& params = query->parameters;
    query->storage->query_groups(query->filter, query->meta, SUGOI_LAMBDA(add_group));
    struct task_t {
        uint32_t groupIndex;
        uint32_t startIndex;
        sugoi_chunk_view_t view;
    };
    struct SharedData
    {
        sugoi_query_t* query;
        sugoi_group_t** groups;
        uint32_t groupCount;
        std::bitset<32>* readonly;
        sugoi_type_index_t* localTypes;
        std::bitset<32>* atomic;
        std::bitset<32>* randomAccess;
        bool hasRandomWrite;
        bool hasWriteChunkComponent;
        EIndex entityCount;
        sugoi_system_callback_t callback;
        void* userdata;
        skr::stl_vector<task_t> tasks;
    };
    SharedData* job = nullptr;
    skr::SPtr<SharedData> sharedData;

    auto groupCount = (uint32_t)groups.size();
    {
        SkrZoneScopedN("AllocateSharedData");
        struct_arena_t<SharedData> arena;
        arena.record(&SharedData::groups, groupCount);
        arena.record(&SharedData::localTypes, groupCount * params.length);
        arena.record(&SharedData::readonly, groupCount);
        arena.record(&SharedData::atomic, groupCount);
        arena.record(&SharedData::randomAccess, groupCount);  
        job = arena.end();
        job->groups =       arena.get(&SharedData::groups, groupCount);
        job->localTypes =   arena.get(&SharedData::localTypes, groupCount * params.length);
        job->readonly =     arena.get(&SharedData::readonly, groupCount);
        job->atomic =       arena.get(&SharedData::atomic, groupCount);
        job->randomAccess = arena.get(&SharedData::randomAccess, groupCount);
    }
    job->groupCount = groupCount;
    job->hasRandomWrite = !query->subqueries.empty();
    job->hasWriteChunkComponent = false;