| /foundation/resourceschedule/ffrt/src/core/ |
| H A D | version_ctx.cpp | 105 void VersionCtx::CreateChildVersion(SCPUEUTask* task __attribute__((unused)), DataStatus dataStatus) in CreateChildVersion() argument
110 last->status = dataStatus; in CreateChildVersion()
|
| H A D | version_ctx.h | 65 void CreateChildVersion(SCPUEUTask* task, DataStatus dataStatus);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | single_ver_utils.cpp | 144 const DataOperStatus &dataStatus) in InitCommitNotifyDataKeyStatus()
151 if (dataStatus.preStatus == DataStatus::DELETED) { in InitCommitNotifyDataKeyStatus()
153 } else if (dataStatus.preStatus == DataStatus::EXISTED) { in InitCommitNotifyDataKeyStatus()
143 InitCommitNotifyDataKeyStatus(SingleVerNaturalStoreCommitNotifyData *committedData, const Key &hashKey, const DataOperStatus &dataStatus) InitCommitNotifyDataKeyStatus() argument
|
| H A D | single_ver_utils.h | 71 const DataOperStatus &dataStatus);
|
| H A D | storage_executor.h | 90 DataOperStatus dataStatus; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/gaussdb_rd/ |
| H A D | rd_single_ver_storage_executor.cpp | 725 if (!data.dataStatus.isDeleted) { in PutIntoCommittedData()
728 DataType dataType = (data.dataStatus.preStatus == DataStatus::EXISTED) ? DataType::UPDATE : DataType::INSERT; in PutIntoCommittedData()
731 if (data.dataStatus.preStatus == DataStatus::NOEXISTED) { in PutIntoCommittedData()
773 notify.dataStatus.isDeleted = isDelete; in PrepareForNotifyConflictAndObserver()
775 notify.dataStatus.preStatus = DataStatus::EXISTED; in PrepareForNotifyConflictAndObserver()
777 notify.dataStatus.preStatus = DataStatus::NOEXISTED; in PrepareForNotifyConflictAndObserver()
779 InitCommitNotifyDataKeyStatus(notify.committedData, notify.hashKey, notify.dataStatus); in PrepareForNotifyConflictAndObserver()
|
| /foundation/distributeddatamgr/udmf/interfaces/innerkits/common/ |
| H A D | unified_types.h | 54 DataStatus dataStatus { WORKING };
|
| /foundation/communication/dsoftbus/tests/adapter/broadcast/ |
| H A D | softbus_ble_utils_test.cpp | 117 btScanResult.dataStatus = 1; in HWTEST()
129 EXPECT_EQ(softbusScanResult.dataStatus, btScanResult.dataStatus); in HWTEST()
|
| H A D | softbus_ble_gatt_test.cpp | 1231 mockScanResult.dataStatus = OHOS_BLE_DATA_COMPLETE; in HWTEST_F()
1239 mockScanResult.dataStatus = OHOS_BLE_DATA_INCOMPLETE_MORE_TO_COME; in HWTEST_F()
|
| /foundation/communication/dsoftbus/tests/core/discovery/ble/softbus_ble/ |
| H A D | disc_ble_distributed_test.cpp | 140 reportInfo.dataStatus = SOFTBUS_BC_DATA_INCOMPLETE_MORE_TO_COME; in HWTEST_F()
145 reportInfo.dataStatus = SOFTBUS_BC_DATA_COMPLETE; in HWTEST_F()
185 .dataStatus = SOFTBUS_BC_DATA_COMPLETE, in HWTEST_F()
245 .dataStatus = SOFTBUS_BC_DATA_COMPLETE, in HWTEST_F()
|
| /foundation/communication/dsoftbus/adapter/common/net/bluetooth/broadcast/adapter/include/ |
| H A D | softbus_broadcast_adapter_type.h | 127 uint8_t dataStatus; member
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/sqlite/ |
| H A D | sqlite_single_ver_storage_executor_cache.cpp | 270 if (notify.dataStatus.isDefeated) { in MigrateDataItem()
274 bool isUpdate = notify.dataStatus.preStatus != DataStatus::NOEXISTED; in MigrateDataItem()
759 notify.dataStatus.isDefeated = true; in PutIntoConflictAndCommitForMigrateCache()
770 PutConflictData(dataItem, notify.getData, deviceInfo, notify.dataStatus, notify.committedData); in PutIntoConflictAndCommitForMigrateCache()
771 if (notify.dataStatus.isDefeated) { in PutIntoConflictAndCommitForMigrateCache()
776 PutIntoCommittedData(dataItem, notify.getData, notify.dataStatus, notify.committedData); in PutIntoConflictAndCommitForMigrateCache()
|
| H A D | sqlite_single_ver_storage_executor.cpp | 1259 const DataOperStatus &dataStatus) const in GetSyncDataItemExt()
1261 if (dataStatus.preStatus != DataStatus::EXISTED) { in GetSyncDataItemExt()
1321 notify.dataStatus = JudgeSyncSaveType(dataItem, notify.getData, deviceInfo.deviceName, isHashKeyExisted, in PrepareForNotifyConflictAndObserver()
1323 InitCommitNotifyDataKeyStatus(notify.committedData, notify.hashKey, notify.dataStatus); in PrepareForNotifyConflictAndObserver()
1326 if ((notify.dataStatus.preStatus == DataStatus::DELETED || notify.dataStatus.preStatus == DataStatus::NOEXISTED) && in PrepareForNotifyConflictAndObserver()
1340 errCode = GetSyncDataItemExt(dataItem, notify.getData, notify.dataStatus); in PrepareForNotifyConflictAndObserver()
1368 PutConflictData(dataItem, notify.getData, deviceInfo, notify.dataStatus, committedData); in SaveSyncDataItem()
1369 if (notify.dataStatus.isDefeated) { in SaveSyncDataItem()
1374 bool isUpdate = (notify.dataStatus in SaveSyncDataItem()
1505 PutConflictData(const DataItem &itemPut, const DataItem &itemGet, const DeviceInfo &deviceInfo, const DataOperStatus &dataStatus, SingleVerNaturalStoreCommitNotifyData *commitData) PutConflictData() argument
[all...] |
| H A D | sqlite_single_ver_storage_executor.h | 237 const DataOperStatus &dataStatus, SingleVerNaturalStoreCommitNotifyData *commitData);
246 int GetSyncDataItemExt(const DataItem &dataItem, DataItem &itemGet, const DataOperStatus &dataStatus) const;
|
| /foundation/communication/dsoftbus/adapter/common/net/bluetooth/broadcast/adapter/ble/src/ |
| H A D | softbus_ble_utils.c | 173 static uint8_t BtScanDataStatusToSoftbus(unsigned char dataStatus) in BtScanDataStatusToSoftbus() argument
175 switch (dataStatus) { in BtScanDataStatusToSoftbus()
228 dst->dataStatus = BtScanDataStatusToSoftbus(src->dataStatus); in BtScanResultToSoftbus()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/hci/ |
| H A D | hci_def_le_evt.h | 241 uint8_t dataStatus; member
|
| /foundation/communication/dsoftbus/adapter/common/net/bluetooth/broadcast/interface/ |
| H A D | softbus_broadcast_type.h | 369 uint8_t dataStatus; member
|
| /foundation/communication/bluetooth/interfaces/inner_api/include/c_header/ |
| H A D | ohos_bt_gatt.h | 439 unsigned char dataStatus; member
|
| /foundation/distributeddatamgr/udmf/framework/common/ |
| H A D | tlv_util.cpp | 353 data.CountBasic(static_cast<int32_t>(input.dataStatus)) + data.Count(input.sourcePackage) + in CountBufferSize()
382 if (!data.WriteBasic(TAG::TAG_DATA_STATUS, static_cast<int32_t>(input.dataStatus))) { in Writing()
435 result = TLVUtil::Reading(output.dataStatus, data, headItem); in Reading()
|
| /foundation/distributeddatamgr/udmf/framework/common/unittest/ |
| H A D | tlv_util_test.cpp | 294 runtime.dataStatus = DELETED; in HWTEST_F()
312 EXPECT_EQ(runtime.dataStatus, runtimeResult.dataStatus); in HWTEST_F()
|
| /foundation/communication/dsoftbus/tests/core/discovery/ble/bluetooth_mock/ |
| H A D | bluetooth_mock.cpp | 329 .dataStatus = OHOS_BLE_DATA_COMPLETE, in CallbackScanResult()
|
| /foundation/communication/dsoftbus/core/discovery/ble/softbus_ble/src/ |
| H A D | disc_ble.c | 375 DISC_CHECK_AND_RETURN_RET_LOGE(reportInfo->dataStatus == SOFTBUS_BC_DATA_COMPLETE, in ScanFilter()
377 "dataStatus is invalid. dataStatus=%{public}u", reportInfo->dataStatus); in ScanFilter()
|
| /foundation/communication/dsoftbus/adapter/common/net/bluetooth/broadcast/manager/src/ |
| H A D | softbus_broadcast_mgr.c | 424 bcInfo->dataStatus = reportData->dataStatus; in BuildBcInfoCommon()
|
| /foundation/communication/bluetooth/frameworks/inner/c_adapter/ |
| H A D | ohos_bt_gatt.cpp | 90 scanResult.dataStatus = OHOS_BLE_DATA_COMPLETE;
|