| /foundation/graphic/graphic_2d/rosen/modules/render_service_client/core/transaction/ |
| H A D | rs_transaction.cpp | 36 syncId_ = GenerateSyncId(); in OpenSyncTransaction()
53 RS_TRACE_NAME_FMT("CloseSyncTransaction syncId: %lu syncCount: %d", syncId_, transactionCount_); in CloseSyncTransaction()
55 "CloseSyncTransaction syncId: %{public}" PRIu64 " syncCount: %{public}d", syncId_, transactionCount_); in CloseSyncTransaction()
58 transactionProxy->SetSyncId(syncId_); in CloseSyncTransaction()
80 "CommitSyncTransaction syncId: %lu syncCount: %d parentPid: %d", syncId_, transactionCount_, parentPid_); in Commit()
82 transactionProxy->SetSyncId(syncId_); in Commit()
108 syncId_ = 0; in ResetSyncTransactionInfo()
127 if (!parcel.WriteUint64(syncId_)) { in Marshalling()
144 RS_TRACE_NAME_FMT("RSTransaction::Marshalling syncId: %lu syncCount: %d", syncId_, transactionCount_); in Marshalling()
145 ROSEN_LOGD("Marshalling syncId: %{public}" PRIu64 " syncCount: %{public}d", syncId_, transactionCount in Marshalling()
[all...] |
| H A D | rs_transaction.h | 69 return syncId_; in GetSyncId()
77 uint64_t syncId_ { 0 };
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/ |
| H A D | sync_operation.cpp | 26 syncId_(syncId), in SyncOperation()
48 LOGD("[SyncOperation] Init SyncOperation id:%d.", syncId_); in Initialize()
56 processInfo.syncId = syncId_; in Initialize()
153 return syncId_; in GetSyncId()
180 LOGI("[SyncOperation] SyncId=%d finished, %s", syncId_, msg.c_str()); in Finished()
201 LOGD("[SyncOperation] Sync %d finished call onFinished.", syncId_); in Finished()
202 onFinished_(syncId_); in Finished()
304 LOGD("[SetSyncProcessTotal] total=%u, syncId=%u, deviceId=%s{private}", total, syncId_, deviceId.c_str()); in SetSyncProcessTotal()
323 if ((syncId_ > 0) && onFinalize_) { in Finalize()
|
| H A D | sync_operation.h | 160 uint32_t syncId_; member in DistributedDB::SyncOperation
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/ |
| H A D | sync_task_context.cpp | 42 syncId_(0), in SyncTaskContext()
156 syncId_ = 0; in Clear()
281 return syncId_; in GetSyncId()
582 syncId_ = syncOperation_->GetSyncId(); in CopyTargetData()
590 mode_, syncId_, isAutoSync_, syncTaskRetryStatus_, deviceId_.c_str()); in CopyTargetData()
591 DBDfxAdapter::StartAsyncTrace(syncActionName_, static_cast<int>(syncId_)); in CopyTargetData()
629 DBDfxAdapter::FinishAsyncTrace(syncActionName_, static_cast<int>(syncId_)); in ClearSyncOperation()
641 if (syncId_ >= syncId) { in CancelCurrentSyncRetryIfNeed()
790 if (syncId_ != syncId) { in AbortMachineIfNeed()
813 sessionId = Hash::Hash32Func(deviceId_ + std::to_string(syncId_) in GenerateRequestSessionId()
[all...] |
| H A D | sync_task_context.h | 251 volatile uint32_t syncId_; member in DistributedDB::SyncTaskContext
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/include/transaction/ |
| H A D | rs_transaction_data.h | 155 syncId_ = syncId; in SetSyncId()
160 return syncId_; in GetSyncId()
196 uint64_t syncId_ { 0 };
|
| H A D | rs_transaction_proxy.h | 66 syncId_ = syncId; in SetSyncId()
107 uint64_t syncId_ { 0 };
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/cloud/ |
| H A D | sync_manager.cpp | 54 syncId_ = SyncManager::GenerateId(user); in SyncInfo()
63 syncId_ = SyncManager::GenerateId(user); in SyncInfo()
70 syncId_ = SyncManager::GenerateId(user); in SyncInfo()
79 syncId_ = SyncManager::GenerateId(param.user); in SyncInfo()
295 UpdateFinishSyncInfo({ cloud.id, schema.bundleName, "" }, info.syncId_, E_ERROR); in GetPostEventTask()
302 UpdateFinishSyncInfo({ cloud.id, schema.bundleName, "" }, info.syncId_, E_ERROR); in GetPostEventTask()
308 info.user_, "", info.syncId_ }; in GetPostEventTask()
313 UpdateFinishSyncInfo({ cloud.id, schema.bundleName, "" }, info.syncId_, status); in GetPostEventTask()
339 activeInfos_.Erase(info.syncId_);
457 RadarReporter::Report({ info.bundleName_.c_str(), CLOUD_SYNC, FINISH_SYNC, info.syncId_, inf
[all...] |
| H A D | sync_manager.h | 79 uint64_t syncId_ = 0; member in OHOS::CloudData::SyncManager::final
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/dfx/src/ |
| H A D | radar_reporter.cpp | 52 std::to_string(param.syncId_), TRIGGER_MODE, param.triggerMode_, WATER_VERSION, param.changeCount); in Report()
59 std::to_string(param.syncId_), TRIGGER_MODE, param.triggerMode_, WATER_VERSION, param.changeCount); in Report()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/adapter/include/dfx/ |
| H A D | radar_reporter.h | 72 uint64_t syncId_ = 0; member
|
| /foundation/graphic/graphic_2d/rosen/modules/render_service_base/src/transaction/ |
| H A D | rs_transaction_proxy.cpp | 227 implicitCommonTransactionDataStack_.top()->SetSyncId(syncId_); in CommitSyncTransaction()
237 implicitRemoteTransactionDataStack_.top()->SetSyncId(syncId_); in CommitSyncTransaction()
|
| H A D | rs_transaction_data.cpp | 160 success = success && parcel.WriteUint64(syncId_); in Marshalling()
294 parcel.ReadUint64(index_) && parcel.ReadUint64(syncId_) && parcel.ReadInt32(parentPid_); in UnmarshallingCommand()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/multiver/ |
| H A D | multi_ver_sync_task_context.cpp | 231 syncId_ = 0; in Clear()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.h | 156 std::atomic_uint64_t syncId_ = 0; member in OHOS::DistributedKv::final
|
| H A D | kvdb_service_impl.cpp | 255 syncInfo.syncId = ++syncId_; in Sync()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/device/singlever/ |
| H A D | single_ver_sync_task_context.cpp | 216 syncId_ = 0; in Clear()
|
| /foundation/window/window_manager/wm/test/unittest/ui_extension/ |
| H A D | window_extension_session_impl_test.cpp | 1024 rsTransaction->syncId_ = 1; in HWTEST_F()
1035 rsTransaction->syncId_ = -1; in HWTEST_F()
|