Method OnSyncTableAdd

src/plugin/kernel/src/AFCKernelModule.cpp:782–837

}

int AFCKernelModule::OnSyncTableAdd(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;
    }

    auto pTable = pEntity->FindTable(event.table_index_);
    if (nullptr == pTable)
    {
        ARK_LOG_ERROR("sync table failed table do no exist, self={}, table={}", self, event.table_name_);
        return -1;
    }

    auto pRow = pTable->FindRow(event.row_);
    if (nullptr == pRow)
    {
        ARK_LOG_ERROR(
            "sync table failed table row do no exist, self={}, table={}, row={}", self, event.table_name_, event.row_);
        return -1;
    }

    AFMsg::pb_entity_table_add 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 (!RowToPBData(pRow, event.row_, &pb_row))
    {
        ARK_LOG_ERROR(
            "sync table failed table row 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::OnSyncTableDelete(const AFGUID& self, const TABLE_EVENT_DATA& event, const ArkDataMask mask_value)