Home
last modified time | relevance | path

Searched refs:commitId (Results 1 – 25 of 33) sorted by relevance

12

/ohos5.0/base/startup/init/services/param/include/
H A Dparam_atomic.h41 #define ATOMIC_INIT(commitId, value) *(commitId) = (value) argument
42 #define ATOMIC_LOAD_EXPLICIT(commitId, order) *(commitId) argument
43 #define ATOMIC_STORE_EXPLICIT(commitId, value, order) *(commitId) = (value) argument
44 #define ATOMIC_UINT64_INIT(commitId, value) *(commitId) = (value) argument
45 #define ATOMIC_UINT64_LOAD_EXPLICIT(commitId, order) *(commitId) argument
46 #define ATOMIC_UINT64_STORE_EXPLICIT(commitId, value, order) *(commitId) = (value) argument
47 #define ATOMIC_SYNC_OR_AND_FETCH(commitId, value, order) *(commitId) |= (value) argument
48 #define ATOMIC_SYNC_ADD_AND_FETCH(commitId, value, order) *(commitId) += (value) argument
90 #define ATOMIC_INIT(commitId, value) atomic_init((commitId), (value))
91 #define ATOMIC_UINT64_INIT(commitId, value) atomic_init((commitId), (value))
[all …]
H A Dparam_common.h77 ATOMIC_UINT32 commitId; member
96 ATOMIC_LLONG commitId; member
H A Dparam_init.h63 int SystemGetParameterCommitId(ParamHandle handle, uint32_t *commitId);
/ohos5.0/base/startup/init/test/unittest/param/
H A Datomic_unittest.cpp48 ATOMIC_UINT32 commitId;
57 uint32_t commitId = ATOMIC_LOAD_EXPLICIT(&g_testData.commitId, MEMORY_ORDER_RELAXED); in TestSetData() local
58 … ATOMIC_STORE_EXPLICIT(&g_testData.commitId, commitId | PARAM_FLAGS_MODIFY, MEMORY_ORDER_RELAXED); in TestSetData()
63 ATOMIC_STORE_EXPLICIT(&g_testData.commitId, (++commitId) | flags, MEMORY_ORDER_RELEASE); in TestSetData()
72 uint32_t commitId = ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_ACQUIRE); in TestReadCommitId() local
73 while (commitId & PARAM_FLAGS_MODIFY) { in TestReadCommitId()
74 futex_wait(&entry->commitId, commitId); in TestReadCommitId()
75 commitId = ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_ACQUIRE); in TestReadCommitId()
77 return commitId & PARAM_FLAGS_COMMITID; in TestReadCommitId()
83 uint32_t id = *commitId; in TestReadParamValue()
[all …]
H A Dclient_unittest.cpp96 uint32_t commitId = 0; in TestParamTraversal() local
97 int ret = SystemGetParameterCommitId(handle, &commitId); in TestParamTraversal()
158 uint32_t commitId = 0; in TestClientApi() local
159 ret = SystemGetParameterCommitId(handle, &commitId); in TestClientApi()
/ohos5.0/base/startup/init/services/param/base/
H A Dparam_base.h49 uint32_t commitId = ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_ACQUIRE); in ReadCommitId() local
51 while (commitId & PARAM_FLAGS_MODIFY) { in ReadCommitId()
52 futex_wait(&entry->commitId, commitId); in ReadCommitId()
53 commitId = ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_ACQUIRE); in ReadCommitId()
58 return commitId & PARAM_FLAGS_COMMITID; in ReadCommitId()
61 static inline int ReadParamValue_(ParamNode *entry, uint32_t *commitId, char *value, uint32_t *leng… in ReadParamValue_() argument
63 uint32_t id = *commitId; in ReadParamValue_()
65 *commitId = id; in ReadParamValue_()
71 } while (*commitId != id); // if change,must read in ReadParamValue_()
/ohos5.0/base/startup/init/interfaces/innerkits/include/param/
H A Dsys_param.h45 #define ATOMIC_UINT64_LOAD_EXPLICIT(commitId, order) *(commitId) argument
51 #define ATOMIC_UINT64_LOAD_EXPLICIT(commitId, order) atomic_load_explicit((commitId), order)
61 #define ATOMIC_UINT64_LOAD_EXPLICIT(commitId, order) param_atomic_uint64_load((commitId), order)
93 ATOMIC_LLONG commitId; member
159 …long long spaceCommitId = ATOMIC_UINT64_LOAD_EXPLICIT(&param->workspace->area->commitId, MEMORY_OR… in CachedParameterGet()
178 …long long spaceCommitId = ATOMIC_UINT64_LOAD_EXPLICIT(&param->workspace->area->commitId, MEMORY_OR… in CachedParameterGetChanged()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/multiver/
H A Dmulti_ver_storage_executor.cpp157 CommitID commitId = commit.commitId; in GetCommitData() local
853 CommitID commitId; in CommitTransaction() local
882 CommitNotifiedData(commitId); in CommitTransaction()
965 if (!commitId.empty()) { in InitCurrentReadVersion()
1165 commitId.resize(COMMIT_ID_LENGTH); in AllocNewCommitId()
1184 (void)(AllocNewCommitId(commitId)); in FillAndCommitLogEntry()
1196 commit->SetCommitId(commitId); in FillAndCommitLogEntry()
1233 commit->SetCommitId(commitId); in FillCommitByForeign()
1266 (void)(AllocNewCommitId(commitId)); in FillAndCommitLogEntry()
1300 CommitID commitId; in CommitTransaction() local
[all …]
H A Dmulti_ver_storage_executor.h131 void CommitNotifiedData(const CommitID &commitId);
133 int GetParentCommitId(const CommitID &commitId, CommitID &parentId, Version &curVersion) const;
135 int AllocNewCommitId(CommitID &commitId) const;
137 …int FillAndCommitLogEntry(const Version &versionInfo, CommitID &commitId, uint64_t timestamp) cons…
140 const Version &versionInfo, const CommitID &commitId, bool isMerge) const;
143 CommitID &commitId, bool isMerge, Timestamp &timestamp) const;
H A Dmulti_ver_natural_store_commit_storage.h46 IKvDBCommit *GetCommit(const CommitID &commitId, int &errCode) const override;
49 int RemoveCommit(const CommitID &commitId) override;
53 int SetHeader(const CommitID &commitId) override;
56 bool CommitExist(const CommitID &commitId, int &errCode) const override;
104 int SetHeaderInner(const CommitID &commitId);
H A Dmulti_ver_natural_store_commit_storage.cpp198 TransferCommitIDToKey(commitId, key); in GetCommit()
278 commitNode.commitId = currentCommitIter->first; in GetAllCommitsInTree()
352 if (header == commitId) { in RemoveCommit()
353 IKvDBCommit *commit = GetCommit(commitId, errCode); in RemoveCommit()
370 TransferCommitIDToKey(commitId, key); in RemoveCommit()
395 int MultiVerNaturalStoreCommitStorage::SetHeader(const CommitID &commitId) in SetHeader() argument
402 if (commitId.size() != 0) { in SetHeader()
404 if (!CommitExist(commitId, errCode)) { in SetHeader()
410 return SetHeaderInner(commitId); in SetHeader()
441 IKvDBCommit *commit = GetCommit(commitId, errCode); in CommitExist()
[all …]
H A Dmulti_ver_vacuum_executor_impl.cpp78 … leftBranchCommits.emplace_back(MultiVerCommitInfo{eachCommit.version, eachCommit.commitId}); in GetVacuumAbleCommits()
80 … rightBranchCommits.emplace_back(MultiVerCommitInfo{eachCommit.version, eachCommit.commitId}); in GetVacuumAbleCommits()
279 int MultiVerVacuumExecutorImpl::MarkCommitAsVacuumDone(const std::vector<uint8_t> &commitId) in MarkCommitAsVacuumDone() argument
289 int errCode = writeHandle_->UpdateTrimedFlag(commitId); in MarkCommitAsVacuumDone()
H A Dmulti_ver_vacuum_executor_impl.h61 int MarkCommitAsVacuumDone(const std::vector<uint8_t> &commitId) override;
H A Dmulti_ver_vacuum.cpp429 VEC_TO_STR(commit.commitId), isLeft); in DoDealCommitOfLeftOrRight()
434 "errCode=%d.", ULL(commit.version), VEC_TO_STR(commit.commitId), isLeft, errCode); in DoDealCommitOfLeftOrRight()
458 errCode = inTask.databaseHandle->MarkCommitAsVacuumDone(commit.commitId); in DoDealCommitOfLeftOrRight()
461 ULL(commit.version), VEC_TO_STR(commit.commitId), isLeft, errCode); in DoDealCommitOfLeftOrRight()
/ohos5.0/base/startup/init/services/param/manager/
H A Dparam_manager.c140 entry->commitId, entry->keyLength, entry->valueLength, entry->data); in DumpTrieDataNodeTraversal()
456 uint32_t commitId = ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_RELAXED); in UpdateParam() local
457 ATOMIC_STORE_EXPLICIT(&entry->commitId, commitId | PARAM_FLAGS_MODIFY, MEMORY_ORDER_RELAXED); in UpdateParam()
464 uint32_t flags = commitId & ~PARAM_FLAGS_COMMITID; in UpdateParam()
465 uint32_t commitIdCount = (++commitId) & PARAM_FLAGS_COMMITID; in UpdateParam()
477 entry->commitId |= PARAM_FLAGS_PERSIST; in UpdateParam()
479 futex_wake(&entry->commitId, INT_MAX); in UpdateParam()
723 uint32_t commitId = ReadCommitId(entry); in ReadParamValue() local
724 return ReadParamValue_(entry, &commitId, value, length); in ReadParamValue()
776 int SystemGetParameterCommitId(ParamHandle handle, uint32_t *commitId) in SystemGetParameterCommitId() argument
[all …]
H A Dparam_persist.c80 if ((entry->commitId & PARAM_FLAGS_PERSIST) == 0) { in SavePersistParam()
156 PARAM_LOGV("CheckAndSavePersistParam commit %lld %lld", commit, g_persistWorkSpace.commitId); in CheckAndSavePersistParam()
157 if (g_persistWorkSpace.commitId == commit) { in CheckAndSavePersistParam()
160 g_persistWorkSpace.commitId = commit; in CheckAndSavePersistParam()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dikvdb_commit_storage.h45 virtual IKvDBCommit *GetCommit(const CommitID &commitId, int &errCode) const = 0;
47 virtual int RemoveCommit(const CommitID &commitId) = 0;
49 virtual int SetHeader(const CommitID &commitId) = 0;
51 virtual bool CommitExist(const CommitID &commitId, int &errCode) const = 0;
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/
H A Ddistributeddb_storage_transaction_data_test.cpp99 RAND_bytes(multiVerCommit.commitId.data(), 20); in RunSyncMergeForOneCommit()
125 static uint64_t GetCommitTimestamp(const CommitID& commitId) in GetCommitTimestamp() argument
143 if (commitId.empty()) { in GetCommitTimestamp()
149 newCommitId = commitId; in GetCommitTimestamp()
173 CommitID commitId; in GetMaxTimestamp() local
174 return GetCommitTimestamp(commitId); in GetMaxTimestamp()
1022 RAND_bytes(multiVerCommit.commitId.data(), 20);
1337 CommitID commitId; variable
1397 newCommit.commitId.resize(20); // commit id size in PutSecondSyncCommitData()
1399 newCommit.leftParent = multiVerCommit.commitId; in PutSecondSyncCommitData()
[all …]
H A Dmulti_ver_vacuum_executor_stub.cpp43 commit.commitId.push_back(i); in GetVacuumAbleCommits()
49 commit.commitId.push_back(i); in GetVacuumAbleCommits()
123 int MultiVerVacuumExecutorStub::MarkCommitAsVacuumDone(const std::vector<uint8_t> &commitId) in MarkCommitAsVacuumDone() argument
H A Dmulti_ver_vacuum_executor_stub.h52 int MarkCommitAsVacuumDone(const std::vector<uint8_t> &commitId);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/
H A Dmulti_ver_vacuum_executor.h39 std::vector<uint8_t> commitId; member
76 virtual int MarkCommitAsVacuumDone(const std::vector<uint8_t> &commitId) = 0;
H A Dmulti_ver_def.h33 std::vector<uint8_t> commitId; member
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Dparcel.cpp233 int errCode = WriteVectorChar(commit.commitId); in WriteMultiVerCommit()
276 uint64_t len = ReadVectorChar(commit.commitId); in ReadMultiVerCommit()
299 errCode = WriteVectorChar(iter.commitId); in WriteMultiVerCommits()
355 len += ReadVectorChar(commit.commitId); in ReadMultiVerCommits()
487 uint64_t len = GetVectorCharLen(commit.commitId); in GetMultiVerCommitLen()
504 len += GetVectorCharLen(iter.commitId); in GetMultiVerCommitsLen()
/ohos5.0/base/startup/init/interfaces/innerkits/syspara/
H A Dparameter.c50 uint32_t commitId = 0; in GetParameterCommitId() local
51 int ret = SystemGetParameterCommitId(handle, &commitId); in GetParameterCommitId()
53 return commitId; in GetParameterCommitId()
/ohos5.0/base/startup/init/services/param/linux/
H A Dparam_service.c67 …if ((ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_RELAXED) & PARAM_FLAGS_TRIGGED) != PARAM_… in CheckAndSendTrigger()
71 ATOMIC_SYNC_OR_AND_FETCH(&entry->commitId, PARAM_FLAGS_TRIGGED, MEMORY_ORDER_RELEASE); in CheckAndSendTrigger()
77 …if ((ATOMIC_LOAD_EXPLICIT(&entry->commitId, MEMORY_ORDER_RELAXED) & PARAM_FLAGS_WAITED) != PARAM_F… in CheckAndSendTrigger()
81 ATOMIC_SYNC_OR_AND_FETCH(&entry->commitId, PARAM_FLAGS_WAITED, MEMORY_ORDER_RELEASE); in CheckAndSendTrigger()

12