Home
last modified time | relevance | path

Searched refs:syncId (Results 1 – 25 of 57) sorted by relevance

123

/ohos5.0/foundation/multimedia/media_foundation/src/osal/base/
H A Dsynchronizer.h49 waitSet_.insert(syncId); in Wait()
51 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
52 syncMap_.erase(syncId); in Wait()
64 waitSet_.insert(syncId); in WaitFor()
68 syncMap_.erase(syncId); in WaitFor()
70 waitSet_.erase(syncId); in WaitFor()
83 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
85 syncMap_.erase(syncId); in Wait()
97 waitSet_.insert(syncId); in WaitFor()
99 waitSet_.erase(syncId); in WaitFor()
[all …]
/ohos5.0/foundation/multimedia/media_foundation/engine/include/foundation/osal/base/
H A Dsynchronizer.h50 waitSet_.insert(syncId); in Wait()
52 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
53 syncMap_.erase(syncId); in Wait()
65 waitSet_.insert(syncId); in WaitFor()
69 syncMap_.erase(syncId); in WaitFor()
71 waitSet_.erase(syncId); in WaitFor()
84 cv_.Wait(lock, [this, syncId] { return syncMap_.find(syncId) != syncMap_.end(); }); in Wait()
86 syncMap_.erase(syncId); in Wait()
98 waitSet_.insert(syncId); in WaitFor()
100 waitSet_.erase(syncId); in WaitFor()
[all …]
/ohos5.0/foundation/multimedia/media_foundation/test/unittest/
H A DTestSynchronizer.cpp64 int syncId = 0; variable
65 task1->RegisterHandler([this, syncId] { in __anon43a178830102()
67 synchronizer.Notify(syncId, 1234); in __anon43a178830102()
72 syncId, [] {}, timeoutMs); in __anon43a178830202()
82 int syncId = 0; variable
83 task1->RegisterHandler([this, syncId] { in __anon43a178830302()
85 synchronizer.Notify(syncId, 1234); in __anon43a178830302()
90 syncId, [] {}, timeoutMs); in __anon43a178830402()
96 int syncId = 0; variable
113 int syncId = 0; variable
[all …]
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_relational_syncer.cpp63 DoOnComplete(param, syncId); in PrepareSync()
82 DoOnSubSyncComplete(subSyncId, syncId, param, devicesMap); in GenerateEachSyncTask()
86 fullSyncIdMap_[syncId].insert(subSyncId); in GenerateEachSyncTask()
92 fullSyncIdMap_[syncId].erase(subSyncId); in GenerateEachSyncTask()
106 fullSyncIdMap_[syncId].erase(subSyncId); in DoOnSubSyncComplete()
107 allFinish = fullSyncIdMap_[syncId].empty(); in DoOnSubSyncComplete()
114 DoOnComplete(param, syncId); in DoOnSubSyncComplete()
128 void SingleVerRelationalSyncer::DoOnComplete(const SyncParma &param, uint32_t syncId) in DoOnComplete() argument
137 tmpMap = resMap_[syncId]; in DoOnComplete()
148 resMap_.erase(syncId); in DoOnComplete()
[all …]
H A Dsingle_ver_relational_syncer.h36 int PrepareSync(const SyncParma &param, uint32_t syncId, uint64_t connectionId) override;
42 int GenerateEachSyncTask(const SyncParma &param, uint32_t syncId,
47 void DoOnComplete(const SyncParma &param, uint32_t syncId);
48 void DoOnSubSyncComplete(const uint32_t subSyncId, const uint32_t syncId,
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp229 auto syncId = GenerateId(syncInfo.user_); in DoCloudSync() local
230 auto ref = GenSyncRef(syncId); in DoCloudSync()
244 if (Compare(syncId, user) == 0) { in StopCloudSync()
474 auto syncId = GenerateId(info.user_); in GetRetryer() local
475 auto ref = GenSyncRef(syncId); in GetRetryer()
480 return syncId; in GetRetryer()
489 return (syncId << MV_BIT) | (++genId_); in GenerateId()
492 RefCount SyncManager::GenSyncRef(uint64_t syncId) in GenSyncRef() argument
494 return RefCount([syncId, this]() { in GenSyncRef()
495 actives_.Erase(syncId); in GenSyncRef()
[all …]
H A Dsync_manager.h137 RefCount GenSyncRef(uint64_t syncId);
138 int32_t Compare(uint64_t syncId, int32_t user);
141 void UpdateFinishSyncInfo(const QueryKey &queryKey, uint64_t syncId, int32_t code);
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvstore_sync_manager.cpp24 Status KvStoreSyncManager::AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syn… in AddSyncOperation() argument
27 if (syncId == 0 || syncFunc == nullptr) { in AddSyncOperation()
40 KvSyncOperation syncOp{ syncId, opSeq, delayMs, syncFunc, endFunc, beginTime }; in AddSyncOperation()
69 Status KvStoreSyncManager::RemoveSyncOperation(uintptr_t syncId) in RemoveSyncOperation() argument
71 auto pred = [syncId](const KvSyncOperation &op) -> bool { return syncId == op.syncId; }; in RemoveSyncOperation()
H A Dkvstore_sync_manager.h45 uintptr_t syncId = 0; member
54 …Status AddSyncOperation(uintptr_t syncId, uint32_t delayMs, const SyncFunc &syncFunc, const SyncEn…
55 Status RemoveSyncOperation(uintptr_t syncId);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dgeneric_syncer.cpp188 uint32_t syncId = GenerateSyncId(); in Sync() local
234 int GenericSyncer::RemoveSyncOperation(int syncId) in RemoveSyncOperation() argument
238 auto iter = syncOperationMap_.find(syncId); in RemoveSyncOperation()
242 syncOperationMap_.erase(syncId); in RemoveSyncOperation()
258 syncIdMap_.erase(syncId); in RemoveSyncOperation()
275 for (auto syncId : syncIdList) { in StopSync() local
276 RemoveSyncOperation(syncId); in StopSync()
369 syncEngine_->RemoveSyncOperation(syncId); in SyncOperationKillCallbackInner()
375 SyncOperationKillCallbackInner(syncId); in SyncOperationKillCallback()
560 void GenericSyncer::OnSyncFinished(int syncId) in OnSyncFinished() argument
[all …]
H A Dgeneric_syncer.h59 int RemoveSyncOperation(int syncId) override;
128 virtual int PrepareSync(const SyncParma &param, uint32_t syncId, uint64_t connectionId);
134 virtual void SyncOperationKillCallbackInner(int syncId);
137 void SyncOperationKillCallback(int syncId);
171 void OnSyncFinished(int syncId);
H A Dsync_task_context.cpp83 auto syncId = static_cast<uint32_t>(target->GetSyncId()); in AddSyncTarget() local
95 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, targetMode, syncId]() { in AddSyncTarget()
96 CancelCurrentSyncRetryIfNeed(targetMode, syncId); in AddSyncTarget()
168 int SyncTaskContext::RemoveSyncOperation(int syncId) in RemoveSyncOperation() argument
172 [syncId](const ISyncTarget *target) { in RemoveSyncOperation()
176 return target->GetSyncId() == syncId; in RemoveSyncOperation()
645 void SyncTaskContext::CancelCurrentSyncRetryIfNeed(int newTargetMode, uint32_t syncId) in CancelCurrentSyncRetryIfNeed() argument
651 if (syncId_ >= syncId) { in CancelCurrentSyncRetryIfNeed()
795 void SyncTaskContext::AbortMachineIfNeed(uint32_t syncId) in AbortMachineIfNeed() argument
800 if (syncId_ != syncId) { in AbortMachineIfNeed()
H A Dsync_task_context.h56 int RemoveSyncOperation(int syncId) override;
210 void AbortMachineIfNeed(uint32_t syncId) override;
238 void CancelCurrentSyncRetryIfNeed(int newTargetMode, uint32_t syncId);
H A Disync_engine.h47 virtual void RemoveSyncOperation(int syncId) = 0;
97 virtual void AbortMachineIfNeed(uint32_t syncId) = 0;
H A Disync_task_context.h54 virtual int RemoveSyncOperation(int syncId) = 0;
182 virtual void AbortMachineIfNeed(uint32_t syncId) = 0;
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp540 SyncId syncId = ++syncTaskId_; in Sync() local
548 tasks_->Insert(syncId, { id, callback }); in Sync()
553 tasks_ != nullptr ? GetCB(syncId) : callback, syncId); in Sync()
557 … tasks_->ComputeIfPresent(syncId, [executor = executor_](SyncId syncId, const FinishTask &task) { in Sync() argument
1101 bool RdbGeneralStore::IsFinished(SyncId syncId) const in IsFinished()
1116 task->Erase(syncId); in GetFinishTask()
1119 if (!IsFinished(syncId)) { in GetFinishTask()
1120 … task->ComputeIfPresent(syncId, [executor = executor_, this](SyncId syncId, FinishTask &task) { in GetFinishTask() argument
1127 …task->ComputeIfPresent(syncId, [&cb, executor = executor_](SyncId syncId, const FinishTask &task) { in GetFinishTask() argument
1158 syncId); in RemoveTasks()
[all …]
H A Drdb_general_store.h141 DBProcessCB GetCB(SyncId syncId);
142 DBProcessCB GetDBProcessCB(DetailAsync async, uint32_t syncMode, SyncId syncId,
144 Executor::Task GetFinishTask(SyncId syncId);
155 bool IsFinished(uint64_t syncId) const;
/ohos5.0/docs/zh-cn/device-dev/reference/hdi-apis/ril/
H A D_cell_rat_tdscdma_v10.md21 | int [syncId](#syncid) | 同步标识 |
114 ### syncId subsection
117 int CellRatTdscdma::syncId
H A D_cell_rat_tdscdma_v11.md21 | int [syncId](#syncid) | 同步标识 |
114 ### syncId subsection
117 int CellRatTdscdma::syncId
H A D_cell_list_rat_tdscdma_v10.md21 | int [syncId](#syncid) | 同步标识 |
114 ### syncId subsection
117 int CellListRatTdscdma::syncId
H A D_cell_list_rat_tdscdma_v11.md21 | int [syncId](#syncid) | 同步标识 |
114 ### syncId subsection
117 int CellListRatTdscdma::syncId
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/
H A Dmulti_ver_syncer.cpp115 void MultiVerSyncer::SyncOperationKillCallbackInner(int syncId) in SyncOperationKillCallbackInner() argument
118 LOGI("[MultiVerSyncer] Operation on kill id = %d", syncId); in SyncOperationKillCallbackInner()
122 GenericSyncer::SyncOperationKillCallbackInner(syncId); in SyncOperationKillCallbackInner()
/ohos5.0/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/transaction/
H A Drs_transaction_proxy.h65 void SetSyncId(const uint64_t syncId) in SetSyncId() argument
67 syncId_ = syncId; in SetSyncId()
H A Drs_transaction_data.h153 void SetSyncId(const uint64_t syncId) in SetSyncId() argument
155 syncId_ = syncId; in SetSyncId()
/ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/
H A Dkvdb_service_test.cpp235 uintptr_t syncId = 0; variable
238 auto kvStatus = syncManager.AddSyncOperation(syncId, 0, syncFunc, syncEnd);
240 syncId = 1;
241 kvStatus = syncManager.AddSyncOperation(syncId, 0, syncFunc, syncEnd);
262 uintptr_t syncId = 0; variable
263 auto kvStatus = syncManager.RemoveSyncOperation(syncId);
278 syncOp.syncId = 1;

123