Home
last modified time | relevance | path

Searched refs:changeData (Results 1 - 7 of 7) sorted by relevance

/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/
H A Dkvdb_watcher.cpp34 auto changeData = values.find(store); in OnChange() local
35 if (changeData != values.end()) { in OnChange()
41 keys[OP_INSERT] = ConvertToKeys(changeData->second[OP_INSERT]); in OnChange()
42 keys[OP_UPDATE] = ConvertToKeys(changeData->second[OP_UPDATE]); in OnChange()
43 keys[OP_DELETE] = ConvertToKeys(changeData->second[OP_DELETE]); in OnChange()
55 auto changeData = datas.find(store); in OnChange() local
56 if (changeData != datas.end()) { in OnChange()
61 auto inserts = ConvertToEntries(changeData->second[OP_INSERT]); in OnChange()
62 auto updates = ConvertToEntries(changeData->second[OP_UPDATE]); in OnChange()
63 auto deletes = ConvertToEntries(changeData in OnChange()
[all...]
H A Dkvdb_general_store.cpp643 Watcher::ChangeData changeData; in OnChange() local
644 ConvertChangeData(inserts, changeData[storeId_][DistributedDB::OP_INSERT]); in OnChange()
645 ConvertChangeData(deletes, changeData[storeId_][DistributedDB::OP_DELETE]); in OnChange()
646 ConvertChangeData(updates, changeData[storeId_][DistributedDB::OP_UPDATE]); in OnChange()
651 watcher_->OnChange(genOrigin, {}, std::move(changeData)); in OnChange()
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/test/unittest/src/
H A DObjectStoreJsunit.test.js23 function changeCallback(sessionId, changeData) {
25 if (changeData != null && changeData != undefined) {
26 changeData.forEach(element => {
33 function changeCallback2(sessionId, changeData) {
35 if (changeData != null && changeData != undefined) {
36 changeData.forEach(element => {
112 g_object.on("change", function (sessionId, changeData) {
114 if (changeData !
[all...]
H A DObjectStoreJsunitV9.test.js23 function changeCallback(sessionId, changeData) {
26 if (changeData != null && changeData != undefined) {
27 changeData.forEach(element => {
252 g_object.on("change", function (sessionId, changeData) {
254 if (changeData != null && changeData != undefined) {
255 changeData.forEach(element => {
295 g_object.on(123, function (sessionId, changeData) {
298 if (changeData !
[all...]
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/mock/
H A Ddb_store_mock.cpp279 DBChangeDataMock changeData({}, entries, {}); in PutBatch()
280 observers_.ForEachCopies([&changeData](const auto &observer, auto &keys) mutable { in PutBatch()
282 observer->OnChange(changeData); in PutBatch()
291 DBChangeDataMock changeData({}, {}, {}); in DeleteBatch()
297 changeData.AddEntry({key, std::move(it.second)}); in DeleteBatch()
301 observers_.ForEachCopies([&changeData](const auto &observer, auto &keys) { in DeleteBatch()
303 observer->OnChange(changeData); in DeleteBatch()
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/src/adaptor/
H A Djs_watcher.cpp93 void JSWatcher::Emit(const char *type, const std::string &sessionId, const std::vector<std::string> &changeData) in Emit() argument
95 if (changeData.empty()) { in Emit()
99 LOG_INFO("start %{public}s, %{public}s", sessionId.c_str(), changeData.at(0).c_str()); in Emit()
107 ChangeArgs *changeArgs = new (std::nothrow) ChangeArgs(handler->callbackRef, sessionId, changeData); in Emit()
377 const napi_ref callback, const std::string &sessionId, const std::vector<std::string> &changeData) in ChangeArgs()
378 : callback_(callback), sessionId_(sessionId), changeData_(changeData) in ChangeArgs()
376 ChangeArgs( const napi_ref callback, const std::string &sessionId, const std::vector<std::string> &changeData) ChangeArgs() argument
/foundation/distributeddatamgr/data_object/frameworks/jskitsimpl/include/adaptor/
H A Djs_watcher.h97 void Emit(const char *type, const std::string &sessionId, const std::vector<std::string> &changeData);
106 ChangeArgs(const napi_ref callback, const std::string &sessionId, const std::vector<std::string> &changeData);

Completed in 5 milliseconds