Searched refs:remoteDbAbility (Results 1 – 6 of 6) sorted by relevance
441 void SingleVerSyncTaskContext::SetDbAbility(DbAbility &remoteDbAbility) in SetDbAbility() argument445 remoteDbAbility_ = remoteDbAbility; in SetDbAbility()450 remoteDbAbility.GetAbilityItem(SyncConfig::ALLPREDICATEQUERY), in SetDbAbility()451 remoteDbAbility.GetAbilityItem(SyncConfig::SUBSCRIBEQUERY), in SetDbAbility()452 remoteDbAbility.GetAbilityItem(SyncConfig::INKEYS_QUERY)); in SetDbAbility()
122 void SetDbAbility(DbAbility &remoteDbAbility) override;
567 DbAbility remoteDbAbility = packet->GetDbAbility(); in HandleVersionV3RequestParam() local568 (static_cast<SingleVerSyncTaskContext *>(context))->SetDbAbility(remoteDbAbility); in HandleVersionV3RequestParam()841 DbAbility remoteDbAbility; in RequestPacketDeSerializationTailPart() local842 int errCode = DbAbility::DeSerialize(parcel, remoteDbAbility); in RequestPacketDeSerializationTailPart()847 packet->SetDbAbility(remoteDbAbility); in RequestPacketDeSerializationTailPart()884 DbAbility remoteDbAbility; in AckPacketDeSerializationTailPart() local885 int errCode = DbAbility::DeSerialize(parcel, remoteDbAbility); in AckPacketDeSerializationTailPart()890 packet->SetDbAbility(remoteDbAbility); in AckPacketDeSerializationTailPart()1322 DbAbility remoteDbAbility = packet->GetDbAbility(); in AckRecvWithHighVersion() local1324 singleVerContext->SetDbAbility(remoteDbAbility); in AckRecvWithHighVersion()
186 virtual void SetDbAbility(DbAbility &remoteDbAbility) = 0;
214 void SetDbAbility(DbAbility &remoteDbAbility) override;
835 void SyncTaskContext::SetDbAbility([[gnu::unused]] DbAbility &remoteDbAbility)