Home
last modified time | relevance | path

Searched defs:syncType (Results 1 – 8 of 8) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
Dlog_table_manager_factory.cpp23 TableSyncType syncType) in GetTableManager()
Dsqlite_single_ver_relational_storage_executor.cpp73 int CheckTableConstraint(const TableInfo &table, DistributedTableMode mode, TableSyncType syncType) in CheckTableConstraint()
154 const std::string &identity, TableInfo &table, TableSyncType syncType) in CreateDistributedTable()
208 …ributedTableMode mode, bool &schemaChanged, RelationalSchemaObject &schema, TableSyncType syncType) in UpgradeDistributedTable()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
Dsingle_ver_data_sync_utils.cpp243 int SingleVerDataSyncUtils::GetMessageId(SyncType syncType) in GetMessageId()
262 int SingleVerDataSyncUtils::GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType) in GetReSendMode()
425 SyncTimeRange SingleVerDataSyncUtils::ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataT… in ReviseLocalMark()
438 SyncTimeRange SingleVerDataSyncUtils::GetRecvDataTimeRange(SyncType syncType, in GetRecvDataTimeRange()
447 SyncTimeRange SingleVerDataSyncUtils::GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, … in GetSyncDataTimeRange()
Dsingle_ver_data_sync.cpp455 SyncTimeRange SingleVerDataSync::GetSyncDataTimeRange(SyncType syncType, SingleVerSyncTaskContext *… in GetSyncDataTimeRange()
465 int SingleVerDataSync::SaveLocalWaterMark(SyncType syncType, const SingleVerSyncTaskContext *contex… in SaveLocalWaterMark()
514 void SingleVerDataSync::GetPeerWaterMark(SyncType syncType, const std::string &queryIdentify, in GetPeerWaterMark()
535 void SingleVerDataSync::GetLocalWaterMark(SyncType syncType, const std::string &queryIdentify, in GetLocalWaterMark()
800 …SyncType syncType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_S… in PullRequestStart() local
874 void SingleVerDataSync::UpdateQueryPeerWaterMark(SyncType syncType, const std::string &queryId, in UpdateQueryPeerWaterMark()
888 void SingleVerDataSync::UpdatePeerWaterMark(SyncType syncType, const std::string &queryId, in UpdatePeerWaterMark()
1034 int SingleVerDataSync::SendDataPacket(SyncType syncType, const DataRequestPacket *packet, in SendDataPacket()
1079 …SyncType syncType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_S… in SendPullResponseDataPkt() local
1418 …SyncType syncType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_S… in SendReSendPacket() local
[all …]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/relational/
Dsqlite_single_relational_storage_engine.cpp154 TableSyncType syncType) in SaveSyncTableTypeToMeta()
169 const std::string &identity, bool &schemaChanged, TableSyncType syncType) in CreateDistributedTable()
249 TableSyncType syncType) in UpgradeDistributedTable()
Dsqlite_relational_store_connection.cpp144 …tionalStoreConnection::CreateDistributedTable(const std::string &tableName, TableSyncType syncType) in CreateDistributedTable()
Dsqlite_relational_store.cpp424 …SQLiteRelationalStore::CreateDistributedTable(const std::string &tableName, TableSyncType syncType) in CreateDistributedTable()
/foundation/communication/dsoftbus/core/bus_center/lnn/net_builder/src/
Dlnn_net_builder.c1674 static void LnnProcessCompleteNotTrustedMsg(LnnSyncInfoType syncType, const char *networkId, in LnnProcessCompleteNotTrustedMsg()