Method DelayContainerToPB

src/plugin/kernel/src/AFCKernelModule.cpp:1075–1126

}

bool AFCKernelModule::DelayContainerToPB(std::shared_ptr<AFIEntity> pEntity, const AFDelaySyncContainer& container,
    const uint32_t index, AFMsg::pb_delay_entity& data)
{
    AFMsg::delay_container pb_delay_container;
    AFMsg::pb_container pb_conatiner;
    for (auto& iter : container.index_list_)
    {
        auto entity_index = iter;
        auto pContaier = pEntity->FindContainer(index);
        if (pContaier == nullptr)
        {
            continue;
        }

        auto pContainerEntity = pContaier->Find(entity_index);
        if (pContainerEntity == nullptr)
        {
            pb_delay_container.mutable_entity_list()->insert({entity_index, NULL_GUID});
        }
        else if (pEntity->IsSent())
        {
            pb_delay_container.mutable_entity_list()->insert({entity_index, pContainerEntity->GetID()});
        }
        else
        {
            AFMsg::pb_entity pb_container_entity;
            if (!EntityToPBData(pContainerEntity, &pb_container_entity))
            {
                continue;
            }

            pb_conatiner.mutable_datas_value()->insert({entity_index, pb_container_entity});
        }
    }

    if (pb_conatiner.datas_value_size() > 0)
    {
        data.mutable_data()->mutable_datas_container()->insert({index, pb_conatiner});
    }
    data.mutable_container_entity()->insert({index, pb_delay_container});

    AFMsg::delay_container pb_destroy_entity;
    for (auto& iter : container.destroy_list_)
    {
        auto entity_index = iter;
        pb_destroy_entity.mutable_entity_list()->insert({entity_index, NULL_GUID});
    }

    data.mutable_destroy_entity()->insert({index, pb_destroy_entity});

    return true;
}

bool AFCKernelModule::TryAddContainerPBEntity(std::shared_ptr<AFIContainer> pContainer, const AFGUID& self,
    AFMsg::pb_entity_data& pb_entity_data, AFGUID& parent_id, AFMsg::pb_entity_data* pb_container_entity)