Method OnSyncTableDelete

src/plugin/kernel/src/AFCKernelModule.cpp:839–870

}

int AFCKernelModule::OnSyncTableDelete(const AFGUID& self, const TABLE_EVENT_DATA& event, const ArkDataMask mask_value)
{
    // 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_delete 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;
    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});

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

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