| /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()
105 LOGW("[ProcessNotifier] cancel notify because syncer is nullptr"); in NotifyProcess()
108 RefObject::IncObjRef(syncer); in NotifyProcess()
109 auto id = syncer->GetIdentify(); in NotifyProcess()
110 int errCode = RuntimeContext::GetInstance()->ScheduleQueuedTask(id, [callback, currentProcess, syncer]() { in NotifyProcess()
112 if (syncer->IsClosed()) { in NotifyProcess()
114 RefObject::DecObjRef(syncer); in NotifyProcess()
[all...] |
| H A D | process_notifier.h | 22 explicit ProcessNotifier(ICloudSyncer *syncer);
|
| /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()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_mock_sync_module_test.cpp | 267 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); in SyncLifeTest001() local
273 EXPECT_EQ(syncer->Initialize(syncDBInterface, true), -E_INVALID_ARGS); in SyncLifeTest001()
274 syncer->EnableAutoSync(true); in SyncLifeTest001()
276 syncer->LocalDataChanged(static_cast<int>(SQLiteGeneralNSNotificationEventType::SQLITE_GENERAL_NS_PUT_EVENT)); in SyncLifeTest001()
279 syncer = nullptr; in SyncLifeTest001()
286 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); in SyncLifeTest002() local
300 EXPECT_EQ(syncer->Initialize(syncDBInterface, true), E_OK); in SyncLifeTest002()
301 syncer->EnableAutoSync(true); in SyncLifeTest002()
303 std::thread writeThread([syncer]() { in SyncLifeTest002()
304 syncer in SyncLifeTest002()
355 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); SyncerCheck001() local
1097 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); HWTEST_F() local
1129 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); HWTEST_F() local
1844 SingleVerKVSyncer syncer; HWTEST_F() local
1877 MockSingleVerKVSyncer syncer; HWTEST_F() local
1924 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); HWTEST_F() local
1966 MockSingleVerKVSyncer syncer; HWTEST_F() local
2000 MockSingleVerKVSyncer syncer; HWTEST_F() local
2013 MockSingleVerKVSyncer syncer; HWTEST_F() local
2029 std::shared_ptr<SingleVerKVSyncer> syncer = std::make_shared<SingleVerKVSyncer>(); HWTEST_F() local
2048 MockSingleVerKVSyncer syncer; HWTEST_F() local
2073 MockSingleVerKVSyncer syncer; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 148 LOGI("syncer no need to active"); in SetSyncModuleActive()
164 // Start syncer
211 // Stop syncer
318 // if syncer not start, get offset time from database in GetTimestamp()
540 LOGW("[SyncAbleKvDB][StartCloudSyncer] start cloud syncer and cloud syncer was not initialized"); in StartCloudSyncer()
571 int SyncAbleKvDB::CheckSyncOption(const CloudSyncOption &option, const CloudSyncer &syncer) in CheckSyncOption() argument
577 const std::map<std::string, std::shared_ptr<ICloudDb>> &cloudDBs = syncer.GetCloudDB(); in CheckSyncOption()
609 auto syncer = GetAndIncCloudSyncer(); in Sync() local
610 if (syncer in Sync()
628 auto syncer = GetAndIncCloudSyncer(); SetCloudDB() local
640 auto syncer = GetAndIncCloudSyncer(); CleanAllWaterMark() local
[all...] |
| H A D | sync_able_kvdb.h | 125 // Start syncer
130 // Stop syncer
163 int CheckSyncOption(const CloudSyncOption &option, const CloudSyncer &syncer);
|
| /foundation/multimedia/media_foundation/engine/include/pipeline/core/ |
| H A D | i_media_sync_center.h | 38 virtual void AddSynchronizer(IMediaSynchronizer* syncer) = 0;
40 virtual void RemoveSynchronizer(IMediaSynchronizer* syncer) = 0;
|
| H A D | media_sync_manager.h | 44 void AddSynchronizer(IMediaSynchronizer* syncer) override;
46 void RemoveSynchronizer(IMediaSynchronizer* syncer) override;
|
| /foundation/multimedia/av_codec/test/unittest/media_sink_test/ |
| H A D | sync_manager_test.cpp | 261 // Scenario1: Test when syncer is nullptr then AddSynchronizer does nothing.
264 IMediaSynchronizer* syncer = nullptr;
in HWTEST_F() local
265 syncManager_->AddSynchronizer(syncer);
in HWTEST_F()
269 // Scenario2: Test when syncer is not nullptr and not already in syncers_ then AddSynchronizer adds the syncer.
272 IMediaSynchronizer* syncer = new VideoSink();
in HWTEST_F() local
273 syncManager_->AddSynchronizer(syncer);
in HWTEST_F()
275 EXPECT_EQ(syncManager_->syncers_[0], syncer);
in HWTEST_F()
276 delete syncer;
in HWTEST_F()
279 // Scenario3: Test when syncer i
282 IMediaSynchronizer* syncer = new VideoSink(); HWTEST_F() local
292 IMediaSynchronizer* syncer = nullptr; HWTEST_F() local
300 IMediaSynchronizer* syncer = new VideoSink(); HWTEST_F() local
[all...] |
| /foundation/multimedia/av_codec/test/unittest/media_sink_test/mock/include/ |
| H A D | media_sync_center_mock.h | 28 void AddSynchronizer(Pipeline::IMediaSynchronizer* syncer) override;
29 void RemoveSynchronizer(Pipeline::IMediaSynchronizer* syncer) override;
|
| /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 supplie in RemoveSynchronizer()
[all...] |
| /foundation/multimedia/av_codec/services/media_engine/modules/sink/ |
| H A D | i_media_sync_center.h | 42 virtual void AddSynchronizer(IMediaSynchronizer* syncer) = 0;
44 virtual void RemoveSynchronizer(IMediaSynchronizer* syncer) = 0;
|
| H A D | media_sync_manager.cpp | 44 void MediaSyncManager::AddSynchronizer(IMediaSynchronizer* syncer) in AddSynchronizer() argument
46 if (syncer != nullptr) { in AddSynchronizer()
48 if (std::find(syncers_.begin(), syncers_.end(), syncer) != syncers_.end()) { in AddSynchronizer()
51 syncers_.emplace_back(syncer); in AddSynchronizer()
55 void MediaSyncManager::RemoveSynchronizer(IMediaSynchronizer* syncer) in RemoveSynchronizer() argument
57 if (syncer != nullptr) { in RemoveSynchronizer()
59 auto ite = std::find(syncers_.begin(), syncers_.end(), syncer); in RemoveSynchronizer()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_strategy_test.cpp | 324 auto syncer = new(std::nothrow) VirtualCloudSyncer(nullptr); in HWTEST_F() local
325 ASSERT_NE(syncer, nullptr); in HWTEST_F()
329 EXPECT_EQ(syncer->CallTagStatusByStrategy(true, localInfo, cloudInfo, result), E_OK); in HWTEST_F()
332 EXPECT_EQ(syncer->CallTagStatusByStrategy(true, localInfo, cloudInfo, result), -E_INTERNAL_ERROR); in HWTEST_F()
333 RefObject::KillAndDecObjRef(syncer); in HWTEST_F()
|
| /foundation/multimedia/av_session/services/session/server/remote/ |
| H A D | remote_session_source_impl.cpp | 42 auto syncer = std::make_shared<RemoteSessionSyncerImpl>(session->GetSessionId(), sourceDevice, sinkDevice); in CastSessionToRemote() local
43 CHECK_AND_RETURN_RET_LOG(syncer != nullptr, AVSESSION_ERROR, "syncer is nullptr"); in CastSessionToRemote()
44 int32_t ret = syncer->Init(); in CastSessionToRemote()
45 CHECK_AND_RETURN_RET_LOG(ret == AVSESSION_SUCCESS, ret, "syncer init failed"); in CastSessionToRemote()
46 syncers_[sinkDevice] = syncer; in CastSessionToRemote()
57 "syncer is not exist"); in CastSessionToRemote()
77 "syncer is not exist"); in CastSessionToRemote()
114 CHECK_AND_RETURN_RET_LOG(!syncers_.empty(), AVSESSION_SUCCESS, "syncer is empty"); in CancelCastAudio()
158 SLOGI("syncer in SetAVPlaybackState()
[all...] |
| /foundation/multimedia/av_codec/interfaces/inner_api/native/ |
| H A D | media_sync_manager.h | 53 void AddSynchronizer(IMediaSynchronizer* syncer) override;
55 void RemoveSynchronizer(IMediaSynchronizer* syncer) override;
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/ |
| H A D | meta_data_manager.h | 56 API_EXPORT void SetSyncer(const Syncer &syncer);
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 171 void MetaDataManager::SetSyncer(const Syncer &syncer) in SetSyncer() argument
176 syncer_ = syncer; in SetSyncer()
|