Home
last modified time | relevance | path

Searched refs:SyncType (Results 1 - 20 of 20) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp345 SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SYNC_TYPE; in GetUnsyncData()
351 if (curType == SyncType::QUERY_SYNC_TYPE) { in GetUnsyncData()
369 SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SYNC_TYPE; in GetUnsyncData()
376 if (curType != SyncType::QUERY_SYNC_TYPE) { in GetUnsyncData()
405 SyncType curType, const QuerySyncObject &query) in SaveData()
455 SyncTimeRange SingleVerDataSync::GetSyncDataTimeRange(SyncType syncTyp
[all...]
H A Dsingle_ver_data_sync_utils.cpp98 if (SyncOperation::GetSyncType(packet->GetMode()) != SyncType::QUERY_SYNC_TYPE) { in RequestQueryCheck()
276 int SingleVerDataSyncUtils::GetMessageId(SyncType syncType) in GetMessageId()
278 if (syncType == SyncType::QUERY_SYNC_TYPE) { in GetMessageId()
295 int SingleVerDataSyncUtils::GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType) in GetReSendMode()
302 return (syncType == SyncType::QUERY_SYNC_TYPE) ? SyncModeType::QUERY_PUSH : SyncModeType::PUSH; in GetReSendMode()
307 return (syncType == SyncType::QUERY_SYNC_TYPE) ? SyncModeType::QUERY_PUSH_PULL : SyncModeType::PUSH_AND_PULL; in GetReSendMode()
309 return (syncType == SyncType::QUERY_SYNC_TYPE) ? SyncModeType::QUERY_PUSH : SyncModeType::PUSH; in GetReSendMode()
458 SyncTimeRange SingleVerDataSyncUtils::ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataTimeRange, in ReviseLocalMark()
462 if (updateMark.deleteUpdateMark && syncType == SyncType::QUERY_SYNC_TYPE) { in ReviseLocalMark()
471 SyncTimeRange SingleVerDataSyncUtils::GetRecvDataTimeRange(SyncType syncTyp
[all...]
H A Dsingle_ver_data_sync.h100 bool WaterMarkErrHandle(SyncType syncType, SingleVerSyncTaskContext *context, const Message *message);
120 void GetLocalWaterMark(SyncType syncType, const std::string &queryIdentify, const SingleVerSyncTaskContext *context,
151 SyncTimeRange GetSyncDataTimeRange(SyncType syncType, SingleVerSyncTaskContext *context,
170 int SaveData(const SingleVerSyncTaskContext *context, const std::vector<SendDataItem> &inData, SyncType curType,
173 int SaveLocalWaterMark(SyncType syncType, const SingleVerSyncTaskContext *context,
176 void GetPeerWaterMark(SyncType syncType, const std::string &queryIdentify, const DeviceID &deviceId,
186 int SendDataPacket(SyncType syncType, DataRequestPacket *packet, SingleVerSyncTaskContext *context);
188 void UpdateQueryPeerWaterMark(SyncType syncType, const std::string &queryId, const SyncTimeRange &dataTime,
191 void UpdatePeerWaterMark(SyncType syncType, const std::string &queryId, const SingleVerSyncTaskContext *context,
H A Dsingle_ver_data_sync_utils.h57 static int GetMessageId(SyncType syncType);
61 static int GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType);
87 static SyncTimeRange ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataTimeRange,
90 static SyncTimeRange GetRecvDataTimeRange(SyncType syncType,
93 static SyncTimeRange GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, WaterMark deleteMark,
H A Dsingle_ver_sync_state_machine.h213 SyncType GetSyncType(uint32_t messageId) const;
H A Dsingle_ver_sync_state_machine.cpp1159 SyncType SingleVerSyncStateMachine::GetSyncType(uint32_t messageId) const in GetSyncType()
1162 return SyncType::QUERY_SYNC_TYPE; in GetSyncType()
1164 return SyncType::MANUAL_FULL_SYNC_TYPE; in GetSyncType()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_operation.cpp358 SyncType type = SyncType::INVALID_SYNC_TYPE;
370 SyncType SyncOperation::GetSyncType(int mode) in GetSyncType()
373 {static_cast<int>(SyncModeType::PUSH), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
374 {static_cast<int>(SyncModeType::PULL), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
375 {static_cast<int>(SyncModeType::PUSH_AND_PULL), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
376 {static_cast<int>(SyncModeType::RESPONSE_PULL), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
377 {static_cast<int>(SyncModeType::AUTO_PULL), SyncType::AUTO_SYNC_TYPE}, in GetSyncType()
378 {static_cast<int>(SyncModeType::AUTO_PUSH), SyncType::AUTO_SYNC_TYPE}, in GetSyncType()
379 {static_cast<int>(SyncModeType::QUERY_PUSH), SyncType in GetSyncType()
[all...]
H A Dsync_types.h54 enum class SyncType { class
H A Dsync_operation.h127 static SyncType GetSyncType(int mode);
/foundation/filemanagement/dfs_service/interfaces/inner_api/native/cloudsync_kit_inner/
H A Dcloud_sync_callback.h41 virtual void OnSyncStateChanged(SyncType type, SyncPromptState state) {}; in OnSyncStateChanged()
H A Dcloud_sync_constants.h20 enum class SyncType : int32_t { class
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync/include/
H A Dcloud_sync_helper.h67 void OnSyncStateChanged(FileManagement::CloudSync::SyncType type,
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkv_radar_reporter.h58 enum SyncType { enum
/foundation/filemanagement/dfs_service/test/fuzztest/cloudsynccallbackstub_fuzzer/
H A Dcloudsynccallbackstub_fuzzer.cpp35 void OnSyncStateChanged(SyncType type, SyncPromptState state) override {}
/foundation/multimedia/media_library/frameworks/services/media_cloud_sync/src/
H A Dcloud_sync_helper.cpp174 void MediaCloudSyncCallback::OnSyncStateChanged(SyncType type, SyncPromptState state) in OnSyncStateChanged()
/foundation/communication/dsoftbus/core/common/dfx/event/src/convert/
H A Dtrans_event_converter.h130 TRANS_ALARM_ASSIGNER(Int32, SyncType, syncType)
/foundation/filemanagement/dfs_service/interfaces/kits/js/cloudfilesync/
H A Dcloud_sync_napi.h81 void OnSyncStateChanged(SyncType type, SyncPromptState state) override;
H A Dcloud_sync_napi.cpp196 void CloudSyncCallbackImpl::OnSyncStateChanged(SyncType type, SyncPromptState state)
/foundation/filemanagement/dfs_service/test/fuzztest/cloudsyncmanager_fuzzer/
H A Dcloudsyncmanager_fuzzer.cpp36 void OnSyncStateChanged(SyncType type, SyncPromptState state) override {}
/foundation/filemanagement/dfs_service/test/fuzztest/cloudsyncservicestub_fuzzer/
H A Dcloudsyncservicestub_fuzzer.cpp49 void OnSyncStateChanged(SyncType type, SyncPromptState state) override {}

Completed in 14 milliseconds