Home
last modified time | relevance | path

Searched refs:SyncType (Results 1 – 25 of 48) sorted by relevance

12

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/
H A Dsync_operation.cpp291 SyncType type = SyncType::INVALID_SYNC_TYPE;
299 SyncType SyncOperation::GetSyncType(int mode) in GetSyncType()
302 {static_cast<int>(SyncModeType::PUSH), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
303 {static_cast<int>(SyncModeType::PULL), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
304 {static_cast<int>(SyncModeType::PUSH_AND_PULL), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
305 {static_cast<int>(SyncModeType::RESPONSE_PULL), SyncType::MANUAL_FULL_SYNC_TYPE}, in GetSyncType()
306 {static_cast<int>(SyncModeType::AUTO_PULL), SyncType::AUTO_SYNC_TYPE}, in GetSyncType()
307 {static_cast<int>(SyncModeType::AUTO_PUSH), SyncType::AUTO_SYNC_TYPE}, in GetSyncType()
308 {static_cast<int>(SyncModeType::QUERY_PUSH), SyncType::QUERY_SYNC_TYPE}, in GetSyncType()
309 {static_cast<int>(SyncModeType::QUERY_PULL), SyncType::QUERY_SYNC_TYPE}, in GetSyncType()
[all …]
H A Dsync_types.h54 enum class SyncType { enum
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_data_sync.cpp344 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in GetUnsyncData()
368 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in GetUnsyncData()
597 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in DealRemoveDeviceDataByAck()
664 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in FillDataRequestPacket()
738 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in RequestStart()
770 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in PushStart()
802 …SyncType syncType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_S… in PullRequestStart()
853 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in PullResponseStart()
1086 …SyncType syncType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_S… in SendPullResponseDataPkt()
1290 …SyncType curType = (context->IsQuerySync()) ? SyncType::QUERY_SYNC_TYPE : SyncType::MANUAL_FULL_SY… in DealWaterMarkException()
[all …]
H A Dsingle_ver_data_sync.h100 …bool WaterMarkErrHandle(SyncType syncType, SingleVerSyncTaskContext *context, const Message *messa…
146 SyncTimeRange GetSyncDataTimeRange(SyncType syncType, SingleVerSyncTaskContext *context,
165 …const SingleVerSyncTaskContext *context, const std::vector<SendDataItem> &inData, SyncType curType,
168 int SaveLocalWaterMark(SyncType syncType, const SingleVerSyncTaskContext *context,
171 …void GetLocalWaterMark(SyncType syncType, const std::string &queryIdentify, const SingleVerSyncTas…
174 …void GetPeerWaterMark(SyncType syncType, const std::string &queryIdentify, const DeviceID &deviceI…
186 …int SendDataPacket(SyncType syncType, DataRequestPacket *packet, SingleVerSyncTaskContext *context…
188 …void UpdateQueryPeerWaterMark(SyncType syncType, const std::string &queryId, const SyncTimeRange &…
191 …void UpdatePeerWaterMark(SyncType syncType, const std::string &queryId, const SingleVerSyncTaskCon…
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()
309 return (syncType == SyncType::QUERY_SYNC_TYPE) ? SyncModeType::QUERY_PUSH : SyncModeType::PUSH; in GetReSendMode()
458 SyncTimeRange SingleVerDataSyncUtils::ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataT… in ReviseLocalMark()
462 if (updateMark.deleteUpdateMark && syncType == SyncType::QUERY_SYNC_TYPE) { in ReviseLocalMark()
471 SyncTimeRange SingleVerDataSyncUtils::GetRecvDataTimeRange(SyncType syncType, in GetRecvDataTimeRange()
474 if (syncType != SyncType::QUERY_SYNC_TYPE) { in GetRecvDataTimeRange()
[all …]
H A Dsingle_ver_data_sync_utils.h56 static int GetMessageId(SyncType syncType);
60 static int GetReSendMode(int mode, uint32_t sequenceId, SyncType syncType);
86 static SyncTimeRange ReviseLocalMark(SyncType syncType, const SyncTimeRange &dataTimeRange,
89 static SyncTimeRange GetRecvDataTimeRange(SyncType syncType,
92 …static SyncTimeRange GetSyncDataTimeRange(SyncType syncType, WaterMark localMark, WaterMark delete…
/ohos5.0/base/security/asset/test/unittest/inner_kits_rust/src/
H A Dadd.rs42 assert_eq!(SyncType::ThisDevice, res[0].get_enum_attr::<SyncType>(&Tag::SyncType).unwrap()); in add_all_tags()
65 assert_eq!(SyncType::Never, res[0].get_enum_attr::<SyncType>(&Tag::SyncType).unwrap()); in add_required_tags()
161 let sync_type = (SyncType::ThisDevice as u32) | (SyncType::TrustedDevice as u32); in add_multiple_sync_types()
165 attrs.insert_attr(Tag::SyncType, sync_type); in add_multiple_sync_types()
171 assert_eq!(sync_type, res[0].get_num_attr(&Tag::SyncType).unwrap()); in add_multiple_sync_types()
H A Dremove_abnormal.rs50 …let sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::TrustedAc… in remove_invalid_sync_type()
51 query.insert_attr(Tag::SyncType, sync_type + 1); in remove_invalid_sync_type()
97 let tags_bytes = [Tag::Accessibility, Tag::AuthType, Tag::SyncType]; in remove_number_tag_with_unmatched_type()
H A Dpre_query_abnormal.rs49 …let sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::TrustedAc… in pre_query_invalid_sync_type()
50 query.insert_attr(Tag::SyncType, sync_type + 1); in pre_query_invalid_sync_type()
106 let tags_num = [Tag::Accessibility, Tag::AuthType, Tag::SyncType, Tag::AuthValidityPeriod]; in pre_query_number_tag_with_unmatched_type()
H A Dadd_abnormal.rs186 …let sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::TrustedAc… in add_invalid_sync_type()
187 attrs.insert_attr(Tag::SyncType, sync_type + 1); in add_invalid_sync_type()
198 …let sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::TrustedAc… in add_sync_type_with_max_len()
199 attrs.insert_attr(Tag::SyncType, sync_type); in add_sync_type_with_max_len()
269 let tags_num = [Tag::Accessibility, Tag::AuthType, Tag::SyncType, Tag::ConflictResolution]; in add_number_tag_with_unmatched_type()
H A Dquery_abnormal.rs50 …let sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::TrustedAc… in query_invalid_sync_type()
51 query.insert_attr(Tag::SyncType, sync_type + 1); in query_invalid_sync_type()
86 Tag::SyncType, in query_invalid_return_ordered_by()
189 Tag::SyncType, in query_number_tag_with_unmatched_type()
H A Dupdate_abnormal.rs114 …let sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::TrustedAc… in update_query_invalid_sync_type()
115 query.insert_attr(Tag::SyncType, sync_type + 1); in update_query_invalid_sync_type()
198 let tags_num = [Tag::Accessibility, Tag::AuthType, Tag::SyncType]; in update_query_number_tag_with_unmatched_type()
354 Tag::SyncType, in update_unsupported_tags()
H A Dquery.rs441 …let mut sync_type = SyncType::ThisDevice as u32 | SyncType::TrustedDevice as u32 | SyncType::Trust… in query_with_sync_type()
442 query.insert_attr(Tag::SyncType, sync_type); in query_with_sync_type()
445 sync_type = SyncType::ThisDevice as u32; in query_with_sync_type()
446 query.insert_attr(Tag::SyncType, sync_type); in query_with_sync_type()
H A Dpre_query.rs77 query.insert_attr(Tag::SyncType, SyncType::TrustedDevice); in pre_query_with_wrong_sync_type()
H A Dcommon.rs124 attrs.insert_attr(Tag::SyncType, SyncType::ThisDevice); in add_all_tags_asset()
H A Dpost_query_abnormal.rs57 Tag::SyncType, in post_query_unsupported_tags()
/ohos5.0/base/security/asset/services/core_service/src/operations/
H A Doperation_add.rs29 SyncStatus, SyncType, Tag, Value,
59 condition.insert(column::SYNC_TYPE, Value::Number(SyncType::TrustedAccount as u32)); in resolve_conflict()
92 db_data.entry(column::SYNC_TYPE).or_insert(Value::Number(SyncType::default() as u32)); in add_default_attrs()
133 if attributes.get(&Tag::SyncType).is_none() || in check_sync_permission()
134 (attributes.get_num_attr(&Tag::SyncType)? & SyncType::TrustedAccount as u32) == 0 { in check_sync_permission()
H A Doperation_remove.rs23 use asset_definition::{log_throw_error, AssetMap, ErrCode, Result, SyncStatus, SyncType, Value};
72 reverse_condition.insert(column::SYNC_TYPE, Value::Number(SyncType::TrustedAccount as u32)); in remove()
H A Dcommon.rs39 (Tag::SyncType, column::SYNC_TYPE),
88 Tag::SyncType,
/ohos5.0/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 { enum
/ohos5.0/base/security/asset/frameworks/definition/src/
H A Dlib.rs72 SyncType = DataType::Number as isize | 0x10,
300 pub enum SyncType {
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkv_radar_reporter.h58 enum SyncType { enum
/ohos5.0/foundation/multimedia/media_library/frameworks/services/media_cloud_sync/include/
H A Dcloud_sync_helper.h70 void OnSyncStateChanged(FileManagement::CloudSync::SyncType type,
/ohos5.0/foundation/filemanagement/dfs_service/test/fuzztest/cloudsynccallbackstub_fuzzer/
H A Dcloudsynccallbackstub_fuzzer.cpp35 void OnSyncStateChanged(SyncType type, SyncPromptState state) override {} in OnSyncStateChanged()

12