Home
last modified time | relevance | path

Searched refs:syncId (Results 1 - 25 of 55) sorted by relevance

123

/foundation/multimedia/media_foundation/engine/include/foundation/osal/base/
H A Dsynchronizer.h44 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps) in Wait() argument
47 name_.c_str(), static_cast<int>(syncId)); in Wait()
50 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()
57 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor() argument
60 name_.c_str(), static_cast<int>(syncId), timeoutMs); in WaitFor()
65 waitSet_.insert(syncId); in WaitFor()
67 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { retur in WaitFor()
76 Wait(SyncIdType syncId, const std::function<void()>& asyncOps, ResultType& result) Wait() argument
90 WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result) WaitFor() argument
115 Notify(SyncIdType syncId, ResultType result = ResultType()) Notify() argument
[all...]
/foundation/multimedia/media_foundation/src/osal/base/
H A Dsynchronizer.h43 void Wait(SyncIdType syncId, const std::function<void()>& asyncOps) in Wait() argument
46 name_.c_str(), static_cast<int>(syncId)); in Wait()
49 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()
56 bool WaitFor(SyncIdType syncId, const std::function<void()>& asyncOps, int timeoutMs) in WaitFor() argument
59 name_.c_str(), static_cast<int>(syncId), timeoutMs); in WaitFor()
64 waitSet_.insert(syncId); in WaitFor()
66 auto rtv = cv_.WaitFor(lock, timeoutMs, [this, syncId] { retur in WaitFor()
75 Wait(SyncIdType syncId, const std::function<void()>& asyncOps, ResultType& result) Wait() argument
89 WaitFor(SyncIdType syncId, const std::function<bool()>& asyncOps, int timeoutMs, ResultType& result) WaitFor() argument
114 Notify(SyncIdType syncId, ResultType result = ResultType()) Notify() argument
[all...]
/foundation/multimedia/media_foundation/test/unittest/
H A DTestSynchronizer.cpp64 int syncId = 0; in HWTEST_F() local
65 task1->RegisterHandler([this, syncId] { in HWTEST_F()
67 synchronizer.Notify(syncId, 1234); in HWTEST_F()
72 syncId, [] {}, timeoutMs); in HWTEST_F()
82 int syncId = 0; in HWTEST_F() local
83 task1->RegisterHandler([this, syncId] { in HWTEST_F()
85 synchronizer.Notify(syncId, 1234); in HWTEST_F()
90 syncId, [] {}, timeoutMs); in HWTEST_F()
96 int syncId = 0; in HWTEST_F() local
98 task1->RegisterHandler([this, syncId, expec in HWTEST_F()
113 int syncId = 0; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/
H A Dsingle_ver_relational_syncer.cpp41 int SingleVerRelationalSyncer::PrepareSync(const SyncParma &param, uint32_t syncId, uint64_t connectionId) in PrepareSync() argument
51 int errCode = GenerateEachSyncTask(param, syncId, tablesQuery, connectionId, subSyncIdSet); in PrepareSync()
63 DoOnComplete(param, syncId); in PrepareSync()
69 int SingleVerRelationalSyncer::GenerateEachSyncTask(const SyncParma &param, uint32_t syncId, in GenerateEachSyncTask() argument
79 subSyncId, syncId, STR_MASK(DBCommon::TransferStringToHex(hashTableName))); in GenerateEachSyncTask()
81 subParam.onComplete = [this, subSyncId, syncId, param](const std::map<std::string, int> &devicesMap) { in GenerateEachSyncTask()
82 DoOnSubSyncComplete(subSyncId, syncId, param, devicesMap); in GenerateEachSyncTask()
86 fullSyncIdMap_[syncId].insert(subSyncId); in GenerateEachSyncTask()
92 fullSyncIdMap_[syncId].erase(subSyncId); in GenerateEachSyncTask()
100 void SingleVerRelationalSyncer::DoOnSubSyncComplete(const uint32_t subSyncId, const uint32_t syncId, in DoOnSubSyncComplete() argument
128 DoOnComplete(const SyncParma &param, uint32_t syncId) DoOnComplete() argument
[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,
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/
H A Dsync_manager.cpp218 actives_.ForEachCopies([this](auto &syncId, auto &taskId) { in ~SyncManager()
237 auto syncId = GenerateId(syncInfo.user_); in DoCloudSync() local
238 auto ref = GenSyncRef(syncId); in DoCloudSync()
239 actives_.Compute(syncId, [this, &ref, &syncInfo](const uint64_t &key, TaskId &taskId) mutable { in DoCloudSync()
251 actives_.ForEachCopies([this, user](auto &syncId, auto &taskId) { in StopCloudSync()
252 if (Compare(syncId, user) == 0) { in StopCloudSync()
265 ZLOGE("cloudInfo invalid:%{public}d, <syncId:%{public}s, metaId:%{public}s>", cloud.IsValid(), in IsValid()
406 { storeInfo.bundleName.c_str(), CLOUD_SYNC, TRIGGER_SYNC, storeInfo.syncId, evt.GetTriggerMode() },
419 UpdateFinishSyncInfo({ GetAccountId(storeInfo.user), storeInfo.bundleName, "" }, storeInfo.syncId, E_ERROR);
424 RadarReporter::Report({ storeInfo.bundleName.c_str(), CLOUD_SYNC, FINISH_SYNC, storeInfo.syncId,
[all...]
H A Dsync_manager.h138 RefCount GenSyncRef(uint64_t syncId);
139 int32_t Compare(uint64_t syncId, int32_t user);
141 void UpdateFinishSyncInfo(const QueryKey &queryKey, uint64_t syncId, int32_t code);
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/
H A Dgeneric_syncer.cpp188 uint32_t syncId = GenerateSyncId(); in Sync() local
189 errCode = PrepareSync(param, syncId, connectionId); in Sync()
198 int GenericSyncer::CancelSync(uint32_t syncId) in CancelSync() argument
200 LOGI("[Syncer] Start cancelSync %" PRIu32 "", syncId); in CancelSync()
210 auto iter = syncOperationMap_.find(syncId); in CancelSync()
212 LOGE("[Syncer] Non-existent syncId %" PRIu32 "", syncId); in CancelSync()
217 LOGE("[Syncer] Can't cancel syncId %" PRIu32 " %" PRIu32 "", syncId, iter->second->CanCancel()); in CancelSync()
228 LOGI("[Syncer] End cancelSync %" PRIu32 ", devices = %s", syncId, GetSyncDevicesSt in CancelSync()
235 PrepareSync(const SyncParma &param, uint32_t syncId, uint64_t connectionId) PrepareSync() argument
271 RemoveSyncOperation(int syncId) RemoveSyncOperation() argument
402 SyncOperationKillCallbackInner(int syncId) SyncOperationKillCallbackInner() argument
410 SyncOperationKillCallback(int syncId) SyncOperationKillCallback() argument
597 OnSyncFinished(int syncId) OnSyncFinished() argument
[all...]
H A Dgeneric_syncer.h59 int CancelSync(uint32_t syncId) override;
61 // Remove the operation, with the given syncId, used to clean resource if sync finished or failed.
62 int RemoveSyncOperation(int syncId) override;
131 virtual int PrepareSync(const SyncParma &param, uint32_t syncId, uint64_t connectionId);
137 virtual void SyncOperationKillCallbackInner(int syncId);
140 void SyncOperationKillCallback(int syncId);
174 void OnSyncFinished(int syncId);
H A Dsync_task_context.cpp82 auto syncId = static_cast<uint32_t>(target->GetSyncId()); in AddSyncTarget() local
94 int errCode = RuntimeContext::GetInstance()->ScheduleTask([this, targetMode, syncId]() { in AddSyncTarget()
95 CancelCurrentSyncRetryIfNeed(targetMode, syncId); in AddSyncTarget()
167 int SyncTaskContext::RemoveSyncOperation(int syncId) in RemoveSyncOperation() argument
171 [syncId](const ISyncTarget *target) { in RemoveSyncOperation()
175 return target->GetSyncId() == syncId; in RemoveSyncOperation()
589 LOGI("[SyncTaskContext][copyTarget] mode=%d,syncId=%d,isAutoSync=%d,isRetry=%d,dev=%s{private}", in CopyTargetData()
635 void SyncTaskContext::CancelCurrentSyncRetryIfNeed(int newTargetMode, uint32_t syncId) in CancelCurrentSyncRetryIfNeed() argument
641 if (syncId_ >= syncId) { in CancelCurrentSyncRetryIfNeed()
785 void SyncTaskContext::AbortMachineIfNeed(uint32_t syncId) in AbortMachineIfNeed() argument
[all...]
H A Dsyncer_proxy.cpp75 int SyncerProxy::CancelSync(uint32_t syncId) in CancelSync() argument
80 return syncer_->CancelSync(syncId); in CancelSync()
83 int SyncerProxy::RemoveSyncOperation(int syncId) in RemoveSyncOperation() argument
88 return syncer_->RemoveSyncOperation(syncId); in RemoveSyncOperation()
H A Disync_engine.h46 // Clear the SyncTarget matched the syncId.
47 virtual void RemoveSyncOperation(int syncId) = 0;
97 virtual void AbortMachineIfNeed(uint32_t syncId) = 0;
H A Dsync_task_context.h55 // remove a sync target by syncId
56 int RemoveSyncOperation(int syncId) override;
75 // Get the current task syncId
210 void AbortMachineIfNeed(uint32_t syncId) override;
234 void CancelCurrentSyncRetryIfNeed(int newTargetMode, uint32_t syncId);
H A Disync_task_context.h53 // Remove a sync target by syncId
54 virtual int RemoveSyncOperation(int syncId) = 0;
73 // Get the current task syncId
182 virtual void AbortMachineIfNeed(uint32_t syncId) = 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 &syncFunc, 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 SyncEnd &syncEnd);
55 Status RemoveSyncOperation(uintptr_t syncId);
/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()
H A Dmulti_ver_syncer.h58 void SyncOperationKillCallbackInner(int syncId) override;
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_general_store.cpp526 SyncId syncId = ++syncTaskId_; in Sync() local
531 auto callback = GetDBProcessCB(std::move(async), syncMode, syncId, highMode); in Sync()
533 auto id = executor_->Schedule(std::chrono::minutes(INTERVAL), GetFinishTask(syncId)); in Sync()
534 tasks_->Insert(syncId, { id, callback }); in Sync()
539 tasks_ != nullptr ? GetCB(syncId) : callback, syncId); in Sync()
543 tasks_->ComputeIfPresent(syncId, [executor = executor_](SyncId syncId, const FinishTask &task) { in Sync()
717 RdbGeneralStore::DBProcessCB RdbGeneralStore::GetDBProcessCB(DetailAsync async, uint32_t syncMode, SyncId syncId, in GetDBProcessCB() argument
721 return [async, autoAsync = async_, highMode, storeInfo = storeInfo_, flag = syncNotifyFlag_, syncMode, syncId, in GetDBProcessCB()
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/
H A Dstore_info.h29 uint64_t syncId = 0; member
/foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/transaction/
H A Drs_transaction_proxy.h64 void SetSyncId(const uint64_t syncId) in SetSyncId() argument
66 syncId_ = syncId; in SetSyncId()
H A Drs_transaction_data.h153 void SetSyncId(const uint64_t syncId) in SetSyncId() argument
155 syncId_ = syncId; in SetSyncId()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/include/
H A Dsyncer_proxy.h52 int CancelSync(uint32_t syncId) override;
54 // Remove the operation, with the given syncId, used to clean resource if sync finished or failed.
55 int RemoveSyncOperation(int syncId) override;
H A Disyncer.h72 virtual int CancelSync(uint32_t syncId) = 0;
74 // Remove the operation, with the given syncId, used to clean resource if sync finished or failed.
75 virtual int RemoveSyncOperation(int syncId) = 0;
/foundation/distributeddatamgr/udmf/interfaces/innerkits/common/
H A Dunified_types.h97 uint32_t syncId; member

Completed in 12 milliseconds

123