Method OnSyncNode

src/plugin/kernel/src/AFCKernelModule.cpp:610–649

}

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

    AFMsg::pb_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 node failed container entity do no exist, self={}", self);
            return -1;
        }
    }

    if (!NodeToPBData(index, data, pb_entity))
    {
        ARK_LOG_ERROR("node to pb failed, self={}, index={}", self, index);
        return -1;
    }

    pb_data.set_id(entity_id);
    if (SendSyncMsg(entity_id, mask_value, pb_data) < 0)
    {
        ARK_LOG_ERROR("send sync msg failed, self={}, index={}", entity_id, index);
        return -1;
    }

    return 0;
}

int AFCKernelModule::OnSyncTable(
    const AFGUID& self, const TABLE_EVENT_DATA& event, const ArkDataMask mask_value, const AFIData& data)