Home
last modified time | relevance | path

Searched refs:insertEntries (Results 1 - 15 of 15) sorted by relevance

/foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/src/
H A Ddistributeddb_kv_observer_test.cpp182 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() local
184 insertEntries.push_back(entry); in HWTEST_F()
185 EXPECT_TRUE(VerifyObserverResult(observer, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
217 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() local
219 insertEntries.push_back(entry); in HWTEST_F()
220 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
235 insertEntries.clear(); in HWTEST_F()
237 insertEntries.push_back(entry2); in HWTEST_F()
238 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
254 insertEntries in HWTEST_F()
295 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
359 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
442 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
483 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
529 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
806 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
844 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1043 vector<DistributedDB::Entry> insertEntries; KvObserverVerifyTransactionCommit() local
1205 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1253 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1292 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1328 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1557 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1584 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1611 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
[all...]
H A Ddistributeddb_kv_observer_snap_test.cpp296 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() local
297 insertEntries.push_back(ENTRY_1); in HWTEST_F()
298 EXPECT_TRUE(VerifyObserverResult(observer, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
315 insertEntries.clear(); in HWTEST_F()
316 EXPECT_TRUE(VerifyObserverResult(observer, CHANGED_ZERO_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
362 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() local
363 EXPECT_TRUE(VerifyObserverResult(observer, CHANGED_ZERO_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
493 vector<DistributedDB::Entry> insertEntries; in HWTEST_F() local
495 insertEntries.push_back(entry); in HWTEST_F()
496 EXPECT_TRUE(VerifyObserverResult(observer1, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
543 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
817 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
855 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1088 vector<DistributedDB::Entry> insertEntries, updateEntries, deleteEntries; ObserverSnapVerifyTransactionCommit() local
1130 vector<DistributedDB::Entry> insertEntries; ObserverSnapVerifyTransactionRollback() local
1249 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1479 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1508 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
1536 vector<DistributedDB::Entry> insertEntries; HWTEST_F() local
[all...]
H A Ddistributeddb_nb_local_batch_crud_test.cpp926 vector<Entry> insertEntries; in HWTEST_F() local
928 GenerateAppointPrefixAndSizeRecords(insertEntries, entrySize, TEN_RECORDS, {'k'}, {'v', 'm'}); in HWTEST_F()
929 DBStatus status = DistributedDBNbTestTools::PutLocalBatch(*g_nbLocalBatchDelegate, insertEntries); in HWTEST_F()
944 status = DistributedDBNbTestTools::PutBatch(*g_nbLocalBatchDelegate, insertEntries); in HWTEST_F()
963 for (size_t index = INDEX_FIFTH; index < insertEntries.size(); index++) { in HWTEST_F()
964 localDeleteKeys.push_back(insertEntries[index].key); in HWTEST_F()
965 localDeleteEntries.push_back(insertEntries[index]); in HWTEST_F()
974 EXPECT_TRUE(VerifyObserverResult(observerNative, CHANGED_ONE_TIME, INSERT_LIST, insertEntries)); in HWTEST_F()
1012 vector<Entry> insertEntries = { ENTRY_1, ENTRY_2, ENTRY_3, ENTRY_4, ENTRY_5 }; in HWTEST_F() local
1013 DBStatus status = DistributedDBNbTestTools::PutLocalBatch(*g_nbLocalBatchDelegate, insertEntries); in HWTEST_F()
[all...]
/foundation/ability/dmsfwk/services/dtbschedmgr/test/unittest/mission/
H A Ddistributed_mission_info_test.cpp148 * @tc.steps: step2. test OnChange when insertEntries is not empty. in HWTEST_F()
150 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F() local
156 insertEntries.emplace_back(entry); in HWTEST_F()
160 DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), std::move(updateEntries), in HWTEST_F()
167 insertEntries.clear(); in HWTEST_F()
171 insertEntries.emplace_back(entry); in HWTEST_F()
174 DistributedKv::ChangeNotification changeNotification1(std::move(insertEntries), std::move(updateEntries), in HWTEST_F()
200 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F() local
206 insertEntries.emplace_back(entry); in HWTEST_F()
210 DistributedKv::ChangeNotification changeNotification(std::move(insertEntries), st in HWTEST_F()
458 std::vector<DistributedKv::Entry> insertEntries; HWTEST_F() local
[all...]
/foundation/distributeddatamgr/kv_store/frameworks/innerkitsimpl/distributeddatafwk/src/
H A Dchange_notification.cpp24 ChangeNotification::ChangeNotification(std::vector<Entry> &&insertEntries, std::vector<Entry> &&updateEntries, in ChangeNotification() argument
26 : insertEntries_(std::move(insertEntries)), updateEntries_(std::move(updateEntries)), in ChangeNotification()
/foundation/distributeddatamgr/kv_store/interfaces/innerkits/distributeddata/include/
H A Dchange_notification.h28 * @param insertEntries Inserted entries.
34 API_EXPORT ChangeNotification(std::vector<Entry> &&insertEntries, std::vector<Entry> &&updateEntries,
/foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/
H A Dprofile_change_handler_test.cpp425 std::vector<DistributedKv::Entry> insertEntries; in HWTEST_F() local
431 insertEntries.emplace_back(entry); in HWTEST_F()
435 DistributedKv::ChangeNotification profileNotification(std::move(insertEntries), std::move(updateEntries), in HWTEST_F()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributeddata/src/
H A Djs_util.cpp913 napi_value insertEntries = nullptr; in SetValue() local
914 status = SetValue(env, in.GetInsertEntries(), insertEntries, hasSchema); in SetValue()
915 CHECK_RETURN((status == napi_ok) || (insertEntries == nullptr), "GetInsertEntries failed!", status); in SetValue()
916 status = napi_set_named_property(env, out, "insertEntries", insertEntries); in SetValue()
917 CHECK_RETURN((status == napi_ok), "set_named_property insertEntries failed!", status); in SetValue()
/foundation/distributeddatamgr/kv_store/frameworks/jskitsimpl/distributedkvstore/src/
H A Djs_util.cpp983 napi_value insertEntries = nullptr; in SetValue() local
984 statusMsg = SetValue(env, in.GetInsertEntries(), insertEntries, hasSchema); in SetValue()
985 ASSERT((statusMsg.status == napi_ok) || (insertEntries == nullptr), "GetInsertEntries failed!", statusMsg); in SetValue()
986 statusMsg = napi_set_named_property(env, out, "insertEntries", insertEntries); in SetValue()
987 ASSERT((statusMsg.status == napi_ok), "set_named_property insertEntries failed!", statusMsg); in SetValue()
/foundation/distributeddatamgr/kv_store/kvstoremock/frameworks/jskitsimpl/distributeddata/src/
H A Djs_util.cpp947 napi_value insertEntries = nullptr; in SetValue() local
948 status = SetValue(env, in.GetInsertEntries(), insertEntries, hasSchema); in SetValue()
949 CHECK_RETURN((status == napi_ok) || (insertEntries == nullptr), "GetInsertEntries failed!", status); in SetValue()
950 status = napi_set_named_property(env, out, "insertEntries", insertEntries); in SetValue()
951 CHECK_RETURN((status == napi_ok), "set_named_property insertEntries failed!", status); in SetValue()
/foundation/distributeddatamgr/kv_store/frameworks/cj/include/
H A Ddistributed_kv_store_impl.h113 CArrEntry insertEntries; member
/foundation/distributeddatamgr/kv_store/frameworks/cj/src/
H A Ddistributed_kv_store_impl.cpp400 std::vector<Entry> insertEntries = c.GetInsertEntries(); in ChangeNotificationToCChangeNotification() local
404 return CChangeNotification{.insertEntries = EntriesToCArrEntry(insertEntries), in ChangeNotificationToCChangeNotification()
/foundation/distributeddatamgr/kv_store/test/unittest/distributeddata/
H A DSingleKvStoreDataPromiseJsTest.js2737 resolve(ChangeNotification.insertEntries);
2743 await getInsertEntries.then(function(insertEntries){
2744 console.info('SingleKvStoreChangeNotificationPromiseTest001 getInsertEntries' + JSON.stringify(insertEntries));
2745 expect(insertEntries).assertNotNull();
/foundation/distributeddatamgr/kv_store/test/unittest/distributedKVStore/
H A DSingleKvStoreKVPromiseJsTest.js2536 resolve(ChangeNotification.insertEntries);
2542 await getInsertEntries.then(function (insertEntries) {
2543 console.info('SingleKvStoreChangeNotificationPromiseTest getInsertEntries' + JSON.stringify(insertEntries));
2544 expect(insertEntries != null).assertTrue();
H A DDeviceKvStoreKVPromiseJsTest.js2442 resolve(ChangeNotification.insertEntries);
2448 await getInsertEntries.then(function (insertEntries) {
2449 console.info('DeviceKvStoreChangeNotificationPromiseTest getInsertEntries' + JSON.stringify(insertEntries));
2450 expect(insertEntries != null).assertTrue();

Completed in 25 milliseconds