Method OnSyncContainerPlace

src/plugin/kernel/src/AFCKernelModule.cpp:914–968

}

int AFCKernelModule::OnSyncContainerPlace(
    const AFGUID& self, const uint32_t index, const ArkDataMask mask, uint32_t src_index)
{
    // find parent entity
    auto pEntity = GetEntity(self);
    if (pEntity == nullptr)
    {
        ARK_LOG_ERROR("sync container failed entity do no exist, self={}", self);
        return -1;
    }

    auto pContainer = pEntity->FindContainer(index);
    if (pEntity == nullptr)
    {
        ARK_LOG_ERROR("sync container failed container do no exist, self={}, container={}", self, index);
        return -1;
    }

    auto pContainerEntity = pContainer->Find(src_index);
    if (pContainerEntity == nullptr)
    {
        ARK_LOG_ERROR("sync container failed container entity do no exist, self={}, container={}, entity={}", self,
            index, src_index);
        return -1;
    }

    if (pContainerEntity->IsSent())
    {
        AFMsg::pb_container_place pb_data;
        pb_data.set_id(self);
        pb_data.set_index(index);
        pb_data.set_entity_index(src_index);
        pb_data.set_entity_id(pContainerEntity->GetID());

        SendSyncMsg(self, mask, pb_data);
    }
    else
    {
        AFMsg::pb_container_create pb_data;
        if (!EntityToPBData(pContainerEntity, pb_data.mutable_data()))
        {
            ARK_LOG_ERROR("sync container failed container entity to pb failed, self={}, container={}, entity={}", self,
                index, src_index);
            return -1;
        }

        pb_data.set_id(self);
        pb_data.set_index(index);
        pb_data.set_entity_index(src_index);

        SendSyncMsg(self, mask, pb_data);
    }

    return 0;
}

int AFCKernelModule::OnSyncContainerRemove(
    const AFGUID& self, const uint32_t index, const ArkDataMask mask, uint32_t src_index)