Home
last modified time | relevance | path

Searched refs:ERROR_FIELD (Results 1 - 12 of 12) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/
H A Ddb_common.cpp637 if (record.find(CloudDbConstant::ERROR_FIELD) == record.end()) { in IsRecordError()
640 if (record.at(CloudDbConstant::ERROR_FIELD).index() != TYPE_INDEX<int64_t>) { in IsRecordError()
643 auto status = std::get<int64_t>(record.at(CloudDbConstant::ERROR_FIELD)); in IsRecordError()
652 if (record.find(CloudDbConstant::ERROR_FIELD) == record.end()) { in IsIntTypeRecordError()
655 return record.at(CloudDbConstant::ERROR_FIELD).index() == TYPE_INDEX<int64_t>; in IsIntTypeRecordError()
660 if (record.find(CloudDbConstant::ERROR_FIELD) == record.end()) { in IsRecordIgnored()
663 if (record.at(CloudDbConstant::ERROR_FIELD).index() != TYPE_INDEX<int64_t>) { in IsRecordIgnored()
666 auto status = std::get<int64_t>(record.at(CloudDbConstant::ERROR_FIELD)); in IsRecordIgnored()
673 if (record.find(CloudDbConstant::ERROR_FIELD) == record.end()) { in IsRecordVersionConflict()
676 if (record.at(CloudDbConstant::ERROR_FIELD) in IsRecordVersionConflict()
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/include/cloud/
H A Dcloud_db_constant.h35 static constexpr const char *ERROR_FIELD = "#_error"; member in DistributedDB::CloudDbConstant
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/cloud/
H A Dschema_meta.h58 static constexpr const char *ERROR_FIELD = "#_error"; member in OHOS::DistributedData::final
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/
H A Ddistributeddb_cloud_assets_operation_sync_test.cpp1066 case 0: // record[0] is successful because ERROR_FIELD is not verified when BatchInsert returns OK status. in HWTEST_F()
1067 extend[std::string(CloudDbConstant::ERROR_FIELD)] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
1070 extend[std::string(CloudDbConstant::ERROR_FIELD)] = in HWTEST_F()
1086 case 5: // record[5] is successful because ERROR_FIELD is not verified when BatchInsert returns OK status. in HWTEST_F()
1087 extend[std::string(CloudDbConstant::ERROR_FIELD)] = std::string(""); in HWTEST_F()
1169 extend[std::string(CloudDbConstant::ERROR_FIELD)] = in HWTEST_F()
1217 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_NOT_FOUND); in HWTEST_F()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/rdb/
H A Drdb_cloud.cpp316 extend[SchemaMeta::ERROR_FIELD] = DBStatus::CLOUD_RECORD_EXIST_CONFLICT; in PostEventAsset()
337 auto errorField = extend.find(SchemaMeta::ERROR_FIELD); in ConvertErrorField()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/
H A Ddistributeddb_cloud_kv_syncer_test.cpp340 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_NOT_FOUND); in HWTEST_F()
391 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_ALREADY_EXISTED); in HWTEST_F()
448 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_NOT_FOUND); in HWTEST_F()
H A Dvirtual_cloud_db.cpp89 extend[i][CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_EXIST_CONFLICT); in InnerBatchInsert()
454 extend[i][CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_EXIST_CONFLICT); in InnerUpdateWithoutLock()
473 extend[i][CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_EXIST_CONFLICT); in InnerUpdateWithoutLock()
H A Ddistributeddb_cloud_syncer_download_assets_test.cpp1706 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::LOCAL_ASSET_NOT_FOUND); in HWTEST_F()
1752 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::LOCAL_ASSET_NOT_FOUND); in HWTEST_F()
1800 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::LOCAL_ASSET_NOT_FOUND); in HWTEST_F()
1840 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::LOCAL_ASSET_NOT_FOUND); in HWTEST_F()
1877 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::LOCAL_ASSET_NOT_FOUND); in HWTEST_F()
2092 extend.insert_or_assign(CloudDbConstant::ERROR_FIELD, static_cast<int64_t>(DBStatus::CLOUD_NETWORK_ERROR)); in HWTEST_F()
2113 extend.insert_or_assign(CloudDbConstant::ERROR_FIELD, err); in HWTEST_F()
2117 extend.insert_or_assign(CloudDbConstant::ERROR_FIELD, err); in HWTEST_F()
H A Ddistributeddb_cloud_syncer_lock_test.cpp598 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_VERSION_CONFLICT); in HWTEST_F()
1046 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_NOT_FOUND); in HWTEST_F()
1099 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_ALREADY_EXISTED); in HWTEST_F()
1156 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_NOT_FOUND); in HWTEST_F()
H A Ddistributeddb_cloud_kv_test.cpp1432 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
1892 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
1950 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
2157 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
H A Ddistributeddb_cloud_syncer_upload_test.cpp884 item[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in HWTEST_F()
921 item[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_ERROR); in SetFuncs015()
/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/
H A Ddistributeddb_cloud_interfaces_relational_remove_device_data_test.cpp1356 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_ALREADY_EXISTED); in HWTEST_F()
1568 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_ALREADY_EXISTED); in HWTEST_F()
1571 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_EXIST_CONFLICT); in HWTEST_F()
1575 extend[CloudDbConstant::ERROR_FIELD] = static_cast<int64_t>(DBStatus::CLOUD_RECORD_NOT_FOUND); in HWTEST_F()
1579 extend[CloudDbConstant::ERROR_FIELD] = std::string("x"); in HWTEST_F()

Completed in 22 milliseconds