| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/ |
| H A D | distributeddb.gni | 209 "${distributeddb_path}/syncer/src/cloud/cloud_locker.cpp",
210 "${distributeddb_path}/syncer/src/cloud/cloud_syncer.cpp",
218 "${distributeddb_path}/syncer/src/device/ability_sync.cpp",
221 "${distributeddb_path}/syncer/src/device/db_ability.cpp",
224 "${distributeddb_path}/syncer/src/device/meta_data.cpp",
250 "${distributeddb_path}/syncer/src/device/sync_engine.cpp",
252 "${distributeddb_path}/syncer/src/device/sync_target.cpp",
256 "${distributeddb_path}/syncer/src/device/time_sync.cpp",
257 "${distributeddb_path}/syncer/src/sync_config.cpp",
258 "${distributeddb_path}/syncer/src/sync_operation.cpp",
[all …]
|
| H A D | BUILD.gn | 41 "syncer/include",
42 "syncer/src",
43 "syncer/src/cloud",
44 "syncer/src/device",
45 "syncer/src/device/multiver",
46 "syncer/src/device/singlever",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/ |
| H A D | BUILD.gn | 55 "./unittest/common/syncer",
56 "./unittest/common/syncer/cloud",
85 "../syncer/include",
86 "../syncer/src",
87 "../syncer/src/cloud",
88 "../syncer/src/device",
89 "../syncer/src/device/multiver",
90 "../syncer/src/device/singlever",
140 "unittest/common/syncer/cloud/virtual_cloud_db.cpp",
143 "unittest/common/syncer/kv_virtual_device.cpp",
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/cloudsync_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../test/unittest/common/syncer",
27 "../../../test/unittest/common/syncer/cloud",
54 "../../../syncer/include",
55 "../../../syncer/src",
56 "../../../syncer/src/cloud",
57 "../../../syncer/src/device",
58 "../../../syncer/src/device/multiver",
59 "../../../syncer/src/device/singlever",
82 "../../../test/unittest/common/syncer/cloud/virtual_asset_loader.cpp",
83 "../../../test/unittest/common/syncer/cloud/virtual_cloud_data_translate.cpp",
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/sync_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
86 …buteddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/generic_virtual_de…
87 …buteddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/kv_virtual_device.…
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 21 ProcessNotifier::ProcessNotifier(ICloudSyncer *syncer) in ProcessNotifier() argument
22 : syncer_(syncer) in ProcessNotifier()
103 ICloudSyncer *syncer = syncer_; in NotifyProcess() local
104 if (syncer == nullptr) { in NotifyProcess()
108 RefObject::IncObjRef(syncer); in NotifyProcess()
109 auto id = syncer->GetIdentify(); in NotifyProcess()
110 …Code = RuntimeContext::GetInstance()->ScheduleQueuedTask(id, [callback, currentProcess, syncer]() { in NotifyProcess()
112 if (syncer->IsClosed()) { in NotifyProcess()
114 RefObject::DecObjRef(syncer); in NotifyProcess()
118 RefObject::DecObjRef(syncer); in NotifyProcess()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/storage_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../test/unittest/common/syncer",
27 "../../../test/unittest/common/syncer/cloud",
53 "../../../syncer/include",
54 "../../../syncer/src",
55 "../../../syncer/src/cloud",
56 "../../../syncer/src/device",
57 "../../../syncer/src/device/multiver",
58 "../../../syncer/src/device/singlever",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_mock_sync_module_test.cpp | 274 syncer->EnableAutoSync(true); in SyncLifeTest001()
279 syncer = nullptr; in SyncLifeTest001()
314 syncer = nullptr; in SyncLifeTest002()
357 syncer = nullptr; in SyncerCheck001()
1114 syncer = nullptr;
1145 syncer->Close(true);
1152 syncer = nullptr;
1844 SingleVerKVSyncer syncer; variable
1947 syncer->Close(true);
1952 syncer = nullptr;
[all …]
|
| /ohos5.0/foundation/multimedia/av_codec/test/unittest/media_sink_test/ |
| H A D | sync_manager_test.cpp | 158 IMediaSynchronizer* syncer = nullptr; variable
159 syncManager_->AddSynchronizer(syncer);
167 syncManager_->AddSynchronizer(syncer);
170 delete syncer;
177 syncManager_->AddSynchronizer(syncer);
178 syncManager_->AddSynchronizer(syncer);
180 delete syncer;
186 IMediaSynchronizer* syncer = nullptr; variable
187 syncManager_->RemoveSynchronizer(syncer);
196 syncManager_->AddSynchronizer(syncer);
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 600 auto syncer = GetAndIncCloudSyncer(); in Sync() local
601 if (syncer == nullptr) { in Sync()
607 RefObject::DecObjRef(syncer); in Sync()
612 errCode = syncer->Sync(info); in Sync()
613 RefObject::DecObjRef(syncer); in Sync()
619 auto syncer = GetAndIncCloudSyncer(); in SetCloudDB() local
620 if (syncer == nullptr) { in SetCloudDB()
625 RefObject::DecObjRef(syncer); in SetCloudDB()
632 if (syncer == nullptr) { in CleanAllWaterMark()
636 syncer->CleanAllWaterMark(); in CleanAllWaterMark()
[all …]
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoredelegate_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
89 …buteddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/virtual_communicat…
90 …buteddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/virtual_communicat…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/relationalstoremanager_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
89 …buteddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/virtual_communicat…
90 …buteddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/virtual_communicat…
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/fileoper_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/iprocesscommunicator_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/nbdelegate_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/query_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/delegate_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/importfile_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/kvdelegatemanager_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/kvstoreresultset_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/parseckeck_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/rekey_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/fuzztest/schemadelegate_fuzzer/ |
| H A D | BUILD.gn | 26 "../../../syncer/cloud",
31 "../../../syncer/src/cloud",
32 "../../../syncer/src/device",
34 "../../../syncer/src/device/multiver",
35 "../../../syncer/src/device/singlever",
38 …/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer",
57 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include",
58 "//foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src",
|
| /ohos5.0/foundation/multimedia/av_codec/test/unittest/media_sink_test/mock/src/ |
| H A D | media_sync_center_mock.cpp | 28 void MockMediaSyncCenter::AddSynchronizer(Pipeline::IMediaSynchronizer* syncer) in AddSynchronizer() argument
30 (void)syncer; in AddSynchronizer()
33 void MockMediaSyncCenter::RemoveSynchronizer(Pipeline::IMediaSynchronizer* syncer) in RemoveSynchronizer() argument
35 (void)syncer; in RemoveSynchronizer()
|
| /ohos5.0/foundation/multimedia/media_foundation/engine/pipeline/core/ |
| H A D | media_sync_manager.cpp | 41 void MediaSyncManager::AddSynchronizer(IMediaSynchronizer* syncer) in AddSynchronizer() argument
43 if (syncer != nullptr) { in AddSynchronizer()
45 if (std::find(syncers_.begin(), syncers_.end(), syncer) != syncers_.end()) { in AddSynchronizer()
48 syncers_.emplace_back(syncer); in AddSynchronizer()
49 MEDIA_LOG_I("add syncer supplier " PUBLIC_LOG_S, syncer->GetSynchronizerName().c_str()); in AddSynchronizer()
53 void MediaSyncManager::RemoveSynchronizer(IMediaSynchronizer* syncer) in RemoveSynchronizer() argument
55 if (syncer != nullptr) { in RemoveSynchronizer()
57 auto ite = std::find(syncers_.begin(), syncers_.end(), syncer); in RemoveSynchronizer()
60 … MEDIA_LOG_I("remove syncer supplier " PUBLIC_LOG_S, syncer->GetSynchronizerName().c_str()); in RemoveSynchronizer()
|