| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | syncer_proxy.cpp | 24 : syncer_(nullptr) in SyncerProxy()
41 if (syncer_ == nullptr) { in Initialize()
51 if (syncer_ == nullptr) { in Close()
69 if (syncer_ == nullptr) { in Sync()
85 if (syncer_ == nullptr) { in StopSync()
93 if (syncer_ == nullptr) { in GetTimestamp()
101 if (syncer_ == nullptr) { in EnableAutoSync()
115 if (syncer_ == nullptr) { in EraseDeviceWaterMark()
124 if (syncer_ == nullptr) { in LocalDataChanged()
132 if (syncer_ == nullptr) { in GetQueuedSyncSize()
[all …]
|
| /ohos5.0/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()
79 … CHECK_AND_RETURN_RET_LOG(syncer_->GetAVMetaData(metaData) == AVSESSION_SUCCESS, AVSESSION_ERROR, in HandleSessionDataCategory()
129 syncer_->Destroy(); in CancelCastSession()
130 syncer_ = nullptr; in CancelCastSession()
136 CHECK_AND_RETURN_RET_LOG(syncer_ != nullptr, AVSESSION_ERROR, "syncer is nullptr"); in SetControlCommand()
137 auto ret = syncer_->PutControlCommand(command); in SetControlCommand()
152 CHECK_AND_RETURN_RET_LOG(syncer_ != nullptr, AVSESSION_ERROR, "syncer is nullptr"); in SetCommonCommand()
[all …]
|
| H A D | remote_session_sink_impl.h | 46 std::shared_ptr<RemoteSessionSyncer> syncer_;
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/kv/ |
| H A D | sync_able_kvdb.cpp | 102 return syncer_.EnableAutoSync(enable); in EnableAutoSync()
116 syncer_.StopSync(connectionId); in StopSync()
239 syncer_.Close(isClosedOperation); in StopSyncerWithNoLock()
313 return syncer_.GetTimestamp(); in GetTimestamp()
350 return syncer_.DisableManualSync(); in DisableManualSync()
355 return syncer_.EnableManualSync(); in EnableManualSync()
443 return syncer_.SetSyncRetry(isRetry); in SetSyncRetry()
461 syncer_.Dump(fd); in Dump()
507 syncer_.ResetSyncStatus(); in ResetSyncStatus()
541 return syncer_.GetLocalTimeOffset(); in GetLocalTimeOffset()
[all …]
|
| H A D | sync_able_kvdb.h | 164 SyncerProxy syncer_; variable
|
| /ohos5.0/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_.Dump(fd); in Dump()
[all …]
|
| H A D | sync_able_engine.h | 76 SyncerProxy syncer_; // use for sync Interactive variable
|
| /ohos5.0/drivers/hdf_core/interfaces/inner_api/hdi/base/ |
| H A D | hdi_smq.h | 257 std::unique_ptr<SharedMemQueueSyncer> syncer_ = nullptr; variable
347 syncer_ = std::make_unique<SharedMemQueueSyncer>(syncerPtr_); in Init()
444 return syncer_->Wake(SharedMemQueueSyncer::SYNC_WORD_READ); in Write()
460 ret = syncer_->Wait(SharedMemQueueSyncer::SYNC_WORD_WRITE, waitTimeNanoSec); in Write()
472 ret = syncer_->Wake(SharedMemQueueSyncer::SYNC_WORD_READ); in Write()
489 return syncer_->Wake(SharedMemQueueSyncer::SYNC_WORD_WRITE); in Read()
505 ret = syncer_->Wait(SharedMemQueueSyncer::SYNC_WORD_READ, waitTimeNanoSec); in Read()
516 ret = syncer_->Wake(SharedMemQueueSyncer::SYNC_WORD_WRITE); in Read()
|
| /ohos5.0/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_; variable
|
| /ohos5.0/drivers/hdf_core/adapter/uhdf2/hdi/test/smq_test/ |
| H A D | smq_test.cpp | 345 std::unique_ptr<OHOS::HDI::Base::SharedMemQueueSyncer> syncer_ = variable
347 syncer_->Wake(OHOS::HDI::Base::SharedMemQueueSyncer::SYNC_WORD_WRITE);
348 syncer_->Wait(OHOS::HDI::Base::SharedMemQueueSyncer::SYNC_WORD_WRITE, 0);
349 syncer_->Wake(OHOS::HDI::Base::SharedMemQueueSyncer::SYNC_WORD_WRITE);
350 syncer_->Wait(OHOS::HDI::Base::SharedMemQueueSyncer::SYNC_WORD_WRITE, 5);
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include/ |
| H A D | syncer_proxy.h | 123 std::shared_ptr<ISyncer> syncer_; variable
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/ |
| H A D | meta_data_manager.h | 95 Syncer syncer_; variable
|
| /ohos5.0/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_… in LocalChange()
68 return syncer_.Close(true); in Close()
71 SyncerProxy syncer_; member in TestKvDb
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 176 syncer_ = syncer; in SetSyncer()
|