Method OnDelaySyncData

src/plugin/kernel/src/AFCKernelModule.cpp:716–780

}

int AFCKernelModule::OnDelaySyncData(const AFGUID& self, const ArkDataMask mask_value, const AFDelaySyncData& data)
{
    if (data.node_list_.size() == 0 && data.table_list_.size() == 0)
    {
        return 0;
    }

    // find parent entity
    auto pEntity = GetEntity(self);
    if (pEntity == nullptr)
    {
        ARK_LOG_ERROR("sync delay data failed entity do no exist, self={}", self);
        return -1;
    }

    AFMsg::pb_delay_entity pb_data;
    auto entity_id = self;
    auto pb_entity = pb_data.mutable_data();

    auto pParentContainer = pEntity->GetParentContainer();
    if (pParentContainer != nullptr)
    {
        if (!TryAddContainerPBEntity(pParentContainer, self, *pb_data.mutable_data(), entity_id, pb_entity))
        {
            ARK_LOG_ERROR("sync delay data failed container entity do no exist, self={}", self);
            return -1;
        }
    }

    // node to pb
    for (auto& iter : data.node_list_)
    {
        auto pNode = iter;
        if (!NodeToPBData(pNode, pb_entity))
        {
            continue;
        }
    }

    // table to pb
    for (auto& iter : data.table_list_)
    {
        auto table_index = iter.first;
        auto& table = iter.second;
        DelayTableToPB(table, table_index, pb_data, *pb_entity);
    }

    // container to pb
    for (auto& iter : data.container_list_)
    {
        auto container_index = iter.first;
        auto& container = iter.second;
        DelayContainerToPB(pEntity, container, container_index, pb_data);
    }

    pb_data.set_id(entity_id);

    if (SendSyncMsg(entity_id, mask_value, pb_data) < 0)