| /ohos5.0/foundation/communication/dsoftbus/core/adapter/kv_store/src/ |
| H A D | lnn_kv_data_change_listener.cpp | 50 … origin.store.c_str(), keys[ChangeOp::OP_UPDATE].size(), keys[ChangeOp::OP_INSERT].size()); in OnChange()
52 …changeKeys.insert(changeKeys.end(), keys[ChangeOp::OP_INSERT].begin(), keys[ChangeOp::OP_INSERT].e… in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_watcher.cpp | 41 keys[OP_INSERT] = ConvertToKeys(changeData->second[OP_INSERT]); in OnChange()
61 auto inserts = ConvertToEntries(changeData->second[OP_INSERT]); in OnChange()
|
| H A D | kvdb_general_store.cpp | 650 ConvertChangeData(inserts, changeData[storeId_][DistributedDB::OP_INSERT]); in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/ |
| H A D | ikvstore_observer.cpp | 95 … if (!ITypesUtil::Marshal(data, origin.store, keys[OP_INSERT], keys[OP_UPDATE], keys[OP_DELETE])) { in OnChange()
146 … if (!ITypesUtil::Unmarshal(data, store, keys[OP_INSERT], keys[OP_UPDATE], keys[OP_DELETE])) { in OnRemoteRequest()
|
| /ohos5.0/foundation/distributeddatamgr/relational_store/rdbmock/frameworks/native/rdb/ |
| H A D | store_observer.h | 27 OP_INSERT = 0, enumerator
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/ |
| H A D | kvstore_observer.h | 29 OP_INSERT, enumerator
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/include/ |
| H A D | store_observer.h | 25 OP_INSERT = 0, enumerator
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/include/ |
| H A D | ikvstore_observer.h | 32 OP_INSERT, enumerator
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/cloud/ |
| H A D | distributeddb_cloud_table_without_primary_key_sync_test.cpp | 123 InitExpectChangedDataByDetailsType(ChangedDataType::DATA, cloudCount, ChangeType::OP_INSERT, in TestChangedDataInTrackerTable()
219 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_INSERT);
309 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_INSERT);
|
| H A D | distributeddb_cloud_table_compound_primary_key_sync_test.cpp | 154 InitExpectChangedData(ChangedDataType::DATA, cloudCount, ChangeType::OP_INSERT);
244 InitExpectChangedData(ChangedDataType::ASSET, cloudCount, ChangeType::OP_INSERT);
|
| H A D | distributeddb_cloud_db_proxy_test.cpp | 912 changedData.primaryData[OP_INSERT] = {{}};
|
| /ohos5.0/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/store/ |
| H A D | general_watcher.h | 47 OP_INSERT, enumerator
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/syncer/src/cloud/ |
| H A D | cloud_sync_utils.cpp | 53 return OP_INSERT; in OpTypeToChangeType()
132 return changedData.primaryData[ChangeType::OP_INSERT].empty() || in IsChangeDataEmpty()
409 … param.downloadData.data[dataIndex], param.changedData, dataInfo.localInfo, ChangeType::OP_INSERT); in SaveChangedData()
|
| H A D | cloud_syncer.cpp | 510 param.changedData.primaryData[ChangeType::OP_INSERT].push_back(primaryValues); in UpdateChangedData()
947 if (changedData.primaryData[OP_INSERT].empty() && changedData.primaryData[OP_UPDATE].empty() && in NeedNotifyChangedData()
|
| /ohos5.0/foundation/deviceprofile/device_info_manager/services/core/src/deviceprofilemanager/listener/ |
| H A D | kv_data_change_listener.cpp | 80 .GetEntriesByKeys(keys[ChangeOp::OP_INSERT]); in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_cloud_interfaces_relational_ext_test.cpp | 1514 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_INSERT].size(); i++) { in CheckChangedData()
1515 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_INSERT][i - 1][0]), in CheckChangedData()
1524 for (size_t i = 1; i <= g_changedData[num].primaryData[ChangeType::OP_INSERT].size(); i++) { in CheckChangedData()
1525 … EXPECT_EQ(std::get<int64_t>(g_changedData[num].primaryData[ChangeType::OP_INSERT][i - 1][0]), in CheckChangedData()
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/src/resourcemanager/ |
| H A D | meta_info_manager.cpp | 363 std::vector<DistributedKv::Entry> insertRecords = GetEntriesByKeys(keys[ChangeOp::OP_INSERT]); in OnChange()
|
| H A D | capability_info_manager.cpp | 356 std::vector<DistributedKv::Entry> insertRecords = GetEntriesByKeys(keys[ChangeOp::OP_INSERT]); in OnChange()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/cloud/ |
| H A D | distributeddb_cloud_interfaces_relational_sync_test.cpp | 1172 … changedDataForTable1.primaryData[ChangeType::OP_INSERT].push_back({"Cloud" + std::to_string(i)});
1173 changedDataForTable2.primaryData[ChangeType::OP_INSERT].push_back({(int64_t)i + 10});
1339 … changedDataForTable1.primaryData[ChangeType::OP_INSERT].push_back({"Cloud" + std::to_string(i)});
1340 changedDataForTable2.primaryData[ChangeType::OP_INSERT].push_back({(int64_t)i + 10});
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/common/ |
| H A D | distributeddb_tools_unit_test.cpp | 875 for (uint64_t type = ChangeType::OP_INSERT; type < ChangeType::OP_BUTT; ++type) { in IsAllTypePrimaryDataEq()
|
| /ohos5.0/foundation/distributedhardware/distributed_hardware_fwk/services/distributedhardwarefwkservice/test/unittest/common/resourcemanager/src/ |
| H A D | resource_manager_test.cpp | 538 keys[CapabilityInfoManager::OP_INSERT] = {"strBase"};
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/relational/ |
| H A D | relational_store_sqlite_ext.cpp | 717 if (option < ChangeType::OP_INSERT || option >= ChangeType::OP_BUTT) { in SaveChangedData()
|
| /ohos5.0/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/relational/ |
| H A D | relational_sync_able_storage.cpp | 1518 for (size_t i = ChangeType::OP_INSERT; i < ChangeType::OP_BUTT; ++i) { in FilterChangeDataByDetailsType()
|