| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | syncer_proxy.cpp | 24 : syncer_(nullptr) in SyncerProxy()
37 if (syncer_ == nullptr) { in Initialize()
38 syncer_ = SyncerFactory::GetSyncer(interfaceType); in Initialize()
41 if (syncer_ == nullptr) { in Initialize()
46 return syncer_->Initialize(syncInterface, isNeedActive); in Initialize()
51 if (syncer_ == nullptr) { in Close()
54 return syncer_->Close(isClosedOperation); in Close()
61 if (syncer_ == nullptr) { // LCOV_EXCL_BR_LINE in Sync()
64 return syncer_->Sync(devices, mode, onComplete, onFinalize, wait); in Sync()
69 if (syncer_ in Sync()
[all...] |
| /foundation/multimedia/av_session/services/session/server/remote/ |
| H A D | remote_session_sink_impl.cpp | 42 syncer_ = std::make_shared<RemoteSessionSyncerImpl>(sourceSessionId, sourceDevice, sinkDevice); in CastSessionFromRemote()
43 CHECK_AND_RETURN_RET_LOG(syncer_ != nullptr, AVSESSION_ERROR, "syncer_ is nullptr"); in CastSessionFromRemote()
44 int32_t ret = syncer_->Init(); in CastSessionFromRemote()
50 ret = syncer_->RegisterDisconnectNotifier([this](const std::string& deviceId) { in CastSessionFromRemote()
64 ret = syncer_->RegisterDataNotifier([this](const SessionDataCategory category, const std::string& deviceId) { in CastSessionFromRemote()
66 CHECK_AND_RETURN_RET_LOG(session_ != nullptr && syncer_ != nullptr, AVSESSION_ERROR, "session_ is nullptr"); in CastSessionFromRemote()
79 CHECK_AND_RETURN_RET_LOG(syncer_->GetAVMetaData(metaData) == AVSESSION_SUCCESS, AVSESSION_ERROR, in HandleSessionDataCategory()
86 CHECK_AND_RETURN_RET_LOG(syncer_->GetAVPlaybackState(playbackState) == AVSESSION_SUCCESS, AVSESSION_ERROR, in HandleSessionDataCategory()
94 CHECK_AND_RETURN_RET_LOG(syncer_ in HandleSessionDataCategory()
[all...] |
| H A D | remote_session_sink_impl.h | 46 std::shared_ptr<RemoteSessionSyncer> syncer_; member in OHOS::AVSession::RemoteSessionSinkImpl
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | sync_able_engine.cpp | 28 : syncer_(), in SyncAbleEngine()
54 return syncer_.Sync(parm, connectionId); in Sync()
73 return syncer_.GetTimestamp(); in GetTimestamp()
84 return syncer_.EraseDeviceWaterMark(deviceId, isNeedHash, tableName); in EraseDeviceWaterMark()
111 int errCode = syncer_.Initialize(store_, isNeedActive); in StartSyncerWithNoLock()
154 syncer_.Close(isClosedOperation); in StopSyncerWithNoLock()
240 return syncer_.GetLocalIdentity(outTarget); in GetLocalIdentity()
246 syncer_.StopSync(connectionId); in StopSync()
252 SyncerBasicInfo basicInfo = syncer_.DumpSyncerBasicInfo(); in Dump()
257 syncer_ in Dump()
[all...] |
| H A D | sync_able_engine.h | 76 SyncerProxy syncer_; // use for sync Interactive member in DistributedDB::final
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 69 syncer_.LocalDataChanged(notifyEvent); in TriggerSync()
94 return syncer_.Sync(parma, connectionId); in Sync()
103 return syncer_.CancelSync(syncId); in CancelSync()
111 return syncer_.EnableAutoSync(enable); in EnableAutoSync()
125 syncer_.StopSync(connectionId); in StopSync()
189 int errCode = syncer_.Initialize(syncInterface, isNeedActive); in StartSyncerWithNoLock()
248 syncer_.Close(isClosedOperation); in StopSyncerWithNoLock()
322 return syncer_.GetTimestamp(); in GetTimestamp()
339 return syncer_.EraseDeviceWaterMark(deviceId, isNeedHash); in EraseDeviceWaterMark()
344 return syncer_ in GetQueuedSyncSize()
[all...] |
| H A D | sync_able_kvdb.h | 167 SyncerProxy syncer_; member in DistributedDB::SyncAbleKvDB
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | process_notifier.cpp | 22 : syncer_(syncer) in ProcessNotifier()
24 RefObject::IncObjRef(syncer_); in ProcessNotifier()
29 RefObject::DecObjRef(syncer_); in ~ProcessNotifier()
103 ICloudSyncer *syncer = syncer_; in NotifyProcess()
|
| H A D | process_notifier.h | 53 ICloudSyncer *syncer_; member in DistributedDB::ProcessNotifier
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/ |
| H A D | meta_data_manager.h | 95 Syncer syncer_; member in OHOS::DistributedData::MetaDataManager
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include/ |
| H A D | syncer_proxy.h | 126 std::shared_ptr<ISyncer> syncer_; member in DistributedDB::SyncerProxy
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | distributeddb_mock_sync_module_test.cpp | 59 syncer_.Initialize(syncInterface, true); in Initialize()
60 syncer_.EnableAutoSync(true); in Initialize()
64 syncer_.LocalDataChanged(static_cast<int>(SQLiteGeneralNSNotificationEventType::SQLITE_GENERAL_NS_PUT_EVENT)); in LocalChange()
68 return syncer_.Close(true); in Close()
71 SyncerProxy syncer_; member in TestKvDb
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 176 syncer_ = syncer; in SetSyncer()
|