Home
last modified time | relevance | path

Searched refs:DataStatus (Results 1 – 13 of 13) sorted by relevance

/ohos5.0/foundation/resourceschedule/ffrt/src/core/
H A Dversion_ctx.cpp24 if (version->status == DataStatus::IDLE) { in BuildConsumeRelationship()
28 if (version->status == DataStatus::CONSUMED) { in BuildConsumeRelationship()
29 version->status = DataStatus::READY; in BuildConsumeRelationship()
35 if (preVersion->status != DataStatus::CONSUMED) { in BuildProducerProducerRelationship()
49 CreateChildVersion(consumer, DataStatus::READY); in AddConsumer()
66 parentVersion->CreateChildVersion(producer, DataStatus::IDLE); in AddProducer()
79 status = DataStatus::CONSUMED; in onProduced()
83 status = DataStatus::READY; in onProduced()
99 status = DataStatus::CONSUMED; in onConsumed()
121 if (status == DataStatus::READY) { in MergeChildVersion()
[all …]
H A Dversion_ctx.h49 DataStatus status {DataStatus::IDLE};
56 if (last != nullptr && last->status == DataStatus::IDLE) { in AddDataWaitTaskByThis()
65 void CreateChildVersion(SCPUEUTask* task, DataStatus dataStatus);
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/
H A Dstorage_executor.h39 enum class DataStatus { enum
54 DataStatus preStatus = DataStatus::NOEXISTED;
H A Dsingle_ver_utils.cpp151 if (dataStatus.preStatus == DataStatus::DELETED) { in InitCommitNotifyDataKeyStatus()
153 } else if (dataStatus.preStatus == DataStatus::EXISTED) { in InitCommitNotifyDataKeyStatus()
/ohos5.0/foundation/distributeddatamgr/udmf/interfaces/innerkits/common/
H A Dunified_types.h27 enum DataStatus : int32_t { enum
54 DataStatus dataStatus { WORKING };
/ohos5.0/foundation/distributeddatamgr/udmf/framework/common/
H A Dtlv_util.cpp115 template <> size_t CountBufferSize(const DataStatus &input, TLVObject &data) in CountBufferSize()
121 template <> bool Writing(const DataStatus &input, TLVObject &data, TAG tag) in Writing()
128 template <> bool Reading(DataStatus &output, TLVObject &data, const TLVHead &head) in Reading()
134 if (status < DataStatus::WORKING || status >= DataStatus::FADE) { in Reading()
137 output = static_cast<DataStatus>(status); in Reading()
H A Dtlv_util.h76 template <> size_t API_EXPORT CountBufferSize(const DataStatus &input, TLVObject &data);
77 template <> bool API_EXPORT Writing(const DataStatus &input, TLVObject &data, TAG tag);
78 template <> bool API_EXPORT Reading(DataStatus &output, TLVObject &data, const TLVHead &head);
/ohos5.0/foundation/resourceschedule/ffrt/src/internal_inc/
H A Dtypes.h46 enum class DataStatus { enum
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/
H A Drd_single_ver_storage_executor.cpp722 …DataType dataType = (data.dataStatus.preStatus == DataStatus::EXISTED) ? DataType::UPDATE : DataTy… in PutIntoCommittedData()
725 if (data.dataStatus.preStatus == DataStatus::NOEXISTED) { in PutIntoCommittedData()
769 notify.dataStatus.preStatus = DataStatus::EXISTED; in PrepareForNotifyConflictAndObserver()
771 notify.dataStatus.preStatus = DataStatus::NOEXISTED; in PrepareForNotifyConflictAndObserver()
/ohos5.0/foundation/resourceschedule/ffrt/src/sched/
H A Dscheduler.h56 if (waitVersion->status != DataStatus::IDLE) { // 数据已经被生产出来 in onWait()
/ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/
H A Dsqlite_single_ver_storage_executor.cpp1126 …DataType dataType = (status.preStatus == DataStatus::EXISTED) ? DataType::UPDATE : DataType::INSER… in PutIntoCommittedData()
1237 status.preStatus = DataStatus::DELETED; in JudgeSyncSaveType()
1239 status.preStatus = DataStatus::EXISTED; in JudgeSyncSaveType()
1262 if (dataStatus.preStatus != DataStatus::EXISTED) { in GetSyncDataItemExt()
1327 …if ((notify.dataStatus.preStatus == DataStatus::DELETED || notify.dataStatus.preStatus == DataStat… in PrepareForNotifyConflictAndObserver()
1375 bool isUpdate = (notify.dataStatus.preStatus != DataStatus::NOEXISTED); in SaveSyncDataItem()
1519 if (dataStatus.preStatus == DataStatus::NOEXISTED || in PutConflictData()
1520 ((dataStatus.preStatus == DataStatus::DELETED) && dataStatus.isDeleted)) { in PutConflictData()
H A Dsqlite_single_ver_storage_executor_cache.cpp274 bool isUpdate = notify.dataStatus.preStatus != DataStatus::NOEXISTED; in MigrateDataItem()
/ohos5.0/foundation/distributeddatamgr/udmf/framework/common/unittest/
H A Dtlv_util_test.cpp89 DataStatus status = HISTORY;
213 DataStatus status = HISTORY;
227 DataStatus statusResult;