| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/metadata/ |
| H A D | meta_data_manager.cpp | 34 bool isLocal = false);
50 std::shared_ptr<MetaStore> metaStore, std::shared_ptr<Filter> filter, Observer observer, bool isLocal) in MetaObserver()
54 int mode = isLocal ? DistributedDB::OBSERVER_CHANGES_LOCAL_ONLY in MetaObserver()
57 if (!isLocal) { in MetaObserver()
187 bool MetaDataManager::SaveMeta(const std::string &key, const Serializable &value, bool isLocal) in SaveMeta() argument
194 auto status = isLocal ? metaStore_->PutLocal({ key.begin(), key.end() }, { data.begin(), data.end() }) in SaveMeta()
197 ZLOGE("db corrupted! status:%{public}d isLocal:%{public}d, key:%{public}s", in SaveMeta()
198 status, isLocal, Anonymous::Change(key).c_str()); in SaveMeta()
205 if (!isLocal && cloudSyncer_) { in SaveMeta()
209 ZLOGE("failed! status:%{public}d isLocal in SaveMeta()
49 MetaObserver( std::shared_ptr<MetaStore> metaStore, std::shared_ptr<Filter> filter, Observer observer, bool isLocal) MetaObserver() argument
215 LoadMeta(const std::string &key, Serializable &value, bool isLocal) LoadMeta() argument
240 GetEntries(const std::string &prefix, std::vector<Bytes> &entries, bool isLocal) GetEntries() argument
262 DelMeta(const std::string &key, bool isLocal) DelMeta() argument
320 Subscribe(std::string prefix, Observer observer, bool isLocal) Subscribe() argument
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/framework/include/metadata/ |
| H A D | meta_data_manager.h | 58 API_EXPORT bool SaveMeta(const std::string &key, const Serializable &value, bool isLocal = false);
59 API_EXPORT bool LoadMeta(const std::string &key, Serializable &value, bool isLocal = false);
61 API_EXPORT bool LoadMeta(const std::string &prefix, std::vector<T> &values, bool isLocal = false) in LoadMeta()
67 if (!GetEntries(prefix, entries, isLocal)) { in LoadMeta()
77 API_EXPORT bool DelMeta(const std::string &key, bool isLocal = false);
79 API_EXPORT bool Subscribe(std::string prefix, Observer observer, bool isLocal = false);
87 API_EXPORT bool GetEntries(const std::string &prefix, std::vector<Bytes> &entries, bool isLocal);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/common/distributeddb/include/ |
| H A D | distributed_test_tools.h | 134 bool isLocal; member
143 bool putBatch, bool getBatch, bool useClear, bool getSysInfo, bool isLocal) in PerformanceData()
146 getSysInfo(getSysInfo), isLocal(isLocal), in PerformanceData()
282 bool isLocal; member
287 bool isLocal, bool isPresetRecords, int presetRecordsCnt) in NbGalleryPerfData()
289 isLocal(isLocal), isPresetRecords(isPresetRecords), presetRecordsCnt(presetRecordsCnt) in NbGalleryPerfData()
297 bool isLocal; member
302 bool isLocal, boo in NbLocalPerfData()
323 bool isLocal; global() member
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/interfaces/src/ |
| H A D | kv_store_nb_conflict_data_impl.cpp | 59 return data_.oldData.isLocal; in IsNative()
61 return data_.newData.isLocal; in IsNative()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/communicator/src/ |
| H A D | db_status_adapter.cpp | 130 bool isLocal = IsLocalDeviceId(devInfos.identifier); in NotifyDBInfos()
131 if (!isLocal && !IsSupport(devInfos.identifier)) { in NotifyDBInfos()
135 bool isChange = LoadIntoCache(isLocal, devInfos, dbInfos); in NotifyDBInfos()
137 if (!isLocal && remoteCallback_ != nullptr) { in NotifyDBInfos()
139 } else if (isLocal && localCallback_ != nullptr && isChange) { in NotifyDBInfos()
242 bool DBStatusAdapter::LoadIntoCache(bool isLocal, const DeviceInfos &devInfos, const std::vector<DBInfo> &dbInfos) in LoadIntoCache() argument
244 if (isLocal) { in LoadIntoCache()
|
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/btm/ |
| H A D | btm_snoop_filter.c | 170 uint8_t module, uint8_t rfcommScn, uint16_t l2capPsm, bool isLocal, const BtAddr *remoteAddr) in AllocFilterInfo()
177 info->isLocal = isLocal; in AllocFilterInfo()
256 .isLocal = true, in BTM_RemoveLocalL2capPsmForLogging()
276 .isLocal = false, in BTM_RemoveRemoteL2capPsmForLogging()
334 .isLocal = true, in BTM_RemoveLocalRfcommScnChannelForLogging()
355 .isLocal = true, in BTM_RemoveRemoteRfcommScnChannelForLogging()
169 AllocFilterInfo( uint8_t module, uint8_t rfcommScn, uint16_t l2capPsm, bool isLocal, const BtAddr *remoteAddr) AllocFilterInfo() argument
|
| /foundation/deviceprofile/device_info_manager/old/interfaces/innerkits/core/include/ |
| H A D | profile_change_notification.h | 53 std::string& networkId, bool isLocal) in ProfileChangeNotification()
55 deviceId_(std::move(networkId)), isLocal_(isLocal) {} in ProfileChangeNotification()
52 ProfileChangeNotification(std::vector<ProfileEntry>& profileEntries, std::string& networkId, bool isLocal) ProfileChangeNotification() argument
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/interfaces/ |
| H A D | distributeddb_interfaces_encrypt_database_test.cpp | 42 static void CheckRekeyWithMultiKvStore(bool isLocal);
43 static void CheckRekeyWithExistedSnapshot(bool isLocal);
44 static void CheckRekeyWithExistedObserver(bool isLocal);
73 void DistributedDBInterfacesEncryptDatabaseTest::CheckRekeyWithMultiKvStore(bool isLocal) in CheckRekeyWithMultiKvStore() argument
82 KvStoreDelegate::Option option = {true, isLocal, false}; in CheckRekeyWithMultiKvStore()
118 void DistributedDBInterfacesEncryptDatabaseTest::CheckRekeyWithExistedSnapshot(bool isLocal) in CheckRekeyWithExistedSnapshot() argument
127 KvStoreDelegate::Option option = {true, isLocal, false}; in CheckRekeyWithExistedSnapshot()
161 void DistributedDBInterfacesEncryptDatabaseTest::CheckRekeyWithExistedObserver(bool isLocal) in CheckRekeyWithExistedObserver() argument
170 KvStoreDelegate::Option option = {true, isLocal, false}; in CheckRekeyWithExistedObserver()
|
| /foundation/communication/ipc/ipc/native/src/core/include/ |
| H A D | process_skeleton.h | 68 bool AttachInvokerProcInfo(bool isLocal, InvokerProcInfo &invokeInfo);
69 bool QueryInvokerProcInfo(bool isLocal, InvokerProcInfo &invokeInfo);
70 bool DetachInvokerProcInfo(bool isLocal);
|
| /foundation/deviceprofile/device_info_manager/old/services/core/test/unittest/ |
| H A D | profile_change_notification_test.cpp | 94 bool isLocal = true; in HWTEST_F() local
95 ProfileChangeNotification notification(profileEntries, networkId, isLocal); in HWTEST_F()
110 bool isLocal = true; in HWTEST_F() local
112 std::make_shared<ProfileChangeNotification>(profileEntries, networkId, isLocal); in HWTEST_F()
155 bool isLocal = true; in HWTEST_F() local
156 ProfileChangeNotification notification(profileEntries, networkId, isLocal); in HWTEST_F()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/syncer/ |
| H A D | virtual_single_ver_sync_db_Interface.cpp | 142 if (data.isLocal) { in GetUnSyncTotal()
169 if (!data.isLocal) { in GetUnSyncTotal()
226 item.isLocal = true; in PutData()
271 dataItem.isLocal = iter->isLocal; in GetSyncData()
385 dbDataIter->isLocal = false; in PutSyncData()
395 dataItem.isLocal = false; in PutSyncData()
471 if (!data.isLocal) { in GetSyncData()
559 item.isLocal = false; in PutSyncDataWithQuery()
644 if (data.isLocal) { in GetDataInner()
[all...] |
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/include/ |
| H A D | kvdb_conflict_entry.h | 25 bool isLocal = false; member
|
| H A D | multi_ver_def.h | 38 uint64_t isLocal = 0; // merge node or native node member
|
| /foundation/communication/ipc/ipc/native/src/core/source/ |
| H A D | process_skeleton.cpp | 279 bool ProcessSkeleton::AttachInvokerProcInfo(bool isLocal, InvokerProcInfo &invokeInfo) in AttachInvokerProcInfo() argument
283 std::string key = std::to_string(gettid()) + "_" + std::to_string(isLocal); in AttachInvokerProcInfo()
291 bool ProcessSkeleton::QueryInvokerProcInfo(bool isLocal, InvokerProcInfo &invokeInfo) in QueryInvokerProcInfo() argument
295 std::string key = std::to_string(gettid()) + "_" + std::to_string(isLocal); in QueryInvokerProcInfo()
307 bool ProcessSkeleton::DetachInvokerProcInfo(bool isLocal) in DetachInvokerProcInfo() argument
311 std::string key = std::to_string(gettid()) + "_" + std::to_string(isLocal); in DetachInvokerProcInfo()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/moduletest/include/ |
| H A D | distributed_crud_transaction_tools.h | 33 CrudMode first, CrudMode second, bool preset, bool isLocal);
|
| /foundation/communication/dsoftbus/tests/core/bus_center/service/fuzztest/buscenterevent_fuzzer/ |
| H A D | buscenterevent_fuzz.cpp | 152 bool isLocal = GetData<bool>(); in LnnNotifyBtAclStateChangeEventFuzzTest() local
157 LnnNotifyNodeAddressChanged(btMac, networkId, isLocal); in LnnNotifyBtAclStateChangeEventFuzzTest()
|
| /foundation/communication/dsoftbus/core/bus_center/service/include/ |
| H A D | bus_center_event.h | 213 bool isLocal; member
279 void LnnNotifyNodeAddressChanged(const char *addr, const char *networkId, bool isLocal);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/test/unittest/common/storage/ |
| H A D | distributeddb_storage_register_conflict_test.cpp | 229 if (notifyData.oldData.isLocal != expectNotifyData.oldData.isLocal) { in CheckNewConflictData()
231 notifyData.oldData.isLocal, expectNotifyData.oldData.isLocal); in CheckNewConflictData()
263 if (notifyData.newData.isLocal != expectNotifyData.newData.isLocal) { in CheckOldConflictData()
264 LOGD("New Data IsLocal ERROR! Actual %d vs Expected %d", notifyData.newData.isLocal, in CheckOldConflictData()
265 expectNotifyData.newData.isLocal); in CheckOldConflictData()
|
| /foundation/multimedia/media_library/frameworks/services/media_dfx/include/ |
| H A D | dfx_database_utils.h | 33 EXPORT static int32_t QueryFromPhotos(int32_t mediaType, bool isLocal);
|
| H A D | dfx_reporter.h | 56 bool isLocal);
|
| /foundation/multimedia/media_library/frameworks/services/media_dfx/src/ |
| H A D | dfx_database_utils.cpp | 33 int32_t DfxDatabaseUtils::QueryFromPhotos(int32_t mediaType, bool isLocal) in QueryFromPhotos() argument
37 if (isLocal) { in QueryFromPhotos()
67 albumInfo.isLocal = GetStringVal(PhotoAlbumColumns::ALBUM_CLOUD_ID, resultSet) == "" ? true : false; in QueryAlbumInfoBySubtype()
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/common/src/ |
| H A D | parcel.cpp | 259 errCode = WriteUInt64(commit.isLocal); in WriteMultiVerCommit()
261 LOGE("Parcel::WriteMultiVerCommit write isLocal err!"); in WriteMultiVerCommit()
281 len += ReadUInt64(commit.isLocal); in ReadMultiVerCommit()
324 errCode = WriteUInt64(iter.isLocal); in WriteMultiVerCommits()
326 LOGE("Parcel::WriteMultiVerCommit write isLocal err!"); in WriteMultiVerCommits()
360 len += ReadUInt64(commit.isLocal); in ReadMultiVerCommits()
|
| /foundation/multimedia/media_library/frameworks/innerkitsimpl/media_library_helper/src/ |
| H A D | photo_album.cpp | 275 void PhotoAlbum::SetIsLocal(const int32_t isLocal) in SetIsLocal() argument
277 isLocal_ = isLocal; in SetIsLocal()
|
| /foundation/graphic/graphic_2d/rosen/modules/platform/ipc_core/ |
| H A D | ipc_object_proxy.h | 80 int SendRequestInner(bool isLocal, uint32_t code, MessageParcel &data, MessageParcel &reply, MessageOption &option);
|
| /foundation/distributeddatamgr/kv_store/frameworks/libs/distributeddb/storage/src/ |
| H A D | storage_executor.h | 74 bool isLocal = false; member
|