Home
last modified time | relevance | path

Searched refs:AbilitySync (Results 1 – 8 of 8) sorted by relevance

/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dability_sync.cpp352 AbilitySync::AbilitySync() in AbilitySync() function in DistributedDB::AbilitySync
360 AbilitySync::~AbilitySync() in ~AbilitySync()
499 ackCode = AbilitySync::LAST_NOTIFY; in AckNotifyRecv()
505 bool AbilitySync::GetAbilitySyncFinishedStatus() const in GetAbilitySyncFinishedStatus()
614 int AbilitySync::RegisterTransformFunc() in RegisterTransformFunc()
627 uint32_t AbilitySync::CalculateLen(const Message *inMsg) in CalculateLen()
1062 int AbilitySync::GetDbAbilityInfo(DbAbility &dbAbility) in GetDbAbilityInfo()
1103 bool AbilitySync::IsSingleKvVer() const in IsSingleKvVer()
1107 bool AbilitySync::IsSingleRelationalVer() const in IsSingleRelationalVer()
1356 void AbilitySync::InitAbilitySyncFinishStatus(ISyncTaskContext &context) in InitAbilitySyncFinishStatus()
[all …]
H A Dability_sync.h150 class AbilitySync {
154 AbilitySync();
155 ~AbilitySync();
H A Dsync_engine.cpp577 return AbilitySync::CalculateLen(inMsg); in GetMsgSize()
H A Dgeneric_syncer.cpp614 errCode = AbilitySync::RegisterTransformFunc(); in SyncResourceInit()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/
H A Ddistributeddb_ability_sync_test.cpp145 ASSERT_TRUE(AbilitySync::Serialization(buff.data(), bufflen, &msg1) == E_OK);
153 ASSERT_TRUE(AbilitySync::DeSerialization(buff.data(), bufflen, &msg2) == E_OK);
196 ASSERT_TRUE(AbilitySync::Serialization(buff.data(), bufflen, &msg1) == E_OK);
204 ASSERT_TRUE(AbilitySync::DeSerialization(buff.data(), bufflen, &msg2) == E_OK);
247 ASSERT_TRUE(AbilitySync::Serialization(buff.data(), bufflen, &msg1) == E_OK);
304 ASSERT_TRUE(AbilitySync::Serialization(buff.data(), bufflen, &msg1) == E_OK);
362 ASSERT_EQ(AbilitySync::Serialization(buff.data(), bufflen, &msg1), E_OK);
397 AbilitySync async;
430 AbilitySync async;
501 AbilitySync async;
[all …]
H A Ddistributeddb_mock_sync_module_test.cpp959 AbilitySync abilitySync;
981 AbilitySync abilitySync;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_sync_state_machine.cpp133 abilitySync_ = std::make_unique<AbilitySync>(); in Initialize()
1289 if (ackCode != AbilitySync::CHECK_SUCCESS && ackCode != AbilitySync::LAST_NOTIFY) { in AbilitySyncNotifyRecv()
1296 if (ackCode == AbilitySync::LAST_NOTIFY && AbilityMsgSessionIdCheck(inMsg)) { in AbilitySyncNotifyRecv()
1306 } else if (ackCode != AbilitySync::LAST_NOTIFY) { in AbilitySyncNotifyRecv()
H A Dsingle_ver_sync_state_machine.h231 std::unique_ptr<AbilitySync> abilitySync_;