Method OnSyncTableUpdate

src/plugin/kernel/src/AFCKernelModule.cpp:872–912

}

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

    AFMsg::pb_entity_table_update 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;
        }
    }

    AFMsg::pb_entity_data pb_row;
    if (!NodeToPBData(event.data_index_, data, &pb_row))
    {
        ARK_LOG_ERROR(
            "sync table failed table node do no exist, self={}, table={}, row={}", self, event.table_name_, event.row_);
        return -1;
    }

    AFMsg::pb_table pb_table;
    pb_table.mutable_datas_value()->insert({event.row_, pb_row});
    pb_entity->mutable_datas_table()->insert({event.table_index_, pb_table});

    pb_data.set_id(entity_id);
    SendSyncMsg(entity_id, mask_value, pb_data);
    return 0;
}

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