| /foundation/multimedia/media_foundation/engine/include/foundation/osal/base/ |
| D | synchronizer.h | 44 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps) in Wait()
57 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor()
76 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps, ResultType& result) in Wait()
90 …bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& … in WaitFor()
|
| /foundation/multimedia/media_foundation/src/osal/base/ |
| D | synchronizer.h | 43 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps) in Wait()
56 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor()
75 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps, ResultType& result) in Wait()
89 …bool WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& … in WaitFor()
|
| /foundation/multimedia/media_foundation/test/unittest/ |
| D | TestSynchronizer.cpp | 64 int syncId = 0; variable
82 int syncId = 0; variable
96 int syncId = 0; variable
113 int syncId = 0; variable
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| D | single_ver_relational_syncer.cpp | 41 int SingleVerRelationalSyncer::PrepareSync(const SyncParma ¶m, uint32_t syncId, uint64_t connec… in PrepareSync()
69 int SingleVerRelationalSyncer::GenerateEachSyncTask(const SyncParma ¶m, uint32_t syncId, in GenerateEachSyncTask()
100 void SingleVerRelationalSyncer::DoOnSubSyncComplete(const uint32_t subSyncId, const uint32_t syncId, in DoOnSubSyncComplete()
128 void SingleVerRelationalSyncer::DoOnComplete(const SyncParma ¶m, uint32_t syncId) in DoOnComplete()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
| D | store_info.h | 29 uint64_t syncId = 0; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/kvdb/include/ |
| D | kvdb_service.h | 35 uint64_t syncId = 0; member
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/transaction/ |
| D | rs_transaction_proxy.h | 65 void SetSyncId(const uint64_t syncId) in SetSyncId()
|
| D | rs_transaction_data.h | 153 void SetSyncId(const uint64_t syncId) in SetSyncId()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| D | sync_manager.cpp | 210 actives_.ForEachCopies([this](auto &syncId, auto &taskId) { in ~SyncManager()
229 auto syncId = GenerateId(syncInfo.user_); in DoCloudSync() local
243 actives_.ForEachCopies([this, user](auto &syncId, auto &taskId) { in StopCloudSync()
474 auto syncId = GenerateId(info.user_); in GetRetryer() local
488 uint64_t syncId = static_cast<uint64_t>(user) & 0xFFFFFFFF; in GenerateId() local
492 RefCount SyncManager::GenSyncRef(uint64_t syncId) in GenSyncRef()
499 int32_t SyncManager::Compare(uint64_t syncId, int32_t user) in Compare()
709 void SyncManager::UpdateFinishSyncInfo(const QueryKey &queryKey, uint64_t syncId, int32_t code) in UpdateFinishSyncInfo()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/ |
| D | rdb_general_store.cpp | 540 SyncId syncId = ++syncTaskId_; in Sync() local
557 … tasks_->ComputeIfPresent(syncId, [executor = executor_](SyncId syncId, const FinishTask &task) { in Sync()
731 …e::DBProcessCB RdbGeneralStore::GetDBProcessCB(DetailAsync async, uint32_t syncMode, SyncId syncId, in GetDBProcessCB()
1111 Executor::Task RdbGeneralStore::GetFinishTask(SyncId syncId) in GetFinishTask()
1120 … task->ComputeIfPresent(syncId, [executor = executor_, this](SyncId syncId, FinishTask &task) { in GetFinishTask()
1127 …task->ComputeIfPresent(syncId, [&cb, executor = executor_](SyncId syncId, const FinishTask &task) { in GetFinishTask()
1155 …tasks_->EraseIf([&cbs, &taskIds, store = storeInfo_.storeName](SyncId syncId, const FinishTask &ta… in RemoveTasks()
1178 RdbGeneralStore::DBProcessCB RdbGeneralStore::GetCB(SyncId syncId) in GetCB()
1185 … task->ComputeIfPresent(syncId, [&cb, &progress, executor](SyncId syncId, FinishTask &finishTask) { in GetCB()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| D | generic_syncer.cpp | 188 uint32_t syncId = GenerateSyncId(); in Sync() local
198 int GenericSyncer::PrepareSync(const SyncParma ¶m, uint32_t syncId, uint64_t connectionId) in PrepareSync()
234 int GenericSyncer::RemoveSyncOperation(int syncId) in RemoveSyncOperation()
275 for (auto syncId : syncIdList) { in StopSync() local
365 void GenericSyncer::SyncOperationKillCallbackInner(int syncId) in SyncOperationKillCallbackInner()
373 void GenericSyncer::SyncOperationKillCallback(int syncId) in SyncOperationKillCallback()
560 void GenericSyncer::OnSyncFinished(int syncId) in OnSyncFinished()
|
| D | sync_task_context.cpp | 83 auto syncId = static_cast<uint32_t>(target->GetSyncId()); in AddSyncTarget() local
168 int SyncTaskContext::RemoveSyncOperation(int syncId) in RemoveSyncOperation()
645 void SyncTaskContext::CancelCurrentSyncRetryIfNeed(int newTargetMode, uint32_t syncId) in CancelCurrentSyncRetryIfNeed()
795 void SyncTaskContext::AbortMachineIfNeed(uint32_t syncId) in AbortMachineIfNeed()
|
| D | syncer_proxy.cpp | 75 int SyncerProxy::RemoveSyncOperation(int syncId) in RemoveSyncOperation()
|
| D | sync_engine.cpp | 186 void SyncEngine::RemoveSyncOperation(int syncId) in RemoveSyncOperation()
1164 void SyncEngine::AbortMachineIfNeed(uint32_t syncId) in AbortMachineIfNeed()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| D | kvstore_sync_manager.cpp | 24 Status KvStoreSyncManager::AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syn… in AddSyncOperation()
69 Status KvStoreSyncManager::RemoveSyncOperation(uintptr_t syncId) in RemoveSyncOperation()
|
| D | kvstore_sync_manager.h | 45 uintptr_t syncId = 0; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| D | multi_ver_syncer.cpp | 115 void MultiVerSyncer::SyncOperationKillCallbackInner(int syncId) in SyncOperationKillCallbackInner()
|
| /foundation/multimedia/media_lite/services/player_lite/impl/player_control/sink/ |
| D | player_sink_manager.h | 32 int32_t syncId; member
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| D | kvdb_service_test.cpp | 235 uintptr_t syncId = 0; variable
262 uintptr_t syncId = 0; variable
|
| /foundation/graphic/graphic_2d/interfaces/kits/napi/graphic/webgl/src/ |
| D | webgl2_rendering_context_impl.cpp | 433 int64_t syncId = webGlSync->GetSync(); in IsSync() local
445 int64_t syncId = webGlSync->GetSync(); in DeleteSync() local
459 int64_t syncId = webGlSync->GetSync(); in ClientWaitSync() local
478 int64_t syncId = webGlSync->GetSync(); in WaitSync() local
496 int64_t syncId = webGlSync->GetSync(); in GetSyncParameter() local
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| D | sync_operation.cpp | 23 SyncOperation::SyncOperation(uint32_t syncId, const std::vector<std::string> &devices, in SyncOperation()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| D | distributeddb_mock_sync_module_test.cpp | 1277 const int syncId = 1; variable
1315 const int syncId = 1; variable
|